|
|
|
@ -140,7 +140,7 @@ public class NettyServer { |
|
|
|
|
|
|
|
//发送消息 |
|
|
|
public void sendMsg(String client, boolean request, String xml) { |
|
|
|
logger.info("[NETTY] Client: {} online: {}", client, clients.containsKey(client)); |
|
|
|
logger.info("[NETTY] Client: {} online: {}, xml: \n {}", client, clients.containsKey(client), xml); |
|
|
|
if (clients.containsKey(client) && !StringUtil.isNullOrEmpty(xml)) { |
|
|
|
ByteBuf byteBuf = Unpooled.copiedBuffer(xml, CharsetUtil.UTF_8); |
|
|
|
int length = byteBuf.readableBytes(); |
|
|
|
@ -154,7 +154,6 @@ public class NettyServer { |
|
|
|
allBuf.writeBytes(byteBuf); |
|
|
|
allBuf.writeByte(0xEB); |
|
|
|
allBuf.writeByte(0x90); |
|
|
|
|
|
|
|
redisTemplate.opsForValue().set(String.valueOf(sendIndex), allBuf.toString(CharsetUtil.US_ASCII), 60L, TimeUnit.SECONDS); |
|
|
|
nettyServerHandler.SendMsg(clients.get(client), allBuf); |
|
|
|
logger.info("[NETTY] 向设备端机器人发送消息会话序列号: [{}], 接收端序列号: [{}]", sendIndex, receiveIndex); |
|
|
|
|