java编程协议_java编程实现基于UDP协议传输数据的方法

java编程实现基于UDP协议传输数据的方法

发布于 2020-6-18|

复制链接

摘记: 本文实例讲述了java编程实现基于UDP协议传输数据的方法。分享给大家供大家参考&＃xff0c;具体如下&＃xff1a;UDP协议(User Datagram Protocol,用户数据报协议)不同于TCP协议&＃xff0c;它是不可能靠的&＃xff0c;但是它比TCP协议具有更快的传输速度&＃xff0c;UDP发送的数据单元称为数据报&＃xff0c;当网络传输UDP传输UDP数据报是无法保证数据能够到达目的地&＃xff0c;也无法保 ..

本文实例讲述了java编程实现基于UDP协议传输数据的方法。分享给大家供大家参考&＃xff0c;具体如下&＃xff1a;UDP协议(User Datagram Protocol,用户数据报协议)不同于TCP协议&＃xff0c;它是不可能靠的&＃xff0c;但是它比TCP协议具有更快的传输速度&＃xff0c;UDP发送的数据单元称为数据报&＃xff0c;当网络传输UDP传输UDP数据报是无法保证数据能够到达目的地&＃xff0c;也无法保证按发送的顺序到达目的地&＃xff0c;也就是说先发送了“hello”,再发送了“world”,但接收方可能会先收到“world”,再收到“hello”,也有可能收不到数据&＃xff0c;为什么呢&＃xff1f;因为它是不可能靠的&＃xff0c;在传输途中可能丢失了。但UDP比TCP跟适合与传输实时音频。下面是一个简单的UPD传输数据报的例子服务器端&＃xff1a;

&＃96;&＃96;&＃96;java

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 &＃61; 8088;

public static void main(String[] args) throws SocketException {

new EchoServer().service();

}

public EchoServer() throws SocketException{

datagramSocket &＃61; new DatagramSocket(port);

System.out.println("服务器启动");

}

public String echo(String msg){

return "echo:"&＃43;msg;

}

public void service(){

while (true) {

try {

DatagramPacket packet &＃61; new DatagramPacket(new byte[512], 512);

datagramSocket.receive(packet);

String msg &＃61; new String(packet.getData(), 0, packet.getLength());

System.out.println(packet.getAddress()&＃43;"/"&＃43;packet.getPort()&＃43;" msg:"&＃43;msg);

packet.setData(echo(msg).getBytes());

datagramSocket.send(packet);

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

&＃96;&＃96;&＃96;

客户端&＃xff1a;

&＃96;&＃96;&＃96;java

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&＃61;"localhost";

private int remotePort&＃61;8088;

private DatagramSocket datagramSocket;

public EchoClient() throws SocketException{

datagramSocket &＃61; new DatagramSocket();

}

public static void main(String[] args) throws SocketException {

new EchoClient().talk();

}

public void talk(){

try {

BufferedReader reader &＃61; new BufferedReader(new InputStreamReader(System.in));

String msg &＃61; null;

InetAddress address &＃61; InetAddress.getByName(remoteHost);

while ((msg&＃61;reader.readLine())!&＃61;null) {

//发送数据报

byte [] buffer &＃61; msg.getBytes();

DatagramPacket packet &＃61; new DatagramPacket(buffer,buffer.length, address, remotePort);

datagramSocket.send(packet);

//接收数据报

DatagramPacket inputPacket &＃61; 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();

}

}

&＃96;&＃96;&＃96;