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ù)器，比較麻煩。為了克服以上的缺點，我們可以對其進行優(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ì)，我們可以進一步創(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)文章
本文主要介紹了SpringBoot?Cache?二級緩存的使用，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-06-06
Spring Boot 中的 Spring Cloud Feign的原
Spring Cloud Feign 是 Spring Cloud 中的一個組件，它可以幫助我們實現(xiàn)聲明式的 REST 客戶，這篇文章主要介紹了Spring Boot 中的 Spring Cloud Feign,需要的朋友可以參考下2023-07-07
這篇文章主要為大家詳細介紹了Java實現(xiàn)郵件發(fā)送QQ郵箱帶附件功能，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2020-03-03
今天小編就為大家分享一篇關(guān)于Java內(nèi)部類及其特點的講解，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-01-01
SpringBoot整合Groovy腳本實現(xiàn)動態(tài)編程詳解
這篇文章主要為大家介紹了SpringBoot整合Groovy腳本實現(xiàn)動態(tài)編程詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-09-09
首先說一下思路，防止這種類似于注入攻擊，就是使用攔截器（Filter）處理特殊字符或過濾特殊字符 今天介紹一個方法，利用覆蓋Servlet的getParameter方法達到處理特殊字符的目的來解決（防止）Xss攻擊 web.xml,需要的朋友可以參考下2020-02-02
這篇文章主要介紹了Java中泛型使用實例詳解的相關(guān)資料,需要的朋友可以參考下2017-05-05
淺談Ribbon、Feign和OpenFeign的區(qū)別
這篇文章主要介紹了淺談Ribbon、Feign和OpenFeign的區(qū)別。具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-06-06
本文主要介紹了java?動態(tài)線程池的簡單實現(xiàn)思路，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-06-06
這篇文章主要介紹了idea插件在線和離線安裝方法,文末補充介紹了IntelliJ IDEA 安裝mybaits當前運行sql日志插件在線與離線安裝方法2023-12-12
,感興趣的朋友一起看看吧