/*
编写一个聊天程序
有收数据的部分，和发数据的部分。
这两个部分需要同时执行。
那就需要用到多线程技术。
一个线程控制收，一个线程控制发。
因为收和发动作是不一致的，所以要定义两个run方法。
而且这两个方法要封装到不同的类中。
*/
import java.io.*;
import java.net.*;
class Send implements Runnable
{
private DatagramSocket ds;
private 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))
     break;
    byte[]buf=line.getBytes();
    DatagramPacket dp=new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.3"),10003);
   }
   
  }
  catch (Exception e)
  {
   throw new RuntimeException("发送端失败");
  }
}
}
class Rece implements Runnable
{
private DatagramSocket ds;
private Rece(DatagramSocket ds)
{
  this.ds=ds;
}
public void run()
{
  try
  {
   while(true)
   {
    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("接收失败");
  }
}
}
class  ChatDemo
{
public static void main(String[] args) throws Exception
{
  DatagramSocket sendSocket=new DatagramSocket();
  DatagramSocket receSocket=new DatagramSocket(10002);
  new Thread(new Send(sendSocket)).start();
  new Thread(new Rece(receSocket)).start();
  //System.out.println("Hello World!");
}
}


疑问：编译提示：“Send(java.net.DatagramSocket)可以在Send中访问new Thread(new Send(sendSocket)).start()”是什么意思？应该怎么修改

1. package com.gaga.test1;
   
2. 
   
3. 
   
4. /*
   
5. 编写一个聊天程序
   
6. 有收数据的部分，和发数据的部分。
   
7. 这两个部分需要同时执行。
   
8. 那就需要用到多线程技术。
   
9. 一个线程控制收，一个线程控制发。
   
10. 因为收和发动作是不一致的，所以要定义两个run方法。
    
11. 而且这两个方法要封装到不同的类中。
    
12. */
    
13. import java.io.*;
    
14. import java.net.*;
    
15. class Send implements Runnable
    
16. {
    
17. private DatagramSocket ds;
    
18. Send(DatagramSocket ds)
    
19. {
    
20.   this.ds=ds;
    
21. }
    
22. public void run()
    
23. {
    
24.   try
    
25.   {
    
26.    BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));
    
27.    String line=null;
    
28.    byte[]buf=null;
    
29.    StringBuffer buff=new StringBuffer();
    
30.    while((line=bufr.readLine())!=null)
    
31.    {
    
32.     if ("886".equals(line))
    
33.      break;
    
34.     if(buff!=null){
    
35.             buff.append("\n");
    
36.     }
    
37.     buff.append(line);
    
38.    // buf=line.getBytes();
    
39.    }
    
40.    buf=buff.toString().getBytes();
    
41.     DatagramPacket dp=new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),10012);
    
42.     ds.send(dp);
    
43.    
    
44.    
    
45.   }
    
46.   catch (Exception e)
    
47.   {
    
48.    throw new RuntimeException("发送端失败");
    
49.   }
    
50. }
    
51. }
    
52. class Rece implements Runnable
    
53. {
    
54. private DatagramSocket ds;
    
55. Rece(DatagramSocket ds)
    
56. {
    
57.   this.ds=ds;
    
58. }
    
59. public void run()
    
60. {
    
61.   try
    
62.   {
    
63.    while(true)
    
64.    {
    
65.     byte[]buf=new byte[1024];
    
66.     DatagramPacket dp=new DatagramPacket(buf,buf.length);
    
67.     ds.receive(dp);
    
68.     String ip=dp.getAddress().getHostAddress();
    
69.     String data=new String(dp.getData(),0,dp.getLength());
    
70.     System.out.println(ip+":"+data);
    
71.    }
    
72.   }
    
73.   catch (Exception e)
    
74.   {
    
75.    throw new RuntimeException("接收失败");
    
76.   }
    
77. }
    
78. }
    
79. public class  ChatDemo
    
80. {
    
81. public static void main(String[] args) throws Exception
    
82. {
    
83.   DatagramSocket sendSocket=new DatagramSocket();
    
84.   DatagramSocket receSocket=new DatagramSocket(10012);
    
85.   new Thread(new Send(sendSocket)).start();
    
86.   new Thread(new Rece(receSocket)).start();
    
87.   //System.out.println("Hello World!");
    
88. }
    
89. }
    

复制代码

此问题已解决