程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 更多編程語言 >> 更多關於編程 >> Java基於socket服務實現UDP協議的方法

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

編輯:更多關於編程

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

      示例1:

      接收類:

      ?

    1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 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(); } }

      發送類:

      ?

    1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 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:

      接收類:

      ?

    1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 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(); } }

      發送類:

      ?

    1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 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(); } }

      運行效果圖如下:

      接收:

      發送:

      希望本文所述對大家的java程序設計有所幫助。

    1. 上一頁:
    2. 下一頁:
    Copyright © 程式師世界 All Rights Reserved