#athena 消息系统

本来打算做一个客服系统，想了想还是先把消息通道做起来。正好之前写的还有些问题，借此机会重构一版。

目前功能：

1. 基于zookeeper实现的分布式消息服务器，可实现动态发现、注册、重连。手动或自动降级尚未实现，可使用第三方能力实现。
2. 使用kafka实现消息堆积能力
3. 支持用户在消息服务器间的动态迁移
4. 准实时用户在线数监控，每台服务器的用户数量伴随心跳包传输，每45秒更新一次。
5. 多项目管理，通过AppId与AppSecret来实现用户绑定、认证、发送消息等功能。
6. 支持Tcp消息以及Http消息（comet实现）
7. 支持用户多端登陆

要求基础组件：

kafka、redis、mysql

服务器模块功能说明：

client-agent 模块

该模块为消息服务器主体，用户与该服务器连接后即可实时收到消息。

message-agent 模块

该模块用作消息转发，根据token来分别路由至各个消息服务端（client-agent），再由消息服务端分发至各个用户。

message-web 模块

该模块主要处理用户认证、绑定、及消息发送功能。因此，消息发送能力由该服务提供，同时伴有可视化的服务器监控与管理功能。

试验下来消息处理能力很客观，消息服务器对服务器调优有很大的依赖，使用前建议根据自己实际情况做调优。