代码拉取完成,页面将自动刷新
本项目开源免费,欢迎交流学习、贡献代码。
MqttWk
├── mqtt-auth -- MQTT服务连接时用户名和密码认证
├── mqtt-broker -- MQTT服务器功能的核心实现
├── mqtt-common -- 公共类及其他模块使用的服务接口及对象
├── mqtt-store -- MQTT服务器会话信息(redis缓存及kafka加载)
├── mqtt-client -- MQTT客户端示例代码(配置文件修改数据库连接启动之)
├── mqtt-zoo -- 教程文档或文件
├── mqtt-test-kafka -- kafka消费者接收消息
├── mqtt-test-websocket -- websocket通信测试示例
test_topic
/mqtt/test
--不能以/结尾, 通配符订阅 #
/mqtt/#
--以#结尾)http://127.0.0.1:8922/open/api/mqttwk/info
mvn install
mvn clean package nutzboot:shade
进行打包java -jar mqtt-broker-xxx.jar -Dnutz.profiles.active=prod
[此时加载application-prod.yaml配置文件]nohup java -Dnutz.boot.configure.yaml.dir=/data -jar mqtt-broker-xxx.jar >/dev/null 2>&1 &
mqtt-zoo
\keystore\server.cermqttwk:
broker:
cluster-on: true
kafka:
# 是否启用kafka消息转发
broker-enabled: false
bootstrap:
servers: 192.168.1.101:9092,192.168.1.102:9093
redis:
mode: cluster
nodes: 192.168.1.103:16379,192.168.1.104:26379,192.168.1.103:36379
mqttwk:
broker:
cluster-on: true
kafka:
# 是否启用kafka消息转发
broker-enabled: false
bootstrap:
servers: 192.168.1.101:9092,192.168.1.102:9093
redis:
mode: normal
host: 127.0.0.1
port: 6379
mqtt-auth
模块下的相应方法即可mqtt-broker
的resources/keystore/server.pfx
如果您觉得还不错请在右上角点一下 star,帮忙转发,谢谢 🙏🙏🙏 大家的支持是开源最大动力
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。