springboot-rocketmq批量消息

提供者：

@RestController
@RequestMapping("/demo")
public class Producer {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@GetMapping("/send")
public String send(){
List<Message<User>> msgs = new ArrayList<>();
for (int i = 0; i < 10; i++) {
msgs.add(MessageBuilder.withPayload(new User("用户:"+i,18,1,"哈哈")).build());
}
SendResult sr = rocketMQTemplate.syncSend("topic1:tag1", msgs, 60000);
System.out.println(sr);
return "success";
}
}

消费者：

@Service
//监听 topic 为 topic1 并且 组为 group1 并且 tag 为 tag1 的消息
@RocketMQMessageListener(topic = "topic1",consumerGroup = "group1",selectorExpression = "tag1")
public class Consumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println(message);
}
}

最后

以上就是自信指甲油为你收集整理的springboot-rocketmq批量消息的全部内容，希望文章能够帮你解决springboot-rocketmq批量消息所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。