jmqtt icon indicating copy to clipboard operation
jmqtt copied to clipboard

A MQTT broker,implemented by java and netty,support persistence and cluster

Results 28 jmqtt issues
Sort by recently updated
recently updated
newest added

Bumps [mysql-connector-java](https://github.com/mysql/mysql-connector-j) from 8.0.17 to 8.0.28. Changelog Sourced from mysql-connector-java's changelog. Changelog https://dev.mysql.com/doc/relnotes/connector-j/8.0/en/ Version 8.0.29 Fix for Bug#21978230, COMMENT PARSING NOT PROPER IN PREPSTMT.EXECUTEBATCH(). Fix for Bug#81468 (23312764), MySQL server...

dependencies

Bumps [fastjson](https://github.com/alibaba/fastjson) from 1.2.75 to 1.2.83. Release notes Sourced from fastjson's releases. FASTJSON 1.2.83版本发布(安全修复) 这是一个安全修复版本,修复最近收到在特定场景下可以绕过autoType关闭限制的漏洞,建议fastjson用户尽快采取安全措施保障系统安全。 安全修复方案 :https://github.com/alibaba/fastjson/wiki/security_update_20220523 Issues 安全加固 修复JDK17下setAccessible报错的问题 #4077 下载 https://repo1.maven.org/maven2/com/alibaba/fastjson/1.2.83/ 文档 https://github.com/alibaba/fastjson/wiki/%E5%B8%B8%E8%A7%81%E9%97%AE%E9%A2%98 源码 https://github.com/alibaba/fastjson/tree/1.2.83 fastjson 1.2.79版本发布,BUG修复 这又是一个bug...

dependencies

看代码应该都是本地消息流转,没看出怎么用akka的集群能力? 作者想用akka集群方式是想保存pub/sub的订阅关系还是message?

jmq_product_topic jmq_device 表结构定义没有加进来 需要根据mapper定义自己建表

后续有什么想做的吗。 加砖加瓦啊。

rt. 点开了几个类,看了都没有注释。

本地启动两个节点,A tcp 端口1883 , canonical.port = 25251 ,B tcp 端口2883 canonical.port = 25252 ,设备链接A 节点,通过B 节点发消息到设备订阅的主题,A节点没有收到发送的消息的事件

将连接字符串修改为 jdbc:mysql://127.0.0.1:3306/jmqtt?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8 即可正常启动