简单Client与Server的单向通信和双向通信

骑猪看日落 2022-04-06 12:42 183阅读 0赞

从Console中读取内容：

BufferedReader inputReader;  
    // Alt + Shift + z    try...catch等快捷键  
    // 从Console读取内容  
    try {  
        inputReader = new BufferedReader(new InputStreamReader(System.in));  
        String inputContent;  
        while (!(inputContent = inputReader.readLine()).equals("bye")) {  
            System.out.println(inputContent);  
        }  
    } catch (Exception e) {  
        e.printStackTrace();  
    }

**一.单向通信**

Client -> Server

SocketClient.java

import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.net.Socket;
    
    public class SocketClient {
    
        public static void main(String[] args) {
            SocketClient client = new SocketClient();
            client.start();
        }
    
        public void start() {
            BufferedReader inputReader = null;
            BufferedWriter writer = null;
            Socket socket = null;
            // 从Console读取内容  
            try {
                socket = new Socket("127.0.0.1", 9898);
                // 从socket进行写入  
                writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
                inputReader = new BufferedReader(new InputStreamReader(System.in));
                String inputContent;
                while (!(inputContent = inputReader.readLine()).equals("bye")) {
                    writer.write(inputContent + "\n");
                    writer.flush(); 
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                try {
                    writer.close();
                    inputReader.close();
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

SocketServer.java

import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class SocketServer {
    
        public static void main(String[] args) {
            SocketServer socketServer = new SocketServer();
            socketServer.startServer();
        }
    
        public void startServer() {
            ServerSocket serverSocket = null;
            BufferedReader reader = null;
            Socket socket = null;
            try {
                // 端口号只要不冲突就行  
                serverSocket = new ServerSocket(9898);
                System.out.println("server started..");
                // 进入阻塞状态，等待客户端接入  
                socket = serverSocket.accept();
                System.out.println("client " + socket.hashCode() + " connected");
                // 从socket中读取数据  
                reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String receiveMsg;
                while ((receiveMsg = reader.readLine()) != null) { // 以"\n"结束  
                    System.out.println(receiveMsg);
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                try {
                    reader.close();
                    socket.close();
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

**二.Client Server双向通信**

即时接受消息，也就是所谓的长连接，记得要先启动Server。

SocketClient2.java

import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.net.Socket;
    
    public class SocketClient2 {
    
        public static void main(String[] args) {
            SocketClient2 client = new SocketClient2();
            client.start();
        }
    
        public void start() {
            BufferedReader inputReader = null;
            // 从socket读取  
            BufferedReader reader = null;
            BufferedWriter writer = null;
            Socket socket = null;
            // Alt + Shift + z    try...catch等快捷键  
            // 从Console读取内容  
            try {
                socket = new Socket("127.0.0.1", 9898);
                // 用于读取服务器返回的数据  
                reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                // 从socket进行写入  
                writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
                inputReader = new BufferedReader(new InputStreamReader(System.in));
                String inputContent;
                while (!(inputContent = inputReader.readLine()).equals("bye")) {
                    writer.write(inputContent + "\n");
                    writer.flush();
                    //              System.out.println(inputContent);  
                    // 服务器返回的数据  
                    String response = reader.readLine();
                    System.out.println(response);
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                try {
                    reader.close();
                    writer.close();
                    inputReader.close();
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

SocketServer2.java

import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class SocketServer2 {
    
        public static void main(String[] args) {
            SocketServer2 socketServer = new SocketServer2();
            socketServer.startServer();
        }
    
        public void startServer() {
            ServerSocket serverSocket = null;
            BufferedReader reader = null;
            BufferedWriter writer = null;
            Socket socket = null;
            try {
                // 端口号只要不冲突就行  
                serverSocket = new ServerSocket(9898);
                System.out.println("server started..");
                // 进入阻塞状态，等待客户端接入  
                socket = serverSocket.accept();
                System.out.println("client " + socket.hashCode() + " connected");
                // 从socket中读取数据  
                reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
                String receiveMsg;
                while ((receiveMsg = reader.readLine()) != null) { // 以"\n"结束  
                    System.out.println(receiveMsg);
                    writer.write("server reply:" + receiveMsg + "\n");
                    writer.flush();
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                try {
                    reader.close();
                    writer.close();
                    socket.close();
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

**三.Socket模拟http请求响应（仅模拟）**

import java.io.BufferedReader;
    import java.io.InputStreamReader;
    import java.io.PrintStream;
    import java.io.PrintWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.Date;
    import java.util.Random;
    
    public class SimpleServer {
        private ServerSocket ss;
        private Socket socket;
        private BufferedReader in;
        private PrintWriter out;
        private Random random = new Random();
    
        public SimpleServer() {
            try {
                this.ss = new ServerSocket(9898);
    
                System.out.println("The server is waiting your input...");
                for (;;) {
                    this.socket = this.ss.accept();
    
                    this.in = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
                    this.out = new PrintWriter(this.socket.getOutputStream(), true);
                    String line = this.in.readLine();
    
                    System.out.println("you input is : " + line);
    
                    String echo = randomEcho();
                    System.out.println("echo : " + echo);
                    StringBuilder sb = new StringBuilder();
                    sb.append("HTTP/1.1 200 OK").append("\n")
                            .append("Content-Type:application/x-www-form-urlencoded;charset=UTF-8").append("\n")
                            .append("Date:").append(new Date().toString()).append("\n").append("Content-Length:")
                            .append(echo.getBytes().length).append("\n").append("\n").append(echo);
    
                    this.out.println(sb.toString());
                    this.out.flush();
    
                    this.out.close();
                    this.in.close();
                    this.socket.close();
                    if (line.equalsIgnoreCase("quit") || line.equalsIgnoreCase("exit") || line.equalsIgnoreCase("bye")) {
                        break;
                    }
                }
                this.ss.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        private String randomEcho() throws Exception {
            int num = this.random.nextInt();
            StringBuilder sb = new StringBuilder();
            sb.append("respCode=").append("0000").append("&").append("respMsg=").append("随机消息:" + num);
            //    String signature = SignUtil.sign(ResourcesUtils.getInstance().tppPriKey().trim().getBytes("UTF-8"), sb.toString());
            //    sb.append("&").append("signature=").append(signature);
            return sb.toString();
        }
    
        public static void main(String[] args) {
            new SimpleServer();
        }
    }

参考文章：[http://blog.csdn.net/DuanLiuchang/article/details/70148894?locationNum=13&fps=1][http_blog.csdn.net_DuanLiuchang_article_details_70148894_locationNum_13_fps_1]

[http_blog.csdn.net_DuanLiuchang_article_details_70148894_locationNum_13_fps_1]: http://blog.csdn.net/DuanLiuchang/article/details/70148894?locationNum=13&fps=1