一、 RabbitMQ概述 1.1 基本概述RabbitMQ是一种消息中间件，能够很好的处理来自客户端的异步消息发送及请求，将消息发送放入到服务端的队列池中，而接收端可以根据RabbitMQ配置的转发机制接收和过滤服务端转发来的消息。RabbitMQ可以根据指定的消息转发规则进行消息的转发、缓冲和持久化操作，RabbitMQ主要用在多服务器间或单服务器的子系统间进行通信，是分布式系统标准的配置。 同时它支持多个消息传递协议。RabbitMQ可以部署...
最近在搞物联网平台，海量级别的消息Push导致MQ处理速度下降，对MQ进行单队列性能压测，结果很不如意啊！下游设备是通过NB模块和ESP进行双链路数据采集，由于场景就是抄表，但是下游设备太多，老板也没给多少银子买云服务，所以只能自己研究一波儿了~ 抄表也就意味着单Topic，进行测试的时候单个Topic消费端TPS到1.7w/s，大量的消息处于unconfirmed未确认状态，达到了TPS上限，然后通过新增消费端仍然是无法解决，那么就将性能瓶颈...
文章目录版本声明Frame(帧)分析AMQP帧(Frame)的格式Frame源码分析FrameHandlerSocketFrameHandlerSocketChannelFrameHandlerFramehandlerFactoryAbstractFrameHandlerFactorySocketFrameHandlerFactorySocketChannelFrameHandlerFactory版本声明com.rabbitmq:amqp-client:4.3.0 RabbitMQ版本声明: 3.6.15Frame(帧)分析 AMQP帧(Frame)的格式tcp/ip是一个流协议，amqp没有采用在流中添加帧定界符来区分帧数据（原因官方认为简单，但是...
首先我们简单了解一下什么堆、栈、队列。 堆是在程序运行时，而不是在程序编译时，申请某个大小的内存空间。即动态分配内存，对其访问和对一般内存的访问没有区别。 栈就是一个容器，后放进去的先拿出来，它下面本来有的东西要等它出来之后才能出来。（先进后出or后进先出） 队列只能在队头做删除操作,在队尾做插入操作.而栈只能在栈顶做插入和删除操作。（先进先出） 注意：当前展示的是队列（Queue），下一章展示消息队列MQ（Mes...
一、先扔一张图说明: 本文涵盖了关于RabbitMQ很多方面的知识点, 如:消息发送确认机制消费确认机制消息的重新投递消费幂等性, 等等这些都是围绕上面那张整体流程图展开的, 所以有必要先贴出来, 见图知意 二、实现思路简略介绍163邮箱授权码的获取编写发送邮件工具类编写RabbitMQ配置文件生产者发起调用消费者发送邮件定时任务定时拉取投递失败的消息, 重新投递各种异常情况的测试验证拓展: 使用动态代理实现消费端幂等性验证和消息确...