Java基于socket服務實現UDP協議的方法

2019-11-26 15:10:33

字體：大中小

來源：轉載

供稿：網友

本文實例講述了Java基于socket服務實現UDP協議的方法。分享給大家供大家參考。具體如下：

示例1：

接收類：

package com.socket.demo; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; public class UDPReceiveDemo {  public static void main(String[] args) throws IOException{   System.out.println("接收端啟動…………");  /*   2、建立UDP的socket的服務,必須明確一個端口號   3、創建數據包，用于儲存接收到的數據，方便用數據包對象的方法解析這些數據   4、使用DatagramSocket的receive方法將接收到的數據存儲到數據包中   5、通過數據包的方法解析數據包中的數據   5、關閉socket服務   */   //udpsocket服務，使用DatagramSocket對象   DatagramSocket ds=new DatagramSocket(10002);   //使用DatagramPacket將數據封裝到該對象中   byte[] buf=new byte[1024];   DatagramPacket dp=new DatagramPacket(buf, buf.length);   //通過udp的socket服務將數據包發送出去，通過send方法   ds.receive(dp);   //通過數據包的方法解析數據包中的數據,比如，地址、端口、數據內容等   String ip=dp.getAddress().getHostAddress();   //String name=dp.getAddress().getHostName();   int port=dp.getPort();   String text=new String(dp.getData(),0,dp.getLength());   //System.out.println("-----"+ip+"-----"+name+"-----"+port+"-----"+text);   System.out.println("-----"+ip+"----------"+port+"-----"+text);   //關閉資源   ds.close();  } }

發送類：

package com.socket.demo; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; import java.net.UnknownHostException; public class UDPSendDemo {  public static void main(String[] args) throws IOException{   System.out.println("發送端啟動…………");  /*   * 1、創建udp傳輸的發送端   2、建立UDP的socket的服務   3、將要發送的數據封裝到數據包中   4、通過udp的socket服務將數據包發送出去   5、關閉socket服務   */   //udpsocket服務，使用DatagramSocket對象   DatagramSocket ds=new DatagramSocket(8888);//監聽端口   //將要發送的數據封裝到數據包中   String str="udp傳輸演示，go";   //使用DatagramPacket將數據封裝到該對象中   byte[] buf=str.getBytes();   DatagramPacket dp=     new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.100"),10002);   //通過udp的socket服務將數據包發送出去，通過send方法   ds.send(dp);   //關閉資源   ds.close();  } }

示例2：

接收類：

package com.socket.demo; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; public class UDPReceiveDemo2 {  public static void main(String[] args) throws IOException{   System.out.println("接收端啟動…………");  /*   2、建立UDP的socket的服務,必須明確一個端口號   3、創建數據包，用于儲存接收到的數據，方便用數據包對象的方法解析這些數據   4、使用DatagramSocket的receive方法將接收到的數據存儲到數據包中   5、通過數據包的方法解析數據包中的數據   5、關閉socket服務   */   //udpsocket服務，使用DatagramSocket對象   DatagramSocket ds=new DatagramSocket(10003);   while(true){    //使用DatagramPacket將數據封裝到該對象中    byte[] buf=new byte[1024];    DatagramPacket dp=new DatagramPacket(buf, buf.length);    //通過udp的socket服務將數據包發送出去，通過send方法    ds.receive(dp);//阻塞式的。    //通過數據包的方法解析數據包中的數據,比如，地址、端口、數據內容等    String ip=dp.getAddress().getHostAddress();    //String name=dp.getAddress().getHostName();    int port=dp.getPort();    String text=new String(dp.getData(),0,dp.getLength());    //System.out.println("-----"+ip+"-----"+name+"-----"+port+"-----"+text);    System.out.println("-----"+ip+"----------"+port+"-----"+text);   }   //關閉資源   //ds.close();  } }

發送類：

package com.socket.demo; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; public class UDPSendDemo2 {  public static void main(String[] args) throws IOException{   System.out.println("發送端啟動…………");  /*   * 1、創建udp傳輸的發送端   2、建立UDP的socket的服務   3、將要發送的數據封裝到數據包中   4、通過udp的socket服務將數據包發送出去   5、關閉socket服務   */   //udpsocket服務，使用DatagramSocket對象   DatagramSocket ds=new DatagramSocket(9999);//監聽端口   //將要發送的數據封裝到數據包中   //String str="udp傳輸演示，go";   BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));//鍵盤輸入   String line=null;   //使用DatagramPacket將數據封裝到該對象中   while((line=bufr.readLine())!=null){    byte[] buf=line.getBytes();//    DatagramPacket dp=      new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.100"),10003);    //通過udp的socket服務將數據包發送出去，通過send方法    ds.send(dp);    if("886".equals(line)){     break;    }   }   //關閉資源   ds.close();  } }

運行效果圖如下：

接收：