代码运行后，观察RabbitMQ管理器，change消息队列创建成功，但是消息跑错地方了
RabbitMQ的异步发布确认（Asynchronous Publish Confirm）是一种机制，用于在消息发送过程中异步地接收确认回调，以提高生产者的吞吐量和性能。通过使用异步发布确认，生产者可以在消息发送的同时继续执行其他操作，而不需要等待每条消息的确认回调。
要想保证消息不丢失，首先我们得保证生产者能成功的将消息发送到RabbitMQ服务器。
出处：www.cnblogs.com/haixiang/p/10864339.html
RabbitMQ，是个消息代理人message broker。它接收，存储，转发消息。
不处理路由键，只需要简单的将队列绑定到交换机上发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。 Fanout交换机转发消息是最快的。
RabbitMQ 是实现 AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。 RabbitMQ 主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时，消费者无法快速消费，那么需要一个中间层。保存这个数据。
这个方法的第一个参数，就是我们要创建的队列的名字，如果我们没有这个队列，只要运行这个代码，那么就可以创建队列了。
本文已推送到 github ：https://github.com/whuanle/learnrabbitmq 如果文章排版不方便阅读，可以到仓库下载原版 markdown 文件阅读。
如果要发送一个消息，可以使用channel类的basicPublish方法参考如下，其中在rabbitmqTemplate中封装的方式是：
队列需要设置优先级队列，消息需要设置消息的优先级。消费者需要等待消息已经发送到队列中，然后对队列中的消息进行排序，最后再去消费。
RabbitMQ是一个流行的开源消息队列系统，它提供了消息持久化的功能。消息持久化是指将消息存储到磁盘上，以确保即使在服务器故障或重启后，消息仍然可靠地被传递和处理。
Return返回消息 Return消息机制 Return Listener 用于处理一些不可路由的消息 我们的消息生产者,通过指定一个Exchange和RouteKey, 把消息送达到某一个队列中去,然后我们的消费者监听队列,进行消费处理操作 但是在某些情况下, 我们在发送消息的时候, 当前的Exchange不存在, 或者指定的路由key, 路由不到, 这个时候我们就需要监听这些不可达的消息, 就需要使用Return Listener 在基础API中有一个关键的配置项 Mandatory; 如果为true,
针对问题（1），我们可以通过生产者的确认消息机制来解决，主要分为两种：第一是事务机制、第二是发送方确认机制
前一篇文章介绍到RabbitMQ相关组件的声明，组件声明完成之后，就可以发送消息和消费消息，消费消息的时候需要考虑消息的确认。
如何做到以上几点？RabbitMQ为了适应各个场景的使用，以上的功能需要开发者按照定义自行设置实现。
RabbitMQ的批量发布确认（Batch Publish Confirm）是一种机制，用于在发送大量消息时提高生产者的吞吐量和性能。通过批量发布确认，生产者可以一次性发送多条消息，并等待这批消息的确认回调，而不是每条消息单独等待确认。
因为MQ整个消息周期设计到上述的三个角色，所以我们从这个三个角色开始讨论丢失数据的情况。并如何解决
要解决该问题，就要用到RabbitMQ中持久化的概念，所谓持久化，就是RabbitMQ会将内存中的数据(Exchange 交换器，Queue 队列，Message 消息)固化到磁盘，以防异常情况发生时，数据丢失。
概念 先从概念解释上搞清楚这个定义，死信，顾名思义就是无法被消费的消息，字面意思可以这样理解，一般来说，producer 将消息投递到 broker 或者直接到queue 里了，consumer 从 queue 取出消息 进行消费，但某些时候由于特定的原因导致 queue 中的某些消息无法被消费，这样的消息如果没有后续的处理，就变成了死信，有死信自然就有了死信队列。 应用场景：为了保证订单业务的消息数据不丢失，需要使用到 RabbitMQ 的死信队列机制，当消息消费发生异常时，将消息投入死信队列中。还有
RabbitMQ是一个强大的开源消息队列系统，用于实现分布式系统之间的可靠消息传递。在RabbitMQ中，生产者负责创建并发送消息到消息队列中，以便被消费者获取和处理。
RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而群集和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。
在服务级级别的测试中需要考虑被执行任务的优先级机制，也就是通过线程优先级来进行，设置优先级的目的是在资源非常紧张的情况下，让优先级高的任务优先执行，而优先级低的任务排后执行，当然这样的一种设置机制只能是异步的模式下执行，如果是设计在同步的模式下执行，那这个设计从系统上来说就缺少宏观维度的思考。在RabbitMQ的机制中也是提供了队列的优先级机制，这样设计的目的也是在在生产者生产过快，而消费者消费不过来的情况下，也就是资源在紧张或者说是在有限的情况下，设置的队列优先级高的任务它的消息优先进行消费，而优先级低的消息排后消费。当然，如果是在资源不紧张的情况下，设置优先级其实没多大的意义，因为这个时候优先过来的消息先进行消费，也谈不上排队的机制和优先级的机制。
1、跨系统的异步通信 人民银行二代支付系统，使用重量级消息队列 IBM MQ，异步，解耦，削峰都有体现。 2、应用内的同步变成异步 秒杀：自己发送给自己 3、基于Pub/Sub模型实现的事件驱动 放款失败通知、提货通知、购买碎屏保 系统间同步数据 摒弃ELT（比如全量同步商户数据）； 摒弃API（比如定时增量获取用户、获取产品，变成增量广播）。 4、利用RabbitMQ实现事务的最终一致性
扛不住的Hello World模式 上篇《RabbitMQ入门-从HelloWorld开始》介绍了RabbitMQ中最基本的Hello World模型。正如其名，Hello World模型组成简单，也很好理解，我们也看到了一条消息时如何从一个生产者最终流向队列并最终被消费者消费的过程。 但是，过于简单、单调的模型设计也存在一些缺陷。假使现在队列Queue中挤压了很多的消息没有被消费，Hello World模型中只有一个消费者，在消费消息时会显得力不从心。如果遇上网络状况异常等情况，则消费速率就更加不同乐观，
分布式项目中，模块与模块之间的通信可以使用RPC框架，如Dubbo，但RPC中调用方模块获取到被调用方的结果是同步的，争对一些只需要异步调用的方法，如日志存储、发送消息等，RPC就显得效率低下了，AMQP协议的推出就是用来解决进程之间的异步消息通信
直接回复(Direct reply-to)是一种可以避免声明回复队列并且实现类似于RPC功能的一种特性。RabbitMQ中允许使用客户端和RabbitMQ消息代理中间件实现RPC模式，典型的做法是：RPC客户端发送请求(消息)到一个持久化的已知服务端队列，RPC服务端消费该服务端队列的消息，然后使用消息属性中的reply-to属性对应的值作为客户端回复队列发送回复消息到RPC客户端。
在下图中，“ P” 是我们的生产者，“ C” 是我们的消费者。中间的框是一个队列 RabbitMQ 代表使用者保留的消息缓冲区
RabbitMQ的发布确认（Publish Confirm）是一种机制，用于确保消息在发送到RabbitMQ之后被成功接收和持久化。通过使用发布确认，生产者可以获得对消息的可靠性保证，避免消息丢失。
生产者发布消息到 RabbitMQ 后，需要 RabbitMQ 返回「ACK（已收到）」给生产者，这样生产者才知道自己生产的消息成功发布出去。
可以看到3条消息只有2条消息被消费了, 所以*是只能匹配一个词的, 多个词的没有匹配到
https://www.rabbitmq.com/tutorials/tutorial-one-dotnet.html
RabbitMQ是一个功能强大的消息中间件，其中交换机（Exchange）是消息路由的核心组件之一。交换机负责接收生产者发送的消息，并将消息路由到一个或多个绑定的队列中。
看下官方说明：https://www.rabbitmq.com/tutorials/tutorial-four-java.html
RabbitMQ是一个消息队列，它能够接收和转发消息。这个过程就像寄快递一样，把物件打包给快递小哥，快递小哥会负责把物件派送到正确的地址。
上一个教程中，我们创建了一个work queue. 其中的每个task都会被精确的传送到一个worker. 这节，我们将会讲把一个message传送到多个consumers. 这种模式叫做publish/subscribe（发布/订阅）.
消息队列RabbitMQ提供了六种工作模式：简单模式、work queues、发布订阅模式、路由模式、主题模式、发布确认模式。本文将介绍前三种工作模式。所有的案例代码都是使用Java语言实现。
在Fanout模式中，一条消息，会被所有订阅的队列都消费。但是，在某些场景下，我们希望不同的消息被不同的队列消费。这时就要用到Direct类型的Exchange。
保证生产者将信息成功的发送到 RabbitMQ的 server端了，那么broker就会回一个确认，如果没有收到或者收到拒绝信息，那么说明可能网络不好没有发送成功，server端宕机了，broker拒绝接收等情况，如果不进行后续处理，那么信息就会丢失，生产者收到失败的消息使用回调函数在进行处理。
工作队列模式就是一个生产者，两个消费者。在初步入门的Hello World简单模式里面我们了解到。简单模式就是一个生产者一个消费者，中间通过中间件进行消息通信。
1.引言 RabbitMQ——Rabbit Message Queue的简写，但不能仅仅理解其为消息队列，消息代理更合适。RabbitMQ 是一个由 Erlang 语言开发的AMQP（高级消息队列协议）的开源实现，其内部结构如下： RabbitMQ作为一个消息代理，主要和消息打交道，负责接收并转发消息。RabbitMQ提供了可靠的消息机制、跟踪机制和灵活的消息路由，支持消息集群和分布式部署。适用于排队算法、秒杀活动、消息分发、异步处理、数据同步、处理耗时任务、CQRS等应用场景。 下面我们就来学习下
自动ACK:消费端收到消息后，会自动签收消息 手动ACK:消费端收到消息后，不会自动签收消息，需要我们在业务代码中显式签收消息
1. RabbitMQ 持久化机制 ---- RabbitMQ 的持久化分为队列持久化、消息持久化和交换器持久化。 不管是持久化的消息还是非持久化的消息都可以被写入到磁盘。区别在于重启之后数据还在
Fanout交换机是RabbitMQ中最简单的一种交换机类型。它会将所有接收到的消息广播给所有与之绑定的队列。无论消息的路由键是什么，Fanout交换机都会将消息发送给所有与之绑定的队列。这种广播模式非常适合需要将消息发送给多个消费者的场景。
###消息派发 上篇《RabbitMQ入门-消息派发那些事儿》发布之后，收了不少反馈，其中问的最多的还是有关消息确认以及超时等场景的处理。 楼主，有遇到消费者后台进程不在，但consumer连接还在，当前消息是unacked状态，导致这个消息一直不被消费 队列在等待回复的时候，这个消息是怎么存放的？如果一直没有返回有超时么？ ... 这里再对消息确认做以下补充 有关超时 RabbitMQ是没有超时概念的，如果一个消费者消费一条消息要花费很长时间，比如10分钟，那么这个过程会一直进行下去。除非你采用其他策略来
RabbitMQ通配符模式，也被称为主题模式（Topic Pattern），是一种消息传递模式，它允许消息生产者将消息发送到一个交换机（exchange），并使用通配符形式的路由键来描述消息的特性。消费者则可以使用通配符匹配来订阅感兴趣的消息。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
