java Socket服务Demo

古城微笑少年丶 2021-10-20 00:00 260阅读 0赞

当前服务仅有2个类

一个服务端

一个客户端

！：此代码示例仅供demo演示，在生产环境中请谨慎，谢谢。

客户端像服务端发送消息后返回数据

SocketManager 服务端

package com.isstech.socket;
    
    import lombok.extern.slf4j.Slf4j;
    import java.io.DataInputStream;
    import java.io.DataOutputStream;
    import java.io.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    @Slf4j
    public class SocketManager {
    
        public static void main(String[] args) {
            SocketManager manager = new SocketManager();
            manager.doListen();
        }
    
        public void doListen() {
            ServerSocket server;
            try {
                server = new ServerSocket(9991);
                while (true) {
                    Socket client = server.accept();
                    new Thread(new SSocket(client)).start();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        class SSocket implements Runnable {
            Socket client;
    
            public SSocket(Socket client) {
                this.client = client;
            }
    
            public void run() {
                DataInputStream input;
                DataOutputStream output;
                try {
                    input = new DataInputStream(client.getInputStream());
                    output = new DataOutputStream(client.getOutputStream());
                    Thread.sleep(5000L);
                    String data = input.readUTF();
                    output.writeUTF("Recive1:  " + data);
                    log.info("接口名称 access {}", data);
                    data = input.readUTF();
                    output.writeUTF("Recive2:  " + data);
                    log.info("接收的数据 {}", data);
                } catch (IOException e) {
                    e.printStackTrace();
                } catch (Exception e) {}
            }
        }
    }

SocketClient

客户端

package com.isstech.socket;
    
    import lombok.extern.slf4j.Slf4j;
    import java.io.DataInputStream;
    import java.io.DataOutputStream;
    import java.io.OutputStream;
    import java.net.Socket;
    
    @Slf4j
    public class SocketClient {
    
        public static void main(String[] args) throws Exception {
            exet();
        }
    
        public static void exet() throws Exception {
            Socket socket = null;
            socket = new Socket("127.0.0.1", 9991);
            //向服务器端第一次发送
            OutputStream netOut = socket.getOutputStream();
            DataOutputStream doc = new DataOutputStream(netOut);
            DataInputStream in = new DataInputStream(socket.getInputStream());
            //向服务器端第二次发送
            doc.writeUTF("save");
            String res = in.readUTF();
            log.info("返回的接口名称 {}", res);
            String data = "{name:zhangsan, age:22}";
            doc.writeUTF(data);
            res = in.readUTF();
            log.info("返回的数据 {}", res);
            doc.close();
            in.close();
    
            if (socket != null) {
                socket.close();
            }
        }
    }