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程序设计有所帮助。