TeamTalk消息服务器（群组相关）

2024-08-31 23:36
文章标签 服务器 相关 消息 teamtalk 群组

本文主要是介绍TeamTalk消息服务器（群组相关），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

具体的流程如下介绍，后续需要着重研究数据库相关表的结构设计。

群组信令和协议设计

enum GroupCmdID {CID_GROUP_NORMAL_LIST_REQUEST = 1025,CID_GROUP_NORMAL_LIST_RESPONSE = 1026,CID_GROUP_INFO_REQUEST = 1027,CID_GROUP_INFO_RESPONSE = 1028,// ...... 暂时省略无关信令
};message IMNormalGroupListReq{//cmd id:			0x0401required uint32 user_id = 1;optional bytes attach_data = 20;
}message IMNormalGroupListRsp{//cmd id:			0x0402required uint32 user_id = 1;repeated IM.BaseDefine.GroupVersionInfo group_version_list = 2;optional bytes attach_data = 20;
}message GroupVersionInfo{required uint32 group_id = 1;required uint32 version = 2; // 不同级别的群？？	
}message IMGroupInfoListReq{//cmd id:			0x0403required uint32 user_id = 1; // 用户IDrepeated IM.BaseDefine.GroupVersionInfo group_version_list = 2; // 群ID列表optional bytes attach_data = 20;
}message IMGroupInfoListRsp{//cmd id:			0x0404required uint32 user_id = 1;repeated IM.BaseDefine.GroupInfo group_info_list = 2;optional bytes attach_data = 20;
}message GroupInfo{required uint32 group_id = 1;required uint32 version = 2;required string group_name = 3;required string group_avatar = 4;required uint32 group_creator_id = 5;required GroupType group_type = 6;required uint32 shield_status = 7;		//1: shield  0: not shield repeated uint32 group_member_list = 8;
}

请求用户群组ID

流程图

请添加图片描述

具体代码逻辑

db_proxy_server 收到 CID_GROUP_NORMAL_LIST_REQUEST后调用 DB_PROXY::getNormalGroupList 函数
主要就是读取用户ID所在群的ID列表

// group
m_handler_map.insert(make_pair(uint32_t(CID_GROUP_NORMAL_LIST_REQUEST), DB_PROXY::getNormalGroupList));/***  获取正式群列表**  @param pPdu      收到的packet包指针*  @param conn_uuid 该包过来的socket 描述符*/
void getNormalGroupList(CImPdu* pPdu, uint32_t conn_uuid)
{IM::Group::IMNormalGroupListReq msg;IM::Group::IMNormalGroupListRsp msgResp;if(msg.ParseFromArray(pPdu->GetBodyData(), pPdu->GetBodyLength())){CImPdu* pPduRes = new CImPdu;uint32_t nUserId = msg.user_id();list<IM::BaseDefine::GroupVersionInfo> lsGroup;// 关键函数CGroupModel::getInstance()->getUserGroup(nUserId, lsGroup, IM::BaseDefine::GROUP_TYPE_NORMAL);msgResp.set_user_id(nUserId);for(auto it=lsGroup.begin(); it!=lsGroup.end(); ++it){IM::BaseDefine::GroupVersionInfo* pGroupVersion = msgResp.add_group_version_list();pGroupVersion->set_group_id(it->group_id());pGroupVersion->set_version(it->version());}log("getNormalGroupList. userId=%u, count=%d", nUserId, msgResp.group_version_list_size());msgResp.set_attach_data(msg.attach_data());pPduRes->SetPBMsg(&msgResp);pPduRes->SetSeqNum(pPdu->GetSeqNum());pPduRes->SetServiceId(IM::BaseDefine::SID_GROUP);pPduRes->SetCommandId(IM::BaseDefine::CID_GROUP_NORMAL_LIST_RESPONSE);CProxyConn::AddResponsePdu(conn_uuid, pPduRes);}else{log("parse pb failed");}
}void CGroupModel::getUserGroup(uint32_t nUserId, list<IM::BaseDefine::GroupVersionInfo>& lsGroup, uint32_t nGroupType)
{list<uint32_t> lsGroupId;getUserGroupIds(nUserId, lsGroupId,0);if(lsGroupId.size() != 0){getGroupVersion(lsGroupId, lsGroup, nGroupType);}
}void CGroupModel::getUserGroupIds(uint32_t nUserId, list<uint32_t>& lsGroupId, uint32_t nLimited)
{CDBManager* pDBManager = CDBManager::getInstance();CDBConn* pDBConn = pDBManager->GetDBConn("teamtalk_slave");if(pDBConn){string strSql ;if (nLimited != 0) {strSql = "select groupId from IMGroupMember where userId=" + int2string(nUserId) + " and status = 0 order by updated desc, id desc limit " + int2string(nLimited);}else{strSql = "select groupId from IMGroupMember where userId=" + int2string(nUserId) + " and status = 0 order by updated desc, id desc";}CResultSet* pResultSet = pDBConn->ExecuteQuery(strSql.c_str());if(pResultSet){while(pResultSet->Next()){uint32_t nGroupId = pResultSet->GetInt("groupId");lsGroupId.push_back(nGroupId);}delete pResultSet;}else{log("no result set for sql:%s", strSql.c_str());}pDBManager->RelDBConn(pDBConn);}else{log("no db connection for teamtalk_slave");}
}

请求用户群组具体信息

流程图

请添加图片描述

具体代码逻辑

DB_PROXY::getGroupInfo函数主要做：

  1. 解析user_id，解析群ID列表
  2. 根据群ID 通过 redis 缓存查找读取群成员列表
  3. 根据群ID通过数据库查找IMGroup 表获取对应群的详细信息
  4. 组包群信息以及群成员列表
// group
m_handler_map.insert(make_pair(uint32_t(CID_GROUP_INFO_REQUEST), DB_PROXY::getGroupInfo));/***  获取群信息**  @param pPdu      收到的packet包指针*  @param conn_uuid 该包过来的socket 描述符*/
void getGroupInfo(CImPdu* pPdu, uint32_t conn_uuid)
{IM::Group::IMGroupInfoListReq msg;IM::Group::IMGroupInfoListRsp msgResp;if(msg.ParseFromArray(pPdu->GetBodyData(), pPdu->GetBodyLength())){CImPdu* pPduRes = new CImPdu;uint32_t nUserId = msg.user_id();uint32_t nGroupCnt = msg.group_version_list_size();map<uint32_t, IM::BaseDefine::GroupVersionInfo> mapGroupId;for(uint32_t i=0; i<nGroupCnt; ++i){IM::BaseDefine::GroupVersionInfo groupInfo = msg.group_version_list(i);// redisif(CGroupModel::getInstance()->isValidateGroupId(groupInfo.group_id())){mapGroupId[groupInfo.group_id()] = groupInfo;}}list<IM::BaseDefine::GroupInfo> lsGroupInfo;CGroupModel::getInstance()->getGroupInfo(mapGroupId, lsGroupInfo);msgResp.set_user_id(nUserId);for(auto it=lsGroupInfo.begin(); it!=lsGroupInfo.end(); ++it){IM::BaseDefine::GroupInfo* pGroupInfo = msgResp.add_group_info_list();pGroupInfo->set_group_id(it->group_id());pGroupInfo->set_version(it->version());pGroupInfo->set_group_name(it->group_name());pGroupInfo->set_group_avatar(it->group_avatar());pGroupInfo->set_group_creator_id(it->group_creator_id());pGroupInfo->set_group_type(it->group_type());pGroupInfo->set_shield_status(it->shield_status());uint32_t nGroupMemberCnt = it->group_member_list_size();for (uint32_t i=0; i<nGroupMemberCnt; ++i) {uint32_t userId = it->group_member_list(i);pGroupInfo->add_group_member_list(userId);}}log("userId=%u, requestCount=%u", nUserId, nGroupCnt);msgResp.set_attach_data(msg.attach_data());pPduRes->SetPBMsg(&msgResp);pPduRes->SetSeqNum(pPdu->GetSeqNum());pPduRes->SetServiceId(IM::BaseDefine::SID_GROUP);pPduRes->SetCommandId(IM::BaseDefine::CID_GROUP_INFO_RESPONSE);CProxyConn::AddResponsePdu(conn_uuid, pPduRes);}else{log("parse pb failed");}
}// redis
bool CGroupModel::isValidateGroupId(uint32_t nGroupId)
{bool bRet = false;CacheManager* pCacheManager = CacheManager::getInstance();CacheConn* pCacheConn = pCacheManager->GetCacheConn("group_member");if(pCacheConn){string strKey = "group_member_"+int2string(nGroupId);bRet = pCacheConn->isExists(strKey);pCacheManager->RelCacheConn(pCacheConn);}return bRet;
}// mysql
void CGroupModel::getGroupInfo(map<uint32_t,IM::BaseDefine::GroupVersionInfo>& mapGroupId, list<IM::BaseDefine::GroupInfo>& lsGroupInfo)
{ if (!mapGroupId.empty()){CDBManager* pDBManager = CDBManager::getInstance();CDBConn* pDBConn = pDBManager->GetDBConn("teamtalk_slave");if (pDBConn){string strClause;bool bFirst = true;for(auto it=mapGroupId.begin(); it!=mapGroupId.end(); ++it){if(bFirst){bFirst = false;strClause = int2string(it->first);}else{strClause += ("," + int2string(it->first));}}string strSql = "select * from IMGroup where id in (" + strClause  + ") order by updated desc";CResultSet* pResultSet = pDBConn->ExecuteQuery(strSql.c_str());if(pResultSet){while (pResultSet->Next()) {uint32_t nGroupId = pResultSet->GetInt("id");uint32_t nVersion = pResultSet->GetInt("version");if(mapGroupId[nGroupId].version() < nVersion){IM::BaseDefine::GroupInfo cGroupInfo;cGroupInfo.set_group_id(nGroupId);cGroupInfo.set_version(nVersion);cGroupInfo.set_group_name(pResultSet->GetString("name"));cGroupInfo.set_group_avatar(pResultSet->GetString("avatar"));IM::BaseDefine::GroupType nGroupType = IM::BaseDefine::GroupType(pResultSet->GetInt("type"));if(IM::BaseDefine::GroupType_IsValid(nGroupType)){cGroupInfo.set_group_type(nGroupType);cGroupInfo.set_group_creator_id(pResultSet->GetInt("creator"));lsGroupInfo.push_back(cGroupInfo);}else{log("invalid groupType. groupId=%u, groupType=%u", nGroupId, nGroupType);}}}delete pResultSet;}else{log("no result set for sql:%s", strSql.c_str());}pDBManager->RelDBConn(pDBConn);if(!lsGroupInfo.empty()){fillGroupMember(lsGroupInfo);}}else{log("no db connection for teamtalk_slave");}}else{log("no ids in map");}
}

最近联系会话信令和协议设计

enum BuddyListCmdID {CID_BUDDY_LIST_RECENT_CONTACT_SESSION_REQUEST = 513,CID_BUDDY_LIST_RECENT_CONTACT_SESSION_RESPONSE = 514,// ...... 暂时省略无关信令CID_BUDDY_LIST_USERS_STATUS_REQUEST = 522,CID_BUDDY_LIST_USERS_STATUS_RESPONSE = 523,// ...... 暂时省略无关信令
};

获取最近联系会话

流程图

具体代码逻辑

这篇关于TeamTalk消息服务器（群组相关）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1125313。

相关文章

ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法

ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法

《ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法》本文介绍了Elasticsearch的基本概念,包括文档和字段、索引和映射,还详细描述了如何通过Docker... 目录1、ElasticSearch概念2、ElasticSearch、Kibana和IK分词器部署
阅读更多...
部署Vue项目到服务器后404错误的原因及解决方案

部署Vue项目到服务器后404错误的原因及解决方案

《部署Vue项目到服务器后404错误的原因及解决方案》文章介绍了Vue项目部署步骤以及404错误的解决方案,部署步骤包括构建项目、上传文件、配置Web服务器、重启Nginx和访问域名,404错误通常是... 目录一、vue项目部署步骤二、404错误原因及解决方案错误场景原因分析解决方案一、Vue项目部署步骤
阅读更多...
Linux流媒体服务器部署流程

Linux流媒体服务器部署流程

《Linux流媒体服务器部署流程》文章详细介绍了流媒体服务器的部署步骤,包括更新系统、安装依赖组件、编译安装Nginx和RTMP模块、配置Nginx和FFmpeg,以及测试流媒体服务器的搭建... 目录流媒体服务器部署部署安装1.更新系统2.安装依赖组件3.解压4.编译安装（添加RTMP和openssl模块
阅读更多...
如何通过Python实现一个消息队列

如何通过Python实现一个消息队列

《如何通过Python实现一个消息队列》这篇文章主要为大家详细介绍了如何通过Python实现一个简单的消息队列,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录如何通过 python 实现消息队列如何把 http 请求放在队列中执行1. 使用 queue.Queue 和 reque
阅读更多...
JavaWeb-WebSocket浏览器服务器双向通信方式

JavaWeb-WebSocket浏览器服务器双向通信方式

《JavaWeb-WebSocket浏览器服务器双向通信方式》文章介绍了WebSocket协议的工作原理和应用场景,包括与HTTP的对比,接着,详细介绍了如何在Java中使用WebSocket,包括配... 目录一、概述二、入门2.1 POM依赖2.2 编写配置类2.3 编写WebSocket服务2.4 浏
阅读更多...
查询SQL Server数据库服务器IP地址的多种有效方法

查询SQL Server数据库服务器IP地址的多种有效方法

《查询SQLServer数据库服务器IP地址的多种有效方法》作为数据库管理员或开发人员,了解如何查询SQLServer数据库服务器的IP地址是一项重要技能,本文将介绍几种简单而有效的方法,帮助你轻松... 目录使用T-SQL查询方法1：使用系统函数方法2：使用系统视图使用SQL Server Configu
阅读更多...
解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)

解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)

《解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)》该文章介绍了使用Redis的阻塞队列和Stream流的消息队列来优化秒杀系统的方案,通过将秒杀流程拆分为两条流水线,使用Redi... 目录Redis秒杀优化方案(阻塞队列+Stream流的消息队列)什么是消息队列？消费者组的工作方式每
阅读更多...
使用C/C++调用libcurl调试消息的方式

使用C/C++调用libcurl调试消息的方式

《使用C/C++调用libcurl调试消息的方式》在使用C/C++调用libcurl进行HTTP请求时,有时我们需要查看请求的/应答消息的内容（包括请求头和请求体）以方便调试,libcurl提供了多种... 目录1. libcurl 调试工具简介2. 输出请求消息使用 CURLOPT_VERBOSE使用 C
阅读更多...
nginx-rtmp-module构建流媒体直播服务器实战指南

nginx-rtmp-module构建流媒体直播服务器实战指南

《nginx-rtmp-module构建流媒体直播服务器实战指南》本文主要介绍了nginx-rtmp-module构建流媒体直播服务器实战指南,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有... 目录1. RTMP协议介绍与应用RTMP协议的原理RTMP协议的应用RTMP与现代流媒体技术的关系2
阅读更多...
mysqld_multi在Linux服务器上运行多个MySQL实例

mysqld_multi在Linux服务器上运行多个MySQL实例

《mysqld_multi在Linux服务器上运行多个MySQL实例》在Linux系统上使用mysqld_multi来启动和管理多个MySQL实例是一种常见的做法,这种方式允许你在同一台机器上运行多个... 目录1. 安装mysql2. 配置文件示例配置文件3. 创建数据目录4. 启动和管理实例启动所有实例
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2