注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

北漂的小羊

Java编程,开发者,程序员,软件开发,编程,代码。新浪微博号:IT国子监

 
 
 

日志

 
 
关于我

在这里是面向程序员的高品质IT技术学习社区,是程序员学习成长的地方。让我们更好地用技术改变世界。请关注新浪微博号: IT国子监(http://weibo.com/itguozijian)

网易考拉推荐

基于Socket长连接多线程传输数据的简单示例  

2012-12-05 14:21:29|  分类: 页面解析技术 |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
Java代码 
  1. import java.io.InputStream;  
  2. import java.net.ServerSocket;  
  3. import java.net.Socket;  
  4.   
  5. public class Server {  
  6.   
  7.     /** 
  8.      * @param args 
  9.      */  
  10.     public static void main(String[] args) throws Exception {  
  11.         ServerSocket socketServer = new ServerSocket(9090);  
  12.         while (true) {  
  13.             Socket socket = socketServer.accept();  
  14.             InputStream in = socket.getInputStream();  
  15.             byte[] b = new byte[7];  
  16.             int len;  
  17.             try {  
  18.                 while ((len = in.read(b)) != -1) {  
  19.                     String value = new String(b, 0, len);  
  20.                     double d=Double.parseDouble(value);  
  21.                     //process data  
  22.                     System.out.println(d);  
  23.                 }  
  24.             } catch (Exception ex) {  
  25.                 //handle exception  
  26.                 ex.printStackTrace();  
  27.             }  
  28.         }  
  29.     }  
  30.   
  31. }  



Java代码 
  1. import java.io.OutputStream;  
  2. import java.net.Socket;  
  3.   
  4. public class Client {  
  5.     static class SendThread extends Thread {  
  6.         Socket server;  
  7.         byte[] value;  
  8.   
  9.         public SendThread(Socket server, String value) {  
  10.             super();  
  11.             this.server = server;  
  12.             this.value = value.getBytes();  
  13.         }  
  14.   
  15.         public void run() {  
  16.             while (true) {  
  17.                 try {  
  18.                     OutputStream out = server.getOutputStream();  
  19.                     out.write(value);  
  20.                     out.flush();  
  21.                     Thread.sleep(1000);  
  22.                 } catch (Exception ex) {  
  23.                     return;  
  24.                 }  
  25.             }  
  26.         }  
  27.     }  
  28.   
  29.     /** 
  30.      * @param args 
  31.      */  
  32.     public static void main(String[] args) throws Exception {  
  33.         Socket server = new Socket("localhost"9090);  
  34.         SendThread t1 = new SendThread(server, "1111.11");  
  35.         SendThread t2 = new SendThread(server, "2222.22");  
  36.         SendThread t3 = new SendThread(server, "3333.33");  
  37.         t1.start();  
  38.         t2.start();  
  39.         t3.start();  
  40.     }  
  41.   
  42. }  
  评论这张
 
阅读(613)| 评论(0)
推荐 转载

历史上的今天

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2016