UDP

☆ UDP
将数据及源和目的封装成数据包中，不需要建立连接
每个数据报的大小在限制在64k内
因无连接，是不可靠协议
不需要建立连接，速度快

DatagramSocket和DatagramPacket类

☆ TCP
建立连接，形成传输数据的通道。
在连接中进行大数据量传输
通过三次握手完成连接，是可靠协议
必须建立连接，效率会稍低

Socket 和 ServerSocket类

☆ Socket
Socket就是为网络服务提供的一种机制。
通信的两端都有Socket。
网络通信其实就是Socket间的通信。
数据在两个Socket间通过IO传输。

UDP传输

DatagramSocket与DatagramPacket
建立发送端，接收端。
建立数据包。
调用Socket的发送接收方法。
关闭Socket。

发送端与接收端是两个独立的运行程序。

UDP传输编程

☆发送端

在发送端，要在数据包对象中明确目的地IP及端口。

DatagramSocket ds = new DatagramSocket();
byte[] by = “hello,udp”.getBytes();
DatagramPacket dp = new DatagramPacket(by,0,by.length, InetAddress.getByName(“127.0.0.1”),10000);
ds.send(dp);
ds.close();
  

 

  
1
  
2
  
3
  
4
  
5
  
6
 

☆接收端

在接收端，要指定监听的端口。

DatagramSocket ds = new DatagramSocket(10000);
byte[] by = new byte[1024];
DatagramPacket dp = new DatagramPacket(by,by.length);
ds.receive(dp);
String str = new String(dp.getData(),0,dp.getLength());
System.out.println(str+"--"+dp.getAddress());
ds.close();
  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
 

发送方：
你们自己写的时候注意修改接收方的ip。

package cn.hncu.url.udp;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

/**
 * 
 * @author 陈浩翔
 *
 * 2016-5-8
 */
public class SendDemo { public static void main(String[] args) { try { DatagramSocket ds = new DatagramSocket(9999);//用9999端口发送消息 String str = "你好，在吗？"; byte buf[] = str.getBytes("gbk"); //DatagramPacket类中，有ip地址的构造方法是用来创建发送数据包的。 DatagramPacket dp = new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.127"), 10000); //注意：ip和端口都是接收方的 ds.send(dp); ds.close(); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }

}

  

 

  
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
 

接收方：

package cn.hncu.url.udp;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class ReceiveDemo { public static void main(String[] args) { try { //接收的端口 DatagramSocket ds = new DatagramSocket(10000); byte buf[] = new byte[1024]; DatagramPacket dp = new DatagramPacket(buf, buf.length); ds.receive(dp); //从dp中解析出我们想要的信息 //获取ip String ip = dp.getAddress().getHostAddress(); int port = dp.getPort();//端口 byte[] data = dp.getData(); System.out.println("ip: "+ip+" 端口："+port+" 消息："+new String(data)); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }

}

  

 

  
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
 

练习：UDP聊天程序

通过键盘录入获取要发送的信息。
将发送和接收分别封装到两个线程中。

package cn.hncu.url.udp;

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;

class UDPChat { public static void main(String[] args) { try { DatagramSocket send = new DatagramSocket(10001); DatagramSocket receive = new DatagramSocket(10000); new Thread(new Send(send)).start(); new Thread(new Receive(receive)).start(); } catch (SocketException e) { e.printStackTrace(); } }

}

class Send implements Runnable{ DatagramSocket ds; public Send(DatagramSocket send) { this.ds=send; } @Override public void run() { DatagramPacket dp ; BufferedReader bfr = new BufferedReader(new InputStreamReader(System.in) ); String line; while(true){ try { line = bfr.readLine(); byte[] buf = line.getBytes(); //填写接收方的ip和端口 dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.1.127"), 10000); ds.send(dp); if("end".equals(line)){ break; } } catch (IOException e) { e.printStackTrace(); } } ds.close(); }
}

class Receive implements Runnable{ DatagramSocket ds; public Receive(DatagramSocket receive) { this.ds=receive; } @Override public void run() { DatagramPacket dp; byte[] buf = new byte[2048];//大小够存一次发送过来的数据就可以了。 String line; String ip; int port; while(true){ dp = new DatagramPacket(buf, buf.length); try { ds.receive(dp); } catch (IOException e) { e.printStackTrace(); } ip = dp.getAddress().getHostAddress();//获得发送方的ip port = dp.getPort();//端口 byte[] bf = dp.getData(); line = new String(bf,0,dp.getLength()); System.out.println("IP:"+ip+" 端口:"+port+" 消息:"+line); if("end".equals(line)){ System.out.println("主机："+ip+" 下线了。"); break; } } ds.close(); }
}

  

 

  
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
 

好了，到现在就可以实现2台联网的机子的互动了。哈哈、
只是现在还有点单调，而且用UDP协议容易丢包。
让我们一起进步吧。

文章来源: chenhx.blog.csdn.net，作者：谙忆，版权归原作者所有，如需转载，请联系作者。

原文链接：chenhx.blog.csdn.net/article/details/51346169