Java如何模擬UDP通信

這篇文章主要為大家展示了Java如何模擬UDP通信，內(nèi)容簡(jiǎn)而易懂，希望大家可以學(xué)習(xí)一下，學(xué)習(xí)完之后肯定會(huì)有收獲的，下面讓小編帶大家一起來(lái)看看吧。

專注于為中小企業(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)健成長(zhǎng)，幫助中小企業(yè)通過(guò)網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

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;

        /*
		通過(guò)UDP發(fā)送消息，需要通過(guò) 包 來(lái)發(fā)送，--> DatagramPacket()，該方法有多種重載形式，以下使用參數(shù)列表最多的那個(gè)
		參數(shù)：
		- 要發(fā)送的 消息 的字節(jié)數(shù)組 
		- 從字節(jié)數(shù)組的哪個(gè)位置開始發(fā)送
		- 發(fā)送的長(zhǎng)度
		- 對(duì)方的 IP地址
		- 對(duì)方的端口號(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ù)組來(lái)接收數(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來(lái)接收
        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];
            // 用來(lái)接收數(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è)線程，并對(duì)以上代碼進(jìn)行【共性提取】，進(jìn)一步進(jìn)行抽象。

由此，雙方可以通過(guò)指定的端口來(lái)互相發(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;
    // 對(duì)方的 IP
    private String toIP;
    // 對(duì)方的端口
    private int toPort;
    // 通過(guò)構(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ā)送方是誰(shuí)
    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();

    }

}

以上就是關(guān)于Java如何模擬UDP通信的內(nèi)容，如果你們有學(xué)習(xí)到知識(shí)或者技能，可以把它分享出去讓更多的人看到。

分享名稱：Java如何模擬UDP通信
URL鏈接：http://bm7419.com/article46/jdsdhg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站策劃、面包屑導(dǎo)航、電子商務(wù)、品牌網(wǎng)站建設(shè)、手機(jī)網(wǎng)站建設(shè)、App開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)

外貿(mào)網(wǎng)站制作