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。

相关文章

Web服务器-Nginx-高并发问题

Web服务器-Nginx-高并发问题

《Web服务器-Nginx-高并发问题》Nginx通过事件驱动、I/O多路复用和异步非阻塞技术高效处理高并发,结合动静分离和限流策略,提升性能与稳定性... 目录前言一、架构1. 原生多进程架构2. 事件驱动模型3. IO多路复用4. 异步非阻塞 I/O5. Nginx高并发配置实战二、动静分离1. 职责2
阅读更多...
Linux搭建ftp服务器的步骤

Linux搭建ftp服务器的步骤

《Linux搭建ftp服务器的步骤》本文给大家分享Linux搭建ftp服务器的步骤,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录ftp搭建1：下载vsftpd工具2：下载客户端工具3：进入配置文件目录vsftpd.conf配置文件4:
阅读更多...
聊聊springboot中如何自定义消息转换器

聊聊springboot中如何自定义消息转换器

《聊聊springboot中如何自定义消息转换器》SpringBoot通过HttpMessageConverter处理HTTP数据转换,支持多种媒体类型,接下来通过本文给大家介绍springboot中... 目录核心接口springboot默认提供的转换器如何自定义消息转换器Spring Boot 中的消息
阅读更多...
Linux查询服务器 IP 地址的命令详解

Linux查询服务器 IP 地址的命令详解

《Linux查询服务器IP地址的命令详解》在服务器管理和网络运维中,快速准确地获取服务器的IP地址是一项基本但至关重要的技能,下面我们来看看Linux中查询服务器IP的相关命令使用吧... 目录一、hostname 命令：简单高效的 IP 查询工具命令详解实际应用技巧注意事项二、ip 命令：新一代网络配置全
阅读更多...
Python开发简易网络服务器的示例详解(新手入门)

Python开发简易网络服务器的示例详解(新手入门)

《Python开发简易网络服务器的示例详解(新手入门)》网络服务器是互联网基础设施的核心组件,它本质上是一个持续运行的程序,负责监听特定端口,本文将使用Python开发一个简单的网络服务器,感兴趣的小... 目录网络服务器基础概念python内置服务器模块1. HTTP服务器模块2. Socket服务器模块
阅读更多...
Linux查询服务器系统版本号的多种方法

Linux查询服务器系统版本号的多种方法

《Linux查询服务器系统版本号的多种方法》在Linux系统管理和维护工作中,了解当前操作系统的版本信息是最基础也是最重要的操作之一,系统版本不仅关系到软件兼容性、安全更新策略,还直接影响到故障排查和... 目录一、引言：系统版本查询的重要性二、基础命令解析：cat /etc/Centos-release详
阅读更多...
Python WSGI HTTP服务器Gunicorn使用详解

Python WSGI HTTP服务器Gunicorn使用详解

《PythonWSGIHTTP服务器Gunicorn使用详解》Gunicorn是Python的WSGI服务器,用于部署Flask/Django应用,性能高且稳定,支持多Worker类型与配置,可处... 目录一、什么是 Gunicorn？二、为什么需要Gunicorn？三、安装Gunicorn四、基本使用启
阅读更多...
通过配置nginx访问服务器静态资源的过程

通过配置nginx访问服务器静态资源的过程

《通过配置nginx访问服务器静态资源的过程》文章介绍了图片存储路径设置、Nginx服务器配置及通过http://192.168.206.170:8007/a.png访问图片的方法,涵盖图片管理与服务... 目录1.图片存储路径2.nginx配置3.访问图片方式总结1.图片存储路径2.nginx配置
阅读更多...
Python极速搭建局域网文件共享服务器完整指南

Python极速搭建局域网文件共享服务器完整指南

《Python极速搭建局域网文件共享服务器完整指南》在办公室或家庭局域网中快速共享文件时,许多人会选择第三方工具或云存储服务,但这些方案往往存在隐私泄露风险或需要复杂配置,下面我们就来看看如何使用Py... 目录一、android基础版：HTTP文件共享的魔法命令1. 一行代码启动HTTP服务器2. 关键参
阅读更多...
SpringBoot改造MCP服务器的详细说明(StreamableHTTP 类型)

SpringBoot改造MCP服务器的详细说明(StreamableHTTP 类型)

《SpringBoot改造MCP服务器的详细说明(StreamableHTTP类型)》本文介绍了SpringBoot如何实现MCPStreamableHTTP服务器,并且使用CherryStudio... 目录SpringBoot改造MCP服务器（StreamableHTTP）1 项目说明2 使用说明2.1
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2