用Java Socket开发支持上千个并发的小型服务器（下） - 编程入门网
| . protected ServerSocket serverSocket;8. public PooledRemoteFileServer(int aListenPort, int maxConnections) {9. listenPort= aListenPort;10. this.maxConnections = maxConnections;11. }12. public void acceptConnections() {13. try {14. ServerSocket server = new ServerSocket(listenPort, 5);15. Socket incomingConnection = null;16. while(true) {17. incomingConnection = server.accept();18. handleConnection(incomingConnection);19. }20. }21. catch(BindException e) {22. System.out.println("");23. }24. catch(IOException e) {25. System.out.println(""+listenPort);26. }27. }28. protected void handleConnection(Socket connectionToHandle) {29. PooledConnectionHandler.processRequest(connectionToHandle);30. }31. public void setUpHandlers() {32. for(int i=0; i<maxConnections; i++) {33. PooledConnectionHandler currentHandler = new PooledConnectionHandler();34. new Thread(currentHandler, "Handler " + i).start();35. }36. }37. public static void main(String args[]) {38. PooledRemoteFileServer server = new PooledRemoteFileServer(1001, 3);39. server.setUpHandlers();40. server.acceptConnections();41. }42.}
请注意一下您现在应该熟悉了的import语句。我们给类以下实例变量以保存： •我们的服务器能同时处理的活动客户机连接的最大数目 •进入的连接的侦听端口（我们没有指定缺省值，但如果您想这样做，并不会受到限制） •将接受客户机连接请求的ServerSocket 类的构造器用的参数是侦听端口和连接的最大数目 我们的类有一个main()方法和三个其它方法。稍后我们将探究这些方法的细节。现在只须知道setUpHandlers()创建数目为maxConnections的大量PooledConnectionHandler，而其它两个方法则与我们前面已经看到的相似：acceptConnections()在ServerSocket上侦听传入的客户机连接，而handleConnection则在客户机连接一旦被建立后就实际处理它。 实现main() 这里我们实现需作改动的main()方法，该方法将创建能够处理给定数目的客户机连接的PooledRemoteFileServer，并告诉它接受连接：
1.public static void main(String args[]) {2. PooledRemoteFileServer server = new PooledRemoteFileServer(1001, 3);3. server.setUpHandlers();4. server.acceptConnections();5.}
我们的main()方法很简单。我们实例化一个新的PooledRemoteFileServer，它将通过调用setUpHandlers()来建立三个PooledConnectionHandler。一旦服务器就绪，我们就告诉它acceptConnections()。 建立连接处理程序
1.public void setUpHandlers() {2. for(int i=0; i<maxConnections; i++) {3. PooledConnectionHandler currentHandler = new PooledConnectionHandler();4. new Thread(currentHandler, "Handler " + i).start();5. }6. }
setUpHandlers()方法创建maxConnections（例如3）个PooledConnectionHandler并在新Thread中激活它们。用实现了Runnable的对象来创建Thread使我们可以在Thread调用start()并且可以期望在Runnable上调用了run()。换句话说，我们的PooledConnectionHandler将等着处理进入的连接， |
凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢! |
