Java Scoket实现双向通信（代码详解）

比眉伴天荒 2023-10-06 11:47 3阅读 0赞

> 你好我是辰兮，很高兴你能来阅读，本篇总结了Java Scoket类的相关知识，并且整理了实现双向通信的相关代码也有案例实现截图，分享获取新知，大家一起进步。

*  `JAVA基础面试常考问题` ： [JAVA面试基础常考题汇集][JAVA]
 *  `JAVA面试SSM框架常考` ：[JAVA框架面试题汇集][JAVA 1]

--------------------

#### 文章目录 ####

*   *   *  一、网络通信
         *  二、接受者（Receiver）
         *  三、发送者(Sender)
         *  四、案例截图

--------------------

#### 一、网络通信 ####

网络通信，在网络中程序（发送者）与程序（接受者）之间的数据交互。

**通信要素①ip + 端口号 ②传输协议**

java.net包: 包含了Java用于网络通信所需的类。

ServerSocket类，用于表示网络服务

创建网络服务（创建ServerSocket对象）

//构造器
    public ServerSocket(int port)
    
    //创建网络服务
    ServerSocket server = new ServerSocket(9999);

接收网络请求

//接收网络请求的方法
    public Socket accept()
    
    //网络服务接收请求（阻塞）
    Socket socket = server.accept();

Socket类，网络套接字，表示网络连接

发送网络请求
    //构造器
    public Socket(String ip, int port)
    //获取网络连接中的输入流
    public InputStream getInputStream()
    //获取网络连接中的输出流
    public OuputStream getOutputStream()

--------------------

#### 二、接受者（Receiver） ####

代码实现如下:信息的接受者

public class Receiver {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                ServerSocket server = new ServerSocket(8888);
                Socket socket = server.accept();
                System.out.println("----程序已经连接++++");
                InputStream is = socket.getInputStream();
                OutputStream os = socket.getOutputStream();
                InputStreamReader isr = new InputStreamReader(is);
                BufferedReader br = new BufferedReader(isr);
                PrintWriter pw = new PrintWriter(os);
                Runnable r1 = new Runnable() {
        
                    @Override
                    public void run() {
        
                        while (true) {
        
                            // 接受信息
                            String str;
                            try {
        
                                str = br.readLine();
                                System.out.println("sender的信息" + str);
                            } catch (IOException e) {
        
                                e.printStackTrace();
                            }
                        }
                    }
                };
                Runnable r2 = new Runnable() {
        
                    @Override
                    public void run() {
        
                        // 返回信息
                        while (true) {
        
                            Scanner scan = new Scanner(System.in);
                            String msg = scan.nextLine();
                            pw.println(msg);
                            pw.flush();
                        }
                    }
                };
                
                Thread t1 = new Thread(r1);
                Thread t2 = new Thread(r2);
                t1.start();
                t2.start();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

--------------------

#### 三、发送者(Sender) ####

代码实现如下:信息的发送者

public class Sender {
        
    
        public static void main(String[] args) {
        
            try {
        
                Socket socket = new Socket("192.168.1.6", 8888);
                InputStream is = socket.getInputStream();
                OutputStream os = socket.getOutputStream();
                InputStreamReader isr = new InputStreamReader(is);
                BufferedReader br = new BufferedReader(isr);
                PrintWriter pw = new PrintWriter(os);
                Runnable r = new Runnable() {
        
                    @Override
                    public void run() {
        
                        while (true) {
        
                            // 发送信息
    
                            try {
        
                                Scanner scan = new Scanner(System.in);
                                String msg = scan.nextLine();
                                pw.println(msg);
                                pw.flush();
                            } catch (Exception e) {
        
                            }
    
                        }
    
                    }
                };
    
                Runnable r2 = new Runnable() {
        
                    @Override
                    public void run() {
        
                        // 接受发送的信息
                        while (true) {
        
                            String str;
                            try {
        
                                str = br.readLine();
                                System.out.println("接受者receiver:" + str);
                            } catch (IOException e) {
        
                                e.printStackTrace();
                            }
                        }
                    }
                };
                Thread t1 = new Thread(r);
                Thread t2 = new Thread(r2);
                t1.start();
                t2.start();
    
            } catch (UnknownHostException e) {
        
    
                e.printStackTrace();
            } catch (IOException e) {
        
    
                e.printStackTrace();
            }
        }
    }

--------------------

#### 四、案例截图 ####

首先看到开启Receiver，然后开启Sender

开启Sender后----看到Receiver控制台显示连接成功

![在这里插入图片描述][20200622180423516.png]  
Sender发送信息  
![在这里插入图片描述][20200622180430845.png]  
Receiver接受到信息，然后回复  
![在这里插入图片描述][20200622180436133.png]  
点开Sender控制台，看到回复的信息然后继续回复  
![在这里插入图片描述][20200622180444213.png]  
双向沟通交流实现  
![在这里插入图片描述][20200622180448280.png]

--------------------

`The best investment is to invest in yourself`

![在这里插入图片描述][20200504104023371.jpg]

`2020.06.22 记录辰兮的第86篇博客`

[JAVA]: https://blog.csdn.net/weixin_45393094/article/details/104816195
[JAVA 1]: https://blog.csdn.net/weixin_45393094/article/details/104878236
[20200622180423516.png]: https://img-blog.csdnimg.cn/20200622180423516.png
[20200622180430845.png]: https://img-blog.csdnimg.cn/20200622180430845.png
[20200622180436133.png]: https://img-blog.csdnimg.cn/20200622180436133.png
[20200622180444213.png]: https://img-blog.csdnimg.cn/20200622180444213.png
[20200622180448280.png]: https://img-blog.csdnimg.cn/20200622180448280.png
[20200504104023371.jpg]: https://img-blog.csdnimg.cn/20200504104023371.jpg