|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122 |
入口：package
chat;import java.net.DatagramSocket;import java.net.SocketException;public class chat { /** * @param args * @throws SocketException */ public
static void main(String[] args) throws
SocketException { // TODO Auto-generated method stub DatagramSocket sd = new
DatagramSocket(); DatagramSocket re = new
DatagramSocket(9000); send s = new
send(sd); receive r = new
receive(re); new
Thread(s).start(); new
Thread(r).start(); }}<br><br><br>发送端：package
chat;import
java.io.BufferedReader;import
java.io.IOException;import
java.io.InputStreamReader;import
java.net.DatagramPacket;import
java.net.DatagramSocket;import
java.net.InetAddress;import
java.net.SocketException;import
java.net.UnknownHostException;public
class send implements
Runnable { public
DatagramSocket ds; public
send(DatagramSocket ds) throws
SocketException { this.ds = ds; } @Override public
void run() { // TODO Auto-generated method stub try
{ InetAddress ip = InetAddress.getByName("192.168.1.255"); String line = null; //第三步：创建UDP数据包 System.out.println("开始聊天了："); BufferedReader in = new
BufferedReader(new
InputStreamReader(System.in)); while((line=in.readLine())!=null) { byte[] buf = line.getBytes(); DatagramPacket dp = new
DatagramPacket(buf, buf.length, ip, 9000); ds.send(dp); if("over".equals(line)) break; } ds.close(); } catch
(UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch
(IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } }}接收端：package
chat;import
java.io.IOException;import
java.net.DatagramPacket;import
java.net.DatagramSocket;public
class receive implements
Runnable { public
DatagramSocket ds; public
receive(DatagramSocket ds) { this.ds = ds; } @Override public
void run() { // TODO Auto-generated method stub try
{ byte[] buf = new
byte[1024]; while(true) { DatagramPacket dp = new
DatagramPacket(buf,buf.length); ds.receive(dp); //阻塞式 //第三步：解析接收到的udp包 String host = dp.getAddress().getHostName(); int
port = dp.getPort(); String data = new
String(dp.getData(),0,dp.getLength()); System.out.println("聊天内容是："); System.out.println(host+"："+data); System.out.println(" "); } } catch
(IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } }} |
原文：http://www.cnblogs.com/justphp/p/3602468.html