【Qt】前后端交互---DataCenter类

news2024/11/17 15:56:05

设计目的

前后端交互系统中，创建并使用数据核心类的目的就是让该类作为客户端的数据中心，也就是说其负责管理客户端的所有数据与服务器的网络通信。

数据持久化

初始化数据文件

该函数设计的目的就是用于检查所需要的文件和目录是否存在，如果不存在创建，确保客户端和服务端的数据都是存储在同一位置上的。

void DataCenter::initDataFile()
{
    QString basePath = QStandardPaths::writableLocation(QStandardPaths::AppDataLocation);
    QString filePath = basePath + "/ChatClient.json";

    QDir dir;
    if (!dir.exists(basePath)) {
        dir.mkpath(basePath);
    }

    QFile file(filePath);
    if (!file.open(QIODevice::WriteOnly | QIODevice::Text)) {
        LOG() << "打开文件失败!" << file.errorString();
        return;
    }
    QString data = "{\n\n}";
    file.write(data.toUtf8());
    file.close();
}

加载数据文件

也就是从本地JSON文件中读取数据，将其解析为可用的对象，然后填充到内存中的数据结构中。

void DataCenter::loadDataFile()
{
    QString filePath = QStandardPaths::writableLocation(QStandardPaths::AppDataLocation) + "/ChatClient.json";
    QFileInfo fileInfo(filePath);
    if (!fileInfo.exists()) {
        initDataFile();
    }

    QFile file(filePath);
    if (!file.open(QIODevice::ReadOnly | QIODevice::Text)) {
        LOG() << "打开文件失败!" << file.errorString();
        return;
    }

    QJsonDocument jsonDoc = QJsonDocument::fromJson(file.readAll());
    if (jsonDoc.isNull()) {
        LOG() << "解析JSON文件失败！ JSON文件格式错误";
        file.close();
        return;
    }

    QJsonObject jsonObj = jsonDoc.object();
    this->loginSessionId = jsonObj["loginSessionId"].toString();

    this->unreadMessageCount->clear();
    QJsonObject jsonUnread = jsonObj["unread"].toObject();
    for (auto it = jsonUnread.begin(); it != jsonUnread.end(); ++it) {
        this->unreadMessageCount->insert(it.key(), it.value().toInt());
    }
    file.close();
}

保存数据文件

设计该方法的目的就是将当前的数据状态写回到JSON文件，从而确保数据在应用程序重启后依然可以使用。

void DataCenter::saveDataFile()
{
    QString filePath = QStandardPaths::writableLocation(QStandardPaths::AppDataLocation) + "/ChatClient.json";

    QFile file(filePath);
    if (!file.open(QIODevice::WriteOnly | QIODevice::Text)) {
        LOG() << "文件打开失败" << file.errorString();
        return;
    }

    QJsonObject jsonObj;
    jsonObj["loginSessionId"] = loginSessionId;

    QJsonObject jsonUnread;
    for (auto it = unreadMessageCount->begin(); it != unreadMessageCount->end(); ++it) {
        jsonUnread[it.key()] = it.value();
    }
    jsonObj["unread"] = jsonUnread;

    QJsonDocument jsonDoc(jsonObj);
    QString s = jsonDoc.toJson();
    file.write(s.toUtf8());

    file.close();
}

内存数据管理

用户信息管理

维护当前登录用户的信息，也就是用来保存当前登录用户的信息、好友列表等相关信息

UserInfo *DataCenter::getMyself()
{
    return myself;
}

void DataCenter::resetMyself(std::shared_ptr<bite_im::GetUserInfoRsp> resp)
{
    if (myself == nullptr) {
        myself = new UserInfo();
    }
    const bite_im::UserInfo &userInfo = resp->userInfo();
    myself->load(userInfo);
}

消息管理

负责管理最近的消息，聊天会话记录、未读信息等相关消息

// 在构造函数中初始化未读消息计数哈希表
DataCenter::DataCenter() : netClient(this)
{
    unreadMessageCount = new QHash<QString, int>();
    // 其他初始化操作
}

前后端通信

异步数据获取

通过netClient对象与服务器通信，使用异步方法来获取数据，避免阻塞线程，从而确保UI响应

void DataCenter::getMyselfAsync()
{
    netClient.getMyself(loginSessionId);
}

数据同步

服务器接收到数据后，需要更新本地的数据

void DataCenter::resetMyself(std::shared_ptr<bite_im::GetUserInfoRsp> resp)
{
    if (myself == nullptr) {
        myself = new UserInfo();
    }
    const bite_im::UserInfo &userInfo = resp->userInfo();
    myself->load(userInfo);
}