java編程實(shí)現(xiàn)基于UDP協(xié)議傳輸數(shù)據(jù)的方法

更新時(shí)間：2015年11月05日 15:17:03 作者：awj3584

這篇文章主要介紹了java編程實(shí)現(xiàn)基于UDP協(xié)議傳輸數(shù)據(jù)的方法,較為詳細(xì)的分析了UDP協(xié)議的原理及Java編程實(shí)現(xiàn)數(shù)據(jù)傳輸客戶端與服務(wù)器端的相關(guān)技巧,需要的朋友可以參考下

本文實(shí)例講述了java編程實(shí)現(xiàn)基于UDP協(xié)議傳輸數(shù)據(jù)的方法。分享給大家供大家參考，具體如下：

UDP協(xié)議（User Datagram Protocol,用戶數(shù)據(jù)報(bào)協(xié)議）不同于TCP協(xié)議，它是不可能靠的，但是它比TCP協(xié)議具有更快的傳輸速度，UDP發(fā)送的數(shù)據(jù)單元稱為數(shù)據(jù)報(bào)，當(dāng)網(wǎng)絡(luò)傳輸U(kuò)DP傳輸U(kuò)DP數(shù)據(jù)報(bào)是無(wú)法保證數(shù)據(jù)能夠到達(dá)目的地，也無(wú)法保證按發(fā)送的順序到達(dá)目的地，也就是說先發(fā)送了“hello”,再發(fā)送了“world”,但接收方可能會(huì)先收到“world”,再收到“hello”,也有可能收不到數(shù)據(jù)，為什么呢？因?yàn)樗遣豢赡芸康?，在傳輸途中可能丟失了。但UDP比TCP跟適合與傳輸實(shí)時(shí)音頻。下面是一個(gè)簡(jiǎn)單的UPD傳輸數(shù)據(jù)報(bào)的例子

服務(wù)器端：

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("服務(wù)器啟動(dòng)"); 
 } 
 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(); 
   } 
  } 
 } 
}

客戶端：

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) { 
    //發(fā)送數(shù)據(jù)報(bào) 
    byte [] buffer = msg.getBytes(); 
    DatagramPacket packet = new DatagramPacket(buffer,buffer.length, address, remotePort); 
    datagramSocket.send(packet); 
    //接收數(shù)據(jù)報(bào) 
    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(); 
  } 
}

希望本文所述對(duì)大家Java程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: