suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

优化tcp keepalive

This commit is contained in:
zhou-hao 2020-03-23 14:33:30 +08:00
parent 547ba4c6d9
commit dbea53aa75
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java
View File

@ -177,12 +177,12 @@ class TcpServerDeviceGateway implements DeviceGateway, MonitorSupportDeviceGatew
);
}))
.flatMap(device -> {
DeviceSession fSession = sessionRef.get() == null ?
sessionManager.getSession(device.getDeviceId()) :
sessionRef.get();
//处理设备上线消息
if (message instanceof DeviceOnlineMessage) {
DeviceSession fSession = sessionRef.get() == null ?
sessionManager.getSession(device.getDeviceId()) :
sessionRef.get();
if (fSession == null) {
fSession = new TcpDeviceSession(client.getId(), device, client, getTransport()) {
@Override
@ -199,11 +199,15 @@ class TcpServerDeviceGateway implements DeviceGateway, MonitorSupportDeviceGatew
sessionRef.set(fSession);
sessionManager.register(fSession);
}
fSession.keepAlive();
if (keepaliveTimeout.get() != null) {
fSession.setKeepAliveTimeout(keepaliveTimeout.get());
}
return Mono.empty();
}
if (fSession != null) {
fSession.keepAlive();
}
//设备下线
if (message instanceof DeviceOfflineMessage) {
sessionManager.unregister(device.getDeviceId());