有哪些信誉好的足球投注网站- 1、本文档共6页，可阅读全部内容。
- 2、有哪些信誉好的足球投注网站（book118）网站文档一经付费（服务费），不意味着购买了该文档的版权，仅供个人/单位学习、研究之用，不得用于商业用途，未经授权，严禁复制、发行、汇编、翻译或者网络传播等，侵权必究。
- 3、本站所有内容均由合作方或网友上传，本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺！文档内容仅供研究参考，付费前请自行鉴别。如您付费，意味着您自己接受本站规则且自行承担风险，本站不退款、不进行额外附加服务；查看《如何避免下载的几个坑》。如果您已付费下载过本站文档，您可以点击 这里二次下载。
- 4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等，请点击“版权申诉”（推荐），也可以打举报电话：400-050-0827(电话支持时间：9:00-18:30)。
查看更多
多客户端访问服务器_使用JDK自带线程池实现(三)
Socket通讯
使用线程池实现多客户端访问服务器
使用线程池
Java.util.concurrent包提供了线程池的实现
一、运行方法
先编译源码：
javac EchoServer.java javac EchoClient.java
启动服务器
java EchoServer
准备接收客户端的请求，客户端给服务器发送什么信息，服务器给客户端回复什么信息，客户端给服务器发送bye后，服务器与客户端的基本同事断开socket连接，服务器并不会停止，继续为其他的客户端服务。该服务器引用Java.util.concurrent包中线程池的实现比自己创建更加健壮，除非你是骨灰级的高手。
启动多客户端
java EchoClient
客户端1：
客户端2：
二、JAVA源码：
服务器java代码(EchoServer.java)
import java.util.*;
import java.net.*;
import java.io.*;
import java.util.concurrent.*;
public class EchoServer{
private int port = 8000;
private ServerSocket serverSocket;
private ExecutorService executorService; //线程池
private final int POOL_SIZE = 6; //单个CPU时线程池中工作线程的数目
public EchoServer() throws IOException{
serverSocket = new ServerSocket(port);
// 创建线程池
// Runtime的availableProcessors()返回当前系统CPU的数目
// 系统CPU越多线程池中的工作线程越多
executorService = Executors.newFixedThreadPool(
Runtime.getRuntime().availableProcessors()*POOL_SIZE);
System.out.println(CPU线程的数目：+Runtime.getRuntime().availableProcessors());
System.out.println(服务器启动);
}
public void service(){
while(true){
Socket socket = null;
try{
socket = serverSocket.accept();
executorService.execute(new Handler(socket));
}catch(IOException e){
e.printStackTrace();
}
}
}
//负责单个客户端通讯的任务
class Handler implements Runnable{
private Socket socket;
public Handler(Socket socket){
this.socket = socket;
}
private PrintWriter getWriter(Socket socket)throws IOException{
OutputStream socketOut = socket.getOutputStream();
return new PrintWriter(socketOut,true);
}
private BufferedReader getReader(Socket socket) throws IOException{
InputStream socketIn =socket.getInputStream();
return new BufferedReader(new InputStreamReader(socketIn));
}
private String echo(String msg){
return echo : + msg;
}
public void run(){
try{
System.out.println(New connection acception : +
socket.getInetAddress()+:+socket.getPort());
BufferedReader br = getRea
文档评论（0）