Java网络编程中客户端接收不到消息的问题的解决方法

解决方法"/>

Java网络编程中客户端接收不到消息的问题的解决方法

文章目录

• Java网络编程中的客户端接收不到消息问题的解决方法
• • 问题分析
  • 解决方案 一
  • 解决方案 二

Java网络编程中的客户端接收不到消息问题的解决方法

问题分析

今天在使用Java尝试使用网络编程进行客户端和服务器的通信是，发现服务器能够正常收到消息，但是客户端不能，一开始以为是代码逻辑问题，所以想了很久，最后参考了以下博客才成功解决问题：
博客地址
首先贴上原始出现问题的代码：
服务器端的代码：

//TCPsever.java
package Net;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;public class TCPServer {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(8888);Socket sever = ss.accept();InputStream inputStream = sever.getInputStream();int len;byte [] bytes = new byte[1024];while((len = inputStream.read(bytes)) != -1){System.out.println(new String(bytes,0,len));}OutputStream outputStream = sever.getOutputStream();outputStream.write("我收到了你的消息".getBytes());sever.close();ss.close();inputStream.close();outputStream.close();}
}

客户端代码：

//TCPClient.java
package Net;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;public class TCPClient {public static void main(String[] args) throws IOException {//创建Socket对象，构造方法绑定服务器和IP地址的通信号Socket client = new Socket("localhost",8888);//获取OutputStream对象OutputStream outputStream = client.getOutputStream();//使用流中的write方法给服务器写数据outputStream.write("你好服务器".getBytes());//获取InputStream对象InputStream inputStream = client.getInputStream();int len;byte [] bytes = new byte[1024];while((len = inputStream.read(bytes)) != -1){System.out.println(new String(bytes,0,len));}client.close();inputStream.close();outputStream.close();}
}

解决方案 一

运行以上代码后我们发现，只有服务器端有输出，而客户端是没有输出的，这是因为，read()方法要读到流的结束标记才会返回 -1 （也就是说要关闭流的时候会返回-1），而我们的 inputStream是客户端的， 我们不可能在客户端 就把 InputStram给关闭了， 因为这个流对象， 服务端也要使用，所以 我们的客户端 socket还有一个方法 shutdownOutput(), 禁止此套接字的输出流，通俗点说，就是给输出流加了一个结束标记， 可以使 is.read()在读的时候可以返回 -1；所以，客户端的代码中在 os.write()后面要加上一个，结束标记的语句， socket.shutdownOutput(), 它可以添加一个结束标记， 又不至于把 流给关闭
因此修改后的代码如下：
服务器端的代码：

//TCPsever.java
package Net;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;public class TCPServer {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(8888);Socket sever = ss.accept();InputStream inputStream = sever.getInputStream();int len;byte [] bytes = new byte[1024];while((len = inputStream.read(bytes)) != -1){System.out.println(new String(bytes,0,len));}OutputStream outputStream = sever.getOutputStream();outputStream.write("我收到了你的消息".getBytes());sever.close();ss.close();inputStream.close();outputStream.close();}
}

客户端代码：

//TCPClient.java
package Net;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;public class TCPClient {public static void main(String[] args) throws IOException {//创建Socket对象，构造方法绑定服务器和IP地址的通信号Socket client = new Socket("localhost",8888);//获取OutputStream对象OutputStream outputStream = client.getOutputStream();//使用流中的write方法给服务器写数据outputStream.write("你好服务器".getBytes());client.shutdownOutput();	//增加的用来解决问题的代码//获取InputStream对象InputStream inputStream = client.getInputStream();int len;byte [] bytes = new byte[1024];while((len = inputStream.read(bytes)) != -1){System.out.println(new String(bytes,0,len));}client.close();inputStream.close();outputStream.close();}
}

————————————————
版权声明：本文为CSDN博主「A黄俊辉A」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。

解决方案 二

当然我们也可以不使用while循环使用以下方法来解决问题，但是缺点是需要自己判断什么时候输入的数据的大小，即调整bytes数组的大小：

//TCPsever.java
package Net;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;public class TCPServer {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(8888);Socket sever = ss.accept();InputStream inputStream = sever.getInputStream();int len;byte [] bytes = new byte[1024];len = inputStream.read(bytes);System.out.println(new String(bytes,0,len));OutputStream outputStream = sever.getOutputStream();outputStream.write("我收到了你的消息".getBytes());sever.close();ss.close();inputStream.close();outputStream.close();}
}

客户端代码：

//TCPClient.java
package Net;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;public class TCPClient {public static void main(String[] args) throws IOException {//创建Socket对象，构造方法绑定服务器和IP地址的通信号Socket client = new Socket("localhost",8888);//获取OutputStream对象OutputStream outputStream = client.getOutputStream();//使用流中的write方法给服务器写数据outputStream.write("你好服务器".getBytes());//获取InputStream对象InputStream inputStream = client.getInputStream();int len;byte [] bytes = new byte[1024];len = inputStream.read(bytes);System.out.println(new String(bytes,0,len));client.close();inputStream.close();outputStream.close();}
}