今天在测试一个socket客户端的时候出现了一个问题，就是socket的输出流如果不关闭的话，那么消息就发不到服务端，write和flush方法都没有作用，最开始是设置了读超时，等到客户端读超时后到finnaly里面关闭输出流的时候，服务端才收到客户端的消息，然后在flush后面加上socket.shutdownoutputstream，服务端也能够及时收到消息，反过来服务端给客户端回信息也是一样，也要调用shutdownoutputstream客户端才能读到消息，请问有人知道是什么原因吗
代码如下，其中shutdownoutputstream是出现问题后填上的：
服务端
public class ServerTest {
public static void main(String[] a) throws IOException, InterruptedException {
ServerSocket server = new ServerSocket();
server.bind(new InetSocketAddress(1287));
while (true) {
Socket socket = server.accept();
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
StringBuilder sb = new StringBuilder();
String temp = null;
long b=System.currentTimeMillis();
while (StringUtils.isNotBlank((temp = br.readLine()))) {
sb.append(temp);
}
long e=System.currentTimeMillis();
System.out.println(e-b);
System.out.println(sb.toString());
// Thread.sleep(2000);
System.out.println("return..........");
bw.write("return..........");
bw.flush();
socket.shutdownOutput();
}
}
}
客户端
public static String send(String message, String serverIp, int port, int connectTimeout, int readTimeout,
String encoding) throws Exception {
Socket socket = null;
if (logger.isDebugEnabled()) {
logger.debug("主机信息：ip=" + serverIp + "，端口=" + port + "，发送报文：" + message);
}
try {
socket = new Socket();
socket.connect(new InetSocketAddress(serverIp, port), connectTimeout);
socket.setSoTimeout(readTimeout);
socket.setSoLinger(true, 1);
socket.setTcpNoDelay(true);
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out.write(message);
out.flush();
socket.shutdownOutput();
StringBuilder sb = new StringBuilder();
String temp = null;
while (StringUtils.isNotBlank((temp = in.readLine()))) {
sb.append(temp);
}
if (logger.isDebugEnabled()) {
logger.debug("接收应答：" + sb.toString());
}
return sb.toString();
} catch (Exception e) {
throw e;
} finally {
if (socket != null) {
socket.close();
}
}
}
