在RabbitMQ上通信MQTT和AMQP

我有问题与mqtt和amqp通信

重点是:

我有一个使用MQTT插件的RabbitMQ实例,我也有一个mqtt生产者/消费者和一个AMQP生产者/消费者(在symfony RabbitMqBundle上使用php-amqplib)

RabbitMQ文档说所有MQTT主题都适用于amq.topic交换。

我的情况:

MQTT消费者/生产者订阅/主题/测试主题AMQP消费者在amq.topic交换,在路由关键.topic.test(我不知道这个,但兔子替换/ for。关于mqtt主题)

AMQP使用MQTT消息:OK AMQP产生消息给MQTT:NOT MQTT to MQTT:OK AMQP to AMQP:OK

我的mqtt pub / sub是一个JS客户端(在一些测试中)我的AMQP pub / sub的php / symfony

OBS:

如果我去了RabbitMQ,在amq.topic交换,.topic.test队列和发送消息,mqtt客户端收到权利

问题出在PHP客户端

old_sound_rabbit_mq:
    connections:
        default:
            host:     '%queue_host%'
            port:     '%queue_port%'
            user:     '%queue_user%'
            password: '%queue_password%'
            vhost:    '/'
            lazy:     false
            connection_timeout: 30
            read_write_timeout: 30
            keepalive: false
            heartbeat: 0
            #use_socket: true
    producers:
        search_driver:
            connection:       default
            exchange_options: {name: 'amq.topic', type: topic}
            queue_options:    {routing_keys: ['.topic.test']}
    consumers:
        search_driver:
            connection:       default
            exchange_options: {name: 'amq.topic', type: topic}
            queue_options:    {routing_keys: ['.topic.test']}
            callback:         my.consumer.service

似乎这不会发生在其他语言和库中:http://blog.airasoul.io/the-internet-of-things-with-rabbitmq-node-js-mqtt-and-amqp/

链接地址: http://www.djcxy.com/p/34175.html

上一篇: Comunication beetwen MQTT and AMQP on RabbitMQ

下一篇: Could this RabbitMQ code cause a memory leak