<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.2.2</version><exclusions><exclusion><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId></exclusion><exclusion><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-acl</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.9.7</version></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-acl</artifactId><version>4.9.7</version></dependency>
server:port: 8082#rocketmq配置信息rocketmq:# tdmq-rocketmq服务接入地址name-server: rocketmq-xxx.rocketmq.ap-bj.public.tencenttdmq.com:8080# 生产者配置producer:# 生产者组名group: group111# 角色密钥access-key: eyJrZXlJZC....# 已授权的角色名称secret-key: admin# 消费者公共配置consumer:# 角色密钥access-key: eyJrZXlJZC....# 已授权的角色名称secret-key: admin# 用户自定义配置producer1:topic: testdev1consumer1:group: group111topic: testdev1subExpression: TAG1consumer2:group: group222topic: testdev1subExpression: TAG2
参数 | 说明 |
name-server | 集群接入地址,在集群基本信息中,根据使用需求,使用不同的内网/公网接入地址 |
group | 生产者 Group 的名称,在控制台 Group 页面复制。 |
secret-key | 角色名称,在 集群权限 页面复制 SecretKey 复制。 |
access-key | 角色密钥,在 集群权限 页面复制 accessKey 复制。 |
topic | Topic 的名称,在控制台 topic 页面复制。 |
subExpression | 用来设置消息的 TAG。 |
RcoketMQTemplate
。@Value("${rocketmq.producer1.topic}")private String topic; // topic名称@Autowiredprivate RocketMQTemplate rocketMQTemplate;
SendResult sendResult = rocketMQTemplate.syncSend(destination, message);/*------------------------------------------------------------------------*/rocketMQTemplate.syncSend(destination, MessageBuilder.withPayload(message).build())
/*** Description: 消息生产者*/@Servicepublic class SendMessage {// 需要使用topic全称,所以进行topic名称的拼接,也可以自己设置 格式:topic名称@Value("${rocketmq.producer1.topic}")private String topic;@Autowiredprivate RocketMQTemplate rocketMQTemplate;/*** 同步发送** @param message 消息内容* @param tags 订阅tags*/public void syncSend(String message, String tags) {// springboot不支持使用header传递tags,根据要求,需要在topic后进行拼接 formats: `topicName:tags`,不拼接标识无tagString destination = StringUtils.isBlank(tags) ? topic : topic + ":" + tags;SendResult sendResult = rocketMQTemplate.syncSend(destination,MessageBuilder.withPayload(message).setHeader(MessageConst.PROPERTY_KEYS, "yourKey") // 指定业务key.build());System.out.printf("syncSend1 to topic %s sendResult=%s %n", topic, sendResult);}}
@Service@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer1.group}", // 消费组,格式:group名称// 需要使用topic全称,所以进行topic名称的拼接,也可以自己设置 格式:topic名称topic = "${rocketmq.consumer1.topic}",selectorExpression = "${rocketmq.consumer1.subExpression}" // 订阅表达式, 不配置表示订阅所有消息)public class MessageConsumer implements RocketMQListener<String> {@Overridepublic void onMessage(String message) {System.out.println("Tag1Consumer receive message:" + message);}}
本页内容是否解决了您的问题?