轉(zhuǎn)載自?Java基于socket服務(wù)實現(xiàn)UDP協(xié)議的方法

這篇文章主要介紹了Java基于socket服務(wù)實現(xiàn)UDP協(xié)議的方法,通過兩個簡單實例分析了java通過socket實現(xiàn)UDP發(fā)送與接收的技巧,需要的朋友可以參考下

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

示例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的服務(wù),必須明確一個端口號 3、創(chuàng)建數(shù)據(jù)包，用于儲存接收到的數(shù)據(jù)，方便用數(shù)據(jù)包對象的方法解析這些數(shù)據(jù) 4、使用DatagramSocket的receive方法將接收到的數(shù)據(jù)存儲到數(shù)據(jù)包中 5、通過數(shù)據(jù)包的方法解析數(shù)據(jù)包中的數(shù)據(jù) 5、關(guān)閉socket服務(wù) */ //udpsocket服務(wù)，使用DatagramSocket對象 DatagramSocket ds=new DatagramSocket(10002); //使用DatagramPacket將數(shù)據(jù)封裝到該對象中 byte[] buf=new byte[1024]; DatagramPacket dp=new DatagramPacket(buf, buf.length); //通過udp的socket服務(wù)將數(shù)據(jù)包發(fā)送出去，通過send方法 ds.receive(dp); //通過數(shù)據(jù)包的方法解析數(shù)據(jù)包中的數(shù)據(jù),比如，地址、端口、數(shù)據(jù)內(nèi)容等 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); //關(guān)閉資源 ds.close(); } }

發(fā)送類：

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("發(fā)送端啟動…………"); /* * 1、創(chuàng)建udp傳輸?shù)陌l(fā)送端 2、建立UDP的socket的服務(wù) 3、將要發(fā)送的數(shù)據(jù)封裝到數(shù)據(jù)包中 4、通過udp的socket服務(wù)將數(shù)據(jù)包發(fā)送出去 5、關(guān)閉socket服務(wù) */ //udpsocket服務(wù)，使用DatagramSocket對象 DatagramSocket ds=new DatagramSocket(8888);//監(jiān)聽端口 //將要發(fā)送的數(shù)據(jù)封裝到數(shù)據(jù)包中 String str="udp傳輸演示，go"; //使用DatagramPacket將數(shù)據(jù)封裝到該對象中 byte[] buf=str.getBytes(); DatagramPacket dp= new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.100"),10002); //通過udp的socket服務(wù)將數(shù)據(jù)包發(fā)送出去，通過send方法 ds.send(dp); //關(guān)閉資源 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的服務(wù),必須明確一個端口號 3、創(chuàng)建數(shù)據(jù)包，用于儲存接收到的數(shù)據(jù)，方便用數(shù)據(jù)包對象的方法解析這些數(shù)據(jù) 4、使用DatagramSocket的receive方法將接收到的數(shù)據(jù)存儲到數(shù)據(jù)包中 5、通過數(shù)據(jù)包的方法解析數(shù)據(jù)包中的數(shù)據(jù) 5、關(guān)閉socket服務(wù) */ //udpsocket服務(wù)，使用DatagramSocket對象 DatagramSocket ds=new DatagramSocket(10003); while(true){ //使用DatagramPacket將數(shù)據(jù)封裝到該對象中 byte[] buf=new byte[1024]; DatagramPacket dp=new DatagramPacket(buf, buf.length); //通過udp的socket服務(wù)將數(shù)據(jù)包發(fā)送出去，通過send方法 ds.receive(dp);//阻塞式的。 //通過數(shù)據(jù)包的方法解析數(shù)據(jù)包中的數(shù)據(jù),比如，地址、端口、數(shù)據(jù)內(nèi)容等 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); } //關(guān)閉資源 //ds.close(); } }

發(fā)送類：

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("發(fā)送端啟動…………"); /* * 1、創(chuàng)建udp傳輸?shù)陌l(fā)送端 2、建立UDP的socket的服務(wù) 3、將要發(fā)送的數(shù)據(jù)封裝到數(shù)據(jù)包中 4、通過udp的socket服務(wù)將數(shù)據(jù)包發(fā)送出去 5、關(guān)閉socket服務(wù) */ //udpsocket服務(wù)，使用DatagramSocket對象 DatagramSocket ds=new DatagramSocket(9999);//監(jiān)聽端口 //將要發(fā)送的數(shù)據(jù)封裝到數(shù)據(jù)包中 //String str="udp傳輸演示，go"; BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));//鍵盤輸入 String line=null; //使用DatagramPacket將數(shù)據(jù)封裝到該對象中 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服務(wù)將數(shù)據(jù)包發(fā)送出去，通過send方法 ds.send(dp); if("886".equals(line)){ break; } } //關(guān)閉資源 ds.close(); } }

運行效果圖如下：

接收：

發(fā)送：

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

總結(jié)

以上是生活随笔為你收集整理的Java基于socket服务实现UDP协议的方法的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。