Java中怎么组建和修改多线程服务器

这篇文章将为大家详细讲解有关Java中怎么组建和修改多线程服务器，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。

修改 acceptConnections() 以用缺省为 50（或任何您想要的大于 1 的指定数字）实例化 ServerSocket 。

修改 ServerSocket 的 handleConnection() 以用 ConnectionHandler 的一个实例生成一个新的 Thread 。

借用 RemoteFileServer 的 handleConnection() 方法的代码实现 ConnectionHandler 类。
附： MultithreadedRemoteFileServer 的完整代码清单

Java代码

import java.io.*;   import java.net.*;   public class MultithreadedRemoteFileServer {   protected int listenPort;   public MultithreadedRemoteFileServer(int aListenPort) {   listenPort = aListenPort;   }   public void acceptConnections() {   try {   ServerSocket server = new ServerSocket(listenPort, 5);   Socket incomingConnection = null;   while (true) {   incomingConnection = server.accept();   handleConnection(incomingConnection);   }   }catch (BindException e) {   System.out.println("Unable to bind to port " + listenPort);   } catch (IOException e) {   System.out.println("Unable to instantiate a ServerSocket on port: " + listenPort);   }   }   public void handleConnection(Socket connectionToHandle) {   new Thread(new ConnectionHandler(connectionToHandle)).start();   }   public static void main(String[] args) {   MultithreadedRemoteFileServer server = new MultithreadedRemoteFileServer(3000);   server.acceptConnections();   }   }   import java.io.*;  import java.net.*;  public class MultithreadedRemoteFileServer {  protected int listenPort;  public MultithreadedRemoteFileServer(int aListenPort) {  listenPort = aListenPort;  }  public void acceptConnections() {  try {  ServerSocket server = new ServerSocket(listenPort, 5);  Socket incomingConnection = null;  while (true) {  incomingConnection = server.accept();  handleConnection(incomingConnection);  }  } catch (BindException e) {  System.out.println("Unable to bind to port " + listenPort);  } catch (IOException e) {  System.out.println("Unable to instantiate a ServerSocket on port: " + listenPort);  }  }  public void handleConnection(Socket connectionToHandle) {  new Thread(new ConnectionHandler(connectionToHandle)).start();  }  public static void main(String[] args) {  MultithreadedRemoteFileServer server = new MultithreadedRemoteFileServer(3000);  server.acceptConnections();  }  }

ConnectionHandler 的完整代码清单

Java代码

import java.io.*;   import java.net.*;   public class ConnectionHandler implements Runnable {   protected Socket socketToHandle;   public ConnectionHandler(Socket aSocketToHandle) {   socketToHandle = aSocketToHandle;   }   public void run() {   try {   PrintWriter streamWriter = new PrintWriter(socketToHandle.getOutputStream());   BufferedReader streamReader = new BufferedReader(new InputStreamReader(socketToHandle.getInputStream()));   String fileToRead = streamReader.readLine();   BufferedReader fileReader = new BufferedReader(new FileReader(fileToRead));   String line = null;   while ((line = fileReader.readLine()) != null)   streamWriter.println(line);   fileReader.close();   streamWriter.close();   streamReader.close();   } catch (Exception e) {   System.out.println("Error handling a client: " + e);   }   }   }

关于Java中怎么组建和修改多线程服务器就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。