异常信息:
1. 启动的时候,控制台会打印出close, 这是outbond通道的类打印出来的
2. 我模拟product发送一条数据,tomcat控制台输出异常信息
ERROR inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:宸叉柇寮?繛鎺? retrying...
ERROR inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:宸叉柇寮?繛鎺? retrying...
接收到信息ooo:close
Mqtt 整合 spring mvc, 启动时候的时候可以链接,但是接收消息就失去链接
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
4条回答
- 独来独往mk 2017-11-09 05:14关注
我的配置如下:
mqtt.xml<bean id="clientFactory" class="org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory"> <property name="userName" value="admin" /> <property name="password" value="password" /> </bean> <!-- 消息适配器 --> <int-mqtt:message-driven-channel-adapter id="mqttInbound" client-id="CID_2016524123456" url="tcp://localhost:61613" topics="iot" qos="1" client-factory="clientFactory" auto-startup="true" send-timeout="12" channel="output" /> <int:service-activator input-channel="output" method="handleMessage" ref="mqttLogger" /> <bean id="mqttLogger" class="com.iot.device.mqtt.MqttReciever" /> <int:service-activator input-channel="errorChannel" ref="errorMessageLogger" method="logError" /> <bean id="errorMessageLogger" class="com.iot.device.mqtt.ErrorMessageLogger" />
解决 无用评论 打赏 举报
悬赏问题
- ¥15 多电路系统共用电源的串扰问题
- ¥15 shape_predictor_68_face_landmarks.dat
- ¥15 slam rangenet++配置
- ¥15 有没有研究水声通信方面的帮我改俩matlab代码
- ¥15 对于相关问题的求解与代码
- ¥15 ubuntu子系统密码忘记
- ¥15 信号傅里叶变换在matlab上遇到的小问题请求帮助
- ¥15 保护模式-系统加载-段寄存器
- ¥15 电脑桌面设定一个区域禁止鼠标操作
- ¥15 求NPF226060磁芯的详细资料