脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java聊天室功能

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

 更新时间：2022年09月16日 17:20:05   作者：一只码农菜汪  
这篇文章主要为大家详细介绍了Java基于UDP协议的聊天室功能，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

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（不分先后顺序）

2. ChatA先发起聊天：

在控制台输入：你好

ChatB显示内容：

3. ChatB向ChatA发起聊天：

ChatA显示内容：

4. 输入over结束聊天：

ChatA：

ChatB：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • 如何使用Bean Validation 解决业务中参数校验

    如何使用Bean Validation 解决业务中参数校验

    这篇文章主要介绍了如何使用Bean Validation 解决业务中参数校验操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-07-07
  • 详解springboot中的jar包部署步骤

    详解springboot中的jar包部署步骤

    这篇文章主要介绍了springboot中的jar包部署步骤及linux中部署项目常用指令，需要的朋友可以参考下
    2018-07-07
  • java实现打砖块小游戏

    java实现打砖块小游戏

    这篇文章主要为大家详细介绍了java实现打砖块小游戏，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2020-05-05
  • java 图片与base64相互转化的示例

    java 图片与base64相互转化的示例

    这篇文章主要介绍了java 图片与base64相互转化的示例，帮助大家更好的理解和使用Java，感兴趣的朋友可以了解下
    2020-10-10
  • springboot vue测试平台接口定义前后端新增功能实现

    springboot vue测试平台接口定义前后端新增功能实现

    这篇文章主要介绍了springboot vue测试平台接口定义前后端新增功能实现,有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-05-05
  • Spring MVC 简单的hello world的实现

    Spring MVC 简单的hello world的实现

    这篇文章主要介绍了Spring MVC 简单的hello world的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-01-01
  • 详解java JDK 动态代理类分析(java.lang.reflect.Proxy)

    详解java JDK 动态代理类分析(java.lang.reflect.Proxy)

    这篇文章主要介绍了详解java JDK 动态代理类分析(java.lang.reflect.Proxy)的相关资料,需要的朋友可以参考下
    2017-06-06
  • Java中常用的设计模式之工厂模式详解

    Java中常用的设计模式之工厂模式详解

    这篇文章主要为大家详细介绍了Java中常用的设计模式之工厂模式，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
    2022-02-02
  • ShardingSphere数据分片算法及测试实战

    ShardingSphere数据分片算法及测试实战

    这篇文章主要为大家介绍了ShardingSphere数据分片算法及测试实战示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-03-03
  • 5种java排序算法汇总工具类

    5种java排序算法汇总工具类

    这篇文章主要总结了java的快速排序，希尔排序，插入排序，堆排序，归并排序五种排序算法，感兴趣的小伙伴们可以参考一下
    2016-08-08

最新评论