1. /**
   
2. * @author 不安份的程序猿
   
3. *
   
4. */
   
5. //UDP协议实现 输出数据
   
6. public class DemoGet {
   
7.         public static void main(String[] args) throws Exception {
   
8.                 final DatagramSocket get = new DatagramSocket(9999); // 创建接口
   
9.                 final boolean t = true;
   
10.                 new Thread(new Runnable() {
    
11. 
    
12.                         @Override
    
13.                         public void run() {
    
14.                                 while (t) {
    
15.                                         // 接收set发送的消息
    
16.                                         byte[] b = new byte[1024]; //
    
17.                                         DatagramPacket dp = new DatagramPacket(b, b.length);// 将从b到b.length都进行打包
    
18.                                         try {
    
19.                                                 get.receive(dp);
    
20.                                         } catch (IOException e) {
    
21.                                                 // TODO Auto-generated catch block
    
22.                                                 e.printStackTrace();
    
23.                                         } // 接受这个包
    
24.                                         int length = dp.getLength();// 获取这个包的长度
    
25.                                         // System.out.println(new String(b,0,length)); //转化成字符串然后输出
    
26.                                         System.out.println("消息是由" + dp.getAddress() + "发送的,端口是："
    
27.                                                         + dp.getPort() + "内容是" + new String(b, 0, length));
    
28.                                 }
    
29.                         }
    
30.                 }).start();
    
31.                 new Thread(new Runnable() {
    
32. 
    
33.                         @Override
    
34.                         public void run() {
    
35.                                 while (t) {
    
36.                                         // 往set回复消息
    
37.                                         try {
    
38.                                                 Scanner sc = new Scanner(System.in);
    
39.                                                 String str = sc.nextLine();
    
40.                                                 DatagramPacket send = new DatagramPacket(
    
41.                                                                 str.getBytes(), str.getBytes().length,
    
42.                                                                 InetAddress.getLocalHost(), 6666);
    
43.                                                 get.send(send);
    
44.                                         } catch (IOException e) {
    
45.                                                 // TODO Auto-generated catch block
    
46.                                                 e.printStackTrace();
    
47.                                         }
    
48.                                 }
    
49.                         }
    
50.                 }).start();
    
51.                 // get.close();
    
52.         }
    
53. }
    

复制代码

1. 
   
2. 
   
3. import java.io.IOException;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. import java.util.Scanner;
   
8. 
   
9. //利用UDP协议编写 实现客户端和服务器
   
10. //此类是输出端
    
11. public class DemoSet {
    
12.         public static void main(String[] args) throws Exception {
    
13.                 final DatagramSocket set = new DatagramSocket(6666);
    
14.                 final boolean t = true;
    
15.                 new Thread(new Runnable() {
    
16. 
    
17.                         @Override
    
18.                         public void run() {
    
19.                                 while (t) {
    
20.                                         try {
    
21.                                                 // 往服务器发送消息
    
22.                                                 Scanner sc = new Scanner(System.in);
    
23.                                                 String str = sc.nextLine();
    
24.                                                 DatagramPacket dp = new DatagramPacket(str.getBytes(),
    
25.                                                                 str.getBytes().length,
    
26.                                                                 InetAddress.getLocalHost(), 9999);
    
27. 
    
28.                                                 set.send(dp);
    
29.                                         } catch (IOException e) {
    
30.                                                 e.printStackTrace();
    
31.                                         }
    
32.                                 }
    
33.                         }
    
34.                 }).start();
    
35.                 new Thread(new Runnable() {
    
36. 
    
37.                         @Override
    
38.                         public void run() {
    
39.                                 while (t) {
    
40.                                         // 从get类里面获取消息
    
41.                                         byte[] b = new byte[1024];
    
42.                                         DatagramPacket re = new DatagramPacket(b, b.length);
    
43.                                         try {
    
44.                                                 set.receive(re);
    
45.                                         } catch (IOException e) {
    
46.                                                 e.printStackTrace();
    
47.                                         }
    
48.                                         int length = re.getLength();
    
49.                                         System.out.println("消息是由" + re.getAddress() + "返回的,它的端口是"
    
50.                                                         + re.getPort() + "，输出的内容是"
    
51.                                                         + new String(b, 0, length));
    
52.                                 }
    
53.                         }
    
54.                 }).start();
    
55.                 // set.close();// 用了线程 就没必要存在了
    
56.         }
    
57. }
    

复制代码