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

复制代码

求大神解答下。

Runnable 接口应该由那些打算通过某一线程执行其实例的类来实现。类必须定义一个称为 run 的无参数方法。

设计该接口的目的是为希望在活动时执行代码的对象提供一个公共协议。例如，Thread 类实现了 Runnable。激活的意思是说某个线程已启动并且尚未停止。

此外，Runnable 为非 Thread 子类的类提供了一种激活方式。通过实例化某个 Thread 实例并将自身作为运行目标，就可以运行实现 Runnable 的类而无需创建 Thread 的子类。大多数情况下，如果只想重写 run() 方法，而不重写其他 Thread 方法，那么应使用 Runnable 接口。

run() 方法： 使用实现接口 Runnable 的对象创建一个线程时，启动该线程将导致在独立执行的线程中调用对象的 run 方法。

实现这个接口就是实现run方法，我估计你是和继承Tread类有点混吧 。

Ticket t = new Ticket();

直接创建Ticket对象，并不是创建线程对象。
因为创建对象只能通过new Thread类，或者new Thread类的子类才可以。
所以最终想要创建线程。既然没有了Thread类的子类，就只能用Thread类。

Thread t1 = new Thread(t); //创建线程。

只要将t作为Thread类的构造函数的实际参数传入即可完成线程对象和t之间的关联
为什么要将t传给Thread类的构造函数呢？其实就是为了明确线程要运行的代码run方法。

crazy_primitive 发表于 2013-8-2 16:29
Runnable 接口应该由那些打算通过某一线程执行其实例的类来实现。类必须定义一个称为 run 的无参数方法。
...

谢谢。。

诸隆隆 发表于 2013-8-2 18:16
实现这个接口就是实现run方法，我估计你是和继承Tread类有点混吧 。

Ticket t = new Ticket();

谢谢。。