Skip to content

一个使用golang实现的push代理,推送协议采用自定义二进制协议,传输数据简单加密,业务实现push、callback、im,后台消息系统采用nsq

Notifications You must be signed in to change notification settings

axengine/galopush

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

20 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

galopush

该项目已过时,推荐经过生产环境验证的:https://github.com/axengine/tuitui

一个使用golang编写的push代理,接收来自调用方的push、callback、im请求,并按照既定规则推送到区分用户、区分终端类型的终端。 galopush内部由comet和router组成,一个router管理多个comet,并实现comet负载均衡;comet从nsq订阅业务消息,并根据规则路由到comet,由comet将消息推送到终端;comet接收来自终端的消息请求,并将消息发布到nsq,由业务层自行获取。 comet与终端(已定义Android、iOS、winPhone、web、PCClient等)之间协议采用自定义二进制协议(web与comet采用ws协议+json方式),数据传输支持加密。

协议

	bit        7        6        5        4        3        2        1       0
	byte1	EnCode(2bit)	Message-Type(6bit)
	byte2	Transaction  ID(4bytes)
	byte3	
	byte4	
	byte5	
	byte6	Body-len(4bytes 可选)
	byte7	
	byte8	
	byte9	
	byte...	消息体(可选)

消息类型

消息类型 值 描述

Reserved	0	保留
REGISTER	1	注册,UA或Service向gComet发起注册
REGRESP	2	注册应答
PING	3	客户端发起心跳消息,心跳间隔建议300S
PONG	4	心跳应答
PUSH	5	推送消息
PUSHRESP	6	推送应答
CALLBACK	7	回调消息,回调超时时长60S
CBRESP	8	回调应答
IM	9	即时消息请求
IMRESP	10	即时消息应答

EnCode

指定消息体编码(加密)方式
0x00:默认,无特殊编码
0x01:按位取反
0x02:字节逆序(两两互逆,若单字节最后一字节不做变换)
0x03:环形异或

TID(Transaction ID)

unsigned int类型的随机不重复事务ID,初始消息ID随机;请求消息与响应消息拥有相同的事务ID;
事务默认超时时长:5秒

消息体长度

可选,类型为unsigned int类型,当指定消息类型携带消息体时有效。

消息体

可选, 当指定消息类型携带消息体时有效

About

一个使用golang实现的push代理,推送协议采用自定义二进制协议,传输数据简单加密,业务实现push、callback、im,后台消息系统采用nsq

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages