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

refactor(基础模块): 优化设备连接

This commit is contained in:
zhouhao 2024-10-21 17:25:56 +08:00
parent 6dc16ce715
commit 945bf2ea82
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -73,8 +73,11 @@ class HttpDeviceSession implements DeviceSession {
@Override
public Mono<Boolean> send(EncodedMessage encodedMessage) {
//未建立websocket链接,不支持此类消息.
if(websocket == null){
return Mono.error(new DeviceOperationException(ErrorCode.UNSUPPORTED_MESSAGE));
if (websocket == null) {
return Mono.error(new DeviceOperationException.NoStackTrace(ErrorCode.UNSUPPORTED_MESSAGE));
}
if (!websocket.isAlive()) {
return Mono.error(new DeviceOperationException.NoStackTrace(ErrorCode.CONNECTION_LOST));
}
if (encodedMessage instanceof WebSocketMessage) {
return websocket
@ -99,7 +102,10 @@ class HttpDeviceSession implements DeviceSession {
@Override
public void close() {
//断开websocket连接
if (websocket != null) {
websocket.close().subscribe();
}
}
@Override

2
jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/client/VertxTcpClient.java
View File

@ -46,7 +46,7 @@ public class VertxTcpClient implements TcpClient {
private final List<Runnable> disconnectListener = new CopyOnWriteArrayList<>();
private final Sinks.Many<TcpMessage> sink = Reactors.createMany();
private final Sinks.Many<TcpMessage> sink = Reactors.createMany(Integer.MAX_VALUE, false);
private final boolean serverClient;