您的位置:首页 > 理论基础 > 计算机网络

黑马程序员-TCP协议服务端ServerScoket接收客户端并发请求。

2012-05-07 21:19 351 查看
---------------------- android培训java培训、期待与您交流! ----------------------

 ServerScoket service = new SercerSocket(端口);

 while(true){
Socket s = ss.sccept();

inputStream in = s.getInputStream();

FileOutputStream os = new FileOutputStrem("conten.txt");

byte[] but = new byte[1024];
int len = 0;
while((len=in.read(but))!=-1){
os.write(but,0,len);
}
os.close();
s.close();

 }

使用while循环处理并发有局限性,也就是说,当a客户端连接上以后,被服务端接收到了,服务端执行具体流程时,

这个时候又有b客户连接上服务端,还没有处理完a客户的请求时while循环是不会结束的,

所以不会获取到b客户的ss.sccept()请求的。

---------

想让服务端处理多个客户端的请求,最好将每个客户端封装到单独的线程中。

只要明确客户端要执行的服务端代码即可,这些代码放入run方法中。

//定义线程

class picThread implements Runnable

{
private Socket s;
picThread(Socket s){
this.s=s;
}
public void run(){
try{
InputStream in = s.getInputStream();

FileOutputStream os = new FileOutputStream("conten.txt");

byte[] but = new byte[1024];
int len = 0;
while((len=in.read(but))!=-1){
os.write(but,0,len);
}
os.close();
s.close();

}catch(Exception e){
throw new RuntimeException("失败");
}
}

}

//服务端,循环获取客户端,并循环建立线程

class picServer{
public static void main(String[] args)throws Exception{

ServerSocket service = new ServerSocket(10001);

  while(true){
Socket s = service.accept();
new Thread(new picThread(s)).start();
}
}

}

这样,当a客户访问服务端的时候会new一个线程给a客户执行,b客户进来时,又new一个线程给b客户执行

这样就成功实现了客户端并发请求。

---------------------- android培训java培训、期待与您交流! ----------------------

详细请查看:http://edu.csdn.net/heima
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
相关文章推荐