create client

Author: magiclu550

.idea/compiler.xml

@@ -0,0 +1,16 @@
+<?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">
+    <output url="file://$MODULE_DIR$/target/classes" />
+    <output-test url="file://$MODULE_DIR$/target/test-classes" />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
+      <sourceFolder url="file://$MODULE_DIR$/src/resources" type="java-resource" />
+      <excludeFolder url="file://$MODULE_DIR$/target" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+    <orderEntry type="library" name="Maven: io.netty:netty-all:5.0.0.Alpha1" level="project" />
+    <orderEntry type="library" name="Maven: com.alibaba:fastjson:1.2.47" level="project" />
+  </component>
+</module>

.idea/misc.xml

@@ -0,0 +1,75 @@
+package cn.jsmod2.client.panel;
+
+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.concurrent.CountDownLatch;
+
+public class Client {
+    private static class SingletonHolder {
+        static final Client instance = new Client();
+    }
+    public static Client getInstance(){
+        return SingletonHolder.instance;
+    }
+    private EventLoopGroup group;
+    private Bootstrap b;
+    private ChannelFuture cf ;
+    private ClientInitializer clientInitializer;
+    private CountDownLatch lathc;
+    private Client(){
+        lathc = new CountDownLatch(0);
+        clientInitializer = new ClientInitializer(lathc);
+        group = new NioEventLoopGroup();
+        b = new Bootstrap();
+        b.group(group)
+                .channel(NioSocketChannel.class)
+                .handler(clientInitializer);
+    }
+    public void connect(){
+        //192.168.43.51测试端口8766 192.168.43.102 线上端口8765
+        try {
+            this.cf = b.connect("127.0.01", 8888).sync();
+            System.out.println("远程服务器已经连接, 可以进行数据交换..");
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        } finally {
+        }
+    }
+    public ChannelFuture getChannelFuture(){
+        if(this.cf == null) {
+            this.connect();
+        }
+        if(!this.cf.channel().isActive()){
+            this.connect();
+        }
+        return this.cf;
+    }
+    public void close(){
+        try {
+            this.cf.channel().closeFuture().sync();
+            this.group.shutdownGracefully();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+    public String setMessage(String msg) {
+        try {
+            ChannelFuture cf = getInstance().getChannelFuture();//单例模式获取ChannelFuture对象
+            cf.channel().writeAndFlush(msg);
+            //发送数据控制门闩加一
+            lathc = new CountDownLatch(1);
+            clientInitializer.resetLathc(lathc);
+            lathc.await();//开始等待结果返回后执行下面的代码
+            return clientInitializer.getServerResult();
+        }catch (InterruptedException e){
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+
+}

panel-client.iml

@@ -0,0 +1,44 @@
+package cn.jsmod2.client.panel;
+
+import io.netty.channel.ChannelHandlerAdapter;
+import io.netty.channel.ChannelHandlerContext;
+
+import java.util.concurrent.CountDownLatch;
+
+public class ClientHandler extends ChannelHandlerAdapter {
+
+    private CountDownLatch lathc;
+    private String result;
+    public ClientHandler(CountDownLatch lathc) {
+        this.lathc = lathc;
+    }
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+
+    }
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) {
+        result = (String) msg;
+        lathc.countDown();// 消息接收后释放同步锁，lathc是从Client加一传回来的
+    }
+
+    @Override
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        ctx.close();
+    }
+    public void resetLatch(CountDownLatch lathc) {
+        this.lathc = lathc;
+    }
+
+    public String getResult() {
+        return result;
+    }
+
+}

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

@@ -0,0 +1,32 @@
+package cn.jsmod2.client.panel;
+
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.handler.codec.string.StringDecoder;
+import io.netty.handler.codec.string.StringEncoder;
+import io.netty.handler.timeout.ReadTimeoutHandler;
+
+import java.util.concurrent.CountDownLatch;
+
+public class ClientInitializer extends ChannelInitializer<SocketChannel> {
+
+    private CountDownLatch lathc;
+    public ClientInitializer(CountDownLatch lathc) {
+        this.lathc = lathc;
+    }
+    private ClientHandler handler;
+    @Override
+    protected void initChannel(SocketChannel sc) throws Exception {
+        handler =  new ClientHandler(lathc);
+        sc.pipeline().addLast(new StringDecoder());//进行字符串的编解码设置
+        sc.pipeline().addLast(new StringEncoder());
+        sc.pipeline().addLast(new ReadTimeoutHandler(60));//设置超时时间
+        sc.pipeline().addLast(handler);
+    }
+    public String getServerResult(){
+        return handler.getResult();
+    }
+    public void resetLathc(CountDownLatch lathc) {
+        handler.resetLatch(lathc);
+    }
+}

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

@@ -0,0 +1,82 @@
+package cn.jsmod2.client.panel;
+
+import javafx.collections.ObservableList;
+import javafx.scene.control.TextArea;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+/**
+ * @ClassName: ConsoleOutputStream
+ * @Description: OutputStream
+ * @Author: GNX-Susanoo
+ * @Date: 2019/7/20 19:39
+ * @Version: 1.0
+ */
+public class ConsoleOutputStream extends OutputStream {
+    private TextArea textArea;
+    private int lineHeight = 100;
+    private volatile boolean scroll = true;
+
+    @Override
+    public void write(int b) throws IOException {
+        if (textArea == null) {
+            return;
+        }
+        textArea.appendText(String.valueOf((char) b));
+        cleanUpLin(textArea.getParagraphs());
+        if (scroll) {
+            textArea.setScrollTop(Double.MAX_VALUE);
+        }
+    }
+
+    @Override
+    public void write(byte[] b) throws IOException {
+        if (textArea == null) {
+            return;
+        }
+        textArea.appendText(new String(b));
+        cleanUpLin(textArea.getParagraphs());
+        if (scroll) {
+            textArea.setScrollTop(Double.MAX_VALUE);
+        }
+    }
+
+    public void write(String string) throws IOException {
+        if (textArea == null) {
+            return;
+        }
+        textArea.appendText(string);
+        cleanUpLin(textArea.getParagraphs());
+        if (scroll) {
+            textArea.setScrollTop(Double.MAX_VALUE);
+        }
+    }
+
+    private void cleanUpLin(ObservableList<CharSequence> charSequencesList) {
+        if (charSequencesList.size() > lineHeight + 1) {
+            textArea.deleteText(0, charSequencesList.get(0).length() + 1);
+            cleanUpLin(charSequencesList);
+        }
+    }
+
+    public int getLineHeight() {
+        return lineHeight;
+    }
+
+    public void setLineHeight(int lineHeight) {
+        this.lineHeight = lineHeight;
+    }
+
+    public boolean isScroll() {
+        return scroll;
+    }
+
+    public void setScroll(boolean scroll) {
+        this.scroll = scroll;
+    }
+
+    public void setTextArea(TextArea textArea) {
+        this.textArea = textArea;
+    }
+}

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

@@ -0,0 +1,20 @@
+package cn.jsmod2.client.panel;
+
+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);
+    }
+}

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

@@ -0,0 +1,24 @@
+package cn.jsmod2.client.panel;
+
+import javafx.application.Application;
+import javafx.fxml.FXMLLoader;
+import javafx.scene.Parent;
+import javafx.scene.Scene;
+import javafx.stage.Stage;
+
+public class Main extends Application {
+
+    public static void main(String[] args) {
+        launch(args);
+    }
+
+    @Override
+    public void start(Stage primaryStage) throws Exception {
+        Parent root = FXMLLoader.load(getClass().getResource("/ui/start.fxml"));
+        primaryStage.setTitle("Jsmod2-Control-Panel");
+        primaryStage.setResizable(false);
+        primaryStage.setScene(new Scene(root, 650, 450));
+        primaryStage.show();
+    }
+
+}