分享解决TCP服务端客户端一次性交互read阻塞的问题 - 黑马程序员技术交流社区

/*
服务端
*/
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
class TcpServer
{
public static void main(String[] args) throws Exception
{
ServerSocket ss = new ServerSocket(10000);
Socket s = ss.accept();
InputStream is = s.getInputStream();
String ip = s.getInetAddress().getHostAddress();
System.out.println(ip);
byte[] buf = new byte[1024];
int len = 0;
while((len=is.available())!=0) //判断流对象数据是否到达末尾
{
len=is.read(buf);//获取流对象数据长度
String str = new String(buf,0,len);
System.out.println(str);
}
PrintWriter os = new PrintWriter(s.getOutputStream(),true);
os.println("send to client");
s.close(); //关闭客户端对象
ss.close(); //关闭服务器这里可选，可关可不关
}
}
/*
客户端
*/
import java.io.InputStream;
import java.io.PrintWriter;
import java.net.Socket;
class TcpClient
{
public static void main(String[] args) throws Exception
{
Socket s = new Socket("192.168.2.100",10000);
PrintWriter os = new PrintWriter(s.getOutputStream(),true);
os.println("send to server");
InputStream is = s.getInputStream();
byte[] buf = new byte[1024];
int len = 0;
while((len=is.read(buf))!=-1) //这里用这种循环其实也会进入等待状态，而因为服务器端传回“send to client”后就把s.close()关了，所以这里就算等待也会被结束掉。
{
System.out.println(new String(buf,0,len));
}
s.close();
}
}

复制代码