永州公司做网站seo搜索引擎优化案例
问题描述：
在用socket的通信中，经常会出现这种情况，客户端连接服务器，客户端使用输出流写数据，服务器用输入流读数据，但是服务器会出现read()的阻塞，导致程序一直阻塞跑不下去。
解决方法：
一 客户端使用flush()方法，刷新缓存。
结果没用，一样会阻塞。
二 客户端使用输出流时用write(b, off, len)方法，请求数据多长就输出多长，服务器接收时也按照这个长度接。
结果没用，而且不实际，服务器读数据时要先判断数据长度，有点麻烦。
三 客户端在用完write方法后马上用out.close()关闭输出流，这样服务器就不会阻塞。
可以解决服务器的阻塞，但是现实情况是客户端与服务器的交互时相互的，如果采用这种方法，服务端可以接受客户端的数据，但是客户端无法接受服务端返回的数据，如果协议是单向的可以采用这种方法。
四 服务器用一个byte当做容器，设置这个容器的长度，每次读数据时，如果读的长度等于这个容器长度，说明后面还可能有数据，当读的数据长度小于这个容器长度时，说明后面没有数据了，就用break来退出read()方法，解决阻塞。
可以解决服务器的阻塞， 也是没有副作用。
分析原因：
服务端在用read方法的时候，如用byte[1024]来当容器，当客户端剩余数据不够填满的这个容器时，服务端就会一直读，等读够为止，但是当客户端输出流写完数据时，服务端却不知道读完了，本应read()返回-1的，却一直在阻塞。哪怕客户端用了flush()或者用write(b, off, len)，服务端本应知道输出流结束的，但是无法得知，虽然客户端如果主动把输出流关闭，服务端就可以知道输出流结束，继续跑程序，但是缺点明显， 解决方法三时已经说了，所以只有解决方法四才能解决这个问题。
代码示例：
TCP服务端：
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;import org.omg.CORBA.INTERNAL;public class Server { public static final int PORT = 12345;//监听的端口号 public static void main(String[] args) { System.out.println("TCP服务器启动:\n"); Server server = new Server(); server.init(); } public void init() { try { ServerSocket serverSocket = new ServerSocket(PORT); while (true) { Socket client = serverSocket.accept(); System.out.println("接到新连接：" + client.getInetAddress() + "-" + client.getPort());// 用线程处理 new HandlerThread(client); } } catch (Exception e) { System.out.println("服务器异常: " + e.getMessage()); } } private class HandlerThread implements Runnable { private Socket socket; public HandlerThread(Socket client) { socket = client; new Thread(this).start(); } public void run() { try { // 读取客户端数据 InputStream input = socket.getInputStream(); StringBuffer acceptMsg = new StringBuffer();int MsgLong = 0;//接收数据总长度int len = 0; //每次容器读时的长度byte[] b = new byte[1024]; //容器，存放数据while ((len = input.read(b)) != -1) {//一直读，读到没数据为止acceptMsg.append(new String(b, 0, len, "GBK"));MsgLong += len;if (len < 1024) {//如果读的长度小于1024，说明是最后一次读,后面已经没有数据，跳出循环break;}} // 处理客户端数据 System.out.println("客户端发过来的内容长度:" + MsgLong); System.out.println("客户端发过来的内容:" + acceptMsg.toString()); // 向客户端回复信息 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); // 发送键盘输入的一行 String s = "server send msg to client"; System.out.print("服务端返回数据:\t"+s); out.write(s.getBytes()); out.close(); input.close(); } catch (Exception e) { System.out.println("服务器 run 异常: " + e.getMessage()); } finally { if (socket != null) { try { socket.close(); } catch (Exception e) { socket = null; System.out.println("服务端 finally 异常:" + e.getMessage()); } } } } }
}TCP客户端
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;public class TcpClient {public static final String IP_ADDR = "localhost";//服务器地址 public static final int PORT = 12345;//服务器端口号 public static void main(String[] args) { System.out.println("客户端启动..."); // while (true) { Socket socket = null; try { //创建一个流套接字并将其连接到指定主机上的指定端口号 socket = new Socket(IP_ADDR, PORT); //向服务器端发送数据 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); //String Msg = "WC傅九 1620102198311152715 "; //String Msg = "1a9x317 <?xml version=\"1.0\" encoding=\"GBK\"?><HEAD><stdbwtype>Request</stdbwtype><stdyhdm>08</stdyhdm><stdprocode>DS90</stdprocode><stdseqnum>DS900820190125091052</stdseqnum></HEAD><ROOT><std400idtp>01</std400idtp><std400idno>440702198209151846</std400idno><std400cunm>余洁丽</std400cunm><stddkksrq>20190101</stddkksrq></ROOT>"; //String Msg = "1a9x472 2jC3sFn90ZE+vNG+/ivuKKiBDB97pTNyUgPKx6e8co6PfyHywlKTapd8pIwwR0mEsF3e3oJdlQGLeD1Qe2hyKm3Bo+HGy4wQrK34RKQgcindIxjMrOIzxcIVL1AmX7ROUNDVnvk9FiPnHGGAi1uUWWwa+QlvD5e2r23WvLrOU0ZLrZEGr1tqmkLxnpMIIbEFO5JxwNoVd6yihyvvH+vg2Vcgj7C2+K/3o+nn+pFPkDtoHKhoON5ZOsEoIkU3M2l4G9DRgP30wPzcFdEaOoN094z/mg80aY0pfgG+3LNJowXwxGDBRoaRwulHvRNZBU2yuzNhImm4YVnckVCwhA35YqKr/E5aIyQzAWsmQZ3CtMoDJNxC7kI35YHmY446Fs48niuO8pdxI0NONIl/mciT8eH7VlFDDU0CfNLLFpSw8rdQUXzRByC5zAHI400AhEb2pHYBVthrGrVWJT3TBb4w7g==";String Msg = "client send to server";System.out.println("客户端数据长度" + Msg.length());System.out.println("客户端发送数据：" + Msg);out.write(Msg.getBytes() , 0 , Msg.length());out.flush(); out.close(); //读取服务器端数据 DataInputStream input = new DataInputStream(socket.getInputStream()); StringBuffer returnMsg = new StringBuffer();int len = 0;byte[] b = new byte[1024]; //容器，存放数据while ((len = input.read(b)) != -1) {//一直读，读到没数据为止returnMsg.append(new String(b, 0, len, "UTF-8"));} System.out.println("服务器端返回过来的是: " + returnMsg.toString()); out.close(); input.close(); } catch (Exception e) { System.out.println("客户端异常:" + e.getMessage()); } finally { if (socket != null) { try { socket.close(); } catch (IOException e) { socket = null; System.out.println("客户端 finally 异常:" + e.getMessage()); } } } }
}