(七)如何实现即时通信系统中用户的文字聊天功能？

news2025/2/24 15:17:21

文章目录

一、引言
二、实现用户文字功能
- 2.1 使用QTextEdit控件实现用户输入文字消息
- 2.2 实现文字消息的发送和接收
- 2.3 实现文字消息的展示和管理
三、解码接收到的文字消息
- 3.1 接收数据并解码
- 3.2 在客户端展示文字消息
- 3.3 客户端关键代码展示
- 3.4 服务端关键代码展示
四、效果展示
五、个人经验分享
- 5.1 经验和总结
- 5.2 遇到的问题和解决方案
六、结语

一、引言

在现代社交交流中，文字聊天成为了人们互动交流的一种基本方式，即时通信系统也是如此。为了满足用户的文字聊天需求，实现稳定高效的文字消息传输至关重要。本文旨在介绍即时通信系统中用户文字功能的重要性和应用场景，同时简述使用TCP连接传输用户文字消息的基本原理。

二、实现用户文字功能

2.1 使用QTextEdit控件实现用户输入文字消息

用户可以使用QTextEdit控件在客户端输入文字消息。该控件是一个多行文本编辑器，具有设置文本颜色、字体、粗体、斜体等格式的功能，可以满足用户的文本编辑需求。

2.2 实现文字消息的发送和接收

用户输入文字消息后，需要通过TCP连接将消息发送给服务端。服务端收到消息后，可以将其转发给指定的用户。

在客户端，可以通过连接QTextEdit的文本改变信号，获取用户输入的消息。发送按钮的槽函数可以将消息打包成JSON格式，通过QTcpSocket发送给服务端。客户端也需要实现onReadyRead()槽函数，用于接收服务端发送的文字消息。接收到消息后，客户端可以将消息打包成QListWidgetItem，并插入到聊天记录列表中。

2.3 实现文字消息的展示和管理

客户端可以使用QListWidget控件实现文字消息的展示和管理。该控件可以展示多个列表项，每个列表项可以包含多个控件，可以自定义控件来展示不同类型的消息。在本例中，可以创建一个自定义控件，将其包含在QListWidgetItem中，用于展示消息发送者的头像、昵称和消息内容。当接收到一条新的消息时，客户端可以将其打包成QListWidgetItem，插入到聊天记录列表中。

三、解码接收到的文字消息

3.1 接收数据并解码

在客户端中，通过 QTcpSocket 类的 onReadyRead() 信号来接收从服务器传来的数据。
接收到数据后，通过 QJsonDocument 类将数据解析为 JSON 对象。
从 JSON 对象中获取消息的类型，如果是文字消息，则从中获取发件人 ID、时间戳、文字内容等信息。
解析获取到的内容，保存到消息列表中等待展示。

3.2 在客户端展示文字消息

使用自定义的类实现聊天框，该类继承自 QWidget 类。

通过 QListWidget 控件来展示聊天记录，每一条消息都显示在一个聊天气泡中。

在接收到文字消息后，创建一个新的聊天气泡，并将消息内容添加到其中。

在聊天气泡中添加时间戳和消息发件人的头像，以及对气泡的样式设置。

将聊天气泡添加到 QListWidget 控件中，展示出来。

3.3 客户端关键代码展示

// 给服务端发送数据
void chatBox::send_Message_Server(QString message) {
    qDebug() << "给服务端发消息 tcpSocket:" << socket;
    json["Type"] = "message";
    json["from"] = meId;
    json["nikeName"]=userNikeName;
    json["to"] = myFriendId;
    json["content"] = message;
    qDebug() << "from:" << meId
             <<"to:" << myFriendId
            <<"content:" << message;
    QJsonDocument doc(json);
    QByteArray data = doc.toJson();
    socket->write(data);
}

3.4 服务端关键代码展示

// 用户是否在线
void message::sendDataToClient(QHash<QString, QTcpSocket*> userHash,QJsonObject jsonObj){
    bool isUserOnline=true; // 假设用户在线
    QString to=jsonObj["to"].toString();
    for (auto iter = userHash.constBegin(); iter != userHash.constEnd(); ++iter) {
        if (iter.key() == to) { // 如果 to 与当前遍历的 userID 相等
            isUserOnline=false;
            QTcpSocket *socket = iter.value(); // 获取对应的 socket
            // 在这里可以向 socket 写入数据
            qDebug() << "已经找到该用户";
            // 构建QByteArray格式数据
            QJsonDocument document;
            document.setObject(jsonObj);
            QByteArray jsonData = document.toJson(QJsonDocument::Compact);
            socket->write(jsonData);
            break; // 如果找到了对应的 userID，可以直接跳出循环
        }
    }
    // 用户不在线
    if(isUserOnline){
        SavemessageDataBase(jsonObj); // 调用相应的函数给数据库中插入数据
    }
}