- 博客(13)
- 收藏
- 关注
RSS订阅原创 Spring整合RabbitMQ-05-MessageConvert
消息转换器文章目录RabbitConfigMyMessageListenerDelegateOrderUserMyTextMessageConvertMyPngMesssageConvertMyPDFMessageConvertRabbitConfigpackage com.wyg.rabbitmq.springamqp;import com.wyg.rabbitmq.springamq...
2019-12-01 21:59:13
423
原创 Spring整合RabbitMQ-04-MessageListenerAdapter
文章目录RabbitConfigMyMessageListenerDelegate，自定义适配器RabbitConfigTest 单元测试RabbitConfigpackage com.wyg.rabbitmq.springamqp;import com.wyg.rabbitmq.springamqp.convert.MyPngMesssageConvert;import com.wyg...
2019-12-01 21:53:53
304
原创 Spring整合RabbitMQ-03-SimpleMessageListenerContainer
文章目录SimpleMessageListenerContainer代码单元测试SimpleMessageListenerContainer简单消息监听容器，这个类非常强大，我们可以对他进行很多设置，对于消息的配置项，这个类都可以满足；监听队列(多个对列),自动启动，自动声明功能设置事务特性，事务管理器，事务属性。事务容量(并发),是否开启事务，回滚消息等设置消费者的数量，最大最小数量...
2019-12-01 21:50:26
905
原创 Spring整合RabbitMQ-02-RabbitTemplate
文章目录RabbitTemplate，消息模板RabbitConfigRabbitConfigTestRabbitTemplate，消息模板发送消息的关键类，该类提供了丰富的发送消息的方法，包括可靠性投递的方法，回调监听消息接口ConfirmCallback,返回值确认接口ReturnCallback等。同样我们需要进行注入到Spring容器中，然后直接使用。RabbitConfigpac...
2019-12-01 21:46:36
348
原创 Spring整合RabbitMQ-01-RabbitAdmin使用
文章目录RabbitAdmin使用代码示例RabbitConfigRabbitConfigTestRabbitAdmin使用autoStartup 必须要设为 true ，否则Spring容器不会加载RabbitAdmin类RabbitAdmin底层实现就是从Spring容器中获取Exchange,Binding,RoutingKey以及Queue的@Bean申明RabbitTempl...
2019-12-01 21:40:05
386
原创 RabbitMQ高级特性-死信队列
文章目录死信什么是死信消息变为死信有以下几种情况死信队列 Dead Letter Exchange(DLX)DLX死信队列设置代码实现producer正常consumerDLXConusmer,监听消费死信队列中的消息死信什么是死信消息没有任何消费者去消费就变为死信消息变为死信有以下几种情况消息被拒绝(basic.reject/basic.nack),并且requeue=false...
2019-11-22 23:12:11
275
原创 RabbitMQ高级特性-TTL队列/消息
TTLtime to live,即生存时间RabbitMQ 支持消息的过期时间，可以在发消息是指定RabbitMQ 支持队列的过期时间，从消息入队开始计算，只要超过了队列的超时时间配置，那么消息会自动清除代码package com.wyg.rabbitmq.javaclient.ttl;import java.io.IOException;import java.util.Hash...
2019-11-22 23:09:11
252
原创 RabbitMQ高级特性-消费端的ack和重回队列
文章目录消费端的手工ack和nack什么是ack和nack手工ack和nack使用场景消费端的重回队列代码实现ProducerConsumer运行结果消费端的手工ack和nack什么是ack和nackack表示告知RabbitMQ已经成功消费消息nack表示告知RabbitMQ消费端处理消息失败手工ack和nack使用场景消费端进行消费的时候，由于业务异常，我们可以进行日志记录，后续...
2019-11-22 23:06:11
432
原创 RabbitMQ高级特性-消费端限流
文章目录为什么要进行消费者端限流什么是消费端限流消费端限流的实现为什么要进行消费者端限流假设有个场景，RabbitMQ服务器上堆积上万条未处理的消息，我们随便打开一个消费者客户端会出现下面情况：巨量的消息同时推送过来，但是我们单个消费者客户端无法同时处理这么多数据，服务器可能卡死什么是消费端限流RabbitMQ提供了一种qos(服务质量保证)功能，即在非自动确认消息的情况下，如果一定数量的...
2019-11-22 23:03:01
183
原创 RabbitMQ高级特性-生产端Return返回消息机制
文章目录为什么需要Return实现流程图：代码实现ProducerConusumer运行结果为什么需要ReturnReturn Listener用于处理一些不可路由的消息生产者通过指定Exchange和RoutingKey将消息发送达指定队列，消费者只需监听这个队列，进行消费操作。但是在某些情况下，我们在发送消息的时候，当前Exchange不存在或者指定的路由key路由不到，这个时候我们如...
2019-11-22 22:59:25
338
原创 RabbitMQ 高级特性-生产端Confirm消息确认机制
文章目录生产端Confirm消息确认机制什么是消息确认如何实现Confirm确认消息代码实现producerConsumer生产端Confirm消息确认机制什么是消息确认消息确认，是指生产者投递消息后，如果Broker收到消息，则会给我们生产者一个应答。生产者进行接受应答，用来确认消息这条是否正常发送到Broker，这种方式也是消息的可靠性投递的核心保障！如何实现Confirm确认消息...
2019-11-22 22:53:53
274
原创 RabbitMQ生产端保证消息100%投递成功
文章目录什么是生产端的可靠性投递互联网大厂生产端可靠性投递方案消息落库对消息状态进行打标消息的延迟投递，做二次检查，回调确认什么是生产端的可靠性投递保证消息成功发出保证MQ节点的成功接收发送端收到MQ节点(borker)的确认应答完善的消息补偿机制互联网大厂生产端可靠性投递方案消息落库对消息状态进行打标生产者将业务数据和消息入库，并设置信息状态为0，即初始待投递生产者将消...
2019-11-21 21:24:38
316
原创 RabbitMQ 基础
文章目录1. RabbitMQ 特点2. RabbitMQ 中的概念模型2.1. 消息模型2.1.1. RabbitMQ 基本概念2.1.2. AMQP 中的消息路由2.1.3. Exchange 类型2.1.3.1. direct2.1.3.2. fanout2.1.3.3. topic1. RabbitMQ 特点RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现。...
2019-11-21 20:58:56
247
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人