socketperformer.java

基于streamsocket的简单聊天室

package socketChat;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class SocketPerformer {
		Socket socket;
    public SocketPerformer(Socket theSoc){
        socket = theSoc;
    }
    public void execut() throws Exception{
        BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 定义连接的输入流
        PrintWriter socketWriter = new PrintWriter(socket.getOutputStream()); // 定义连接的输出流
        System.out.println("connection built !");   
      
        Receiver rec = new Receiver(socketReader); // 新建包装过的输入流线程
        rec.start(); // 包装流线程启动
        
        Sender sender = new Sender(socketWriter); // 新建包装过的输出流线程
        sender.start(); //包装流线程启动
     }
}