本文實例講述了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(); } }
運行效果圖如下:
接收:
發送:
希望本文所述對大家的java程序設計有所幫助。