java多线程—socket编程实例

《java多线程—socket编程实例》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。

1、多线程JavaSocket编程示例这篇做为学习孙卫琴<>的学习笔记吧.其中采用Java5的ExecutorService来进行线程池的方式实现多线程,模拟客户端多用户向同一服务器端发送请求.1.服务端package sterning;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStr

2、eam;import java.io.PrintWriter;import java.net.*;import java.util.concurrent.*;public class MultiThreadServer {    private int port=8821;    private ServerSocket serverSocket;    private ExecutorService executorService;//线程池    private final int POOL_SIZE=10;//单个CPU线程池大

3、小        public MultiThreadServer() throws IOException{        serverSocket=new ServerSocket(port);        //Runtime的availableProcessor()方法返回当前系统的CPU数目.        executorService=Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_SIZE);        Sys

4、tem.out.println("服务器启动");    }otherstaffoftheCentre.Duringthewar,ZhuwastransferredbacktoJiangxi,andDirectorofthenewOfficeinJingdezhen,JiangxiCommitteeSecretary.Startingin1939servedasrecorderoftheWestNorthOrganization,SecretaryoftheSpecialCommitteeAfterthevictoryofthelon

5、gMarch,hehasbeentheNorthwestOfficeoftheFederationofStateenterprisesMinister,ShenmufuguSARmissions,DirectorofNingxiaCountypartyCommitteeSecretaryandrecorderoftheCountypartyCommitteeSecretary,Ministersand        public void service(){        while(true){            Socket

6、 socket=null;            try {                //接收客户连接,只要客户进行了连接,就会触发accept();从而建立连接                socket=serverSocket.accept();                executorService.execute(new Handler(socket));                            } catch (Exception e) {                e.printStackT

7、race();            }        }    }        public static void main(String[] args) throws IOException {        new MultiThreadServer().service();    }}class Handler implements Runnable{    private Socket socket;    public Handler(Socket socket){        this.socket=socket;

8、    }    private PrintWriter getWriter(Socket socket) throws IOException{        OutputStream socketOut=socket