Python如何使用RabbitMQ的消息

示例

从导入库开始。

from amqpstorm import Connection

使用消息时，我们首先需要定义一个函数来处理传入的消息。这可以是任何可调用的函数，并且必须采用一个消息对象或一个消息元组（取决于中to_tuple定义的参数start_consuming）。

除了处理传入消息中的数据外，我们还必须确认或拒绝消息。这很重要，因为我们需要让RabbitMQ知道我们已正确接收并处理了该消息。

def on_message(message):
    """This function is called on message received.

    :param message: Delivered message.
    :return:
    """
    print("Message:", message.body)

    # 确认我们已成功处理该消息。
    message.ack()

    # 拒绝邮件。
    # message.reject()

    # 拒绝邮件，然后将其放回队列中。
    # message.reject（requeue = True）

接下来，我们需要建立与RabbitMQ服务器的连接。

connection = Connection('127.0.0.1', 'guest', 'guest')

之后，我们需要建立一个频道。每个连接可以有多个通道，通常在执行多线程任务时，建议（但不是必需）每个线程一个。

channel = connection.channel()

设置好频道后，我们需要让RabbitMQ知道我们要开始使用消息。在这种情况下，我们将使用先前定义的on_message函数来处理所有消耗的消息。

我们将在RabbitMQ服务器上侦听的队列将成为simple_queue，并且我们还告诉RabbitMQ，一旦处理完所有传入消息，我们将对其进行确认。

channel.basic.consume(callback=on_message, queue='simple_queue', no_ack=False)

最后，我们需要启动IO循环以开始处理RabbitMQ服务器传递的消息。

channel.start_consuming(to_tuple=False)