windmq 1.0.0-RELEASE 发布,MQTT快速开发脚手架
windmq 1.0.0-RELEASE 已经发布,此版本更新内容包括:
- MQTT客户端登录凭证分配(ACL支持阿里云\EMQ目前只支持账号密码,可自定义实现)
- 适合低端设备的查表加密协议(详情见: com.stanwind.wmqtt.security.TableMsgEncrypt)
- 高可用部署(多实例不同clientID上线,EMQ有提供共享订阅,但是阿里云只能靠规则引擎转发MQ,我们线上使用全盘负责机制,谁发命令谁处理)
- 消息处理池(CPU核心数*2 + 1, )
- Topic注解匹配消息处理,支持模糊匹配(正则实现,可取topic路径参数)和精确匹配
windmq - MQTT快速开发脚手架
前言
快速开发处理MQTT topic,一个方法注解就搞定
原样从项目里搬出来的,产线阿里云,测试EMQ,需要统一支持下
有些config和bean不太合理,过年有空整理下
此项目整合springboot部分和topic规则搬运了一个项目,刚接触这个,十分感谢前辈的经验https://gitee.com/yezhihao/mqtt-sample
关于共享订阅的高可用兼容,如果有方案还望各位不吝赐教
功能
- MQTT客户端登录凭证分配(ACL支持阿里云\EMQ目前只支持账号密码,可自定义实现)
- 适合低端设备的查表加密协议(详情见: com.stanwind.wmqtt.security.TableMsgEncrypt)
- 高可用部署(多实例不同clientID上线,EMQ有提供共享订阅,但是阿里云只能靠规则引擎转发MQ,我们线上使用全盘负责机制,谁发命令谁处理)
- 消息处理池(CPU核心数*2 + 1, )
- Topic注解匹配消息处理,支持模糊匹配(正则实现,可取topic路径参数)和精确匹配