create client

Author: magiclu550

.idea/misc.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
-  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_5">
+  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_8">
     <output url="file://$MODULE_DIR$/target/classes" />
     <output-test url="file://$MODULE_DIR$/target/test-classes" />
     <content url="file://$MODULE_DIR$">

panel-client.iml

@@ -1,17 +1,24 @@
-package cn.jsmod2.client.panel;
+package cn.jsmod2.client;
 
+import com.alibaba.fastjson.JSON;
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.EventLoopGroup;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioSocketChannel;
 
+import java.util.HashMap;
 import java.util.concurrent.CountDownLatch;
 
 public class Client {
     private static class SingletonHolder {
         static final Client instance = new Client();
     }
+
+    public String ipAddress;
+
+    public int port;
+
     public static Client getInstance(){
         return SingletonHolder.instance;
     }
@@ -29,22 +36,21 @@ private Client(){
                 .channel(NioSocketChannel.class)
                 .handler(clientInitializer);
     }
-    public void connect(){
+    public void connect(String ip,int port){
         //192.168.43.51测试端口8766 192.168.43.102 线上端口8765
         try {
-            this.cf = b.connect("127.0.01", 8888).sync();
-            System.out.println("远程服务器已经连接, 可以进行数据交换..");
+            this.cf = b.connect(ip, port).sync();
         } catch (InterruptedException e) {
             e.printStackTrace();
         } finally {
         }
     }
-    public ChannelFuture getChannelFuture(){
+    public ChannelFuture getChannelFuture(String ip,int port){
         if(this.cf == null) {
-            this.connect();
+            this.connect(ip,port);
         }
         if(!this.cf.channel().isActive()){
-            this.connect();
+            this.connect(ip,port);
         }
         return this.cf;
     }
@@ -57,8 +63,17 @@ public void close(){
         }
     }
     public String setMessage(String msg) {
+        if(ipAddress == null){
+            return JSON.toJSONString(new HashMap<String,String>(){
+                {
+                    put("status","500");
+                    put("message","unknown ipAddress");
+                    put("value","null");
+                }
+            });
+        }
         try {
-            ChannelFuture cf = getInstance().getChannelFuture();//单例模式获取ChannelFuture对象
+            ChannelFuture cf = getInstance().getChannelFuture(ipAddress,port);//单例模式获取ChannelFuture对象
             cf.channel().writeAndFlush(msg);
             //发送数据控制门闩加一
             lathc = new CountDownLatch(1);
@@ -72,4 +87,5 @@ public String setMessage(String msg) {
     }
 
 
+
 }

src/main/java/cn.jsmod2.client.panel/JsonRequester.java

@@ -1,4 +1,4 @@
-package cn.jsmod2.client.panel;
+package cn.jsmod2.client;
 
 import io.netty.channel.ChannelHandlerAdapter;
 import io.netty.channel.ChannelHandlerContext;

…/java/cn.jsmod2.client.panel/Client.java …c/main/java/cn/jsmod2/client/Client.javasrc/main/java/cn.jsmod2.client.panel/Client.java renamed to src/main/java/cn/jsmod2/client/Client.java src/main/java/cn.jsmod2.client.panel/Client.java renamed to src/main/java/cn/jsmod2/client/Client.java

@@ -1,4 +1,4 @@
-package cn.jsmod2.client.panel;
+package cn.jsmod2.client;
 
 import io.netty.channel.ChannelInitializer;
 import io.netty.channel.socket.SocketChannel;

…n.jsmod2.client.panel/ClientHandler.java …java/cn/jsmod2/client/ClientHandler.javasrc/main/java/cn.jsmod2.client.panel/ClientHandler.java renamed to src/main/java/cn/jsmod2/client/ClientHandler.java src/main/java/cn.jsmod2.client.panel/ClientHandler.java renamed to src/main/java/cn/jsmod2/client/ClientHandler.java

@@ -1,4 +1,4 @@
-package cn.jsmod2.client.panel;
+package cn.jsmod2.client;
 
 import javafx.collections.ObservableList;
 import javafx.scene.control.TextArea;

…mod2.client.panel/ClientInitializer.java …/cn/jsmod2/client/ClientInitializer.javasrc/main/java/cn.jsmod2.client.panel/ClientInitializer.java renamed to src/main/java/cn/jsmod2/client/ClientInitializer.java src/main/java/cn.jsmod2.client.panel/ClientInitializer.java renamed to src/main/java/cn/jsmod2/client/ClientInitializer.java

@@ -0,0 +1,31 @@
+package cn.jsmod2.client;
+
+import com.alibaba.fastjson.JSON;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class JsonRequester {
+
+    private Map<String,String> map = new HashMap<String, String>();
+
+    public JsonRequester append(String key,String value){
+        map.put(key,value);
+        return this;
+    }
+
+    public String toJSON(){
+        return JSON.toJSONString(map);
+    }
+
+    @SuppressWarnings("unchecked")
+    public Response sendOut(){
+        HashMap<String,String> map = JSON.parseObject(Client.getInstance().setMessage(toJSON()),HashMap.class);
+        Response response = new Response();
+        response.setMessage(map.get("message"));
+        response.setValue(map.get("value"));
+        response.setStatus(map.get("status"));
+        return response;
+    }
+}
+

…d2.client.panel/ConsoleOutputStream.java …n/jsmod2/client/ConsoleOutputStream.javasrc/main/java/cn.jsmod2.client.panel/ConsoleOutputStream.java renamed to src/main/java/cn/jsmod2/client/ConsoleOutputStream.java src/main/java/cn.jsmod2.client.panel/ConsoleOutputStream.java renamed to src/main/java/cn/jsmod2/client/ConsoleOutputStream.java

@@ -1,4 +1,4 @@
-package cn.jsmod2.client.panel;
+package cn.jsmod2.client;
 
 import javafx.application.Application;
 import javafx.fxml.FXMLLoader;

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

@@ -0,0 +1,34 @@
+package cn.jsmod2.client;
+
+public class Response {
+
+    private String value;
+
+    private String status;
+
+    private String message;
+
+    public String getValue() {
+        return value;
+    }
+
+    public void setValue(String value) {
+        this.value = value;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+}