ServerSocket和Socket建立通信(服务器和客户端循环接收发送)-白红宇的个人博客

ServerSocket和Socket建立通信(服务器和客户端循环接收发送)

发布日期：2022-01-31 20:00:22 浏览次数：38 分类：技术文章

本文共 1992 字，大约阅读时间需要 6 分钟。

需求：服务器不断的接收返回信息到客户端中，客户端可以不断地额给服务器发送消息，并可以接收到服务器返回的消息。这跟我们聊天一样。

思路：1、服务器端：1）建立ServerSocket和开启监听客户端连接

2）在循环中构建IO流，不断的读取客户端发送过来的数据。

2、客户端：1）建立Socket和服务器连接通信

2）再循环中构建IO流，不断的通过键盘输入消息发送到服务器中，在接收来自服务器返回的消息

服务器端：

[java]
 package server.cotrol;  
   
 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 Server03 {  
     public static void main(String[] args) {  
         try {  
             ServerSocket ss = new ServerSocket(8888);  
             System.out.println("服务器已启动");  
             Socket s = ss.accept();  
             //构建IO流  
             while(true){  
                 BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));  
                 String mess = br.readLine();  
                 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));  
                 //为了证明是服务器返回的数据，我对mess修改在发送到客户端  
                 String str = "服务器>>"+mess+"\n";  
                 bw.write(str);  
                 bw.flush();  
             }  
         } catch (IOException e) {  
             e.printStackTrace();  
         }  
     }  
 }  

客户端：

[java]
 package client.cotrol;  
   
 import java.io.BufferedReader;  
 import java.io.BufferedWriter;  
 import java.io.IOException;  
 import java.io.InputStreamReader;  
 import java.io.OutputStreamWriter;  
 import java.net.Socket;  
 import java.net.UnknownHostException;  
 import java.util.Scanner;  
   
 public class Client03 {  
     public static void main(String[] args) {  
         try {  
             Socket s = new Socket("127.0.0.1",8888);  
             System.out.println("客户端IP:"+s.getLocalAddress()+"端口"+s.getPort());  
             //构建IO流  
             BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));  
               
             //建立键盘输入：  
             Scanner scanner = new Scanner(System.in);  
             while(true){  
                 System.out.println("请输入发送消息内容：");  
                 bw.write(scanner.nextLine()+"\n");  
                 bw.newLine();  
                 bw.flush();  
                 BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));  
                 //读取服务器返回的消息数据  
                 System.out.println(s.getInetAddress().getLocalHost()+":"+s.getPort()+">>"+br.readLine());  
             }  
               
               
         } catch (UnknownHostException e) {  
             e.printStackTrace();  
         } catch (IOException e) {  
             e.printStackTrace();  
         }  
           
     }  
 }  

转载地址：https://blog.csdn.net/qq_23315711/article/details/73693763 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！

上一篇：ServerSocket和Socket建立通信(客户端发送消息服务器接收并返回到客户端接收输出)

下一篇：REST简介

发表评论

关于作者

喝酒易醉，品茶养心，人生如梦，品茶悟道，何以解忧？唯有杜康！

-- 愿君每日到此一游！

发表评论

最新留言

关于作者

推荐文章