socket客户端服务器通信多种情况代码

package edu.hrbeu.serversocket; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.Writer; import java.net.ServerSocket; import java.net.Socket; //双向通信，多个客户端连接同一个服务端 public class Server3 { public static void main(String args[]) throws IOException { //为了简单起见，所有的异常信息都往外抛 int port = 8892; //定义一个ServerSocket监听在端口8899上 ServerSocket server = new ServerSocket(port); while (true) { //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 Socket socket = server.accept(); //每接收到一个Socket就建立一个新的线程来处理它 new Thread(new Task(socket)).start(); } } /** * 用来处理Socket请求的 */ static class Task implements Runnable { private Socket socket; public Task(Socket socket) { this.socket = socket; } public void run() { try { handleSocket(); } catch (Exception e) { e.printStackTrace(); } } /** * 跟客户端Socket进行通信 * @throws Exception */ private void handleSocket() throws Exception { //BufferedReader的readLine方法是一次读一行， //这个方法是阻塞的，直到它读到了一行数据为止程序才会继续往下执行， //直到程序遇到了换行符或者是对应流的结束符readLine方法才会认为读到了一行，才会结束其阻塞，让程序继续往下执行。 //所以在使用BufferedReader的readLine读取数据的时候一定要记得 //在对应的输出流里面一定要写入换行符（流结束之后会自动标记为结束，readLine可以识别）， //写入换行符之后一定记得,如果输出流不是马上关闭的情况下记得flush一下，这样数据才会真正的从缓冲区里面写入 BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream())); StringBuilder sb = new StringBuilder(); String temp; int index; while ((temp=br.readLine()) != null) { System.out.println(temp); if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收 sb.append(temp.substring(0, index)); break; } sb.append(temp); } System.out.println("from client: " + sb); //读完后写一句 Writer writer = new OutputStreamWriter(socket.getOutputStream()); writer.write("Hello Client."); writer.write("eof\n"); writer.flush(); writer.close(); br.close(); socket.close(); } } }