RabbitMQ使用Python从特定队列发送和接收

问题描述

我正在开发可在项目中使用的代理。这个想法是发布者将数据发送给代理，然后代理对数据进行分类，消费者从该特定队列接收消息。

rabbitmq 的架构：

[我的代理架构1

这个想法是第一个交换器有一个队列绑定，接收所有通过的消息。第二个交换器将消息分类并将它们发送到正确的队列。

例如，我只想将 .png 之类的图像发送到队列 4。

class Image(object):
    __slots__ = ["filename"]

def __init__(self,filename):
    self.filename = filename


def get(self):
    with open(self.filename,"rb") as f:
        data = f.read()
    return data
........
image = Image(filename="/xxx/xxx/xxx/xxxx/test.png")
data = image.get 

现在，如果我发送诸如“program.py“name_of_queue”“some_message”之类的内容，我可以使用命令行将其发送到特定队列。但思路是，发布者传入的数据自动知道要发送数据到哪个队列，无需命令行输入。

{{1}}

这是发送图像的代码，但不确定如何将其发送到“队列 4”并从该特定队列接收。

谁能帮帮我？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）