Java利用UDP实现简单群聊

这篇具有很好参考价值的文章主要介绍了Java利用UDP实现简单群聊。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、创建新项目
首先新建一个新的项目,并按如下操作

Java利用UDP实现简单群聊,java,udp,python

二、实现代码
界面ChatFrame类
package 群聊;
 
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.net.InetAddress;
 
public abstract class ChatFrame extends JFrame {
    private JTextArea receiveArea = new JTextArea();//接收文本框,用来显示服务器发送过来的文本
    private JTextArea sendArea = new JTextArea();//发送文本框,用来显示当前用户要发送的文本
 
    private JButton sendBtn = new JButton("SEND");//发送按键
 
    public ChatFrame() {
        this.initFrame();//初始化窗口
        this.initComponent();//初始化组件
        this.initListener();//初始化监听器
        this.receive();//开启监听服务器线程,把接收到的文本显示在receiveArea中
    }
 
    // 初始化监听器
    private void initListener() {
        // 给发送按键添加监听器,当被点击时调用send()方法
        sendBtn.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent evt) {
                send();
            }
        });
 
        // 给发送文本框添加键盘监听器,当按下Ctrl+ENTER时调用send()方法
        sendArea.addKeyListener(new KeyAdapter() {
            public void keyPressed(KeyEvent e) {
                if(e.isControlDown()) {
                    if(e.getKeyCode() == KeyEvent.VK_ENTER) {
                        send();
                    }
                }
            }
        });
    }
 
    // 子类需要重写本方法
    // 在本方法中使用socket实现消息发送
    public abstract void sendText(String text);
 
    // 子类需要重写本方法
    // 在本方法中启动监听服务器线程,调用本类receiveText(String)把接收到的文本显示出来
    public abstract void receive();
 
    // 本方法用来发送文本
    public void send() {
        // 如果发送文本框中没有文本,弹出警告对话框
        if(sendArea.getText().equals("")) {
            javax.swing.JOptionPane.showMessageDialog(this, "空文本不能发送!");
            sendArea.requestFocus();// 把光标归还给发送文本框
            return;
        }
 
        // 调用子类的方法完成文本发送
        sendText(sendArea.getText());
        // 把发送文本框内容清空
        sendArea.setText(null);
    }
 
    // 本方法完成接收服务器消息的后续工作-在文本框中显示服务器消息,子类的receive()方法在接收服务器消息后可以调用本方法
    public void receiveText(String text) {
        receiveArea.append(text);//把接收到的消息添加到文本框中
        // 设置光标位置到最后,如果不设置滚动条不动
        receiveArea.setCaretPosition(receiveArea.getText().length());
    }
 
    // 初始化组件
    private void initComponent() {
        // 使用接收文本框创建滚动窗口(把文本框添加到了滚动窗口中),总是显示纵向滚动条,永不显示横向滚动条
        JScrollPane sp1 = new JScrollPane(receiveArea, JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,
                JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
        // 设置滚动窗口大小、位置、无边框;并把滚动窗口添加到主窗口中
        sp1.setSize(606, 350);
        sp1.setLocation(14, 20);
        sp1.setBorder(null);
        this.add(sp1);
 
        // 设置接收文本框背景色、不可编辑、自动换行
        receiveArea.setBackground(new Color(238, 238, 238));
        receiveArea.setEditable(false);
        receiveArea.setLineWrap(true);
 
        // 创建发送文本框的滚动窗口,设置自动换行、大小、位置,然后添加到主窗口中
        JScrollPane sp2 = new JScrollPane(sendArea, JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,
                JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
        sendArea.setLineWrap(true);
        sp2.setSize(606, 145);
        sp2.setLocation(14, 400);
        this.add(sp2);
 
        // 设置发送按键的大小、位置,并添加到主窗口中
        sendBtn.setSize(68, 21);
        sendBtn.setLocation(553, 560);
        this.add(sendBtn);
 
        // 设置主窗口的标题为当前IP地址
        try {
            this.setTitle(InetAddress.getLocalHost().getHostAddress());
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
 
    // 初始化主窗口
    private void initFrame() {
        // 设置主窗口的大小、布局管理器为空、背景色、位置、大小不可改变
        this.setSize(640, 620);
        this.setLayout(null);
        this.setBackground(new Color(246, 246, 247));
        this.setLocation(350, 50);
        this.setResizable(false);
 
        // 设置主窗口的“X”按钮点击后结束程序
        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    }
 
    // 显示主窗口方法
    public void setVisible(boolean b) {
        super.setVisible(b);//调用父类的显示方法
        sendArea.requestFocus();//让发送文本框得到焦点
    }
}

组播聊天SocketChat类
package 群聊;
 
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.util.Date;
 
/**
 * 本类继承了ChatFrame,ChatFrame实现了GUI显示
 * 本类负责使用MulticastSocket完成群聊的发送消息与接收消息
 */
public class SocketChat extends ChatFrame {
    private MulticastSocket socket;//群组Socket
 
    public SocketChat() throws IOException {
        socket = new MulticastSocket(54321);//创建群组Socket,绑定54321端口
        //加入虚拟IP:235.235.235.235指定的群组中。虚拟IP范围是:224.0.0.1 和 239.255.255.255
        //加入群组后,就可以接收群组的消息,也可以向群组发送消息了
        socket.joinGroup(InetAddress.getByName("235.235.235.235"));
    }
 
    // 发送消息方法
    public void sendText(String text) {
        try {
            // 获取IP地址
            String ip = InetAddress.getLocalHost().getHostAddress();
            // 获取当前时间格式化字符串
            String time = String.format(" <====> %tF %<tT", new Date());
            // 把IP、时间,以及要发送的文本连接在一起
            text = ip + time + "\n" + text + "\n\n";
            // 把文本转换成字节数组
            byte[] buff = text.getBytes();
            // 使用socket向群组发送,socket的send()方法需要两个参数:DatagramPacket、端口号
            // DatagramPacket表示数据包,创建它需要三个参数:数据包的内容、数据包的字节数、要发送的IP地址
            socket.send(new DatagramPacket(buff, buff.length, InetAddress.getByName("235.235.235.235"), 54321));
        } catch(Exception e) {
            e.printStackTrace();
        }
    }
 
    // 本方法用来接收群组发送过来的消息
    public void receive() {
        // 创建监听群组消息的线程,并启动它
        new Thread() {
            public void run() {
                // 循环监听
                while(true) {
                    try {
                        // 创建数据包的字节数组,大小为1KB
                        byte[] buff = new byte[1024];
                        // 创建数据包
                        DatagramPacket dp = new DatagramPacket(buff, buff.length);
                        // 接收群组发送过来的消息到数据包中
                        // 本方法会阻塞当前线程,直到接收到消息为止
                        socket.receive(dp);
                        // 把接收到的消息转换成字符串
                        String text = new String(dp.getData(), 0, dp.getLength());
                        // 调用父类的方法完成显示
                        receiveText(text);
                    } catch(Exception e) {}
                }
            }
        }.start();
    }
 
    public static void main(String[] args) throws IOException {
        SocketChat sc = new SocketChat();
        sc.setVisible(true);
    }
}

三、运行结果

Java利用UDP实现简单群聊,java,udp,python
运行的第一个窗口成员1

第二个窗口为成员2

第三个窗口为成员3

由此可见、新建窗口=添加成员
————————————————
版权声明:本文为CSDN博主「Mr.寒风」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/2301_76534800/article/details/134838262文章来源地址https://www.toymoban.com/news/detail-759744.html

到了这里,关于Java利用UDP实现简单群聊的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【网络编程】利用套接字实现一个简单的网络通信(UDP实现聊天室 附上源码)

    源IP地址(Source IP Address): 源IP地址是数据包发送方(或数据流出发点)的唯一标识符。它用于在互联网或本地网络中定位发送数据包的设备或主机。源IP地址是数据包的出发点,即数据从这个地址开始传送,向目的IP地址指示的设备发送。 在TCP/IP协议中,源IP地址通常由发

    2024年02月14日
    浏览(86)
  • JavaEE 初阶篇-深入了解 UDP 通信与 TCP 通信(综合案例:实现 TCP 通信群聊)

    🔥博客主页: 【 小扳_-CSDN博客】 ❤感谢大家点赞👍收藏⭐评论✍ 文章目录         1.0 UDP 通信         1.1 DatagramSocket 类         1.2 DatagramPacket 类         1.3 实现 UDP 通信(一发一收)         1.3.1 客户端的开发         1.3.2 服务端的开发         1.4 实

    2024年04月26日
    浏览(43)
  • UDP群聊

    package UDP; import java.awt.*; import java.awt.event.*; import javax.swing.*; import java.net.*; import java.io.IOException; import java.lang.String;   public class lt extends JFrame{     private static final int DEFAULT_PORT=8899;     private JLabel stateLB;     private JTextArea centerTextArea;     private JPanel southPanel;     private JT

    2024年02月04日
    浏览(30)
  • 【Java】实现UDP通信

    🎈博客主页:🌈我的主页🌈 🎈欢迎点赞 👍 收藏 🌟留言 📝 欢迎讨论!👏 🎈本文由 【泠青沼~】 原创,首发于 CSDN🚩🚩🚩 🎈由于博主是在学小白一枚,难免会有错误,有任何问题欢迎评论区留言指出,感激不尽!🌠个人主页 TCP —传输控制协议,提供的是面向连接、

    2024年02月07日
    浏览(40)
  • 什么是 TCP 和 UDP?Java 中如何实现 TCP 和 UDP 协议

    在计算机网络中,TCP(传输控制协议)和UDP(用户数据报协议)是两种最常用的传输层协议。它们都用于在网络上传输数据,但是它们之间有很多不同之处。本文将介绍TCP和UDP的基本概念,以及在Java中如何实现TCP和UDP协议。 TCP和UDP都是传输层协议,用于在网络上传输数据。

    2024年02月16日
    浏览(102)
  • java实现UDP及TCP通信

    简介 UDP (User Datagram Protocol)用户数据报协议, TCP (Transmission Control Protocol) 传输控制协议,是传输层的两个重要协议。 UDP是一种 无连接、不可靠 传输的协议。其将数据源IP、目的地IP和端口封装成数据包,不需要建立连接,每个数据包的大小限制在64KB内;发送不管对方是否准

    2024年02月03日
    浏览(46)
  • 使用Java服务器实现UDP消息的发送和接收(多线程)

    在本篇博客中,我们将介绍如何使用Java服务器来实现UDP消息的发送和接收,并通过多线程的方式来处理并发请求。UDP(User Datagram Protocol)是一种无连接、不可靠的传输协议,适合于实时性要求高的应用场景,如实时游戏、语音通信等。 步骤: 首先,我们需要导入Java提供的

    2024年02月12日
    浏览(47)
  • Java实现socket通信详解(UDP/TCP)c/s模式

    在实现具体代码前,我们先来简单了解下TCP/UDP协议 TCP在OSI模型中位于传输层在网络层之上,故在端到端传输的基础上将数据以端口号等标识实现进程/终端设备应用的区分, 将数据精准的传达。 TCP全称为传输控制协议具有以下特点: 面向有连接的服务可靠的数据传输,即在

    2023年04月08日
    浏览(37)
  • 【Java网络编程】基于UDP-Socket 实现客户端、服务器通信

    ​ 哈喽,大家好~我是你们的老朋友: 保护小周ღ   本期为大家带来的是网络编程的 UDP Socket 套接字,基于 UDP协议的 Socket 实现客户端服务器通信 ,Socket 套接字可以理解为是,传输层给应用层提供的一组 API,如此程序,确定不来看看嘛~~ 本期收录于博主的专栏 : JavaEE_保

    2024年02月02日
    浏览(71)
  • 【MFC】实现简单UDP通信

    创建一个基于对话框的MFC项目(名称为UDP),高级功能选中Windows套接字 这个时候在CUDP类的InitInstance()方法中就会出现这样的代码用来初始化套接字 如果没有选中,手动添加也是可以的。 控件ID 关联变量名 类型 作用 IDC_EDIT1 m_edit CEdit 显示接收到的信息 IDC_EDIT2 m_msg CString 保存

    2024年02月09日
    浏览(38)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包