Spring Boot+RocketMQ 实现多实例分布式环境下的事件驱动
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class EventProducer {
@Autowired
private RocketMQTemplate rocketMQTemplate;
public void sendEvent(String topic, String event) {
rocketMQTemplate.convertAndSend(topic, event);
}
}这段代码展示了如何使用Spring Boot和RocketMQ进行消息发送。EventProducer服务类注入了RocketMQTemplate，并提供了一个sendEvent方法用于发送消息到指定的topic。在实际应用中，你可以根据实际情况将topic和event作为参数传递进来。
评论已关闭