這篇文章主要為大家展示了Java如何模擬UDP通信，內(nèi)容簡而易懂，希望大家可以學(xué)習(xí)一下，學(xué)習(xí)完之后肯定會(huì)有收獲的，下面讓小編帶大家一起來看看吧。
專注于為中小企業(yè)提供做網(wǎng)站、網(wǎng)站制作服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)察哈爾右翼后免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了上千企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。
Java基礎(chǔ)：模擬UDP通信
// 發(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地址 - 對方的端口號 */ DatagramPacket packet = new DatagramPacket(msg.getBytes(), 0, msg.getBytes().length, localhost, port); // 2. 發(fā)送數(shù)據(jù)包 socket.send(packet); socket.close(); } }
重慶分公司
重慶分公司
// 接收端，接收端需要保證存在，否則接收不到，所以需要提前開啟
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());
}
}一方多次發(fā)送，一方多次接收，加上一個(gè) while(true) {} 死循環(huán)，并規(guī)定在什么情況下退出即可。
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();
}
}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();
// 打印到控制臺
System.out.println(receiveData);
// 什么時(shí)候退出
if ("bye".equals(receiveData)) {
break;
}
}
// 關(guān)閉
socket.close();
}
}模擬雙方使用UDP通信，需要開啟兩個(gè)線程，并對以上代碼進(jìn)行【共性提取】，進(jìn)一步進(jìn)行抽象。
由此，雙方可以通過指定的端口來互相發(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();
}
}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();
}
}// 學(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();
}
}// 教師端
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();
}
}以上就是關(guān)于Java如何模擬UDP通信的內(nèi)容，如果你們有學(xué)習(xí)到知識或者技能，可以把它分享出去讓更多的人看到。
