多线程Java Socket编程示例

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

多线程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.OutputStream;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线程池大小        public MultiThreadServer() throws IOException{        serverSocket=new ServerSocket(port);        //Runtime的availableProcessor()方法返回当前系统的CPU数目.        executorService=Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_SIZE);        System.out.println("服务器启动");    }         public void service(){        while(true){            Socket socket=null;            try {                //接收客户连接,只要客户进行了连接,就会触发accept();从而建立连接                socket=serverSocket.accept();                executorService.execute(new Handler(socket));                            } catch (Exception e) {                e.printStackTrace();            }        }    }        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;    }    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));    }    public String echo(String msg){        return "echo:"+msg;    }    public void run(){        try {            System.out.println("New connection accepted "+socket.getInetAddress()+":"+socket.getPort());            BufferedReader br=getReader(socket);            PrintWriter pw=getWriter(socket);            String msg=null;            while((msg=br.readLine())!=null){                System.out.println(msg);                pw.println(echo(msg));                if(msg.equals("bye"))                    break;            }        } catch (IOException e) {            e.printStackTrace();        }finally{            try {                if(socket!=null)                    socket.close();            } catch (IOException e) {                e.printStackTrace();            }        }     }}2.客户端package sterning;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.Socket;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class MultiThreadClient {        public static void main(String[] args) {        int numTasks = 10;                ExecutorService exec = Executors.newCachedThreadPool();        for (int i = 0; i < numTasks; i++) {            exec.execute(createTask(i));        }    }    // 定义一个简单的任务    private static Runnable createTask(final int taskID) {        return new Runnable() {             private Socket socket = null;            private int port=8821;            public void run() {                System.out.println("Task " + taskID + ":start");                try {                                        socket = new Socket("localhost", port);                    // 发送关闭命令                    OutputStream socketOut = socket.getOutputStream();                    socketOut.write("shutdownr ".getBytes());                    // 接收服务器的反馈                    BufferedReader br = new BufferedReader(                            new InputStreamReader(socket.getInputStream()));                    String msg = null;                    while ((msg = br.readLine()) != null)                        System.out.println(msg);                } catch (IOException e) {                                        e.printStackTrace();                }            }        };    }}从而实现了多个客户端向服务器端发送请求,服务器端采用多线程的方式来处理的情况.再结合我之前的例子---Java基于Socket文件传输示例,就可以实现多线程文件的传输了 评论# re:多线程JavaSocket编程示例  回复  更多评论  2007-11-1014:25byxiongzeng请问作者：可不可以利用服务端主动发信？# re:多线程JavaSocket编程示例  回复  更多评论  2007-12-0713:12byqifen膏药帖~~# re:多线程JavaSocket编程示例  回复  更多评论  2008-01-0722:19byjava综合网很好！不错！# re:多线程JavaSocket编程示例  回复  更多评论  2008-03-1411:36byfgfdgdgdfggfdgdf# re:多线程JavaSocket编程示例  回复  更多评论  2008-05-2817:14by钟侥我也是参照孙的书，可是运行不能得到正确的结果!很是郁闷啊[code]packagecom.zz.socket;importjava.io.BufferedReader;importjava.io.IOException;importjava.io.InputStreamReader;importjava.io.PrintWriter;importjava.net.ServerSocket;importjava.net.Socket;publicclassEchoServer{privateintport=8000;privateServerSocketss;publicEchoServer()throwsIOException{ ss=newServerSocket(port);System.out.println("serverisstarting....");}privateStringechoString(Stringmsg){return"echo:"+msg;}publicstaticvoidmain(String[]args){try{newEchoServer().service();}catch(IOExceptione){e.printStackTrace();}}privatevoidservice(){while(true){Sockets=null;try{s=ss.accept();System.out.println("aclientiscoming......");BufferedReaderbr=this.getReader(s);PrintWriterpw=this.getWriter(s);Stringmsg=null;while((msg=br.readLine())!=null){System.out.println(msg);pw.println(this.echoString(msg)+" ");pw.flush();if(msg.equals("bye"))break;} }catch(IOExceptione){}}}privatePrintWritergetWriter(Sockets)throwsIOException{returnnewPrintWriter(s.getOutputStream());}privateBufferedReadergetReader(Sockets)throwsIOException{returnnewBufferedReader(newInputStreamReader(s.getInputStream()));}}[/code]# re:多线程JavaSocket编程示例  回复  更多评论  2008-05-2817:15by钟侥packagecom.zz.socket;importjava.io.BufferedReader;importjava.io.IOException;importjava.io.InputStreamReader;importjava.io.PrintWriter;importjava.net.Socket;publicclassEchoClient{ privateStringhost="localhost";privateintport=8000;privateSocketsocket;privateEchoClient()throwsIOException{socket=newSocket(host,port);}publicvoidtalk()throwsIOException{try{BufferedReaderbr=getReader(socket);PrintWriterpw=getWriter(socket);BufferedReaderlocalReader=newBufferedReader(newInputStreamReader(System.in));Stringmsg=null;while((msg=localReader.readLine())!=null){pw.println(msg+" ");pw.flush();System.out.println(br.readLine());if(msg.equals("bye"))break;}}catch(IOExceptione){}finally{try{socket.close();}catch(IOExceptione){e.printStackTrace();}} }privatePrintWritergetWriter(Sockets)throwsIOException{returnnewPrintWriter(s.getOutputStream());}privateBufferedReadergetReader(Sockets)throwsIOException{returnnewBufferedReader(newInputStreamReader(s.getInputStream()));}/***@paramargs*@throwsIOException*/publicstaticvoidmain(String[]args)throwsIOException{newEchoClient().talk();}}# re:多线程JavaSocket编程示例  回复  更多评论  2008-06-1623:04by有猫相伴的日子这个代码有很多问题，如请求处理，怎么封装请求对象，把请求对象放一队列从服务器端怎么发消息到客户端.....# re:多线程JavaSocket编程示例  回复  更多评论  2009-04-2710:22byfei貌似整体思想可以，但是，程序的问题就比较多了...# re:多线程JavaSocket编程示例[未登录]  回复  更多评论  2009-05-0715:38byjh第三方杀毒# re:多线程JavaSocket编程示例  回复  更多评论   2009-05-0717:14byOverKill如果多个线程对同一资源进行读取，能保证资源的原子性吗？应该对资源加锁# re:多线程JavaSocket编程示例  回复  更多评论  2009-05-1715:52by点水点点正找这样的文章多谢# re:多线程JavaSocket编程示例[未登录]  回复  更多评论  2009-08-2319:12byMark如何设定超时的问题呢？# re:多线程JavaSocket编程示例  回复  更多评论  2010-05-0913:48by诗特林fans我是java网络编程的初学者很想加诗特林为好友向你请教些问题。我的qq826463574# re:多线程JavaSocket编程示例  回复  更多评论  2010-05-0914:05by诗特林fans服务器端：publicclassMultiThreadServer{privateintport=8821;privateServerSocketserverSocket;privateExecutorServiceexecutorService;//线程池privatefinalintPOOL_SIZE=10;//单个CPU线程池大小publicMultiThreadServer()throwsIOException{serverSocket=newServerSocket(port);//Runtime的availableProcessor()方法返回当前系统的CPU数目.executorService=Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_SIZE);System.out.println("服务器启动");}publicvoidservice(){while(true){Socketsocket=null;try{//接收客户连接,只要客户进行了连接,就会触发accept();从而建立连接 socket=serverSocket.accept();executorService.execute(newHandler(socket));}catch(Exceptione){e.printStackTrace();}}}publicstaticvoidmain(String[]args)throwsIOException{newMultiThreadServer().service();}}classHandlerimplementsRunnable{privateSocketsocket;publicHandler(Socketsocket){this.socket=socket;}/*privateDataOutputStreamdos(Socketsocket)throwsIOException{OutputStreamsocketOut=socket.getOutputStream();returnnewDataOutputStream(socketOut);}privateDataInputStreamdis(Socketsocket)throwsIOException{InputStreamsocketIn=socket.getInputStream();returnnewDataInputStream(socketIn);}*/publicvoidrun(){ try{System.out.println("Newconnectionaccepted"+socket.getInetAddress()+":"+socket.getPort());OutputStreamos=socket.getOutputStream();DataOutputStreamdos=newDataOutputStream(os);InputStreamis=socket.getInputStream();DataInputStreamdis=newDataInputStream(is);newmyserverread(dis).start();newmyserverwite(dos).start();}catch(IOExceptione){e.printStackTrace();}/*finally{try{if(socket!=null)socket.close();}catch(IOExceptione){e.printStackTrace();}}*/}}classmyserverreadextendsThread{privateDataInputStreamdis;publicmyserverread(DataInputStreamdis){this.dis=dis;}publicvoidrun(){Stringinfo; try{while(true){info=dis.readUTF();System.out.println("对方说"+info);if(info.equals("bye")){System.out.println("对方下线,程序退出");System.exit(0);}}}catch(Exceptione){e.getStackTrace();}}}classmyserverwiteextendsThread{privateDataOutputStreamdos;publicmyserverwite(DataOutputStreamdos){this.dos=dos;}publicvoidrun(){BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in));Stringinfo;try{while(true){info=br.readLine();dos.writeUTF(info);if(info.equals("bye")){System.out.println("自己下线,程序退出"); System.exit(0);}}}catch(Exceptione){e.getStackTrace();}}}# re:多线程JavaSocket编程示例  回复  更多评论  2010-05-0914:06by诗特林fans客户端：importjava.io.BufferedReader;importjava.io.DataInputStream;importjava.io.DataOutputStream;importjava.io.IOException;importjava.io.InputStream;importjava.io.InputStreamReader;importjava.io.OutputStream;importjava.net.Socket;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;publicclassMultiThreadClient{publicstaticvoidmain(String[]args){ intID=Info.i;ExecutorServiceexec=Executors.newCachedThreadPool();/*for(inti=0;i