diff --git a/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java b/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java index d1a13f7f..82587c1c 100644 --- a/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java +++ b/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java @@ -186,6 +186,7 @@ class TcpServerDeviceGateway implements DeviceGateway, MonitorSupportDeviceGatew .andThen(session -> { TcpDeviceSession deviceSession = session.unwrap(TcpDeviceSession.class); deviceSession.setClient(client); + sessionRef.set(deviceSession); }), () -> log.warn("无法从tcp[{}]消息中获取设备信息:{}", address, message) )