解决Java中socket使用getInputStream()阻塞问题
更新时间：2021年12月13日 15:35:03 作者：godelgnis
这篇文章主要介绍了解决Java中socket使用getInputStream()阻塞问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
socket使用getInputStream()阻塞
今天用socket进行编程练习时，发现程序到了getInputStream(）这里就进行不下去了
Socket socket = new Socket("127.0.0.1", 800);
ObjectInputStream reader = new ObjectInputStream(socket.getInputStream());
System.out.println("a");
ObjectOutputStream writer = new ObjectOutputStream(socket.getOutputStream());
就这样的一个测试代码，a不会打印出来
后来发现是getInputStream(）会一直阻塞在那里阻塞
我把两行代码调了一下就好了，还不太清楚原因，先记下来
Socket socket = new Socket("127.0.0.1", 800);
ObjectOutputStream writer = new ObjectOutputStream(socket.getOutputStream());
System.out.println("a");
ObjectInputStream reader = new ObjectInputStream(socket.getInputStream());
用线程解决Socket的getInputStream阻塞
1.背景
在Socket通信中，当我们希望传输对象时，往往会用到输入/输出对象流。
ObjectInputStream in=new ObjectInputStream(socket.getInputStream()); ObjectOutputStream out=new ObjectOutputStream(socket.getOutputStream());
2.问题
当程序调用socket.getInputStream()程序被被卡住。
3.原因
socket.getInputStream()方法会导致程序阻塞，直到inputStream收到对方发过来的报文消息，程序才会继续往下执行。
public ObjectInputStream(InputStream in) throws IOException的官方API显示：
Creates an ObjectInputStream that reads from the specified InputStream. A serialization stream header is read from the stream and verified. This constructor will block until the corresponding ObjectOutputStream has written and flushed the header. [1]
4.解决办法
用线程的方式处理输入流。以下为示例代码：
//===============客户端代码 SocketClient.java=====================
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
public class SocketClient {
private Socket socket;
private ObjectOutputStream out;
private ObjectInputStream in;
public SocketClient(){
try {
socket=new Socket("localhost",8081);
out=new ObjectOutputStream(socket.getOutputStream());
ReadThread readThread=new ReadThread();
readThread.start();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public void sendMessage(String msg){
System.out.println("send message:"+msg);
try {
out.writeObject(msg);
out.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
class ReadThread extends Thread{
boolean runFlag=true;
public void run(){
try {
in=new ObjectInputStream(socket.getInputStream());
} catch (IOException e1) {
e1.printStackTrace();
}
while(runFlag){
if(socket.isClosed()){
return;
}
try {
Object obj=in.readObject();
if(obj instanceof String){
System.out.println("Client recive:"+obj);
}
}
catch (IOException e) {
e.printStackTrace();
}
catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
}
public void exit(){
runFlag=false;
}
}
public static void main(String[] args) {
SocketClient socketClient=new SocketClient();
System.out.println("build socketClient");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
socketClient.sendMessage("Hello first.");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
socketClient.sendMessage("Hello second.");
}
}
//============服务器端代码 SocketService.java===========
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.Date;
public class SocketService {
ServerSocket serverSocket;
public SocketService(){
try {
serverSocket=new ServerSocket(8081);
while(true){
Socket socket=serverSocket.accept();
SocketServiceThread sst=new SocketServiceThread(socket);
sst.start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
class SocketServiceThread extends Thread{
Socket socket;
ObjectInputStream in;
ObjectOutputStream out;
boolean runFlag=true;
public SocketServiceThread(Socket socket){
if(null==socket){
runFlag=false;
return;
}
this.socket=socket;
try {
out=new ObjectOutputStream(socket.getOutputStream());
} catch (IOException e) {
e.printStackTrace();
}
}
public void run(){
if(null==socket){
System.out.println("socket is null");
return;
}
try {
in=new ObjectInputStream(socket.getInputStream());
while(runFlag){
if(socket.isClosed()){
System.out.println("socket is closed");
return;
}
try {
String obj=(String)in.readObject();
if(obj instanceof String){
System.out.println("Server recive:"+obj);
Date date=new Date();
out.writeObject("["+date+"]"+obj);
out.flush();
}
else{
System.out.println("Server recive:"+obj);
}
}
catch (ClassNotFoundException e) {
e.printStackTrace();
}
catch (SocketException e){
e.printStackTrace();
return;
}
catch (IOException e){
e.printStackTrace();
}
}
} catch (IOException e1) {
e1.printStackTrace();
return;
} catch (Exception e){
return;
}
}
public void exit(){
runFlag=false;
}
}
public static void main(String[] args) {
System.out.println("===============start service===============");
new SocketService();
}
}
5.Socket通信注意事项
（1）.writeXXX()方法后一般用flush()来把缓存内容发送出去。
（2）.发送对象时，对象必须串行化，即该对象需要实现Serializable接口。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了springboot使用QQ邮箱发送邮件功能，本文通过实例图文相结合给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2021-10-10
这篇文章主要介绍了Java设计模式中的适配器模式, 适配器模式是将一个类的接口适配成用户所期待的,一个适配允许通常因为接口不兼容而不能在一起工作的类工作在一起,做法是将类自己的接口包裹在一个已存在的类中,需要的朋友可以参考下2024-01-01
这篇文章主要介绍了Spring ProtocolResolver策略接口示例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-04-04
这篇文章主要介绍了java调用shell脚本及注意事项说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-06-06
Spring Cloud Config RSA简介及使用RSA加密配置文件的方法
Spring Cloud 为开发人员提供了一系列的工具来快速构建分布式系统的通用模型 。本文重点给大家介绍Spring Cloud Config RSA简介及使用RSA加密配置文件的方法，感兴趣的朋友跟随脚步之家小编一起学习吧2018-05-05
这篇文章主要介绍了Springboot集成规则引擎Drools方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-11-11
这篇文章主要介绍了RocketMQ重试机制及消息幂代码实例解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-02-02
这篇文章主要为大家详细介绍了java实现网站微信扫码支付，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-07-07
这篇文章给大家介绍了Java中父类Object的三个常用方法，对大家学习或使用Java具有一定的参考借鉴价值，有需要的朋友们下面来一起看看吧。2016-09-09
Spring Boot 项目中整合 MyBatis 和 PageHel
这篇文章主要介绍了Spring Boot 项目中整合 MyBatis 和 PageHelper的操作步骤,整合 PageHelper 到 Spring Boot 项目中主要包括添加依赖、配置数据源与 MyBatis、配置 PageHelper 以及在业务逻辑中使用 PageHelper 进行分页查询,需要的朋友可以参考下2024-04-04
最新评论