我在应用程序中使用ServerSocket
时遇到了问题。
我正在应用程序的构造函数中创建ServerSocket
。套接字的构造函数调用accept()
方法以等待客户端连接。
问题是accept()
方法冻结了我的整个应用程序,直到客户端连接。所以我想问一下,除了在单独的线程中创建整个ServerSocket
之外,是否还有另一种选择,即在我的主应用程序旁边调用ServerSocket
的构造函数及其accept()
方法?
编辑:
感谢Olivier的建议,将.accept放入一个可运行的,并创建一个线程池来处理客户端连接。
这就是我现在的代码:
public void start(){
final ExecutorService clientProcessingPool = Executors.newFixedThreadPool(10);
Runnable serverTask = new Runnable() {
@Override
public void run() {
try {
serverSocket = new ServerSocket(port);
while (true) {
Socket clientSocket = serverSocket.accept();
objectout = new ObjectOutputStream(clientSocket.getOutputStream());
clientProcessingPool.submit(new ClientTask(clientSocket,objectout));
}
} catch (IOException e) {
System.err.println("Accept failed.");
}
}
};
一切运行得很好!谢谢!
发布于 2013-03-21 15:37:57
为此,我通常使用N+1线程:一个用于ServerSocket,以避免阻塞整个应用程序等待客户端连接;N个线程用于处理客户端的请求,N是线程池的大小(我建议使用线程池,而不是为每个客户端创建一个新线程)。
下面是一个示例(只需编写代码,您可能希望有更好的异常管理等等,但这只是一个最小的工作示例)
public class Server {
public static void main(String[] args) {
new Server().startServer();
}
public void startServer() {
final ExecutorService clientProcessingPool = Executors.newFixedThreadPool(10);
Runnable serverTask = new Runnable() {
@Override
public void run() {
try {
ServerSocket serverSocket = new ServerSocket(8000);
System.out.println("Waiting for clients to connect...");
while (true) {
Socket clientSocket = serverSocket.accept();
clientProcessingPool.submit(new ClientTask(clientSocket));
}
} catch (IOException e) {
System.err.println("Unable to process client request");
e.printStackTrace();
}
}
};
Thread serverThread = new Thread(serverTask);
serverThread.start();
}
private class ClientTask implements Runnable {
private final Socket clientSocket;
private ClientTask(Socket clientSocket) {
this.clientSocket = clientSocket;
}
@Override
public void run() {
System.out.println("Got a client !");
// Do whatever required to process the client's request
try {
clientSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
https://stackoverflow.com/questions/15541804
复制相似问题