本文實例講述了java編程實現基于UDP協議傳輸數據的方法。分享給大家供大家參考，具體如下：
UDP協議（User Datagram Protocol,用戶數據報協議）不同于TCP協議，它是不可能靠的，但是它比TCP協議具有更快的傳輸速度，UDP發送的數據單元稱為數據報，當網絡傳輸UDP傳輸UDP數據報是無法保證數據能夠到達目的地，也無法保證按發送的順序到達目的地，也就是說先發送了“hello”,再發送了“world”,但接收方可能會先收到“world”,再收到“hello”,也有可能收不到數據，為什么呢？因為它是不可能靠的，在傳輸途中可能丟失了。但UDP比TCP跟適合與傳輸實時音頻。下面是一個簡單的UPD傳輸數據報的例子
服務器端：
|
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
|
import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.SocketException; public class EchoServer { private DatagramSocket datagramSocket; private final int port = 8088; public static void main(String[] args) throws SocketException { new EchoServer().service(); } public EchoServer() throws SocketException{ datagramSocket = new DatagramSocket(port); System.out.println("服務器啟動"); } public String echo(String msg){ return "echo:"+msg; } public void service(){ while (true) { try { DatagramPacket packet = new DatagramPacket(new byte[512], 512); datagramSocket.receive(packet); String msg = new String(packet.getData(), 0, packet.getLength()); System.out.println(packet.getAddress()+"/"+packet.getPort()+" msg:"+msg); packet.setData(echo(msg).getBytes()); datagramSocket.send(packet); } 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
40
41
|
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; public class EchoClient { private String remoteHost="localhost"; private int remotePort=8088; private DatagramSocket datagramSocket; public EchoClient() throws SocketException{ datagramSocket = new DatagramSocket(); } public static void main(String[] args) throws SocketException { new EchoClient().talk(); } public void talk(){ try { BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); String msg = null; InetAddress address = InetAddress.getByName(remoteHost); while ((msg=reader.readLine())!=null) { //發送數據報 byte [] buffer = msg.getBytes(); DatagramPacket packet = new DatagramPacket(buffer,buffer.length, address, remotePort); datagramSocket.send(packet); //接收數據報 DatagramPacket inputPacket = new DatagramPacket(new byte[512], 512); datagramSocket.receive(inputPacket); System.out.println(new String(inputPacket.getData(), 0 , inputPacket.getLength())); if("bye".equals(msg)){ break; } } } catch (IOException e) { e.printStackTrace(); }finally{ datagramSocket.close(); } } |
希望本文所述對大家Java程序設計有所幫助。
