服务端

package com.ninemax.socket;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;public class SocketServer {public static void main(String[] args) {try {// 监听端口ServerSocket server = new ServerSocket(9999);// 获取客户端链接Socket client = server.accept();// 获取客户端输入流BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));// 获取客户端输出流PrintWriter out = new PrintWriter(client.getOutputStream());// 获取系统输入流BufferedReader sys_in = new BufferedReader(new InputStreamReader(System.in));// 启动接收消息线程new ReceiveMsgThread(server, in, out, sys_in, client).start();// 启动发送消息线程new SendMsghread(out, sys_in, true).start();} catch (IOException e) {e.printStackTrace();}}
}

客户端

package com.ninemax.socket;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;public class SocketClient {public static void main(String[] args) {try {// 获取客户端链接Socket client = new Socket(InetAddress.getLocalHost(), 9999);System.out.println("客户端是否连接成功:" + client.isConnected());// 获取客户端输入流BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));// 获取系统输入流BufferedReader sys_in = new BufferedReader(new InputStreamReader(System.in));// 获取客户端输出流PrintWriter out = new PrintWriter(client.getOutputStream());// 启动发送消息线程new SendMsghread(out, sys_in, false).start();// 启动接收消息线程new ReceiveMsgThread(client, in, out, sys_in).start();} catch (UnknownHostException e) {System.out.println("Host is error!");e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}}

发送消息线程

package com.ninemax.socket;import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.text.SimpleDateFormat;
import java.util.Date;public class SendMsghread extends Thread {// 输出流PrintWriter out;// 输入流BufferedReader in;// 判断服务器是否启动boolean isServer;public SendMsghread(PrintWriter out, BufferedReader in, boolean isServer) {this.out = out;this.in = in;this.isServer = isServer;}@Overridepublic void run() {SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");try {while(true){if(isServer){out.println("Server  "+sf.format(new Date())+"\n\t"+ in.readLine());}else{out.println("client  "+sf.format(new Date())+"\n\t"+ in.readLine());}out.flush();}} catch (IOException e) {e.printStackTrace();}}
}

接收消息线程

package com.ninemax.socket;import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;public class ReceiveMsgThread extends Thread {// 输入流BufferedReader in;// 输入流BufferedReader sys_in;// 输出流PrintWriter out;// 服务端socketServerSocket server;// 客户端socketSocket client;public ReceiveMsgThread(ServerSocket server, BufferedReader in,PrintWriter out, BufferedReader sys_in, Socket client) {this.in = in;this.server = server;this.client = client;this.out = out;this.sys_in = sys_in;}public ReceiveMsgThread(Socket client,BufferedReader in, PrintWriter out,BufferedReader sys_in) {this.in = in;this.client = client;this.out = out;this.sys_in = sys_in;}@Overridepublic void run() {try {while(true){String info = in.readLine();while(info !=null){System.out.println(info);info = in.readLine();}if(in.readLine().equals("end")){break;}}in.close();out.close();sys_in.close();if(client != null){client.close();}server.close();} catch (IOException e) {e.printStackTrace();}}
}

运行结果图