博客

RabbitMQ支持哪些协议？

  • Post category:云计算

RabbitMQ是一个跨平台的消息代理，它支持多种协议。以下是RabbitMQ支持的协议的完整攻略：

  1. 支持的协议

RabbitMQ支持多种协议，包括但不限于：

  • AMQP（Advanced Message Queuing Protocol）
  • STOMP（Simple Text Oriented Messaging Protocol）
  • MQTT（Message Queuing Telemetry Transport）
  • HTTP（Hypertext Transfer Protocol）

这些协议都有相应的RabbitMQ插件，可以方便地与RabbitMQ进行交互。

  1. 示例说明

以下是使用AMQP和STOMP协议与RabbitMQ进行交互的示例说明：

AMQP示例：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

message = 'Hello World!'
channel.basic_publish(exchange='', routing_key='hello', body=message)
print(" [x] Sent '{}'".format(message))

connection.close()

在上面的示例中，我们使用Python客户端库创建了一个名为“hello”的队列，并向该队列发送了一条消息。这个示例使用了AMQP协议。

STOMP示例：

import stomp

conn = stomp.Connection([('localhost', 61613)])
conn.start()
conn.connect()

conn.send(body='Hello World!', destination='/queue/hello')

conn.disconnect()

在上面的示例中，我们使用Python客户端库向名为“hello”的队列发送了一条消息。这个示例使用了STOMP协议。

总之，RabbitMQ支持多种协议，包括AMQP、STOMP、MQTT和HTTP等。这些协议都有相应的RabbitMQ插件，可以方便地与RabbitMQ进行交互。

Tags: