修改测试代码

NESCAR · Jul 22, 2019 · 672fdf9 · 672fdf9
1 parent 79e9dc3
commit 672fdf9
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/src/test/java/cn/com/onlinetool/jt809/client/JT809TcpClient.java b/src/test/java/cn/com/onlinetool/jt809/client/JT809TcpClient.java
@@ -1,5 +1,6 @@
 package cn.com.onlinetool.jt809.client;
 
+import cn.com.onlinetool.jt809.util.ByteArrayUtil;
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelInitializer;
@@ -48,6 +49,7 @@ protected void initChannel(SocketChannel socketChannel) throws Exception {
                 public void operationComplete(Future future) throws Exception {
                     if(future.isSuccess()){
                         System.out.println("服务器连接已经完成，可以确保进行消息准确传输");
+                        channelFuture.channel().write(ByteArrayUtil.hexStr2Bytes("5B000000480000005210010001E24001000100000000000001E2407465737438303900312E37312E3132392E32303100000000000000000000000000000000000000004E8ED9BA5D"));
                     }
                 }
             });

diff --git a/src/test/java/cn/com/onlinetool/jt809/client/JT809TcpClientHandler.java b/src/test/java/cn/com/onlinetool/jt809/client/JT809TcpClientHandler.java
@@ -15,9 +15,9 @@ public class JT809TcpClientHandler extends ChannelInboundHandlerAdapter {
     public void channelActive(ChannelHandlerContext ctx) throws Exception {
         System.out.println("channelActive..........");
         ctx.writeAndFlush(ByteArrayUtil.hexStr2Bytes(
-                "5B0000007300005A01821200022551250100010000000000B8D3474330373232000000000000000000000000000212010000003D3335303130320000000000373035303400000000000000000000000000000000000000000000000000003F001B3C000000303634383336323338353038A76C5D"
-                        + "5B0000007300005A01821200022551250100010000000000B8D3474330373232000000000000000000000000000212010000003D3335303130320000000000373035303400000000000000000000000000000000000000000000000000003F001B3C000000303634383336323338353038A76C5D"
+                "5B000000480000005210010001E24001000100000000000001E2407465737438303900312E37312E3132392E32303100000000000000000000000000000000000000004E8ED9BA5D"
         ));
+        super.channelActive(ctx);
     }
 
     @Override

diff --git a/src/test/java/cn/com/onlinetool/jt809/client/Message2ByteEncoder.java b/src/test/java/cn/com/onlinetool/jt809/client/Message2ByteEncoder.java
@@ -16,5 +16,6 @@ public class Message2ByteEncoder extends MessageToByteEncoder {
     @Override
     protected void encode(ChannelHandlerContext ctx, Object msg, ByteBuf byteBuf) throws Exception {
         byteBuf.writeBytes((byte[]) msg);
+        ctx.writeAndFlush(byteBuf);
     }
 }