RabbitMQ 实现思路 RabbitMQ队列本身是没有直接实现支持延迟队列的功能，但可以通过它的Time-To-Live Extensions 与 Dead Letter Exchange 的特性模拟出延迟队列的功能。 Time-To-Live Extensions RabbitMQ支持为队列或者消息设置TTL（time to live 存活时间）。TTL表明了一条消息可在队列中存活的最大时间。当某条消息被设置了TTL或者当某条消息进入了设置了TTL的队列时，这条消息会在T

RabbitMQ安装 先说一下RabbitMQ的安装，建议使用Docker镜像安装，Docker安装的好处是不管Windows系统还是Linux，安装步骤少，安装方法相同，不容易出错。使用下面的命令就可以： docker run -d --hostname myRabbit --name rabbitmq3.9.11 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin RABBITMQ_DEFAULT_VHOST=m

一、安装与启动rabbitmq        1 首先，rabbitmq需使用centos7及以上版本进行安装！安装依赖环境： yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz         2 下载erlang，socat和rabbitmq的安装包导入虚拟机（自己百度去找吧），安

1 RabbitMQ自带的重试机制 1 示例代码 rabbitMQ为自带了消息重试机制：当消费者消费消息失败时，可以选择将消息重新“推送”给消费者，直至消息消费成功为止。 开启自带的重试机制，需要如下几个配置： 1 开启消费者手动应答机制，对应的springboot配置项： spring.rabbitmq.listener.simple.acknowledge-mode=manual 2 消费异常时，设置消息重新入列 boolean multiple = false; // 单条

RabbitMQ是什么 MQ(message queue)，从字面意思上看，本质是个队列，FIFO 先入先出，只不过队列中存放的内容是message 而已。RabbitMQ 是一个消息中间件：它接受并转发消息。你可以把它当做一个快递站点 RabbitMQ有什么用 1.流量消峰 举个例子，如果订单系统最多能处理一万次订单，这个处理能力应付正常时段的下单时绰绰有余，正常时段我们下单一秒后就能返回结果。但是在高峰期，如果有两万次下单操作系统是处理不了的，只能限制订单超过一万后不允许用户下单。

项目场景： Windows安装RabbitMQ教程,以及解决管理员界面打不开问题。 问题描述 如果你按照默认流程安装好RabbitMQ，但是访问http://localhost:15672管理员界面打不开，最有可能的原因就是你电脑用户名是中文导致的中文路径问题，解决办法如下： 1.首先正常安装Erlang语言环境（RabbitMQ依赖与Erlang语言环境）。 2.然后正常安装RabbitMQ。 3.解决电脑用户名是中文导致的中文路径问题。 1.首先正常安装Erlang语言环境：

kafka如何保证消息不丢失？ kafka是实现异步消息通讯的中间件，整个架构Producer Consumer Broker组成 所以保证消息不丢失从这三个方面考虑和实现 .确保Producer端数据能够到达Broker，并且实现消息的存储 .有可能会出现网络问题，导致消息发送失败 一，Producer默认是异步发送消息，确保消息发送成功 第一种方法 把异步发送改为同步发送，这样就能实时知道消息发送的结果 第二种方法 添加异步或调函数，监听消息发送的结果，如果失败可以在回调中

Celery  PK  APScheduler Celery：我们通常将celery作为一个任务队列来使用，但是celery也有定时任务的功能。当然了，任务就是消息，消息中间件（也就是broker）可以使用redis或者rabbitmq 。 安装Celery模块： pip install celery Celery的默认broker(消息中间件)是RabbitMQ, 当然了，也可以使用Redis 。 APScheduler：算是在实际项目中最好用的一个工具库，不仅可以在程序动态

一、为什么要封装         在软件项目开发中，基本上都是多人共同开发，尤其是大型项目。而消息队列更是大多数业务都会使用，前期基本上都是在业务中直接注入RabbitTemplate，创建各自的交换机、队列、监听者完成业务开发，但是到了项目后期，大量的交换机和队列的定义代码充斥在各个模块，每次需要回溯业务逻辑的时候都在不停的翻找代码，寻找监听者。 致命的是，通常我们找到了发消息的代码，由于通过RabbitTemplate发送消息是直接发给交换机的，想要找到处理消息的消费者业务代码，还需

MQ：MessageQueue，消息队列。 队列，是一种FIFO 先进先出的数据结构。消息由生产者发送到MQ 进行排队，然后按原来的顺序交由消息的消费者进行处理。QQ和微信就是典型的MQ。MQ的作用主要有以下三个方面： 异步 例子：快递员发快递，直接到客户家效率会很低。引入菜鸟驿站后，快递员只需要把快递放到菜鸟 驿站，就可以继续发其他快递去了。客户再按自己的时间安排去菜鸟驿站取快递。 作用：异步能提高系统的响应速度、吞吐量。解耦 例子：《Thinking in JAVA》很经典，但是都是英文，我

LD is tigger forever，CG are not brothers forever， throw the pot and shine forever. Modesty is not false, solid is not naive, treacherous but not deceitful, stay with good people, and stay away from poor people. talk is cheap, show others the c

channel  有了TCP连接后,还需要channel的原因如下: 创建和销毁TCP连接很耗时; 打开太多TCP连接,耗操作系统资源，并发量大到一定程度,系统的吞吐量会降低； 使用一个connection多channel的方式,可以提升连接的利用率。 因此采用多个channel多路复用一个TCP连接的方式才比较合理 exchange（交换机） 生产者发消息发往交换机，交换机会自己投递消息到绑定的queue队列 1.exchange根据什么规则把消息投递到哪些queue中？ excha