黑马程序员技术交流社区

标题: Socket同一窗口显示udp求助 [打印本页]
作者: 张承富    时间: 2013-6-17 13:38
标题: Socket同一窗口显示udp求助
看看哪里不对，找不出来啊！
  1. /*
  2. 编写一个聊天程序。
  3. 有收数据的部分，和发数据的部分
  4. 这两部分需要同时执行，就需要用到多线程技术
  5. 一个线程控制收 一个线程控制发
  6. 因为收和发动作是不一致的，所以要定义两个run方法
  7. 而且这两个方法要封装到不同的类中
  8. */

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

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

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




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2