β

【开源】MQTT推送服务器——zer0MqttServer(Java编写)

Harries Blog™ 494 阅读

目录

  • 说明

  • 功能

  • 如何使用

  • 参考帮助

说明

重要的放前面:V1.0版本是一个非常基础的版本,除了完整的MQTT 协议 实现外,其他功能什么都没做。

MQTT 协议是 IBM 开发 即时通讯 协议,相对于 IM 的实际上的准标准协议 XMPP 来说,MQTT 更小,更快,更轻量。MQTT 适合于任何计算能力有限,工作在低带宽、不可靠的网络中的设备,包括手机,传感器等等。

开发此客户端的目的,是因为实际项目中需要用到推送、即时通讯的内容,而第三方平台有时候不稳定,遇到问题难于 调试 。所以决定自己开发一套即时通讯系统。选用 MQTT 的原因正如上所说,它比XMPP更适合手机端使用。具体比较请参看: Android 推送方案分析(MQTT/XMPP/GCM) 。

项目断断续续写了快一年( 2015 年2月~12月),大部分在业余 时间 完成。 代码 中的每个函数都有明确的中文 注释 信息,对于 MQTT 实现的部分,更是细节到每个功能对应的文档的页数都进行了标明。此 服务器 既可以针对具体项目二次开发使用,也可以用于 MQTT 协议的学习。

功能

已实现:

  • 网络传输功能(使用 Java7 才开始支持的 AIO 实现)~~
  • 会话 管理 功能
  • 任务调度框架(使用Quartz框架为基础封装)
  • 协议层与网络层的分离(即换套协议,网络层一点不用改,也能用)
  • MQTT完整实现(推送,单聊,群聊)

未实现:

  • 安全 层(消息加密、解密、防重放,防中间人等等)
  • 好友功能(添加好友, 删除 好友,好友列表等等)
  • 群组管理功能(添加群组,退出群组等等)
  • 语音
  • 视频
  • 总之就是可以拓展的应用层都没做

所有还没做的都是我之后想要升级的

如何使用

zer0MqttServer 的使用很简单:

  • 下载 源码 (源码中包括所有依赖包)
  • 检查 Java 版本是否为1.7或以上,不是则按照 Java 1.7及以上
  • 导入 IDE
  • 引用依赖包
  • 运行包 com.syxy.server 下的 S tar tServer 文件,即可启动服务器。

【开源】MQTT推送服务器——zer0MqttServer(Java编写)

测试 方法也同样简单:

运行包 test 下的 MQTTClientTest 文件,即可开启测试客户端。

测试客户端包括的功能有:连接服务器、订阅主题、发送固定信息,客户端通过 pahoMqtt 第三方jar包编写,你可以自行修改代码进行更详细的测试

下面简述一下项目的目录结构:

【开源】MQTT推送服务器——zer0MqttServer(Java编写)

com.syxy.util 包中是一些公共类,包括缓冲池BufferPool、任务调度框架QuartzManager、字符串处理类StringTool、日期时间类TimeUtils等等

com.syxy.Aiohandler 是 AIO 的具体实现,包含了 IO 建立、 数据 接收、数据回写3个类。

com.syxy.server 是网络应用层,StartServer 用于启动服务器,并初始化协议相关的类。TcpServer 初始化了服务器的初始资源,包括缓冲区大小,协议处理器, 端口 配置 ,AIO 等等。ClientSession 是会话管理类,每个客户端的连接对应一个此类对象,包含心跳处理,会话断开,数据接收,处理,回写等等内容。

com.syxy.protocol 定义了协议处理接口

com.syxy.protocol.mqttImp 则是具体的 MQTT 协议的处理。包括协议的编码,解码,业务处理等等。其中的 message 包中处理了14种 MQTT 对应的消息类型(编码、解码)。process 包中进行了协议的具体处理。最重要的是 ProtocolProcess. java 文件,其中完整实现了MQTT协议文件中的具体流程。

resource 文件中包含了一些配置文件,其中 mqtt.properties 文件可以针对缓冲区大小、临时存储文件名、服务器端口等信息

参考帮助

  1. moquette 开源项目

  2. MQTT协议V3.1.1版本

  3. MQTT协议V3.1版本

  4. Java AIO 基础

  5. 聂永的 博客

源码

最后附上源码地址: https :// git hub.com/zer0Black/zer0MQTTServer

在github中选择分支 release-V1.0 即可。主干会持续开发,不能保证可以跑通。

转载请注明来源: Harries Blog™ » 【开源】MQTT推送服务器——zer0MqttServer(Java编写)

作者:Harries Blog™
追心中的海,逐世界的梦

发表评论