java實(shí)現(xiàn)基于UDP協(xié)議的聊天小程序操作

更新時間：2021年10月25日 11:35:18 作者：皇正經(jīng)

UDP是與TCP相對應(yīng)的協(xié)議，UDP適用于一次只傳送少量數(shù)據(jù)、對可靠性要求不高的應(yīng)用環(huán)境。正因?yàn)閁DP協(xié)議沒有連接的過程，所以它的通信效率高；但也正因?yàn)槿绱耍目煽啃圆蝗鏣CP協(xié)議高，本文給大家介紹java實(shí)現(xiàn)基于UDP協(xié)議的聊天小程序操作，感興趣的朋友一起看看吧

UDP（User Data Protocol，用戶數(shù)據(jù)報(bào)協(xié)議）是與TCP相對應(yīng)的協(xié)議。它是面向非連接的協(xié)議，它不與對方建立連接，而是直接就把數(shù)據(jù)包發(fā)送過去！

UDP適用于一次只傳送少量數(shù)據(jù)、對可靠性要求不高的應(yīng)用環(huán)境。正因?yàn)閁DP協(xié)議沒有連接的過程，所以它的通信效率高；但也正因?yàn)槿绱?，它的可靠性不如TCP協(xié)議高。QQ就使用UDP發(fā)消息，因此有時會出現(xiàn)收不到消息的情況。

利用UDP協(xié)議的發(fā)送和接收,模擬聊天小程序

創(chuàng)建聊天程序的A端：

        1、發(fā)送信息到接收端
                1 、準(zhǔn)備發(fā)送的信息【鍵盤錄入】
                2 、指定接受端的 ip
                3 、指定接收端的端口
                4 、打包【創(chuàng)建 DatagramPacket 的對象】
                5 、發(fā)送【創(chuàng)建 DatagramSocket 的對象】
        2、接收接收回復(fù)的信息
                1 、準(zhǔn)備接收使用字節(jié)數(shù)組
                2 、把數(shù)組封裝為數(shù)據(jù)報(bào)包【創(chuàng)建 DatagramPacket 的對象】
                3 、接收數(shù)據(jù)
                4 、解析報(bào)包有效數(shù)據(jù)
                3 、上述操作循環(huán)操作

創(chuàng)建聊天程序的B端：

        1、接收發(fā)送端的信息
                1 、準(zhǔn)備接收使用字節(jié)數(shù)組
                2 、把數(shù)組封裝為數(shù)據(jù)報(bào)包【創(chuàng)建 DatagramPacket 的對象】
                3 、接收數(shù)據(jù)【創(chuàng)建 DatagramSocket 的對象】
                4 、解析報(bào)包有效數(shù)據(jù)
        2、回復(fù)發(fā)送端的信息
                1 、準(zhǔn)備發(fā)送的信息【鍵盤錄入】
                2 、指定發(fā)送的 ip 【解析接收的報(bào)包的 ip 即可】
                3 、指定接收端的端口【解析接收的報(bào)包的端口即可】
                4 、打包【創(chuàng)建 DatagramPacket 的對象】
                5 、發(fā)送
        3、上述操作循環(huán)操作

端口一：

package com.offcn.second;
 
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;
 
public class MyQQ {
    public static void main(String[] args) throws Exception{
        DatagramSocket ds = new DatagramSocket();
        Scanner sc= new Scanner(System.in);
        while(true){
            //發(fā)送消息
            System.out.print("My:");
            //輸入發(fā)送信息
            String smsg = sc.nextLine();
            //byte[] sbs = smsg.getBytes();
            //int slen = sbs.length;
            //創(chuàng)建數(shù)據(jù)包
            DatagramPacket sdp = new DatagramPacket(smsg.getBytes(),//數(shù)據(jù)轉(zhuǎn)為byte數(shù)組
                    smsg.getBytes().length,//數(shù)據(jù)長度
                    InetAddress.getLocalHost(),//接收端端口號
                    9999);//接收端，端口號
            //發(fā)送
            ds.send(sdp);
            //接收消息
            //創(chuàng)建接收數(shù)據(jù)的數(shù)據(jù)包
            DatagramPacket rdp = new DatagramPacket(new byte[1024],1024);
            //接收數(shù)據(jù)
            ds.receive(rdp);
            //將接收的數(shù)據(jù)轉(zhuǎn)為字符串
            String rmsg = new String(rdp.getData(),0,rdp.getLength());
            //打印輸出
            System.out.println("His:"+rmsg);
 
 
 
        }
    }
}

端口二：

package com.offcn.second;
 
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.util.Scanner;
 
public class HisQQ {
    public static void main(String[] args) throws Exception{
        DatagramSocket ds = new DatagramSocket(9999);
        Scanner sc = new Scanner(System.in);
        while(true){
            //創(chuàng)建接收數(shù)據(jù)的數(shù)據(jù)包
            DatagramPacket rdp = new DatagramPacket(new byte[1024],1024);
            ds.receive(rdp);
            //將接收的數(shù)據(jù)轉(zhuǎn)換為字符串
            String rmsg = new String(rdp.getData(),0,rdp.getLength());
            //輸出接收到的信息
            System.out.println("His:"+rmsg);
 
 
            //給對方回消息
            //輸入發(fā)送的數(shù)據(jù)
            System.out.print("My:");
            String smsg = sc.nextLine();
            //創(chuàng)建發(fā)送數(shù)據(jù)的數(shù)據(jù)包
            DatagramPacket sdp = new DatagramPacket(smsg.getBytes(),
                    smsg.getBytes().length,
                    rdp.getAddress(),
                    rdp.getPort());
            ds.send(sdp);
        }
    }
}

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