基于go语言的消息推送系统架构分析

栏目: Go · 发布时间: 5年前

内容简介:原文:本系统是猎豹移动基于go语言开发的一套消息推送系统,源码地址:1.comet

原文: https://www.cnblogs.com/shenlanzifa/p/5288701.html

本系统是猎豹移动基于 go 语言开发的一套消息推送系统,源码地址: https://github.com/Terry-Mao/goim

一、架构图

基于go语言的消息推送系统架构分析

架构图

二、功能简介

1.comet

长连接服务器,支持长轮训、tcp、websocket连接,有超时机制

2.logic

逻辑处理服务器,消息推送入口,通过userId在router服务器中查找对应的comet服务器,将serverId和消息一起保存到kafka队列,logic是无状态服务器,可以随意增删,因为comet需要连接logic,所以在comet服务器中需要连接logic的通过LVS的虚IP,LVS加了real server后不会断开,所以需要在comet服务触发SIGHUP,重新load配置文件。

3.router

路由服务器,保存userId和serverId的关系,serverId指的是comet服务器地址,userId和roomId的关系,注册用户roomId为固定1,非注册用户roomId为-1,注册和非注册的区分是我猜的,猎豹IM的同学可以确认下。logic连接router需要一致性hash,所以不能随意添加router服务器。不选择 redis 代替router作者解释是因为有同一userId多次连接序号分配问题以及原子操作,我觉得通过key:userId来记录自增,key:userId:seq来记录每个连接,这样也是可以的。

4.job

消息转发服务器,从kafka队列中获取消息,发送给comet服务器,无状态服务器可以随意增删。

三、推送服务具有的特性

1.支持一个端的多个连接,比如同一用户在不同的电脑上登录可以同时接收到消息;

2.不支持客户端的区分(pc/wap/ios/android)

3.目前没有查询某个用户是否在线,某些业务上有显示在线状态的需求,这个可以在logic服务器中添加一个接口;发送消息时如果不在线可能会通过其他推送服务(如信鸽推送),这个可以通过修改push接口的返回值来判断

4.群发只能是在线才能收到,如果不在线就丢弃此消息,当然用户可以下次登录时再通过未读消息接口获取

5.在长连接的时候comet->logic->router,而不是comet->router,这样是为了可以在逻辑服务器中获取其他用户状态、未读消息等,这样确实使得comet简单了,且不会有一致性问题。

6.支持群发功能,所有用户或按照roomId来群发,这个功能太爽了,效率不是提高一点半点。

在此感谢猎豹的同学开源IM产品,使得我们可以有更多的美好的东西

其他类似的软件有:

moonmq: http://blog.csdn.net/siddontang/article/details/22889495

RocketMQ : http://blog.csdn.net/a19881029/article/details/34446629

Beanstalkd: http://blog.csdn.net/xcl168/article/details/47705725

FishChat: https://github.com/oikomi/FishChatServer

社区交流群:221273219

Golang语言社区论坛 :

www.Golang.Ltd

LollipopGo游戏服务器地址:

https://github.com/Golangltd/LollipopGo

社区视频课程课件GIT地址:

https://github.com/Golangltd/codeclass
基于go语言的消息推送系统架构分析

Golang语言社区


以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

你凭什么做好互联网

你凭什么做好互联网

曹政 / 中国友谊出版公司 / 2016-12 / 42.00元

为什么有人可以预见商机、超越景气,在不确定环境下表现更出色? 在规则之外,做好互联网,还有哪些关键秘诀? 当环境不给机会,你靠什么翻身? 本书为“互联网百晓生”曹政20多年互联网经验的总结,以严谨的逻辑思维分析个人与企业在互联网发展中的一些错误思想及做法,并给出正确解法。 从技术到商业如何实现,每个发展阶段需要匹配哪些能力、分解哪些目标、落实哪些策略都一一点出,并在......一起来看看 《你凭什么做好互联网》 这本书的介绍吧!

HTML 压缩/解压工具
HTML 压缩/解压工具

在线压缩/解压 HTML 代码

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码

HEX CMYK 转换工具
HEX CMYK 转换工具

HEX CMYK 互转工具