为Spring-boot提供消息队列能力的starter, 并提供了VM线程的轻量级实现。
- Consumer
@Consumer(topic = CONSUMER_TOPIC, id = CUSTOM_CONSUMER_ID)
public void consumerMessage(Message message) {
consumerRecordMap.get(CUSTOM_CONSUMER_ID).add(message);
}- Producer
@Autowired
private DefaultProducer<String> producer;
public void sendMessage(){
producer.send(new Message<>(CUSTOM_TOPIC, "This is a message!"));
}