我正在尝试将一个Android应用程序连接到一个ActiveMQ服务器。我使用的是ActiveMQ,因为我的服务器已经使用JMS与ActiveMQ服务器进行了通信,所以将android连接到JMS将非常有益。
我在ActiveMQ中启用了MQTT,下面是:http://activemq.apache.org/mqtt.html和我下载的任何MQTT客户端(IBM客户端或Paho MQTT客户端)都有一个小问题,所以我尝试使用tcp。在activemq.xml中,配置是这样的:
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600"/>
<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireformat.maxFrameSize=104857600"/>
<transportConnector name="mqtt" uri="tcp://0.0.0.0:1883"/>
</transportConnectors>
当我尝试使用任何mqtt客户端示例(如:http://mosquitto.org/2011/11/android-mqtt-example-project/ )连接时,我无法连接到ActiveMQ,并且在服务器端得到一个错误:
2013-09-05 12:34:17,550 | WARN | Transport Connection to: tcp://192.168.0.111:42148 failed: java.io.IOException: Unknown data type: 77 | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///192.168.0.111:42148@1883
有什么建议吗?谢谢!
发布于 2013-09-05 10:13:19
您还没有正确配置MQTT transportConnector。试试这个:
<transportConnectors>
<transportConnector name="mqtt" uri="mqtt://localhost:1883"/>
</transportConnectors>
注意,在您的代码中使用了TCP
uri前缀。
https://stackoverflow.com/questions/18632968
复制相似问题