基于go语言的消息推送系统架构分析
Posted Golang语言社区
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了基于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
4.job
消息转发服务器,从kafka队列中获取消息,发送给comet服务器,无状态服务器可以随意增删。
三、推送服务具有的特性
1.支持一个端的多个连接,比如同一用户在不同的电脑上登录可以同时接收到消息;
2.不支持客户端的区分(pc/wap/ios/android)
3.目前没有查询某个用户是否在线,某些业务上有显示在线状态的需求,这个可以在logic服务器中添加一个接口;发送消息时如果不在线可能会通过其他推送服务(如信鸽推送),这个可以通过修改push接口的返回值来判断
4.群发只能是在线才能收到,如果不在线就丢弃此消息,当然用户可以下次登录时再通过未读消息接口获取
5.在长连接的时候comet->logic->router,而不是comet->router,这样是为了可以在逻辑服务器中获取其他用户状态、未读消息等,这样确实使得comet简单了,且不会有一致性问题。
6.支持群发功能,所有用户或按照roomId来群发,这个功能太爽了,效率不是提高一点半点。
在此感谢猎豹的同学开源IM产品,使得我们可以有更多的美好的东西
版权声明:本文为博主原创文章,未经博主允许不得转载。
本文来自:
查看原文:
以上是关于基于go语言的消息推送系统架构分析的主要内容,如果未能解决你的问题,请参考以下文章