黑马程序员技术交流社区

标题: 用Udp怎样实现两个本地窗口对话？ [打印本页]

---

作者: just_nnnnx    时间: 2013-12-30 21:16
标题: 用Udp怎样实现两个本地窗口对话？

1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. class Send implements Runnable
   
5. {
   
6.         private DatagramSocket ds;
   
7.         Send(DatagramSocket ds)
   
8.         {
   
9.                 this.ds = ds;
   
10.         }
    
11. 
    
12.         public void run()
    
13.         {
    
14.                 try
    
15.                 {
    
16.                         BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
    
17. 
    
18.                         String line = null;
    
19.                         while((line = bufr.readLine())!=null)
    
20.                         {
    
21.                                 if("88".equals(line))
    
22.                                         break;
    
23.                                 byte[] by = line.getBytes();
    
24.                                 DatagramPacket dp =
    
25.                                         new DatagramPacket(by,by.length,InetAddress.getByName("LocalHost"),8888);
    
26. 
    
27.                                 ds.send(dp);
    
28.                         }
    
29.                 }
    
30.                 catch (Exception e)
    
31.                 {
    
32.                         throw new RuntimeException("发送失败");
    
33.                 }
    
34.         }
    
35. }
    
36. 
    
37. class Receive implements Runnable
    
38. {
    
39.         private DatagramSocket ds;
    
40. 
    
41.         Receive(DatagramSocket ds)
    
42.         {
    
43.                 this.ds = ds;
    
44.         }
    
45. 
    
46.         public void run()
    
47.         {
    
48.                 try
    
49.                 {
    
50.                         while(true)
    
51.                         {
    
52.                                 byte[] by = new byte[1024];
    
53.                                 
    
54.                                 DatagramPacket dp = new DatagramPacket(by,by.length);
    
55. 
    
56.                                 ds.receive(dp);
    
57. 
    
58.                                 String ip = dp.getAddress().getHostAddress();
    
59.                                 String data = new String(dp.getData(),0,dp.getLength());
    
60. 
    
61.                                 if("886".equals(data))
    
62.                                         break;
    
63. 
    
64.                                 System.out.println(ip+":"+data);
    
65.                         }
    
66.                 }
    
67.                 catch (Exception e)
    
68.                 {
    
69.                         throw new RuntimeException("接收失败");
    
70.                 }
    
71.         }
    
72. }
    
73. 
    
74. 
    
75. class  MyChat
    
76. {
    
77.         public static void main(String[] args) throws Exception
    
78.         {
    
79.                 DatagramSocket dg = new DatagramSocket(8888);
    
80. 
    
81.                 new Thread(new Send(dg)).start();
    
82.                 new Thread(new Receive(dg)).start();
    
83.         }
    
84. }
    
85. 
    
86. class  MyChat_2
    
87. {
    
88.         public static void main(String[] args) throws Exception
    
89.         {
    
90.                 DatagramSocket dg = new DatagramSocket(8886);
    
91. 
    
92.                 new Thread(new Send(dg)).start();
    
93.                 new Thread(new Receive(dg)).start();
    
94.         }
    
95. }
    

复制代码

现在的情况是，1号窗口可以写，也可以读到2窗口的内容，但2号窗口只能输出，而看不到1号窗口发送的内容，怎么才能实现两个窗口同时可以读写呢？

图片1.png (20.47 KB, 下载次数: 18)

下载附件

2013-12-30 21:14 上传

---

作者: 刘汉文    时间: 2013-12-31 10:11
帮你改好了，其实这是因为你把所有数据都朝着8888这个端口给发了过去，而负责监听此端口的只有MyChat这一个。所以在初始化的时候，要把端口传。


import java.io.*;
import java.net.*;

class Send implements Runnable
{
        private DatagramSocket ds;
        private int num;
        Send(DatagramSocket ds,int num)
        {
                this.ds = ds;
                this.num=num;
        }

        public void run()
        {
                try
                {
                        BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));

                        String line = null;
                        while((line = bufr.readLine())!=null)
                        {
                                if("88".equals(line))
                                        break;
                                byte[] by = line.getBytes();
                                DatagramPacket dp = new DatagramPacket(by,by.length,InetAddress.getByName("LocalHost"),num);


                                ds.send(dp);
                        }
                }
                catch (Exception e)
                {
                        throw new RuntimeException("发送失败");
                }
        }
}

class Receive implements Runnable
{
        private DatagramSocket ds;

        Receive(DatagramSocket ds)
        {
                this.ds = ds;
        }

        public void run()
        {
                try
                {
                        while(true)
                        {
                                byte[] by = new byte[1024];

                                DatagramPacket dp = new DatagramPacket(by,by.length);

                                ds.receive(dp);

                                String ip = dp.getAddress().getHostAddress();
                                String data = new String(dp.getData(),0,dp.getLength());

                                if("886".equals(data))
                                        break;

                                System.out.println(ip+":"+data);
                        }
                }
                catch (Exception e)
                {
                        throw new RuntimeException("接收失败");
                }
        }
}


class  MyChat
{
        public static void main(String[] args) throws Exception
        {
                DatagramSocket dg = new DatagramSocket(8888);

                new Thread(new Send(dg,8886)).start();
                new Thread(new Receive(dg)).start();
        }
}

class  MyChat_2
{
        public static void main(String[] args) throws Exception
        {
                DatagramSocket dg = new DatagramSocket(8886);
                new Thread(new Send(dg,8888)).start();
                new Thread(new Receive(dg)).start();
        }
}

---

作者: just_nnnnx    时间: 2013-12-31 12:24

刘汉文 发表于 2013-12-31 10:11
帮你改好了，其实这是因为你把所有数据都朝着8888这个端口给发了过去，而负责监听此端口的只有MyChat这一个 ...

恩，我也是这样改的，嘿嘿，谢谢了

---

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

黑马程序员IT技术论坛 X3.2