事情是这样子的，麻烦各位大神，复制下代码在自己的机子上运行下，然后通过结束标记来结束，看下是否能够结束，
在我这破机子上结束不了，我不知道是怎么回事， 麻烦各位大神了就！

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

复制代码

1、当你输入886时，接收线程还没停止，死循环，加上一个标志就可以了。
/*
        编写一个聊天小程序，
*/

import java.io.*;
import java.net.*;
/*
需要用到多线程技术，
*/
class Send implements Runnable
{
        private DatagramSocket ds;
        public Send(DatagramSocket ds)
        {
                this.ds = ds;
        }
        public void run()
        {
                try
                {
                       
                        BufferedReader bufr =
                                new BufferedReader(new InputStreamReader(System.in));
                        String line=null;

                        while((line=bufr.readLine())!=null)
                        {
                                if("886".equals(line))
                                {
                                        Receive.flag = false;
                                        System.out.println("结束");
                                        break;
                                }
                                byte[] buf = line.getBytes();
                                DatagramPacket dp =
                                        new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10003);

                                ds.send(dp);

                        }
                     //   System.out.println("test2");
                }

                catch (Exception e)
                {
                        throw new RuntimeException("发送端建立失败");
                }
        }
}

class Receive implements Runnable
{
        private DatagramSocket ds;
       public static boolean flag = true;
        public Receive(DatagramSocket ds)
        {
                this.ds = ds;
        }
        public void run()
        {
                try
                {

                                                while(flag)
                        {
                                byte[] buf = new byte[1024];
                                DatagramPacket dp = new DatagramPacket(buf,buf.length);

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

                                System.out.println(ip+"::"+data);

                        }        
                }
                catch (Exception e)
                {
                        throw new RuntimeException("接收端创建失败");
                }

        }
}

public class ChartDemo
{
       

        public static void main(String[] args) throws Exception
        {

                DatagramSocket sendSocket = new DatagramSocket();
                          DatagramSocket receiveSocket = new DatagramSocket(10003);
                          new Thread(new Send(sendSocket)).start();
            new Thread(new Receive(receiveSocket)).start();

        }
}

楼主你好   如果问题已经解决了，请把帖子的类型改为“已解决”{:soso_e181:}

Den_din 发表于 2013-4-27 10:42
1、当你输入886时，接收线程还没停止，死循环，加上一个标志就可以了。
/*
        编写一个聊天小程序，

谢谢你，昨天刚看完，忘了还有这贴了....

袁梦希 发表于 2013-4-27 10:49
楼主你好   如果问题已经解决了，请把帖子的类型改为“已解决”

谢谢提醒

{:soso_e127:}