在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