You need to enable JavaScript to run this app.
文档中心
文档控制台
注册
消息队列 RabbitMQ版

消息队列 RabbitMQ版

复制全文
下载 pdf
SDK 参考
准备工作
复制全文
下载 pdf
准备工作

通过开源 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 协议)

最近更新时间:2024.01.26 16:09:35
这个页面对您有帮助吗?
有用
有用
无用
无用