欢迎进入Java社区论坛，与200万技术人员互动交流 >>进入
三、多线程服务器
在实际应用中是在服务器上运行一个永久的程序，接收来自其他多个客户端的请求，提供相应的服务。需要利用多线程实现多客户机制。服务器在指定的端口上监听是否有客户请求，一旦监听到就会启动一个专门的服务线程来响应该请求，而服务器本身在启动完线程之后马上又进入监听状态，等待下一个客户的到来。只要将服务端为如下代码，Client1和Client2就会异步执行。
/**
* 多线程服务端0
*
* @author 徐越
*
*/
public class MultiThreadServer0
{
// 端口号
private int port = 8821;
// 服务端
private ServerSocket serverSocket;
public MultiThreadServer0（） throws IOException
{
// 创建服务器端
serverSocket = new ServerSocket（port）；
System.out.println（”服务器启动”）；
}
public void service（）
{
while （true）
{
Socket socket = null;
try
{
// 客户端进行连接时会触发accept方法从而建立连接
socket = serverSocket.accept（）；
new MultiThreadHandler（socket）。start（）；
}
catch （Exception e）
{
e.printStackTrace（）；
}
}
}
public static void main（String[] args） throws IOException
{
new MultiThreadServer1（）。service（）；
}
}
/**
* 多线程处理类
*/
class MultiThreadHandler extends Thread
{
private Socket socket;
public MultiThreadHandler（Socket socket）
{
this.socket = socket;
}
private BufferedReader getReader（Socket socket） throws IOException
{
InputStream socketIn = socket.getInputStream（）；
// InputStreamReader为转换流
// InputStream本是字节流，现加一个Reader,表示用字符流的方式读取字节流
InputStreamReader isr = new InputStreamReader（socketIn）；
return new BufferedReader（isr）；
}
public void run（）
{
try
{
BufferedReader br = getReader（socket）；
String msg = null;
while （（msg = br.readLine（）） != null）
{
System.out.println（”客户端的IP:” + socket.getInetAddress（）。getHostAddress（））；
System.out.println（”客户端的端口：” + socket.getPort（））；
System.out.println（”客户端的信息：” + msg）；
}
}
catch （IOException e）
{
e.printStackTrace（）；
}
finally
{
try
{
if （socket != null）
{
socket.close（）；
}
}
catch （IOException e）
{
e.printStackTrace（）；
}
}
}
}
/**
* 多线程服务端1
*/
public class MultiThreadServer1
{
// 端口号
private int port = 8821;
// 服务端
private ServerSocket serverSocket;
// 线程池
private ExecutorService executorService;
// 单个CPU线程池大小
private final int POOL_SIZE = 10;
public MultiThreadServer1（） throws IOException
{
// 创建服务器端
serverSocket = new ServerSocket（port）；
// 获取当前系统的CPU数目
int cpuNums = Runtime.getRuntime（）。availableProcessors（）；
// 根据系统资源情况灵活定义线程池大小
executorService = Executors.newFixedThreadPool（cpuNums * POOL_SIZE）；
System.out.println（”服务器启动”）；
}
public void service（）
{
while （true）
{
Socket socket = null;
try
{
[1][2][3]
背着背包的路上，看过许多人，听过许多故事，
