开发中mqtt遇到MqttException (128)异常问题-程序员宅基地

最进公司要把mqtt给独立出来,专门给他一个服务器进行部署,然后我就在测试非127.0.0.1连接时抛出异常

异常如下:

MqttException (128)
    at org.eclipse.paho.client.mqttv3.MqttClient.subscribe(MqttClient.java:347)
    at com.dmxj.qianghe.common.push.MqttSub.sub(MqttSub.java:48)
    at com.dmxj.qianghe.common.push.MqttSub.runsub(MqttSub.java:55)
    at com.dmxj.qianghe.common.socket.SocketClientInit.init(SocketClientInit.java:61)
    at javax.servlet.GenericServlet.init(GenericServlet.java:158)
    at org.apache.catalina.core.StandardWrapper.initServlet(StandardWrapper.java:1132)
    at org.apache.catalina.core.StandardWrapper.loadServlet(StandardWrapper.java:1079)
    at org.apache.catalina.core.StandardWrapper.load(StandardWrapper.java:973)
    at org.apache.catalina.core.StandardContext.loadOnStartup(StandardContext.java:4885)
    at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5199)
    at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
    at org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:743

这个网上找了下是订阅异常了,然后看了下我的订阅,果然订阅主题为

$SYS/brokers/[email protected]/clients/#

自然订阅不上,直接修改成对于ip也不行,看来是acl.config文件定义了可订阅$SYS主题的权限

{allow, {user, "dashboard"}, subscribe, ["$SYS/#"]}.

{allow, {ipaddr, "127.0.0.1"}, pubsub, ["$SYS/#", "#"]}.

%%%{deny, all, subscribe, ["$SYS/#", {eq, "#"}]}.

{allow, all}.

acl.config文件第三行默认是禁止客户端订阅$SYS/#主题。我们把它注释掉。开启一个客户端,订阅$SYS/#主题,消息如下:

module(emqttd_broker)这个模块,它会每秒钟publish消息,主题关键字有uptime和datetime等。

module(emqttd_stats)这个模块,它会每60秒钟publish消息,把Ets表mqtt_stats的信息发出来。

module(emqttd_metrics)这个模块,它的原理同上。

eg: 

$SYS/brokers/[email protected]/uptime: qos=0

$SYS/brokers/[email protected]/sysdescr: qos=0

 

打开文件vm.args,把节点名称修改为:

#-name [email protected]
-name [email protected]

eg: 

$SYS/brokers/[email protected]/uptime: qos=0

$SYS/brokers/[email protected]/sysdescr: qos=0

 

订阅客户端上下线的主题

具体某个节点的某个clientId方式的主题是:

$SYS/brokers/(node)/clients/(clientId)/connected
$SYS/brokers/[email protected]/clients/861694030142478/connected
$SYS/brokers/[email protected]/clients/861694030142478/disconnected

 

通配方式的主题是:

$SYS/brokers/+/clients/+/connected
$SYS/brokers/+/clients/+/disconnected
$SYS/brokers/+/clients/#

 

出于安全起见,我们把acl.config文件修改为:

允许客户端订阅"$SYS/brokers/+/clients/#"主题,但是禁止订阅"$SYS/#"主题。

{allow, {user, "dashboard"}, subscribe, ["$SYS/#"]}.

{allow, {ipaddr, "127.0.0.1"}, pubsub, ["$SYS/#", "#"]}.

{allow, all, subscribe, ["$SYS/brokers/+/clients/#"]}.

{deny, all, subscribe, ["$SYS/#", {eq, "#"}]}.

{allow, all}.

  以上修改重试连接OK通过

 

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/lpwakaka/article/details/99821593

智能推荐

jstl标签<c:url>查询分页时拼接参数的用法_jstl 标签输出内容拼接-程序员宅基地

文章浏览阅读1.5k次。先上代码:${ pageContext.request.contextPath }号码段管理 号码段管理 号码段管理 区域号

浅解比SQL更好用的SPL(二)-程序员宅基地

文章浏览阅读118次。从 SQL 到SPL基本查询语法迁移之多表操作上一篇我们针对单表的情形了解了如何把数据计算从 SQL 查询迁移到集算器,或者更准确地说,迁移到集算器所使用的SPL集算语言。这个迁移过程,既有相同的概念,也有不同的思路。接下来,我们一起针对多表的情况看一下集算器和SPL语言是如何发挥更大的..._sql常用比if更好用

国科大高级人工智能10-强化学习(多臂赌博机、贝尔曼)_国科大 强化学习-程序员宅基地

文章浏览阅读1.5k次。文章目录多臂赌博机Multi-armed bandit(无状态)马尔科夫决策过程MDP(markov decision process1.动态规划蒙特卡罗方法——不知道环境完整模型情况下2.1 on-policy蒙特卡罗2.2 off-policy蒙特卡罗时序差分方法强化学习:Reinforcement learning目标:学习从环境状态到行为的映射,智能体选择能够获得环境最大奖赏的行为..._国科大 强化学习

如何用 Visual studio 2003/2005 调试 ASP 应用程序、Javascript 代码(转)_visual studio 2003 asp 远程调试-程序员宅基地

文章浏览阅读1k次。如何用 Visual studio 2003/2005 调试 ASP 应用程序、Javascript 代码 在vs2005中调试ASP网站的错误信息:无法提供此类型的页。说明: 由于已明确禁止所请求的页类型,无法对该类型的页提供服务。扩展名“.asp”可能不正确。 请检查以下的 URL 并确保其拼写正确。 怎么解决这个问题呢?请看下文。 ASP.NET 已经很_visual studio 2003 asp 远程调试

MMO即时战斗:地图角色同步管理和防作弊实现_mmo城镇同步-程序员宅基地

文章浏览阅读1.3w次,点赞2次,收藏29次。一、前言 无论是端游、页游、手游如果是采用了MMO即时战斗游戏模式,基本都会遇到同屏多角色实时移动、释放技能、战斗等场景,于是自然也需要实现如何管理同屏内各种角色的信息同步:例如角色的位置、以及角色身上的装备、时装、buffer等状态的实时切换。同步在网络游戏中是非常重要的,它保证了每个玩家在屏幕上看到的东西大体是一样的,解决同步问题的最简单的方法就是把每个玩家的_mmo城镇同步

Android Studio JNI代码突然无法跳转_android studio jni 类无法自动跳转-程序员宅基地

文章浏览阅读4.5k次。Android Studio JNI代码突然无法跳转AndroidStudio3.2 + gradle 4.6 下突然无法是用 ctrl + 左键 跳转代码。选中代码点击时出现 “Cannot find declaration to go to” 提示. 经过了换 SDK 后比对发现,如果JNI 代码出现这个问题,一般就是 CMake 版本不对。我换成3.6.xxx就好用了。3.10.xxx不知..._android studio jni 类无法自动跳转

随便推点

高通USB 调试总结随笔_高通平台usb debug-程序员宅基地

文章浏览阅读3.5k次。高通USB 调试总结随笔1. 分析USB log2. 正常识别流程3. 修改为host 模式4. USB检测插入原理最近分析了个高通USB 1 通过 主板上的HUB芯片不能正常通信识别USB 外设的问题,注意分析时,一定要再三确认硬件工作正常 ,可以做个实验,剪开一根USB 线,飞线到HUB芯片DPDM 上,如果,USB 接在电脑上,USB 外设接在HUB口上,电脑能正常识别外设,说明HUB芯片正常工作。如下是对软件调试方面的一些方法,写个随笔备份下:1. 分析USB logecho ‘fi_高通平台usb debug

单片机控制PCB板设计的原则和细节说明_单片机下面能不能走线-程序员宅基地

文章浏览阅读679次。设计电路板最基本的过程可以分为三大步骤:电路原理图的设计,产生网络表,印制电路板的设计。不管是板上的器件布局还是走线等等都有着具体的要求。例如,输入输出走线应尽量避免平行,以免产生干扰。两信号线平行走线必要是应加地线隔离,两相邻层布线要尽量互相垂直,平行容易产生寄生耦合。电源与地线应尽量分在两层互相垂直。线宽方面,对数字电路PCB可用宽的地线做一回路,即构成一地网(模拟电路不能这样使用),用大面..._单片机下面能不能走线

携职教育:“涉税信息查询结果告知书”如何查询?_涉税信息告知书-程序员宅基地

文章浏览阅读313次。通过电子税务局【我要办税】—【其他服务事项】—【纳税人涉税信息查询申请】功能申请,待受理通过后,在【我要办税】—【其他服务事项】—【其他涉税事项】—【文书打印】打印涉税信息查询结果。我要查询“涉税信息查询结果告知书”,如何操作?二、其他服务事项—纳税人涉税信息查询申请。二、其他服务事项—其他涉税事项—文书打印。一、我要办税—其他服务事项。一、我要办税—其他服务事项。_涉税信息告知书

Android开发之实现搜索框搜索_android搜索框功能实现-程序员宅基地

文章浏览阅读1.6w次,点赞21次,收藏180次。最近自己在尝试做app开发,遇到搜索框功能,便查找了一下但是感觉自己想的或许更好理解和记住,便自己思考了一下。废话不多说,下面是实现代码,供大家参考,有待改进。先说一下我整体思路,因为刚开始写所以相关数据都没有上传服务器过。首先建立一个数据库,将可以搜索的相关内容存储到数据库当中,然后在搜索框中获取输入的第一个字符,..._android搜索框功能实现

【Java虚拟机】JVM垃圾回收机制和常见回收算法原理-程序员宅基地

文章浏览阅读1.8k次,点赞14次,收藏17次。JVM垃圾回收机制和常见回收算法原理_垃圾回收机制

全栈混合云综合架构方案研究和落地_混合云管纳管双活资源池-程序员宅基地

文章浏览阅读493次。经过一年多团队的刻苦攻坚,目前全栈混合云1.0版本的方案已经落地多个场景,包括(政务云,一城一池,企业云,能源云)等多个场景,已经有超过近百个客户的实践经验,未来全栈混合云将从“可纳管”到“智能纳管”全面迭代,整体架构将想云原生的方向进行全面转化。主要部署全栈混合云管理平台,全部采用虚机/容器化部署模式,包括前台web组件, 中台Java组件, 后台的混合云适配组件,缓存Redis组件,RabbitMQ 组件和数据库PXC集群组件等,每个组件采用多活的方式,对外提供服务,降低单点故障。_混合云管纳管双活资源池