發(fā)送端

import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.util.Scanner;/*** UDP 通訊協(xié)議 局域網(wǎng)通信發(fā)送消息 簡單實現(xiàn) 發(fā)送端** @author silence*/ public class SendDemo {public static void main(String[] args) throws Exception {//此類表示用于發(fā)送和接收數(shù)據(jù)包數(shù)據(jù)包的套接字//數(shù)據(jù)包套接字是分組傳送服務(wù)的發(fā)送或接收點。// 在數(shù)據(jù)包套接字上發(fā)送或接收的每個數(shù)據(jù)包都被單獨尋址和路由。// 從一個機器發(fā)送到另一個機器的多個分組可以不同地路由，并且可以以任何順序到達(dá)。//在可能的情況下，新構(gòu)建的DatagramSocket啟用了SO_BROADCAST套接字選項，// 以允許傳輸廣播數(shù)據(jù)包。 為了接收廣播數(shù)據(jù)包，DatagramSocket應(yīng)該綁定到通配符地址。// 在一些實現(xiàn)中，當(dāng)DatagramSocket綁定到更具體的地址時，也可以接收廣播分組。//示例： DatagramSocket s = new DatagramSocket(null);// s.bind(new InetSocketAddress(8888));// 其中相當(dāng)于： DatagramSocket s = new DatagramSocket(8888);// 這兩種情況都將創(chuàng)建一個DatagramSocket能夠在UDP端口8888上接收廣播。DatagramSocket datagramSocket = new DatagramSocket();InetAddress ip = InetAddress.getByName("127.0.0.1");int port = 1024;Scanner scanner = new Scanner(System.in);while (true) {System.out.println("請輸入要發(fā)送的數(shù)據(jù):");String str = scanner.nextLine();byte[] bytes = str.getBytes();//該類表示數(shù)據(jù)包包。//數(shù)據(jù)包包用于實現(xiàn)無連接分組傳送服務(wù)。 僅基于該數(shù)據(jù)包中包含的信息，// 每個消息從一臺機器路由到另一臺機器。// 從一臺機器發(fā)送到另一臺機器的多個分組可能會有不同的路由，// 并且可能以任何順序到達(dá)。 包傳送不能保證。DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length, ip, port);datagramSocket.send(datagramPacket);//如果發(fā)送的是886就結(jié)束發(fā)送端if ("886".equals(str)) {break;}}datagramSocket.close();} }

========服務(wù)器端

import java.net.DatagramPacket; import java.net.DatagramSocket;/*** UDP 通訊協(xié)議 接收端** @author silence*/ public class ReceiveDemo {public static void main(String[] args) throws Exception {//此類表示用于發(fā)送和接收數(shù)據(jù)包數(shù)據(jù)包的套接字//數(shù)據(jù)包套接字是分組傳送服務(wù)的發(fā)送或接收點。// 在數(shù)據(jù)包套接字上發(fā)送或接收的每個數(shù)據(jù)包都被單獨尋址和路由。// 從一個機器發(fā)送到另一個機器的多個分組可以不同地路由，并且可以以任何順序到達(dá)。//在可能的情況下，新構(gòu)建的DatagramSocket啟用了SO_BROADCAST套接字選項，// 以允許傳輸廣播數(shù)據(jù)包。 為了接收廣播數(shù)據(jù)包，DatagramSocket應(yīng)該綁定到通配符地址。// 在一些實現(xiàn)中，當(dāng)DatagramSocket綁定到更具體的地址時，也可以接收廣播分組。//示例： DatagramSocket s = new DatagramSocket(null);// s.bind(new InetSocketAddress(8888));// 其中相當(dāng)于： DatagramSocket s = new DatagramSocket(8888);// 這兩種情況都將創(chuàng)建一個DatagramSocket能夠在UDP端口8888上接收廣播。DatagramSocket datagramSocket = new DatagramSocket(1024);//用于接收的數(shù)組byte[] bytes = new byte[1024];//該類表示數(shù)據(jù)包。//數(shù)據(jù)包包用于實現(xiàn)無連接分組傳送服務(wù)。 僅基于該數(shù)據(jù)包中包含的信息，// 每個消息從一臺機器路由到另一臺機器。// 從一臺機器發(fā)送到另一臺機器的多個分組可能會有不同的路由，// 并且可能以任何順序到達(dá)。 包傳送不能保證。DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);while (true) {//從此套接字接收數(shù)據(jù)報包。datagramSocket.receive(datagramPacket);int length = datagramPacket.getLength();String str = new String(bytes);System.out.println(str);//如果發(fā)送的是886就結(jié)束發(fā)送端if ("886".equals(str)) {break;}}datagramSocket.close();} }

總結(jié)

以上是生活随笔為你收集整理的UDP 通讯协议 局域网通信发送消息 简单实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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