【Java】Java socket通信使用read,readline函数的阻塞问题
2021-03-13 10:30
标签：传递数据 div 服务 test bsp client stack ide io流 Socket通信是Java网络编程中比较基础的部分，其原理其实就是源ip，源端口和目的ip，目的端口组成的套接字通信。其底层还设及到了TCP协议的通信。 Java中的Socket通信可以通过客户端的Socket与服务端的ServerSocket通信，同时利用IO流传递数据，也就是说Socket通信是面向流的使用的是BIO，并不同于后来的NIO通信面向缓冲。Socket通信中使用的IO流的read，readline等函数都是阻塞的，这就导致了在通信过程中，双方不能确定什么时侯是流的结束，针对这种可以通过约定结束符的方式进行结束，也可以约定一次传输的字节流的长度。下面通过代码进行说明 建立客户端线程，在run方法中不断对服务端进行发送消息，模拟多个客户端的通信，通过写入换行符，表明这次通信的结束。 服务端通过accept接受客户端的连接，这个操作是阻塞的，直到有客户端的连接才能进行下一步。 服务端针对客户端的每条信息都能够进行读取并返回消息给客户端，但是如果注释掉写入换行符，并判断读取是否是换行符的代码，就无法读取到流的结束。 【Java】Java socket通信使用read,readline函数的阻塞问题 标签：传递数据 div 服务 test bsp client stack ide io流 原文地址：https://www.cnblogs.com/silentsherlock/p/13961362.html客户端
1 class Client implements Runnable {
2
3 private byte[] targetIp;
4 private int port;
5
6 Client(byte[] ip, int port) {
7 this.targetIp = ip;
8 this.port = port;
9 }
10
11 @Override
12 public void run() {
13 try {
14 InetAddress inetAddress = InetAddress.getByAddress(targetIp);
15 Socket socket = new Socket(inetAddress, port);
16 System.out.println("client");
17 BufferedReader socketInput = new BufferedReader(new InputStreamReader(socket.getInputStream()));
18 BufferedWriter socketOutput = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
19
20 int i = 0;
21 String NAME = "Client";
22 while (true) {
23 socketOutput.write("This msg from " + NAME + " msg id is " + i);
24 socketOutput.write("\n");//约定结束符表示流的结束
25 i++;
26 socketOutput.flush();
27 System.out.println("here");
28 String str = null;
29 if (!(str = socketInput.readLine()).equals("\n")) {
30 System.out.println(str);
31 }
32
33 }
34
35 /*socket.shutdownInput();
36 socket.shutdownOutput();*/
37 } catch (IOException e) {
38 e.printStackTrace();
39 }
40
41 }
42 }
服务端
1 class Server implements Runnable {
2
3 private int port;
4
5 Server(int port) {
6 this.port = port;
7 }
8 @Override
9 public void run() {
10 try {
11 ServerSocket serverSocket = new ServerSocket(port);
12
13 InetAddress inetAddress = serverSocket.getInetAddress();
14 System.out.println("server" + inetAddress.getHostAddress());
15 Socket socket = serverSocket.accept();
16 BufferedReader socketInput = new BufferedReader(new InputStreamReader(socket.getInputStream()));
17 BufferedWriter socketOutput = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
18
19 int i = 0;
20 while (true) {
21 String str = null;
22 if (!(str = socketInput.readLine()).equals("\n")) System.out.println(str);
23 System.out.println("server");
24
25 String NAME = "Server";
26 socketOutput.write("This msg from " + NAME + " msg num is " + i + " reply to " + str);
27 socketOutput.write("\n");
28 i++;
29 socketOutput.flush();
30 }
31
32 // socket.shutdownInput();
33 // socket.shutdownOutput();
34 } catch (IOException e) {
35 e.printStackTrace();
36 }
37
38 }
39 }
测试
1 public class SocketTest {
2 public static void main(String[] args) {
3 byte[] ip = {127, 0, 0, 1};
4 int port = 27149;
5 Thread server = new Thread(new Server(port), "server");
6 server.start();
7 Thread client = new Thread(new Client(new byte[]{0,0,0,0}, 27149));
8 client.start();
9 }
10 }
结果
下一篇：Python稳基修炼之异常处理
文章标题：【Java】Java socket通信使用read,readline函数的阻塞问题
文章链接：http://soscw.com/index.php/essay/64083.html