<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.1.0</version> </dependency>2. 配置RocketMQ
# application.properties rocketmq.name-server=127.0.0.1:9876 rocketmq.producer.group=my-producer-group或者
# application.yml rocketmq: name-server: 127.0.0.1:9876 producer: group: my-producer-group3. 创建生产者和消费者
import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @Service public class MessageProducer { @Autowired private RocketMQTemplate rocketMQTemplate; // 堆代码 duidaima.com public void sendMessage(String topic, String message) { rocketMQTemplate.convertAndSend(topic, message); } }消费者
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.core.RocketMQListener; import org.springframework.stereotype.Service; @Service @RocketMQMessageListener(topic = "test-topic", consumerGroup = "my-consumer-group") public class MessageConsumer implements RocketMQListener<String> { @Override public void onMessage(String message) { System.out.println("Received message: " + message); } }优缺点分析
容错性:RocketMQ具有很好的容错性,可以在节点故障时自动恢复。这有助于确保应用的稳定性和可靠性。