java实现多线程的socket通信技术
在我们前面一个例子中,我们使用下面这样一段代码
package com.test.net; import java.io.DataInputStream; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; public class EchoServer { /** * 打印客户端的所有输出 */ @SuppressWarnings("deprecation") public static void main(String[] args) throws Exception { ServerSocket serverSocket=new ServerSocket(9999); /*accept方法是阻塞的*/ Socket server=serverSocket.accept(); while(true) { /*getInputStream方法是阻塞的*/ InputStream in=server.getInputStream(); DataInputStream dataIn=new DataInputStream(in); String str=dataIn.readLine(); if(str != null) { System.out.println(str); } } } }
可以持续的处理一个客户端的连接请求,但是如果有两个或者多个连接呢?我们可以看到,虽然有多个,但是程序一直在while循环中执行,accept这个方法已经执行结束,无法在响应其他的连接请求。
那么如果把accept放在里面呢?的确可以接收多个请求,但是,条件是必须等待上一个结束,才会进入到第二个的accept,相当于一个串行事件,那么如何达到多个请求同时处理呢?我们可以采用多线程的方法。
也就是说,每次得到一个socket请求的时候,就开辟一个线程去处理,然后主线程继续等待下一个请求。代码如下
package com.test.net; import java.io.DataInputStream; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; public class MuliEchoServer { /** * @param args * @throws Exception */ public static void main(String[] args) throws Exception { // TODO Auto-generated method stub ServerSocket serverSocket=new ServerSocket(8888); while(true) { Socket s=serverSocket.accept(); task mytask=new task(s); mytask.start(); } } } class task extends Thread { private Socket s=null; public task(Socket s) { this.s=s; } public void run() { InputStream inStream = null; try { inStream = s.getInputStream(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } DataInputStream dStream=new DataInputStream(inStream); String str = null; try { while(true) { str = dStream.readLine(); if(str!=null) { System.out.println(str); } } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
在输出结果中可以看到
其中内容分别来自telnet的A窗口和B窗口,并且可以交换输出内容
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。