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

设计目的

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

数据持久化

初始化数据文件

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

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);
}