add clientHandlers

Author: magiclu550

src/main/java/cn/jsmod2/client/Client.java

@@ -27,6 +27,7 @@ public static Client getInstance(){
     private ChannelFuture cf ;
     private ClientInitializer clientInitializer;
     private CountDownLatch lathc;
+
     private Client(){
         lathc = new CountDownLatch(0);
         clientInitializer = new ClientInitializer(lathc);
@@ -37,7 +38,6 @@ private Client(){
                 .handler(clientInitializer);
     }
     public void connect(String ip,int port){
-        //192.168.43.51测试端口8766 192.168.43.102 线上端口8765
         try {
             this.cf = b.connect(ip, port).sync();
         } catch (InterruptedException e) {
@@ -67,13 +67,13 @@ public String setMessage(String msg) {
             return JSON.toJSONString(new HashMap<String,String>(){
                 {
                     put("status","500");
-                    put("message","unknown ipAddress");
+                    put("message","null");
                     put("value","null");
                 }
             });
         }
         try {
-            ChannelFuture cf = getInstance().getChannelFuture(ipAddress,port);//单例模式获取ChannelFuture对象
+            ChannelFuture cf = this.getChannelFuture(ipAddress,port);//单例模式获取ChannelFuture对象
             cf.channel().writeAndFlush(msg);
             //发送数据控制门闩加一
             lathc = new CountDownLatch(1);

src/main/java/cn/jsmod2/client/ClientHandler.java

@@ -21,6 +21,8 @@ public void channelActive(ChannelHandlerContext ctx) throws Exception {
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) {
         result = (String) msg;
+        System.out.println(result);
+        System.out.println(result);
         lathc.countDown();// 消息接收后释放同步锁，lathc是从Client加一传回来的
     }
 

src/main/java/cn/jsmod2/client/StartController.java

@@ -56,8 +56,16 @@ private void initialize(){
         stream.setTextArea(consoleTextArea);
         new Thread(()->{
             while (true){
-                Response response = new JsonRequester().append("type","log").sendOut();
-                stream.write(response.getMessage());
+                try {
+                    Response response = new JsonRequester().append("type","log").sendOut();
+                    if (response != null) {
+                        if (!response.getMessage().equals("null")) {
+                            stream.write(response.getMessage());
+                        }
+                    }
+                }catch (Exception e){
+                    e.printStackTrace();
+                }
             }
         }).start();
     }
@@ -67,7 +75,7 @@ public void onIpOK(){
         String text = ipText.getText();
         if(text.contains(":")){
             String[] map = text.split(":");
-            Client.getInstance().ipAddress = map[0];
+            Client.getInstance().ipAddress = map[0].trim();
             Client.getInstance().port = Integer.parseInt(map[1]);
         }else{
             Client.getInstance().ipAddress = text;