1

Android アプリケーションを ActiveMQ サーバーに接続しようとしています。私のサーバーはすでにJMSを使用してActiveMQサーバーと通信しているため、私はActiveMQを使用しているため、AndroidクライアントをJMSブローカーに接続することは非常に有益です。

次のページに従って ActiveMQ で MQTT を有効にしました: http://activemq.apache.org/mqtt.html ダウンロードした MQTT クライアント (IBM MQTT クライアントまたは Paho MQTT クライアント) で小さな問題が発生しました。 「mqtt://」の URL プレフィックスを認識できないため、代わりに tcp を使用しようとしました。これは、activemq.xml で構成がどのように見えるかです。

<transportConnectors>
    <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600"/>
    <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;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

助言がありますか？ありがとう！

4

1 に答える 1

2

You haven't configured the MQTT transportConnector properly. Try this:

<transportConnectors>
  <transportConnector name="mqtt" uri="mqtt://localhost:1883"/>
</transportConnectors>

Notice that in yours you used the TCP uri prefix.

于 2013-09-05T10:13:19.530 に答える