快捷導(dǎo)航

Java網(wǎng)絡(luò)編程UDP實(shí)現(xiàn)消息發(fā)送及聊天

更新時(shí)間：2021年07月04日 11:47:07 作者：跑起來要帶風(fēng)！

這篇文章主要為大家詳細(xì)介紹了Java網(wǎng)絡(luò)編程UDP實(shí)現(xiàn)消息發(fā)送及聊天，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

TCP可以實(shí)現(xiàn)聊天，UDP也可以實(shí)現(xiàn)消息發(fā)送及聊天。不同的是，TCP需要有服務(wù)端和客戶端的連接，但UDP不需要，只需要有發(fā)送方和接收方即可。

一、實(shí)現(xiàn)消息發(fā)送

發(fā)送方：

package com.kuang.lesson03;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

//不需要連接服務(wù)器
public class UdpSenderDemo01 {
    public static void main(String[] args) throws Exception {
        //1、建議一個(gè)Socket
        DatagramSocket socket = new DatagramSocket();

        //2、建立包
        String msg = "你好啊，服務(wù)器!";
        InetAddress localhost = InetAddress.getByName("localhost");
        int port = 9090;

        //數(shù)據(jù)、數(shù)據(jù)的長度起始，要發(fā)送給誰
        DatagramPacket packet = new DatagramPacket(msg.getBytes(),0,msg.getBytes().length,localhost,port);

        //3、發(fā)送包
        socket.send(packet);

        //4、關(guān)閉流
        socket.close();
    }
}

接收方：

package com.kuang.lesson03;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

// 不是服務(wù)端，但是還是要等待客戶端的連接。
// 也就是說只有存在這個(gè)才能獲得客戶端發(fā)來的消息
public class UdpReceiveDemo01 {
    public static void main(String[] args) throws Exception {
        //開放端口
        DatagramSocket socket = new DatagramSocket(9090);

        //接收數(shù)據(jù)包
        byte[] buffer = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buffer,0,buffer.length);

        socket.receive(packet);//阻塞接收

        System.out.println(packet.getAddress().getHostAddress());
        System.out.println(new String(packet.getData(),0,packet.getLength()));

        //關(guān)閉連接
        socket.close();
    }
}

運(yùn)行結(jié)果：

1、啟動接收方開放端口，可以看到一直在運(yùn)行，也就是在等待消息發(fā)來。

2、啟動發(fā)送方，可以看到運(yùn)行結(jié)束，說明消息已發(fā)送

3、查看接收方，收到消息。

既然UDP能實(shí)現(xiàn)消息發(fā)送，那么也可以實(shí)現(xiàn)聊天。

二、實(shí)現(xiàn)聊天

發(fā)送方：

package com.kuang.chat;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;

public class UdpSenderDemo01 {
    public static void main(String[] args) throws Exception {
        DatagramSocket socket = new DatagramSocket(8888);

        //準(zhǔn)備數(shù)據(jù)，控制臺讀取System.in
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
        while (true) {
            String data = reader.readLine();
            byte[] datas = data.getBytes();
            DatagramPacket packet = new DatagramPacket(datas,0,datas.length,new InetSocketAddress("localhost",6666));

            socket.send(packet);
            if (data.equals("bye")) {
                break;
            }
        }
        socket.close();
    }
}

接收方：

package com.kuang.chat;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class UdpReceiveDemo01 {
    public static void main(String[] args) throws Exception {
        DatagramSocket socket = new DatagramSocket(6666);
        while (true) {
            //準(zhǔn)備接收數(shù)據(jù)
            byte[] container = new byte[1024];
            DatagramPacket packet = new DatagramPacket(container,0,container.length);
            socket.receive(packet);//阻塞式接受包裹

            //斷開連接 bye
            byte[] data = packet.getData();
            String receiveData = new String(data,0,data.length);

            System.out.println(receiveData);
            if (receiveData.equals("bye")) {
                break;
            }
        }
        socket.close();
    }
}

運(yùn)行結(jié)果：

1、先啟動接收方