ClientApps/CN_Gather
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码调整

Browse Source
This commit is contained in:
chendaofei
2024-12-19 15:41:44 +08:00
parent 0e682e8d33
commit e6d157e35f
5 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java
View File

@@ -117,6 +117,8 @@ public class SocketDevResponseService {
break; break;
case UNPROCESSED_BUSINESS: case UNPROCESSED_BUSINESS:
break; break;
case NO_INIT_DEV:
break;
default: default:
WebSocketVO webSocketVO = new WebSocketVO(); WebSocketVO webSocketVO = new WebSocketVO();

1
detection/src/main/java/com/njcn/gather/detection/pojo/enums/SourceResponseCodeEnum.java
View File

@@ -31,6 +31,7 @@ public enum SourceResponseCodeEnum {
RE_OPERATE(10552,"重复的初始化操作"), RE_OPERATE(10552,"重复的初始化操作"),
COMMUNICATION_ERR(10553,"通讯模块通讯异常"), COMMUNICATION_ERR(10553,"通讯模块通讯异常"),
DATA_RESOLVE(10554,"报文解析异常"), DATA_RESOLVE(10554,"报文解析异常"),
NO_INIT_DEV(10556,"不存在上线的设备"),
//自定义前端展示消息 //自定义前端展示消息
SOCKET_ERROR(20000,"连接服务端失败") SOCKET_ERROR(20000,"连接服务端失败")

3
detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettyDevClientHandler.java
View File

@@ -41,6 +41,8 @@ public class NettyDevClientHandler extends SimpleChannelInboundHandler<String> {
@Override @Override
public void channelActive(ChannelHandlerContext ctx) throws Exception { public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("客户端通道已建立" + ctx.channel().remoteAddress()); System.out.println("客户端通道已建立" + ctx.channel().remoteAddress());
SocketManager.addUser(param.getUserPageId()+"_Dev",ctx.channel());
} }
/** /**
@@ -78,7 +80,6 @@ public class NettyDevClientHandler extends SimpleChannelInboundHandler<String> {
@Override @Override
public void handlerAdded(ChannelHandlerContext ctx) { public void handlerAdded(ChannelHandlerContext ctx) {
SocketManager.addUser(param.getUserPageId()+"_Dev",ctx.channel());
System.out.println("有通道接入" + ctx.channel()); System.out.println("有通道接入" + ctx.channel());
} }

3
detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettySourceClientHandler.java
View File

@@ -32,6 +32,8 @@ public class NettySourceClientHandler extends SimpleChannelInboundHandler<Strin
@Override @Override
public void channelActive(ChannelHandlerContext ctx) throws Exception { public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("客户端通道已建立" + ctx.channel().remoteAddress()); System.out.println("客户端通道已建立" + ctx.channel().remoteAddress());
SocketManager.addUser(webUser.getUserPageId()+"_Source",ctx.channel());
} }
/** /**
@@ -82,7 +84,6 @@ public class NettySourceClientHandler extends SimpleChannelInboundHandler<Strin
@Override @Override
public void handlerAdded(ChannelHandlerContext ctx) { public void handlerAdded(ChannelHandlerContext ctx) {
SocketManager.addUser(webUser.getUserPageId()+"_Source",ctx.channel());
System.out.println("有通道接入" + ctx.channel()); System.out.println("有通道接入" + ctx.channel());
} }

6
detection/src/main/java/com/njcn/gather/detection/util/socket/web/WebSocketHandler.java
View File

@@ -125,5 +125,11 @@ public class WebSocketHandler extends SimpleChannelInboundHandler<TextWebSocketF
public void sendMsgToUser(String userId, String msg) { public void sendMsgToUser(String userId, String msg) {
WebServiceManager.sendMsg(userId, msg); WebServiceManager.sendMsg(userId, msg);
} }
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
cause.printStackTrace();
ctx.close();
}
} }