You need to enable JavaScript to run this app.
导航

准备工作

最近更新时间2024.01.26 16:09:35

首次发布时间2022.01.28 15:17:02

通过开源 SDK 接入火山引擎消息队列 RabbitMQ版收发消息前,您需按照本文提供的步骤来准备开发环境。

步骤 1 开通服务

接入火山引擎消息队列 RabbitMQ版之前,需要在控制台中开通服务并创建 RabbitMQ 实例。消息队列 RabbitMQ版提供多种计算规格和存储规格供您选择,请依据业务需求合理选择实例规格。
详细说明请参考创建实例

步骤 2 获取实例信息

创建实例之后,可以在实例详情页查看该实例的服务访问相关信息,服务访问区域主要展示该实例的各种访问方式,例如 VPC 下 Web UI 的访问地址等等。通过 Web UI 访问地址,可以登录开源 RabbitMQ 控制台创建资源并配置权限;通过开源 Client SDK 收发消息时,需要在代码中传入 AMQP 接入点等参数。
请根据业务需求,安全保存相关接入点的信息。

说明

火山引擎消息队列 RabbitMQ版提供 AMQP 协议下收发消息的示例代码供您参考,您也可以自行实现其他协议下的业务逻辑。
访问 MQTT 接入点或 Web MQTT 接入点之前,请确认已在控制台中开启了 rabbitmq_mqttrabbitmq_web_mqtt 插件。开启插件的详细操作请参考插件管理

步骤 3 创建资源

使用 RabbitMQ 实例收发消息前,您需要提前配置好 Vhost、用户,并创建 Exchange、Queue 等资源。
请勿直接使用 Web UI 展示的默认管理员账户进行消息的收发,因为默认的管理员只配置了管控操作的权限,未配置消息读写的权限。
您需要为进行生产和消费的用户绑定目标 Vhost,否则在生产或消费时将会出现类似access to vhost '/' refused for user 'xxx'无权连接的报错信息。如何为用户绑定 Virtual Host,请参见绑定用户和 Vhost
您可以通过以下方式创建 Exchange、Queue 等资源。

  • 访问开源 RabbitMQ Web UI 控制台,通过控制台操作创建资源并配置权限。
  • 通过接口访问 Web UI 接入点,通过 HTTP 接口创建资源并配置权限。详细操作步骤请参考 RabbitMQ Management HTTP API
  • 通过 Client SDK 创建。请根据使用的编程语言在 SDK 列表中查看对应示例代码。

步骤4 服务接入

调用 Client SDK 进行消息收发。

  • 请根据业务的协议类型,在控制台中复制对应的 AMQP 或 MQTT 接入点进行相关的参数配置。
  • 在消息收发过程中,请使用长连接,避免在每条消息的收发过程中创建连接,否则会造成大量不必要的资源消耗,甚至引起服务端 SYN Flood 防护。

后续步骤

使用 Client SDK 进行消息收发。对于 Java 语言实现消息收发的示例代码,您可以参考 Java SDKJava SDK(MQTT 协议)