socket长连接客户端服务端

package com.socket; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.io.Reader; import .Socket; import java.nio.CharBuffer; /* * Socket 长连接 客户端 */ public class Client03 private String host = ““; private int port = 5055; /* * 数据发送线程 */ class SendThread implements Runnable private Socket socket; public SendThread(Socket socket) this.socket = socket; public void run() while (true) try PrintWriter pw = new PrintWriter(new OutputStreamWriter( socket.getOutputStream(); pw.write(“this is client“); pw.flush(); Thread.sleep(2000); catch (Exception e) e.printStackTrace(); /* * 数据接收线程 */ class ReceiveThread implements Runnable private Socket socket; public ReceiveThread(Socket socket) this.socket = socket; public void run() while (true) try Reader reader = new InputStreamReader( socket.getInputStream(); CharBuffer charBuffer = CharBuffer.allocate(8192); SuppressWarnings(“unused“) int charIndex = -1; while (charIndex = reader.read(charBuffer) != -1) charBuffer.flip(); System.out .println(“client “ + charBuffer.toString(); catch (IOException e) e.printStackTrace(); private void start() try Socket socket = new Socket(host, port);/ 创建 Socket new Thread(new SendThread(socket).start();/ 启动读线程 new Thread(new ReceiveThread(socket).start();/ 启动收线程 catch (Exception e) e.printStackTrace(); public static void main(String args) new Client03().start(); package com.socket; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.io.Reader; import java.io.Writer; import .ServerSocket; import .Socket; import java.nio.CharBuffer; /* * Socket 长连接 服务端 */ public class Server03 private ServerSocket serverSocket; private Socket socket; private int port = 5055; private void start() throws Exception serverSocket = new ServerSocket(port); while (true) socket = serverSocket.accept(); new Thread(new SocketThread(socket).start();/ 多线程阻塞 /* * 处理 socket 连接 s */ class SocketThread implements Runnable private Socket socket; private String temp = “; public SocketThread(Socket socket) this.socket = socket; SuppressWarnings(“unused“) public void run() try Reader reader = new InputStreamReader(socket.getInputStream(); Writer writer = new OutputStreamWriter(socket.getOutputStream(); CharBuffer charBuffer = CharBuffer.allocate(1024); int readIndex = -1; while (readIndex = reader.read(charBuffer) != -1) charBuffer.flip(); temp += charBuffer.toString(); System.out.println(“server“ + temp); writer.write(“this is server“); writer.flush(); catch (IOException e) e.printStackTrace(); finally if (socket != null) if (!socket.isClosed() try socket.close(); catch (IOException e)