MqttWk 1.0.0-netty 发布,Java MQTT服务及消息代理

栏目: 后端 · 发布时间: 6年前

内容简介:基于 nutzboot + netty + redis + kafka 实现的MQTT服务broker(另有t-io版本分支,暂未发布)本项目代码主要来源于 netty/iot-mqtt-server 等众多项目,开源免费,欢迎交流学习

MqttWk by netty

基于 nutzboot + netty + redis + kafka 实现的MQTT服务broker(另有t-io版本分支,暂未发布)

本项目代码主要来源于 netty/iot-mqtt-server 等众多项目,开源免费,欢迎交流学习

参考项目

使用说明

软件架构说明

  1. 使用netty实现通信及协议解析

  2. 使用nutzboot提供依赖注入及属性配置

  3. 使用 redis 实现消息缓存,集群

  4. 使用kafka实现消息代理

项目结构

MqttWk
  ├── mqtt-auth -- MQTT服务连接时用户名和密码认证
  ├── mqtt-broker -- MQTT服务器功能的核心实现
  ├── mqtt-common -- 公共类及其他模块使用的服务接口及对象
  ├── mqtt-store -- MQTT服务器会话信息(redis缓存及kafka加载)
  ├── mqtt-zoo -- 教程文档或文件
    ├── mqtt-test-kafka -- kafka消费者接收消息
    ├── mqtt-test-websocket -- websocket通信测试示例

功能说明

  1. 参考MQTT3.1.1规范实现

  2. 完整的QoS服务质量等级实现

  3. 遗嘱消息, 保留消息及消息分发重试

  4. 心跳机制

  5. MQTT连接认证(可选择是否开启)

  6. SSL方式连接(可选择是否开启)

  7. 主题过滤(支持单主题订阅如 test_topic /mqtt/test --不能以/结尾, 通配符订阅  # /mqtt/# --以#结尾)

  8. Websocket支持(可选择是否开启)

  9. 集群功能(可选择是否开启)

  10. Kafka消息转发功能(可选择是否开启)

快速开始

  • JDK1.8

  • 项目根目录执行 mvn install

  • mqtt-broker 下执行 mvn clean package nutzboot:shade 进行打包

  • java -jar mqtt-broker-xxx.jar -Dnutz.profiles.active=prod [此时加载application-prod.properties配置文件]

  • 打开mqtt-spy客户端, 填写相应配置 下载

  • 连接端口:8885, websocket 端口: 9995 websocket

  • 连接使用的用户名: demo

  • 连接使用的密码: 8F3B8DE2FDC8BD3D792BE77EAC412010971765E5BDD6C499ADCEE840CE441BDEF17E30684BD95CA708F55022222CC6161D0D23C2DFCB12F8AC998F59E7213393

  • 连接使用的证书在 mqtt-zoo \keystore\server.cer

集群使用

  • 多机环境集群:

    • mqttwk.broker.cluster-on=true

    • mqttwk.broker.kafka.bootstrap.servers=192.168.1.101:9092,192.168.1.102:9093

    • redis.mode=cluster

    • redis.nodes=192.168.1.103:16379,192.168.1.104:26379

  • 单机环境集群:

    • mqttwk.broker.cluster-on=true

    • mqttwk.broker.kafka.bootstrap.servers=127.0.0.1:9092,127.0.0.1:9093

    • redis.mode=normal

    • redis.host=127.0.0.1

自定义 - 连接认证

  • 默认只是简单使用对用户名进行RSA密钥对加密生成密码, 连接认证时对密码进行解密和相应用户名进行匹配认证

  • 使用中如果需要实现连接数据库或其他方式进行连接认证, 只需要重写 mqtt-auth 模块下的相应方法即可

自定义 - 服务端证书

  • 服务端证书存储在 mqtt-brokerresources/keystore/server.pfx

  • 用户可以制作自己的证书, 但存储位置和文件名必须使用上述描述的位置及文件名

生产环境部署

  • 多机环境集群

  • 负载均衡: 富人用 L4 Switch,穷人用 Linux HAProxy

示例截图

MqttWk 1.0.0-netty 发布,Java MQTT服务及消息代理

测试截图

MqttWk 1.0.0-netty 发布,Java MQTT服务及消息代理


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

JAVA 2核心技术 卷Ⅰ

JAVA 2核心技术 卷Ⅰ

[美] 霍斯特曼、[美] 科奈尔 / 叶乃文、邝劲筠 等 / 机械工业出版社 / 2006-5 / 88.00元

本书是Java技术经典参考书,多年畅销不衰,第7版在保留以前版本风格的基础上,涵盖Java2开发平台标准版J2SE5.0的基础知识,主要内容包括面各对象程序设计、反射与代理、接口与内部类、事件监听器模型、使用Swing UI工具箱进行图形用户界面设计,异常处理、流输入/输出和对象序列化、泛型程序设计等。 本书内容翔实、深入浅出,附有大量程序实例,极具实用价值,是Java初学者和Java程序员......一起来看看 《JAVA 2核心技术 卷Ⅰ》 这本书的介绍吧!

URL 编码/解码
URL 编码/解码

URL 编码/解码

XML、JSON 在线转换
XML、JSON 在线转换

在线XML、JSON转换工具

html转js在线工具
html转js在线工具

html转js在线工具