a

1. import java.io.BufferedReader;
   
2. import java.io.ByteArrayOutputStream;
   
3. import java.io.IOException;
   
4. import java.io.InputStreamReader;
   
5. import java.net.DatagramPacket;
   
6. import java.net.DatagramSocket;
   
7. import java.net.InetAddress;
   
8. 
   
9. 
   
10. public class MutilThreadUdp {
    
11. 
    
12.         /**
    
13.          * @param args
    
14.          * @throws Exception
    
15.          */
    
16.         public static void main(String[] args) throws Exception {
    
17.                 DatagramSocket ds1 = new DatagramSocket(8888);
    
18.                 DatagramSocket ds2 = new DatagramSocket(10888);
    
19.                 Udpsend send = new Udpsend( ds1);
    
20.                 Udpreceive re = new Udpreceive(ds2);
    
21.                 new Thread(re).start();
    
22.                 new Thread(send).start();
    
23. 
    
24.         }
    
25. 
    
26. }
    
27. class Udpsend implements Runnable{
    
28.         private DatagramSocket ds ;
    
29. 
    
30.         public Udpsend(DatagramSocket ds) {
    
31.                 super();
    
32.                 this.ds = ds;
    
33.         }
    
34. 
    
35.         @Override
    
36.         public void run() {
    
37.                 System.out.println("客户端跑起：");
    
38.                 BufferedReader br = null;
    
39.                 while(true){
    
40.                         br = new BufferedReader(new InputStreamReader(System.in));
    
41.                         String line = null;
    
42.                         try {
    
43.                                 while((line=br.readLine())!=null){
    
44.                                         byte[] buf = line.getBytes();
    
45.                                         DatagramPacket dp = new DatagramPacket(buf,0,buf.length,
    
46.                                                         InetAddress.getByName("192.168.220.255"),10888);
    
47.                                         System.out.println("Send message...:");
    
48.                                         ds.send(dp);
    
49.                                         if(line.equals("886"))
    
50.                                                 break;
    
51.                                 }
    
52.                                 break;
    
53.                         } catch (IOException e) {
    
54.                                 e.printStackTrace();
    
55.                         }finally{
    
56.                                 if(br!=null)
    
57.                                         try {
    
58.                                                 br.close();
    
59.                                         } catch (IOException e) {
    
60.                                                 e.printStackTrace();
    
61.                                         }
    
62.                                 if(ds!=null)
    
63.                                         ds.close();
    
64.                         }
    
65.                 }
    
66.                
    
67.         }       
    
68. }
    
69. class Udpreceive implements Runnable{
    
70.         private DatagramSocket ds;
    
71. 
    
72.         public Udpreceive(DatagramSocket ds) {
    
73.                 super();
    
74.                 this.ds = ds;
    
75.         }
    
76.         @Override
    
77.         public void run() {
    
78.                 byte[] buf = new byte[1024];
    
79.                 DatagramPacket dp = new DatagramPacket(buf,buf.length);
    
80.                 ByteArrayOutputStream bos = new ByteArrayOutputStream();
    
81.                 System.out.println("服务器启动：");
    
82.                 while (true) {
    
83.                         try {
    
84.                                 ds.receive(dp);
    
85.                                 int len = dp.getLength();
    
86.                                 int port = dp.getPort();
    
87.                                 String ip = dp.getAddress().getHostAddress();
    
88.                                 buf = dp.getData();
    
89.                                 String message = new String(buf,0,len);
    
90.                                 System.out.println(ip+" "+port+"发来信息："+message);
    
91.                                 if(message.equals("886"))
    
92.                                         System.out.println(ip+" 下线");
    
93. //                                bos.write(buf, 0, len);
    
94. //                                System.out.println("字节数组输出流长度"+bos.size());
    
95. //                                bos.writeTo(System.out);
    
96. //                                bos.reset();
    
97.                         } catch (IOException e) {
    
98.                                 throw new RuntimeException("接收失败");
    
99.                         }
    
100.                 }
     
101.         }
     
102. }

复制代码

妖风小王子 发表于 2015-10-7 21:32
从哪里复制来的额

看笔记 然后自己打的

从哪里复制来的额