A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 张承富 中级黑马   /  2013-6-17 13:38  /  1112 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

看看哪里不对,找不出来啊!
  1. /*
  2. 编写一个聊天程序。
  3. 有收数据的部分,和发数据的部分
  4. 这两部分需要同时执行,就需要用到多线程技术
  5. 一个线程控制收 一个线程控制发
  6. 因为收和发动作是不一致的,所以要定义两个run方法
  7. 而且这两个方法要封装到不同的类中
  8. */

  9. //用键盘录入
  10. class UdpSend_Thread implements Runnable{
  11.         private DatagramSocket ds;
  12.         public UdpSend_Thread(DatagramSocket ds){
  13.                
  14.         }
  15.         public void run(){
  16.                 try
  17.                 {
  18.                                 BufferedReader bufr = new BufferedReader(
  19.                                         new InputStreamReader(System.in));       
  20.                                 String line = null;
  21.                        
  22.                                 while((line=bufr.readLine())!=null){
  23.                                                 if("886".equals(line)){
  24.                                                                 break;
  25.                                                         }
  26.                                                 byte[] buf = line.getBytes();
  27.                                                 DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10003);
  28.                                                 //通过socket服务,将已有的数据包发送出去,通过send方法
  29.                                                 ds.send(dp);
  30.                                 }
  31.                         }
  32.                         catch(Exception e)
  33.                         {
  34.                                 throw new RuntimeException("发送失败");
  35.                         }
  36.                        
  37.         }
  38.        
  39. }

  40. //接收键盘录入
  41. class UdpRece_Thread implements Runnable
  42. {
  43.         private DatagramSocket ds;
  44.         public UdpRece_Thread(DatagramSocket ds){
  45.                
  46.         }
  47.        
  48.         public void run(){
  49.                 try
  50.                 {
  51.                                 while(true){
  52.                                         //定义数据包,用于存储数据
  53.                                         byte[] buf = new byte[1024];
  54.                                         DatagramPacket dp = new DatagramPacket(buf,buf.length);
  55.                                        
  56.                                         //通过服务的receive方法将受到的数据存入数据包中
  57.                                         ds.receive(dp); //阻塞式方法,没数据就等
  58.                        
  59.                                         //通过数据包的方法获取其中的数据
  60.                                         String ip = dp.getAddress().getHostAddress();//获取ip
  61.                                         String data = new String(dp.getData(),0,dp.getLength());
  62.                                         int port = dp.getPort();
  63.                                        
  64.                                         System.out.println(ip+data+port);
  65.                                 }
  66.                 }       
  67.                 catch(Exception e)
  68.                 {
  69.                         throw new RuntimeException("接收失败");
  70.                 }
  71.         }
  72.        
  73.        
  74. }

  75. class LiaoTian{
  76.        
  77.         public static void main(String[] args) throws Exception{
  78.                 DatagramSocket sendSocket = new DatagramSocket();
  79.                 DatagramSocket receSocket = new DatagramSocket(10003);       
  80.                
  81.                 new Thread(new UdpSend_Thread(sendSocket)).start();
  82.                 new Thread(new UdpRece_Thread(receSocket)).start();
  83.         }       
  84. }
复制代码

评分

参与人数 1技术分 +1 收起 理由
Super_Class + 1 神马都是浮云

查看全部评分

0 个回复

您需要登录后才可以回帖 登录 | 加入黑马