springboot集成RocketMQ消息队列demo源码案例演示

package com.boot.rocketmq.producer; import com.boot.rocketmq.entity.MqMsg; import com.fasterxml.jackson.databind.json.JsonMapper; import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; /** * 消息生产接口 * @author 公众号:知了一笑 * @since 2023-07-30 16:17 */ @RestController public class ProducerWeb { private static final Logger log = LoggerFactory.getLogger(ProducerWeb.class); @Autowired private RocketMQTemplate rocketMqTemplate; @GetMapping("/send/msg1") public String sendMsg1 (){ try { // 构建消息主体 JsonMapper jsonMapper = new JsonMapper(); String msgBody = jsonMapper.writeValueAsString(new MqMsg(1,"boot_mq_msg")); // 发送消息 rocketMqTemplate.convertAndSend("boot-mq-topic",msgBody); } catch (Exception e) { e.printStackTrace(); } return "OK" ; } @Autowired private DefaultMQProducer defaultMqProducer ; @GetMapping("/send/msg2") public String sendMsg2 (){ try { // 构建消息主体 JsonMapper jsonMapper = new JsonMapper(); String msgBody = jsonMapper.writeValueAsString(new MqMsg(2,"boot_mq_msg")); // 构建消息对象 Message message = new Message(); message.setTopic("boot-mq-topic"); message.setTags("boot-mq-tag"); message.setKeys("boot-mq-key"); message.setBody(msgBody.getBytes()); // 发送消息，打印日志 SendResult sendResult = defaultMqProducer.send(message); log.info("msgId:{},sendStatus:{}",sendResult.getMsgId(),sendResult.getSendStatus()); } catch (Exception e) { e.printStackTrace(); } return "OK" ; } }