Java模擬UDP通信示例代碼
更新時(shí)間：2020年06月09日 11:50:35 作者：sunzhongjie
這篇文章主要介紹了Java模擬UDP通信，文中示例代碼非常詳細(xì)，供大家參考和學(xué)習(xí)，感興趣的朋友可以了解下
Java基礎(chǔ)：模擬UDP通信
1、一次發(fā)送，一次接收
1.1、發(fā)送方
// 發(fā)送端，不需要連接服務(wù)器
public class UdpClientDemo {
public static void main(String[] args) throws Exception {
// 1. 發(fā)送數(shù)據(jù)包需要一個(gè)Socket
DatagramSocket socket = new DatagramSocket();
// 1.2 建立一個(gè)包
String msg = "你好";
InetAddress localhost = InetAddress.getByName("localhost");
System.out.println(localhost);
int port = 8080;
/*
通過UDP發(fā)送消息，需要通過 包 來發(fā)送，--> DatagramPacket()，該方法有多種重載形式，以下使用參數(shù)列表最多的那個(gè)
參數(shù)：
- 要發(fā)送的 消息 的字節(jié)數(shù)組
- 從字節(jié)數(shù)組的哪個(gè)位置開始發(fā)送
- 發(fā)送的長度
- 對方的 IP地址
- 對方的端口號(hào)
*/
DatagramPacket packet = new DatagramPacket(msg.getBytes(), 0, msg.getBytes().length, localhost, port);
// 2. 發(fā)送數(shù)據(jù)包
socket.send(packet);
socket.close();
}
}
1.2、接收方
// 接收端，接收端需要保證存在，否則接收不到，所以需要提前開啟
public class UdpServerDemo {
public static void main(String[] args) throws Exception {
// 1. 接收也需要一個(gè)Socket，并且要開啟接收的端口
DatagramSocket socket = new DatagramSocket(8080);
// 需要一個(gè)字節(jié)數(shù)組來接收數(shù)據(jù)
byte[] buffer = new byte[1024];
// 1.2 封裝數(shù)據(jù)包
DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);
// 2. 接收數(shù)據(jù)，阻塞式接收：一直處于監(jiān)聽狀態(tài)
socket.receive(packet);
// 關(guān)閉套接字
socket.close();
// 輸出一下
System.out.println(packet.getAddress().getHostAddress());
// trim()：為了去除多余的空格
System.out.println(new String(packet.getData()).trim());
}
}
2、多次發(fā)送，多次接收
一方多次發(fā)送，一方多次接收，加上一個(gè) while(true) {} 死循環(huán)，并規(guī)定在什么情況下退出即可。
2.1、發(fā)送方
public class ChatSenderDemo {
public static void main(String[] args) throws Exception {
// 使用Socket來接收
DatagramSocket socket = new DatagramSocket();
while (true) {
// 準(zhǔn)備發(fā)送包裹，從鍵盤接收數(shù)據(jù)
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
// 讀取一行
String data = reader.readLine();
byte[] dataBytes = data.getBytes();
DatagramPacket packet = new DatagramPacket(dataBytes, dataBytes.length, new InetSocketAddress("127.0.0.1", 6666));
// 發(fā)送
socket.send(packet);
// 什么時(shí)候退出
if ("bye".equals(data)) {
break;
}
}
// 關(guān)閉
socket.close();
}
}
2.2、接收方
public class ChatReceiveDemo {
public static void main(String[] args) throws Exception {
DatagramSocket socket = new DatagramSocket(6666);
while (true) {
// 準(zhǔn)備接收數(shù)據(jù)包裹
byte[] buffer = new byte[1024];
// 用來接收數(shù)據(jù)
DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);
// 接收包裹，阻塞時(shí)接收
socket.receive(packet);
// 接收到的數(shù)據(jù)
String receiveData = new String(packet.getData()).trim();
// 打印到控制臺(tái)
System.out.println(receiveData);
// 什么時(shí)候退出
if ("bye".equals(receiveData)) {
break;
}
}
// 關(guān)閉
socket.close();
}
}
3、模擬雙方通信
模擬雙方使用UDP通信，需要開啟兩個(gè)線程，并對以上代碼進(jìn)行【共性提取】，進(jìn)一步進(jìn)行抽象。
由此，雙方可以通過指定的端口來互相發(fā)送消息。
3.1、發(fā)送方的線程
// 開啟多線程需要實(shí)現(xiàn) Runnable 接口，實(shí)現(xiàn) run()方法
public class TalkSender implements Runnable {
// 網(wǎng)絡(luò)套接字，發(fā)送需要
DatagramSocket socket = null;
// 緩沖讀取流
BufferedReader reader = null;
// 開啟哪個(gè)端口接收
private int fromPort;
// 對方的 IP
private String toIP;
// 對方的端口
private int toPort;
// 通過構(gòu)造方法進(jìn)行初始化
public TalkSender(int fromPort, String toIP, int toPort) {
this.fromPort = fromPort;
this.toIP = toIP;
this.toPort = toPort;
try {
socket = new DatagramSocket(fromPort);
} catch (SocketException e) {
e.printStackTrace();
}
}
// 重寫 run()方法，設(shè)置線程任務(wù)
@Override
public void run() {
while (true) {
String data = null;
try {
// 準(zhǔn)備發(fā)送包裹，從鍵盤接收數(shù)據(jù)
reader = new BufferedReader(new InputStreamReader(System.in));
// 讀取一行
data = reader.readLine();
byte[] dataBytes = data.getBytes();
DatagramPacket packet = new DatagramPacket(dataBytes, dataBytes.length, new InetSocketAddress(toIP, toPort));
socket.send(packet);
} catch (IOException e) {
e.printStackTrace();
}
// 什么時(shí)候退出
if ("bye".equals(data)) {
break;
}
}
// 關(guān)閉
socket.close();
}
}
3.2、接收方的線程
public class TalkReveicer implements Runnable {
DatagramSocket socket = null;
// 從哪個(gè)端口接收
private int formPort;
// 發(fā)送方是誰
private String who;
public TalkReveicer(int formPort, String who) {
this.formPort = formPort;
this.who = who;
try {
socket = new DatagramSocket(formPort);
} catch (SocketException e) {
e.printStackTrace();
}
}
@Override
public void run() {
while (true) {
String receiveData = null;
try {
// 準(zhǔn)備接收數(shù)據(jù)包裹
byte[] buffer = new byte[1024];
// 接收數(shù)據(jù)
DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);
// 接收數(shù)據(jù)，阻塞式
socket.receive(packet);
// 接收到的數(shù)據(jù)
receiveData = new String(packet.getData());
System.out.println(who + "：" + receiveData.trim());
} catch (IOException e) {
e.printStackTrace();
}
// 什么時(shí)候退出
if ("bye".equals(receiveData)) {
break;
}
}
// 關(guān)閉
socket.close();
}
}
3.3、模擬學(xué)生
// 學(xué)生端
public class TalkStudent {
public static void main(String[] args) {
// 開啟 5555端口，發(fā)送到本機(jī)的 6666端口
new Thread(new TalkSender(5555, "localhost", 6666)).start();
// 規(guī)定使用 7777 端口接收老師發(fā)送的消息
new Thread(new TalkReveicer(7777, "老師")).start();
}
}
3.4、模擬老師
// 教師端
public class TalkTeacher {
public static void main(String[] args) {
// 開啟 8888端口，發(fā)送到本機(jī)的 7777端口
new Thread(new TalkSender(8888, "localhost", 7777)).start();
// 規(guī)定使用 6666 端口接收學(xué)生發(fā)送的消息
new Thread(new TalkReveicer(6666, "學(xué)生")).start();
}
}
總結(jié)：
使用UDP通信，其實(shí)主要的步驟分為三步：
1 用 DatagramSocket() 來開啟端口，通過開啟端口聊天。
2 用DatagramPacket() 來發(fā)送或者接收數(shù)據(jù)。
3 關(guān)閉 DatagramSocket，釋放資源。
以上就是Java模擬UDP通信示例代碼的詳細(xì)內(nèi)容，更多關(guān)于Java模擬UDP通信的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
idea快速搭建spring cloud注冊中心與注冊的方法
這篇文章主要介紹了idea快速搭建spring cloud注冊中心與注冊的方法，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-07-07
基于Java代碼實(shí)現(xiàn)數(shù)字在數(shù)組中出現(xiàn)次數(shù)超過一半
這篇文章主要介紹了基于Java代碼實(shí)現(xiàn)數(shù)字在數(shù)組中出現(xiàn)次數(shù)超過一半的相關(guān)資料,需要的朋友可以參考下2016-02-02
如何在 Linux 上搭建 java 部署環(huán)境(安裝jdk/tomcat/mys
這篇文章主要介紹了如何在 Linux 上搭建 java 部署環(huán)境(安裝jdk/tomcat/mysql) + 將程序部署到云服務(wù)器上的操作),本文通過圖文并茂的形式給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2023-01-01
這篇文章主要介紹了Java的Channel通道之FileChannel類詳解,FileChannel類是Java NIO中的一個(gè)重要類,用于在文件中進(jìn)行讀寫操作,它提供了一種高效的方式來處理大文件和隨機(jī)訪問文件的需求,需要的朋友可以參考下2023-10-10
Java設(shè)計(jì)模式之Template?Pattern模板模式詳解
這篇文章主要介紹了Java設(shè)計(jì)模式之Template?Pattern模板模式詳解,模板模式（Template?Pattern）行為型模式之一,抽象父類定義一個(gè)操作中的算法的骨架,而將一些步驟延遲到子類中,需要的朋友可以參考下2023-10-10
這篇文章主要介紹了SpringMvc @Valid如何拋出攔截異常,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09
Java獲取Object中Value的實(shí)現(xiàn)方法
本文介紹了在Java中獲取對象屬性值的幾種常見方法,包括使用反射機(jī)制、getter方法、接口或抽象類、Map數(shù)據(jù)結(jié)構(gòu)、序列化與反序列化以及JavaBeans規(guī)范,每種方法都有其適用場景和優(yōu)缺點(diǎn),選擇合適的方法取決于具體需求2025-03-03
解決SpringBoot內(nèi)嵌Tomcat并發(fā)容量的問題
這篇文章主要介紹了解決SpringBoot內(nèi)嵌Tomcat并發(fā)容量的問題，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-06-06
Java中的Tuple是一種非常有用的數(shù)據(jù)結(jié)構(gòu),它可以讓開發(fā)者在處理多個(gè)數(shù)據(jù)元素時(shí)更加方便和高效,通過Tuple,我們可以將多個(gè)變量打包成一個(gè)對象,從而減少了代碼量,提高了代碼可讀性,這篇文章主要介紹了Java中Tuple的功能及使用場景,需要的朋友可以參考下2024-01-01
使用StringRedisTemplate操作Redis方法詳解
這篇文章主要為大家介紹了使用StringRedisTemplate操作Redis方法詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-08-08