Netty+Android搭建一个简易聊天室（实现群聊和私聊）

最新推荐文章于 2024-08-15 09:47:49 发布

置顶

Koliday

最新推荐文章于 2024-08-15 09:47:49 发布

阅读量6.2k

点赞数 5

分类专栏： Netty 文章标签： netty android 聊天室

本文链接： https://blog.csdn.net/qq_41773240/article/details/82875205

版权

这篇博客介绍了如何利用Netty框架和Android技术搭建一个包含群聊和私聊功能的简易聊天室。博主首先概述了自己的学习历程，然后详细讲解了服务端的准备工作，包括开发环境、所需jar包。接着，逐步阐述了服务端的搭建，涉及实体类、编解码器、启动服务器、初始化管道等关键步骤。最后，博主提到了客户端的创建，包括ChatClient类、ChatClientInitializer类、ChatClientHandler类等。整个过程结合了具体的代码示例，适合初学者入门。

摘要由CSDN通过智能技术生成

零，前言

JRBM项目中无论是好友私聊，公开聊天室，还是比赛平台都需要用到长连接，之前没有接触过网络通信等知识，更别说框架了，因此直接上手netty确实有些困难，在前期主要是在b站上看（https://www.bilibili.com/video/av26415011）这个视频，但是一些名词根本没有接触过，看着代码也只能照着敲，根本不知道网络通信是什么原理，什么是http协议，什么是socket，什么是编解码等，于是跟着敲了几节课的代码之后准备从实际项目入手，于是看了（ https://www.bilibili.com/video/av16767113）这个聊天室的搭建，至少明白了聊天室的基本结构，然后再入手了《Netty权威指南2》，基本了解了Netty的各个组件的基本用法和基本含义，于是花了两天时间从头搭建了一个能够群聊和私聊的聊天室，仅仅代表本人的粗浅理解，也希望能帮助小白入门，大佬绕行！

一，准备工作

开发环境：android+javaweb，前端（客户端）使用android studio，后端（服务端）使用idea

所需jar包：

主要是三个：

netty的jar包，直接去官网（ https://netty.io/）下载最新即可，然后只要压缩包中的netty-all-4.1.29.Final即可

messagepack的jar包，去这个链接（ http://repo1.maven.org/maven2/org/msgpack/msgpack/0.6.12/）直接下载msgpack-0.6.12.jar

javassist的jar包，去这个链接（ https://github.com/jboss-javassist/javassist/releases）下载最新版的jar包

这三个jar包的作用是，netty负责通信的整体框架，messagepack负责消息的编码和解码，javassist在编解码中需要用到

二，服务端的搭建

创建一个web项目（也可以是javase项目），虽然我写的时候用到了spring，但是这篇文章中就不用spring来管理类了

首先看一下项目的结构，

一共三个包，Coder包放编码和解码器的类，entity包放两个实体类，一个是消息的实体类，所有消息都会被包装成这个ChatMessage类，便于读取，UserChannels用于放当前在线的用户的用户名和其channel地址，这样私聊的时候就可以通过用户名调用目标用户的channel进行消息传送，server包中的类前三个是netty创建连接通道需要用到的比较固定的类，StartServer用于启动服务器。

接下来是服务端搭建的步骤：

1.创建实体类ChatMessage

我们希望传输的数据不仅是简简单单的一个字符串，而是一个有很多信息的实体，因此我们创建一个实体模板，所有的消息都被解码包装成这个类，然后直接对这个类的对象进行读写操作即可

import org.msgpack.annotation.Index;
import org.msgpack.annotation.Message;

//消息实体，协议
@Message
public class ChatMessage {
    @Index(0)
    private String sendUser;
    @Index(1)
    private String receiveUser;
    @Index(2)
    private String message;
    @Index(3)
    private int messagetype;//1:初始化认证消息，2：聊天消息

    public ChatMessage() {
    }

    public ChatMessage(String sendUser, String receiveUser, String message, int messagetype){
        this.sendUser=sendUser;
        this.receiveUser=receiveUser;
        this.message=message;
        this.messagetype=messagetype;
    }

    public String getSendUser() {
        return sendUser;
    }

    public void setSendUser(String sendUser) {
        this.sendUser = sendUser;
    }

    public String getReceiveUser() {
        return receiveUser;
    }

    public void setReceiveUser(String receiveUser) {
        this.receiveUser = receiveUser;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public int getMessagetype() {
        return messagetype;
    }

    public void setMessagetype(int messagetype) {
        this.messagetype = messagetype;
    }

    @Override
    public String toString() {
        return "ChatMessage{" +
                "sendUser='" + sendUser + '\'' +
                ", receiveUser='" + receiveUser + '\'' +
                ", message='" + message + '\'' +
                '}';
    }
}

这个类包含了发送消息的用户、接受消息的用户、消息的内容、消息的类型，分别生成他们的get和set方法，并且为了方便调试，生成他的tostring方法。