首页 > 代码库 > java实现多线程的socket通信技术
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窗口,并且可以交换输出内容
java实现多线程的socket通信技术
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。