activemq 怎样创建MQTT的TOPIC

问题描述

现在想问一下怎样用activemq连接mqtt协议进行消息TOPIC的创建，我试着用如下代码进行连接，好像不行。程序会卡在connection.start();这里，不知道有没有人做过这样的。给点提示也行，谢谢！ConnectionFactoryconnectionFactory=newActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD,"failover:(mqtt://1.1.1.11:1883)");//JMS客户端到JMSProvider的连接Connectionconnection=connectionFactory.createConnection();connection.start();

解决方案

解决方案二：
请求不到路径，等一会看看超时报错。端口默认1883没错，你的ip是不是有问题
解决方案三：
我也是遇到这样的问题啊！求大神解答啊！！！！！！！！！！但是，我发现;failover:(tcp://10.135.23.102:61617,tcp://10.135.23.102:61618)"),用tcp这样写是可以的，mqtt就不行
解决方案四：
卡在那应该是等待响应可能是访问不到这个路径，过一会儿就超时了
解决方案五：
引用2楼zlj526的回复:

我也是遇到这样的问题啊！求大神解答啊！！！！！！！！！！但是，我发现;failover:(tcp://10.135.23.102:61617,tcp://10.135.23.102:61618)"),用tcp这样写是可以的，mqtt就不行

我也是,你解决了吗
解决方案六：
引用4楼lwphk的回复:

Quote: 引用2楼zlj526的回复:

我也是遇到这样的问题啊！求大神解答啊！！！！！！！！！！但是，我发现;failover:(tcp://10.135.23.102:61617,tcp://10.135.23.102:61618)"),用tcp这样写是可以的，mqtt就不行

我也是,你解决了吗

后来就用的tcp这样写的