本文介绍如何在 Spring 框架下用消息队列 RocketMQ 版收发消息。

背景信息

消息队列 RocketMQ 版支持以下消息类型的生产者和消费者与 Spring 集成:
  • 普通消息的生产者和消费者
  • 事务消息的生产者和消费者
  • 顺序消息的生产者和消费者

参数说明

与 Spring 集成中所需配置的参数如下所示。

参数 说明
GROUP_ID 您在控制台创建的 Group ID,用于对消费者或生产者实例进行分类。详情请参见名词解释
AccessKey 阿里云身份验证 AccessKey ID,在阿里云用户信息管理控制台获取。
SecretKey 阿里云身份验证 AccessKey Secret,在阿里云用户信息管理控制台获取。
NAMESRV_ADDR 设置 TCP 接入域名,进入控制台的实例详情页面的 TCP 协议客户端接入点区域查看。
expression 消息过滤表达式,例如 “TagA||TagB”,说明消费者订阅了带有 TagA 和 Tag B 两种 Tag 的消息。详情请参见订阅消息

Spring 框架下支持的更多配置参数请参见 Java SDK 接口和参数说明

Demo 下载

您可以通过以下链接获取相关 Demo: