serverlisten.java

java聊天室服务端

package S;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class ServerListen extends Thread 
{
    static ServerThread serverThread;

	public void run(){
    	Socket s;
    	
		while(true){
			try
			{
				s = TestChatServer.socket.accept();
				OutputStream os = s.getOutputStream();
				TestChatServer.output = new DataOutputStream(os);
				InputStream is = s.getInputStream(); 
				TestChatServer.input = new DataInputStream(is);
				serverThread = new ServerThread();
		        serverThread.start();
		        TestChatServer.textField2.setText("在线用户" + List.getCount() + "人\n");
			}
			catch (IOException e)
			{
				e.printStackTrace();
			}
			
		}
				
		
    	
    	
    	
    }
}