import java.io.DataInputStream;  
import java.io.DataOutputStream;  
import java.io.IOException;  
import java.net.ServerSocket;  
import java.net.Socket;  
  
/** 
 * 服务器返回用户输入的信息， 为多个用户提供服务：为每个客户分配一个工作线程 
 */  
public class ChatServers {  
    private int port = 8189;// 默认服务器端口  
  
    public ChatServers() {  
    }  
  
    // 创建指定端口的服务器  
    public ChatServers(int port) {  
        this.port = port;  
    }  
  
    public void service() {  
       
        try {  
            // 建立服务器连接,设定客户连接请求队列的长度  
            ServerSocket server = new ServerSocket(port,3);  
            while (true) {  
                // 等待客户连接  
                Socket socket = server.accept();  
            socket.setSoTimeout(15000);         
                new Thread(new ServerThread(socket)).start();  
            }  
        } catch (IOException e) {  
            e.printStackTrace();  
        }  
    }  
  
    public static void main(String[] args) {  
        new ChatServers().service();  
    }  
}  
  
class ServerThread implements Runnable {  
    private Socket socket;  
  
    public ServerThread(Socket socket) {  
        this.socket = socket;  
    }  
  
    // 任务是为一个用户提供服务  
    @Override  
    public void run() {  
        try {  
            try {  
                // 读取客户端传过来信息的DataInputStream  
                DataInputStream in = new DataInputStream(socket  
                        .getInputStream());  
                // 向客户端发送信息的DataOutputStream  
                DataOutputStream out = new DataOutputStream(socket  
                        .getOutputStream());  
                while (true) {  
                    // 读取来自客户端的信息  
                    String accpet = in.readUTF();  
                    out.writeUTF("服务器：" + accpet);  
                }  
            } finally {// 建立连接失败的话不会执行socket.close();  
                socket.close();  
            }  
        } catch (IOException e) {  
            e.printStackTrace();  
        }  
    }  
}