Java基于UDP协议的聊天室功能

2024-04-02 19:04:59 221人浏览泡泡鱼

Python 官方文档：入门教程 => 点击学习

摘要

UDP简述 UDP（User Datagram Protocol）协议是Internet 协议集支持的一个无连接的传输协议，中文名为用户数据报协议。它为应用程序提供了一种无需建立连接

UDP简述

UDP（User Datagram Protocol）协议是Internet 协议集支持的一个无连接的传输协议，中文名为用户数据报协议。它为应用程序提供了一种无需建立连接就可以发送封装的 IP 数据报的方法。

Internet 的传输层有两个主要协议，互为补充。无连接的是 UDP，它除了给应用程序发送数据包功能并允许它们在所需的层次上架构自己的协议之外，几乎没有做什么特别的事情。面向连接的是TCP，该协议几乎做了所有的事情。“when in trouble ， use tcp”。

那么今天讲讲如何使用UDP协议构建一个简单的小型聊天室。ChatA先发起聊天，然后ChatB才能在控制台输入聊天内容。如果想结束聊天可以输入over，当一方结束聊天，另一方也将结束聊天。

ChatA类(客户端A)：

代码展示如下：

package my.demo;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
import java.util.Scanner;

//客户端A
public class ChatA {
    public static void main(String[] args) {
        //控制台输入
        Scanner input = new Scanner(System.in);
        
        // 创建基于UDP协议的DatagramSocket对象
        // 客户端A监听8888端口
        try (DatagramSocket socket = new DatagramSocket(8888)) {
            //封装成DatagramPacket对象(数据包)
            DatagramPacket sendPacket = new DatagramPacket(
                    new byte[1024],
                    1024,
                    new InetSocketAddress("192.168.254.105", 7777));//对方的IP地址和端口号
            DatagramPacket receivePacket = new DatagramPacket(new byte[1024], 1024);
            while (true) {
                // 发送数据包
                System.out.print("【客户端A】（你）说: ");
                String sendContent = input.nextLine();
                sendPacket.setData(sendContent.getBytes());
                socket.send(sendPacket);
                if (sendContent.equals("over")) {
                    System.out.println("你退出了聊天......");
                    break;
                }
                // 接收数据包
                socket.receive(receivePacket);
                String receiveContent = new String(
                        receivePacket.getData(),   //数据
                        receivePacket.getOffset(), //读取位置
                        receivePacket.getLength());//长度
                if (receiveContent.equals("over")) {
                    System.out.println("对方退出了聊天......");
                    break;
                }
                System.out.println("【客户端B】（他）说: " + receiveContent);
            }
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

ChatB类(客户端B)：

代码展示如下：

package my.demo;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
import java.util.Scanner;

//客户端B
public class ChatB {
    public static void main(String[] args) {
        // 控制台输入
        Scanner input = new Scanner(System.in);

        try (// 客户端B监听7777端口
                DatagramSocket socket = new DatagramSocket(7777)) {
            // 封装成DatagramPacket对象(数据包)
            DatagramPacket sendPacket = new DatagramPacket(new byte[1024], 1024,
                    new InetSocketAddress("192.168.254.105", 8888));// 对方的IP地址和端口号
            DatagramPacket receivePacket = new DatagramPacket(new byte[1024], 1024);

            while (true) {
                // 接收数据包
                socket.receive(receivePacket);
                String receiveContent = new String(receivePacket.getData(), receivePacket.getOffset(),
                        receivePacket.getLength());
                if (receiveContent.equals("over")) {
                    System.out.println("对方退出了聊天......");
                    break;
                }
                System.out.println("【客户端A】（他）说: " + receiveContent);

                // 发送数据包
                System.out.print("【客户端B】（你）说: ");
                String sendContent = input.nextLine();
                sendPacket.setData(sendContent.getBytes());
                socket.send(sendPacket);
                if (sendContent.equals("over")) {
                    System.out.println("你退出了聊天......");
                    break;
                }
            }
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

运行结果展示：

1.运行ChatA和ChatB（不分先后顺序）