fly_air
独来独往mk
采纳率0%
2017-11-09 05:12 阅读 3.7k

Mqtt 整合 spring mvc, 启动时候的时候可以链接,但是接收消息就失去链接

异常信息:
1. 启动的时候,控制台会打印出close, 这是outbond通道的类打印出来的
2. 我模拟product发送一条数据,tomcat控制台输出异常信息
ERROR inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:宸叉柇寮?繛鎺? retrying...
ERROR inbound.MqttPahoMessageDrivenChannelAdapter - Lost connection:宸叉柇寮?繛鎺? retrying...
接收到信息ooo:close

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享

4条回答 默认 最新

  • xiaoyan_master xiaoyan_master 2017-11-09 08:23

    https://repo.eclipse.org/content/repositories/paho-releases/org/eclipse/paho/org.eclipse.paho.ui.app/1.0.2/

    我用的win7 64位系统,选择 org.eclipse.paho.ui.app-1.0.2-win32.win32.x86_64.zip 下载。 试试这个测试工具,还有就是mqtt服务器有很多 没人知道你用的是什么

    点赞 1 评论 复制链接分享
  • xiaoyan_master xiaoyan_master 2017-11-09 08:32

    你是否开启了相应的账号密码插件 这个密码不是服务器的登录密码 总之你先用这个工具测试一下 你就明白这些参数的意思了

    点赞 1 评论 复制链接分享
  • fly_air 独来独往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" />
    
    点赞 评论 复制链接分享
  • qq_38533859 1162210866 2019-02-22 15:42

    这个是发送端和接收端id重复导致的

    点赞 评论 复制链接分享

相关推荐