java 中模擬UDP傳輸?shù)陌l(fā)送端和接收端實例詳解
更新時間：2017年03月28日 09:47:47 投稿：lqh
這篇文章主要介紹了java 中模擬UDP傳輸?shù)陌l(fā)送端和接收端實例詳解的相關(guān)資料,需要的朋友可以參考下
java 中模擬UDP傳輸?shù)陌l(fā)送端和接收端實例詳解
一、創(chuàng)建UDP傳輸?shù)陌l(fā)送端
1、建立UDP的Socket服務(wù)；
2、將要發(fā)送的數(shù)據(jù)封裝到數(shù)據(jù)包中；
3、通過UDP的Socket服務(wù)將數(shù)據(jù)包發(fā)送出去；
4、關(guān)閉Socket服務(wù)。
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UDPSend {
public static void main(String[] args) throws IOException {
System.out.println("發(fā)送端啟動......");
// 1、創(chuàng)建UDP的Socket，使用DatagramSocket對象
DatagramSocket ds = new DatagramSocket();
// 2、將要發(fā)送的數(shù)據(jù)封裝到數(shù)據(jù)包中
String str = "UDP傳輸演示：I'm coming!";
byte[] buf = str.getBytes(); //使用DatagramPacket將數(shù)據(jù)封裝到該對象的包中
DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.191.1"), 10000);
// 3、通過UDP的Socket服務(wù)將數(shù)據(jù)包發(fā)送出去，使用send方法
ds.send(dp);
// 4、關(guān)閉Socket服務(wù)
ds.close();
}
}
二、創(chuàng)建UDP傳輸?shù)慕邮斩?/strong>
1、建立UDP的Socket服務(wù)，因為要接收數(shù)據(jù)，所以必須明確一個端口號；
2、創(chuàng)建數(shù)據(jù)包，用于存儲接收到的數(shù)據(jù)，方便用數(shù)據(jù)包對象的方法解析這些數(shù)據(jù)；
3、使用UDP的Socket服務(wù)的receive方法接收數(shù)據(jù)并存儲到數(shù)據(jù)包中；
4、通過數(shù)據(jù)包的方法解析這些數(shù)據(jù)；
5、關(guān)閉Socket服務(wù)。
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UDPReceive {
public static void main(String[] args) throws IOException {
System.out.println("接收端啟動......");
// 1、建立UDP的Socket服務(wù)
DatagramSocket ds = new DatagramSocket(10000);
// 2、創(chuàng)建數(shù)據(jù)包
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
// 3、使用接收方法將數(shù)據(jù)存儲到數(shù)據(jù)包中
ds.receive(dp); // 該方法為阻塞式的方法
// 4、通過數(shù)據(jù)包對象的方法解析這些數(shù)據(jù)，例如：地址、端口、數(shù)據(jù)內(nèi)容等
String ip = dp.getAddress().getHostAddress();
int port = dp.getPort();
String text = new String(dp.getData(), 0, dp.getLength());
System.out.println(ip + ":" + port + ":" + text);
// 5、關(guān)閉Socket服務(wù)
ds.close();
}
}
三、優(yōu)化UDP傳輸?shù)陌l(fā)送端和接收端
由于在前兩部分中，我們一次只能發(fā)送（或接收）一條消息，然后就關(guān)閉服務(wù)啦！因此如果我們想要發(fā)送多條消息，則需要不斷的在發(fā)送端修改發(fā)送的內(nèi)容，并且還需要重新啟動服務(wù)器，比較麻煩。為了克服以上的缺點，我們可以對其進(jìn)行優(yōu)化，即：
1、在發(fā)送端，創(chuàng)建BufferedReader，從鍵盤錄入內(nèi)容；
2、在接收端，添加while(ture)循環(huán)，不斷的循環(huán)接收內(nèi)容。
/**
*優(yōu)化UDP傳輸?shù)陌l(fā)送端
*/
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 UDPSend {
public static void main(String[] args) throws IOException {
System.out.println("發(fā)送端啟動......");
// 創(chuàng)建UDP的Socket，使用DatagramSocket對象
DatagramSocket ds = new DatagramSocket();
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while ((line = bufr.readLine()) != null) {
// 使用DatagramPacket將數(shù)據(jù)封裝到該對象的包中
byte[] buf = line.getBytes();
DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.191.1"), 10000);
// 通過UDP的Socket服務(wù)將數(shù)據(jù)包發(fā)送出去，使用send方法
ds.send(dp);
// 如果輸入信息為over，則結(jié)束循環(huán)
if ("over".equals(line))
break;
}
// 關(guān)閉Socket服務(wù)
ds.close();
}
}
/**
*優(yōu)化UDP傳輸?shù)慕邮斩?
*/
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UDPReceive {
public static void main(String[] args) throws IOException {
System.out.println("接收端啟動......");
// 建立UDP的Socket服務(wù)
DatagramSocket ds = new DatagramSocket(10000);
while(true) {
// 創(chuàng)建數(shù)據(jù)包
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
// 使用接收方法將數(shù)據(jù)存儲到數(shù)據(jù)包中
ds.receive(dp); // 該方法為阻塞式的方法
// 通過數(shù)據(jù)包對象的方法解析這些數(shù)據(jù)，例如：地址、端口、數(shù)據(jù)內(nèi)容等
String ip = dp.getAddress().getHostAddress();
int port = dp.getPort();
String text = new String(dp.getData(), 0, dp.getLength());
System.out.println(ip + ":" + port + ":" + text);
}
}
}
四、創(chuàng)建聊天室
根據(jù)UDP（User Datagram Protocol， 用戶數(shù)據(jù)報協(xié)議）的相關(guān)性質(zhì)，我們可以進(jìn)一步創(chuàng)建一個簡單的基于UDP傳輸協(xié)議下的聊天室，實現(xiàn)互動聊天的功能。
/**
*創(chuàng)建UDP傳輸下的聊天室發(fā)送端
*/
package chat;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class Send implements Runnable {
private DatagramSocket ds;
public Send(DatagramSocket ds) {
this.ds = ds;
}
public void run() {
try {
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while ((line = bufr.readLine()) != null) {
byte[] buf = line.getBytes();
DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.191.255"), 10001);
ds.send(dp);
if ("886".equals(line))
break;
}
ds.close();
} catch (Exception e) {
System.out.println("對不起，發(fā)生錯誤啦！");
}
}
}
/**
*創(chuàng)建UDP傳輸下的聊天室接收端
*/
package chat;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class Rece implements Runnable {
private DatagramSocket ds;
public Rece(DatagramSocket ds) {
this.ds = ds;
}
public void run() {
try {
while (true) {
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
ds.receive(dp);
String ip = dp.getAddress().getHostAddress();
String text = new String(dp.getData(), 0, dp.getLength());
System.out.println(ip + ":::" + text);
if(text.equals("886")){
System.out.println(ip+"......退出聊天室！");
}
}
} catch (Exception e) {
System.out.println("對不起，發(fā)生錯誤啦！");
}
}
}
/**
*創(chuàng)建UDP傳輸下的聊天室
*/
package chat;
import java.io.IOException;
import java.net.DatagramSocket;
public class ChatRoom {
public static void main(String[] args) throws IOException {
DatagramSocket send = new DatagramSocket();
DatagramSocket rece = new DatagramSocket(10001);
new Thread(new Send(send)).start();
new Thread(new Rece(rece)).start();
}
}
相關(guān)文章
Java如何利用Easyexcel動態(tài)導(dǎo)出表頭列
這篇文章主要介紹了Java利用Easyexcel動態(tài)導(dǎo)出表頭列的實例,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-04-04
Java的外部類為什么不能使用private和protected進(jìn)行修飾的講解
今天小編就為大家分享一篇關(guān)于Java的外部類為什么不能使用private和protected進(jìn)行修飾的講解，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-04-04
BIO英文全名是 blocking IO,也叫做 阻塞IO,是最容易理解、最容易實現(xiàn)的IO工作方式，本文就來通過一些簡單的示例為大家講講什么是BIO吧2023-06-06
這篇文章主要介紹了Java的信號量semaphore講解,Semaphore底層是基于AbstractQueuedSynchronizer來實現(xiàn)的,Semaphore稱為計數(shù)信號量,它允許n個任務(wù)同時訪問某個資源,需要的朋友可以參考下2023-12-12
本文主要介紹了Java中集合框架的相關(guān)知識，具有很好的參考價值，下面跟著小編一起來看下吧2017-03-03
LinkedHashMap是Java中的一個Map容器,它繼承自HashMap,并且還可以對元素進(jìn)行有序存儲,本文將介紹LinkedHashMap的實現(xiàn)原理以及使用方法,并且提供相應(yīng)的測試用例和全文小結(jié),需要的可以參考下2023-09-09
這篇文章主要介紹了Java在redis中進(jìn)行對象的緩存，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03
這篇文章主要介紹了java程序中foreach用法示例,需要的朋友可以參考下2014-04-04
這篇文章主要為大家詳細(xì)介紹了Java中CountDownLatch用法，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-01-01
這篇文章主要介紹了使用springboot 打包插件去除jar包瘦身的操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-07-07