OpenStack使用RabbitMQ作為消息傳遞系統(tǒng)。為此有多個(gè)交換和隊(duì)列。我發(fā)現(xiàn)用于消息傳輸?shù)拿麨椤?topic”類(lèi)型的名為“ nova”的交換。Exchange使用路由鍵將郵件路由到隊(duì)列（http://www.rabbitmq.com/tutorials/amqp-concepts.html）。 （位于http://www.rabbitmq.com/img/tutorials/intro/hello-world-example-routing.png的有用圖片-信譽(yù)不足，無(wú)法在此處發(fā)布） OpenStack中有多個(gè)隊(duì)列，例如計(jì)算，證書(shū)，網(wǎng)絡(luò)等。他們使用具有相同名稱(chēng)的路由密鑰。因此，我使用這些路由鍵創(chuàng)建了幾個(gè)新隊(duì)列，以將它們與處理消息的使用者綁定在一起。例如，存在一個(gè)名為“計(jì)算”的隊(duì)列，該隊(duì)列使用名為“計(jì)算”的路由鍵。我創(chuàng)建了使用相同路由鍵的新隊(duì)列“ my_compute”。正如我認(rèn)為的那樣，我會(huì)收到消息。我有一些連接交流的代碼，創(chuàng)建了隊(duì)列和使用者。def connect(params):connection = kombu.Connection(hostname=params['host'])exchange = kombu.entity.Exchange(name=params['exchange_name'],                                 type=params['exchange_type'],                                 durable=params['exchange_durable'],                                 auto_delete=params['exchange_auto_delete'],                                 internal=params['exchange_internal'])queue_list = []for queue in params['queues_params']:queue_list.append(kombu.messaging.Queue(name=queue['name'],                                        exchange=exchange,                                        routing_key=queue['routing_key'],                                        channel=connection.channel(),                                        durable=queue['durable'],                                        auto_delete=queue['auto_delete']))consumer = kombu.messaging.Consumer(channel=connection.channel(),                                    queues=queue_list,                                     no_ack=True,                                    callbacks=[self._process_message])consumer.consume()return connection工作正常 但是我只收到網(wǎng)絡(luò)隊(duì)列的消息。我不知道還有其他消息，但看起來(lái)好像還有。我對(duì)嗎？還是出了什么問(wèn)題？還有其他消息，我該如何獲??？