|
|
|
@ -115,6 +115,8 @@ public class NettyServiceImpl implements INettyService { |
|
|
|
); |
|
|
|
); |
|
|
|
Thread.sleep(500); |
|
|
|
Thread.sleep(500); |
|
|
|
// 发送控制指令
|
|
|
|
// 发送控制指令
|
|
|
|
|
|
|
|
// 会话通道
|
|
|
|
|
|
|
|
log.error("会话:{},通道:{},id:{}", serverSession, serverSession.getChannel(), serverSession.getSessionId()); |
|
|
|
serverSession.getChannel().writeAndFlush(ModbusUtils.createByteBuf(controlCode)); |
|
|
|
serverSession.getChannel().writeAndFlush(ModbusUtils.createByteBuf(controlCode)); |
|
|
|
// 等待指令
|
|
|
|
// 等待指令
|
|
|
|
if (NettyTools.waitReceiveMsg("order_wait")) { |
|
|
|
if (NettyTools.waitReceiveMsg("order_wait")) { |
|
|
|
|