springboot中使用rabbitt的详细方法
更新时间：2023年05月25日 15:09:40 作者：我想要她
这篇文章主要介绍了springboot中使用rabbitt,通过本文学习让我们了解如何在Spring Boot中使用RabbitMQ，并使用不同的交换机和队列类型以及消息确认模式，需要的朋友可以参考下
RabbitMQ的示例，涉及到Direct、Fanout、Topic和Headers交换机以及普通队列、延迟队列和死信队列
在pom.xml文件中添加以下依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>配置RabbitMQ连接信息,在application.properties文件中添加以下配置：
spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest
创建消息队列
创建一个普通的Direct交换机和队列：
@Configuration
public class RabbitMQConfig {
@Bean
public Queue queue() {
return new Queue("directQueue", false);
}
@Bean
public DirectExchange directExchange() {
return new DirectExchange("directExchange");
}
@Bean
public Binding binding(Queue queue, DirectExchange directExchange) {
return BindingBuilder.bind(queue).to(directExchange).with("directRoutingKey");
}
}创建一个Fanout交换机和队列：
@Configuration
public class RabbitMQConfig {
@Bean
public Queue queueA() {
return new Queue("fanoutQueueA", false);
}
@Bean
public Queue queueB() {
return new Queue("fanoutQueueB", false);
}
@Bean
public FanoutExchange fanoutExchange() {
return new FanoutExchange("fanoutExchange");
}
@Bean
public Binding bindingA(Queue queueA, FanoutExchange fanoutExchange) {
return BindingBuilder.bind(queueA).to(fanoutExchange);
}
@Bean
public Binding bindingB(Queue queueB, FanoutExchange fanoutExchange) {
return BindingBuilder.bind(queueB).to(fanoutExchange);
}
}创建一个Topic交换机和队列：
@Configuration
public class RabbitMQConfig {
@Bean
public Queue queueA() {
return new Queue("topicQueueA", false);
}
@Bean
public Queue queueB() {
return new Queue("topicQueueB", false);
}
@Bean
public TopicExchange topicExchange() {
return new TopicExchange("topicExchange");
}
@Bean
public Binding bindingA(Queue queueA, TopicExchange topicExchange) {
return BindingBuilder.bind(queueA).to(topicExchange).with("topic.key.*");
}
@Bean
public Binding bindingB(Queue queueB, TopicExchange topicExchange) {
return BindingBuilder.bind(queueB).to(topicExchange).with("topic.#");
}
}创建一个Headers交换机和队列：
@Configuration
public class RabbitMQConfig {
@Bean
public Queue queue() {
return new Queue("headerQueue", false);
}
@Bean
public HeadersExchange headersExchange() {
return new HeadersExchange("headerExchange");
}
@Bean
public Binding binding(Queue queue, HeadersExchange headersExchange) {
Map<String, Object> headers = new HashMap<>();
headers.put("header1", "value1");
headers.put("header2", "value2");
return BindingBuilder.bind(queue).to(headersExchange).whereAll(headers).match();
}
}创建一个延迟队列和死信队列：
@Configuration
public class RabbitMQConfig {
@Bean
public Queue delayQueue() {
Map<String, Object> args = new HashMap<>();
args.put("x-message-ttl", 10000); // 消息过期时间为10秒
args.put("x-dead-letter-exchange", "deadLetterExchange");
args.put("x-dead-letter-routing-key", "deadLetterRoutingKey");
return new Queue("delayQueue", false, false, false, args);
}
@Bean
public Queue deadLetterQueue() {
return new Queue("deadLetterQueue", false);
}
@Bean
public DirectExchange directExchange() {
return new DirectExchange("directExchange");
}
@Bean
public DirectExchange deadLetterExchange() {
return new DirectExchange("deadLetterExchange");
}
@Bean
public Binding binding(Queue delayQueue, DirectExchange directExchange) {
return BindingBuilder.bind(delayQueue).to(directExchange).with("delayRoutingKey");
}
@Bean
public Binding deadLetterBinding(Queue deadLetterQueue, DirectExchange deadLetterExchange) {
return BindingBuilder.bind(deadLetterQueue).to(deadLetterExchange).with("deadLetterRoutingKey");
}
}发送和接收消息
@Service
public class RabbitMQService {
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("directExchange", "directRoutingKey", message);
}
@RabbitListener(queues = "directQueue")
public void receiveDirectMessage(String message) {
System.out.println("Received message from directQueue: " + message);
}
public void sendFanoutMessage(String message) {
rabbitTemplate.convertAndSend("fanoutExchange", "", message);
}
@RabbitListener(queues = "fanoutQueueA")
public void receiveFanoutMessageA(String message) {
System.out.println("Received message from fanoutQueueA: " + message);
}
@RabbitListener(queues = "fanoutQueueB")
public void receiveFanoutMessageB(String message) {
System.out.println("Received message from fanoutQueueB: " + message);
}
public void sendTopicMessage(String message) {
rabbitTemplate.convertAndSend("topicExchange", "topic.key.message", message);
}
@RabbitListener(queues = "topicQueueA")
public void receiveTopicMessageA(String message) {
System.out.println("Received message from topicQueueA: " + message);
}
@RabbitListener(queues = "topicQueueB")
public void receiveTopicMessageB(String message) {
System.out.println("Received message from topicQueueB: " + message);
}
public void sendHeaderMessage(String message) {
MessageProperties messageProperties = new MessageProperties();
messageProperties.setHeader("header1", "value1");
messageProperties.setHeader("header2", "value2");
Message msg = MessageBuilder.withBody(message.getBytes()).andProperties(messageProperties).build();
rabbitTemplate.send("headerExchange", "", msg);
}
@RabbitListener(queues = "headerQueue")
public void receiveHeaderMessage(Message message) {
System.out.println("Received message from headerQueue: " + new String(message.getBody()));
}
public void sendDelayMessage(String message) {
rabbitTemplate.convertAndSend("directExchange", "delayRoutingKey", message);
}
@RabbitListener(queues = "deadLetterQueue")
public void receiveDeadLetterMessage(String message) {
System.out.println("Received message from deadLetterQueue: " + message);
}
}消息确认模式
在RabbitMQ中，消息确认模式有两种：自动确认和手动确认。自动确认是指当消息被成功接收时，RabbitMQ会自动确认消息。手动确认是指当消费者成功处理消息后，显式地向RabbitMQ发送确认消息。 1 使用手动确认模式：
@Configuration
public class RabbitMQConfig {
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
return factory;
}
}@Service
public class RabbitMQService {
@RabbitListener(queues = "directQueue")
public void receiveDirectMessage(Message message, Channel channel) throws IOException {
try {
System.out.println("Received message from directQueue: " + new String(message.getBody()));
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
} catch (Exception e) {
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
}
}
}在上述代码中，我们使用了MANUAL（手动确认）模式，并在消息处理成功后使用channel.basicAck()方法显式地确认消息。如果发生任何异常，我们使用channel.basicNack()方法拒绝消息并重新加入队列。
希望这个示例能够帮助您了解如何在Spring Boot中使用RabbitMQ，并使用不同的交换机和队列类型以及消息确认模式。
到此这篇关于springboot中使用rabbitt的文章就介绍到这了,更多相关springboot使用rabbitt内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
setnx、Redisson、RedLock 都可以实现分布式锁,从易到难得排序为：setnx < Redisson < RedLock,本文为大家整理了三种方法的实现,希望对大家有所帮助2023-11-11
本文主要介绍了两个大的部分，第一部分通过图解的方式讲解BM算法，第二部分则代码实现一个简易的BM算法，感兴趣的小伙伴可以学习一下2022-05-05
这篇文章主要介绍了JAVA流程控制语句的的相关资料，文中讲解非常细致，代码帮助大家更好的理解和学习，感兴趣的朋友可以了解下2020-06-06
这篇文章主要给大家介绍了关于JDK中反模式接口常量的相关资料,文中通过实例代码介绍的非常详细,对大家学习或者使用jdk具有一定的参考学习价值,需要的朋友可以参考下2022-01-01
下面小编就为大家分享一篇Java创建二叉搜索树,实现搜索,插入,删除的操作实例，具有很好的参考价值，希望对大家有所帮助2017-12-12
这篇文章主要介绍了IDEA中java断言assert语法详解,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-04-04
这篇文章主要为大家介绍了Java批量向PDF文件中添加图像水印实现细节，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-05-05
在SpringBoot项目中使用Java8函数式接口的方法示例
在Spring Boot项目中,Java 8 的函数式接口广泛用于实现各种功能,如自定义配置、数据处理等,函数式接口在Spring Boot中非常有用,本文展示了在SpringBoot项目中使用Java8的函数式接口的方法示例,需要的朋友可以参考下2024-03-03
这篇文章主要介绍了SpringBoot 文件或图片上传与下载功能的实现,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-02-02
这篇文章主要介绍了jvm对象的创建和分配的相关资料，帮助大家更好的理解和学习使用Java，感兴趣的朋友可以了解下，希望能够给你带来帮助2021-08-08
最新评论