针对于tcp简单socket的聊天

package TcpChat;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;public class MonitoringMessage extends Thread {private Socket socket;public Socket getSocket() {return socket;}public void setSocket(Socket socket) {this.socket &＃61; socket;}public MonitoringMessage(Socket socket) {super();this.socket &＃61; socket;}public void run() {try {BufferedReader br &＃61; new BufferedReader(new InputStreamReader(this.socket.getInputStream()));while(true){//用死循环等待对方发送的消息
System.out.println(br.readLine());}} catch (IOException e) {e.printStackTrace();}}
}

package TcpChat;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;public class ClientChat {public static void main(String[] args) {Socket socket &＃61; null;try {socket &＃61; new Socket("127.0.0.1",5431);PrintWriter out &＃61; new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);BufferedReader br &＃61; new BufferedReader(new InputStreamReader(System.in));new MonitoringMessage(socket).start(); //监听发送过来的消息while(true){out.println(br.readLine());}} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally{if(null!&＃61;socket){try {socket.close();} catch (IOException e) {// TODO Auto-generated catch block
e.printStackTrace();}}}}
}

package TcpChat;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;public class ServiceChat {public static void main(String[] args) {ServerSocket serverSocket &＃61; null;Socket socket &＃61; null;try {serverSocket &＃61; new ServerSocket(5431);socket &＃61; serverSocket.accept();BufferedReader br &＃61; new BufferedReader(new InputStreamReader(System.in));PrintWriter out &＃61; new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);new MonitoringMessage(socket).start();while(true){out.println(br.readLine());}} catch (IOException e) {e.printStackTrace();}finally{if(null!&＃61;socket){try {socket.close();} catch (IOException e) {e.printStackTrace();}}if(null!&＃61;serverSocket){try {serverSocket.close();} catch (IOException e) {// TODO Auto-generated catch block
e.printStackTrace();}}}}
}