Ist MQTT-support-Warteschlange in ActiveMQ?

Ich bin neu TFT dieses und das lernen über das Protokoll. Beim Lesen auf wiki über MQTT. die erste Zeile "MQTT[1] ist eine publish-subscribe-basierte "light weight" - messaging-Protokoll für den Einsatz auf der TCP/IP-Protokoll."

Bedeutet dies, dass MQTT unterstützen nur Thema und nicht die Unterstützung oder Arbeit mit Warteschlange?

Deshalb, weil Auch ich checke mit den verfügbaren Client-API (fusesource und paho). Ich dint gefunden-client-API für Queue.

InformationsquelleAutor Krutik | 2014-07-03

  1. 2

    ActiveMQ unterstützt das MQTT und Sie können viel Lesen hier :

    http://activemq.apache.org/mqtt.html

    In den letzten Wochen ist die Abkürzung für Message Queue Telemetry Transport ist geändert in MQ Telemetry Transport, da MQTT nicht Warteschlange Konzept ! 🙂

    Als @hardillb sagte, publish und subscribe-Vorgänge ausgeführt werden, die auf Themen.

    Einem Konzept der "Warteschlange" ist nur verwirklicht, wenn Sie das erweiterte "clean-session" , false features, die impliziert, broker, sparen, Nachrichten, veröffentlicht zu einem Thema, wo ein client offline ist, so dass, wenn der client wieder online, werden die Nachrichten empfangen.
    Aber diese Umsetzung ist strikt auf die broker (nicht notwendig mit einer Warteschlange).

    Schrieb ich die folgenden kostenlosen ebook (fokussiert auf Microsoft techonologies) aber das Kapitel 3 widmet sich der MQTT-Protokoll selbst.

    http://www.embedded101.com/DevelopM2MIoTDevicesEbook.aspx

    Paolo.

    InformationsquelleAutor ppatierno

  2. 2

    Ja, MQTT ist Thema, es gibt keine Warteschlange-Unterstützung

    InformationsquelleAutor hardillb

  3. 1

    MQTT nicht unterstützt-queue, wenn Sie möchten, implementieren Sie Queue mit ActiveMQ verwenden STOMP-Protokoll, überprüfen Sie diesen link
    https://github.com/asantos2000/RabbitMQGozirraStompAndroid

    wenn Sie verwenden möchten Thema nur QUEUE_NAME= /Thema/nameof_topic und wenn Sie verwenden möchten Warteschlange verwendet Ziel QUEUE_NAME=/queue/nameof_queue

    filter-Nachricht in der Warteschlange hinzufügen Selektoren

     Map<String,String> header=new HashMap<String, String>();
 header.put("selector","(title = 'selector_name')");
con.subscribe(QUEUE_NAME, new Listener() {
                @Override
                public void message(Map header, String body ) {
                    Log.d(TAG,"onMessage()");
                    Log.d(TAG,"message is " + body);
                    Log.d(TAG,"header is " + header.toString());
                    message = "\n("+ counterReceive +")<-- " + body;
                    myHandler.post(myRunnable);
                    counterReceive++;
                }
            },header);

    erhalten Sie nur die Meldung, die header enthalten Ihre selector name

    InformationsquelleAutor Dayanand Waghmare

  4. 0

    MQTT hat kein Verständnis für Warteschlangen als pro JMS oder viele andere messaging-Systeme. MQTT versteht nur Themen, die veröffentlicht werden können und abonniert.

    Die Lösung kam ich zur Verwendung von ActiveMQ 5.13.1 wie Sie das MQTT-broker war, um ein composite-Thema, zu dem der MQTT-client gesendet wird. ActiveMQ abholen der Nachrichten geschrieben zu dem Thema und schreibt Sie in eine queue (oder mehrere Warteschlangen oder Themen) wie pro Ihre Konfiguration. Beachten Sie, dass das Thema Namen haben sich die Zeiten geändert durch Schrägstriche, also beispielsweise die Namen Thema in dem gegebenen Beispiel LOCAL.EC.T, wird LOCAL/EC/T. Dies galt zumindest für mein test-setup mit dem Eclipse-Paho-Client MQTTv3 1.0.2 und ich glaube, das ist ein MQTT-Implementierung detail.

    ${ACTIVEMQ_HOME}/conf/activemq.xml -Konfiguration.

    <beans>
    <broker>
        ...
        <destinationInterceptors>
            <virtualDestinationInterceptor>
                <virtualDestinations>
                    <compositeTopic name="LOCAL.EC.T">
                        <forwardTo>
                            <queue physicalName="LOCAL.EC.Q.1" />
                            <queue physicalName="LOCAL.EC.Q.2" />                       
                        </forwardTo>
                    </compositeTopic>
                </virtualDestinations>
            </virtualDestinationInterceptor>
        </destinationInterceptors>
        ...
    </broker>
</beans>

    Dies ist die Referenz, die ich verwendet.

    Dieser Kommentar wäre sinnvoller gewesen, wenn Sie tauschte diese um aus 'compositeTopic' zu 'compositeQueue' mit forwardTo 'Thema' statt 'queue'... Das wäre eigentlich das problem der Zuordnung eines ActiveMQ-queue zu einem MQTT Thema.
    Die Richtung wurde nie angegeben. Das Beispiel gegeben Karten ein MQTT Thema, die eine ActiveMQ-queue. Wenn Sie brauchen, im Gegenteil, dann konfigurieren Sie Sie entsprechend. Ich habe nicht diese Einrichtung nicht mehr, so kann ich nicht überprüfen, was das sein könnte, oder ob mein Beispiel ist unidirektional (ich denke, es ist).

    InformationsquelleAutor mookins

Schreibe einen Kommentar