java编程实现基于UDP协议传输数据的方法
本文实例讲述了java编程实现基于UDP协议传输数据的方法。分享给大家供大家参考，具体如下：
UDP协议（UserDatagramProtocol,用户数据报协议）不同于TCP协议，它是不可能靠的，但是它比TCP协议具有更快的传输速度，UDP发送的数据单元称为数据报，当网络传输UDP传输UDP数据报是无法保证数据能够到达目的地，也无法保证按发送的顺序到达目的地，也就是说先发送了“hello”,再发送了“world”,但接收方可能会先收到“world”,再收到“hello”,也有可能收不到数据，为什么呢？因为它是不可能靠的，在传输途中可能丢失了。但UDP比TCP跟适合与传输实时音频。下面是一个简单的UPD传输数据报的例子
服务器端：
importjava.io.IOException;
importjava.net.DatagramPacket;
importjava.net.DatagramSocket;
importjava.net.SocketException;
publicclassEchoServer{
privateDatagramSocketdatagramSocket;
privatefinalintport=8088;
publicstaticvoidmain(String[]args)throwsSocketException{
newEchoServer().service();
}
publicEchoServer()throwsSocketException{
datagramSocket=newDatagramSocket(port);
System.out.println("服务器启动");
}
publicStringecho(Stringmsg){
return"echo:"+msg;
}
publicvoidservice(){
while(true){
try{
DatagramPacketpacket=newDatagramPacket(newbyte[512],512);
datagramSocket.receive(packet);
Stringmsg=newString(packet.getData(),0,packet.getLength());
System.out.println(packet.getAddress()+"/"+packet.getPort()+"msg:"+msg);
packet.setData(echo(msg).getBytes());
datagramSocket.send(packet);
}catch(IOExceptione){
e.printStackTrace();
}
}
}
}
客户端：
importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.net.DatagramPacket;
importjava.net.DatagramSocket;
importjava.net.InetAddress;
importjava.net.SocketException;
publicclassEchoClient{
privateStringremoteHost="localhost";
privateintremotePort=8088;
privateDatagramSocketdatagramSocket;
publicEchoClient()throwsSocketException{
datagramSocket=newDatagramSocket();
}
publicstaticvoidmain(String[]args)throwsSocketException{
newEchoClient().talk();
}
publicvoidtalk(){
try{
BufferedReaderreader=newBufferedReader(newInputStreamReader(System.in));
Stringmsg=null;
InetAddressaddress=InetAddress.getByName(remoteHost);
while((msg=reader.readLine())!=null){
//发送数据报
byte[]buffer=msg.getBytes();
DatagramPacketpacket=newDatagramPacket(buffer,buffer.length,address,remotePort);
datagramSocket.send(packet);
//接收数据报
DatagramPacketinputPacket=newDatagramPacket(newbyte[512],512);
datagramSocket.receive(inputPacket);
System.out.println(newString(inputPacket.getData(),0,inputPacket.getLength()));
if("bye".equals(msg)){
break;
}
}
}catch(IOExceptione){
e.printStackTrace();
}finally{
datagramSocket.close();
}
}
希望本文所述对大家Java程序设计有所帮助。