标签:blog http io os 使用 java ar 2014 art
在我们前面一个例子中,我们使用下面这样一段代码
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); } } } }
那么如果把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窗口,并且可以交换输出内容
标签:blog http io os 使用 java ar 2014 art
原文地址:http://blog.csdn.net/itbuluoge/article/details/39498041