消費者代碼如下
@Component
@RocketMQMessageListener(
topic = "topicTest",
consumerGroup = "consumer-group"
)
public class consumer implements RocketMQListener<String> {
private Logger logger = LoggerFactory.getLogger(getClass());
@Override
public void onMessage(String s) {
logger.info("[onMessage][執行緒編號:{} 訊息內容：{}]", Thread.currentThread().getId(), s);
}
}
生產者發送訊息部分如下
@Test
void contextLoads() {
rocketMQTemplate.convertAndSend("topicTest", "hello springboot rocketmq");
System.out.println("send success");
}
消費者是這么寫的，然后生產者發送訊息，消費者怎么都接受不到訊息，是什么原因呢
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/77597.html
標籤：Java EE
上一篇：json回傳格式的問題