列表的局限前面我们说通过队列的rpush和lpop可以实现消息队列（队尾进队头出），但是消费者需要不停地调用lpop查看List中是否有等待处理的消息（比如写一个while循环）。为了减少通信的消耗，可以sleep()一段时间再消费，但是会有两个问题：1、如果生产者生产消息的速度远大于消费者消费消息的速度，List会占用大量的内存。2、

本文适合JAVA新人，想了解RabbitMQ又不想去看官网文档的人（英语水看的头疼(◎﹏◎)，但建议有能力还是去看官网文档）。消息队列MQ（一）MQ全称为MessageQueue，消息队列是应用程序和应用程序之间的通信方法。先引入一下常见的通讯方案。!(https://oscimg.oschina.net/

Handler、loop、MessageQueue的工作原理Message:Handler接收和处理的消息对象Looper:每个线程只能拥有一个looper.它的loop方法负责读取MessageQueue中的消息，读到信息之后就把消息返回给handler处理MessageQueue:消息队列。程序创建Looper对象时，会在它的构造器中创建

MQ中将消息发送至远程队列的配置摘自MQ资源管理器帮助文档V7在开始学习本教程之前，您需要从系统管理员处了解标识网络上接收机器的名称：IP地址、MQ的端口号、队列管理器、接收（远程机器）或者是发送的队列（本地机器）名称。消息传递如图示：!(https://oscimg.oschina.net/oscnet/57ea

QueuefromqueueimportQueue,LifoQueue,PriorityQueue队列模块queue类Queue类LifoQueue类PriorityQueue与进程中的JoinableQueue使用方式完全一样

上节我们分享了Linux进程间通信的其中两种方式：管道、消息队列，文章如下：Linux进程间通信(上)之管道、消息队列实践(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fmp.weixin.qq.com%2Fs%3F__biz%3DMzA3MjMzNTc4NA%3D%3D%26mid

昨天研究了一下RabbitMQ想做一个动态添加监听的功能依靠springboot实现起来也简单就2个类1个主类实现动态添加队列及绑定关系、动态添加监听、动态调整监听线程池大小、动态删除队列、动态取消监听、发送动态队列的消息。还有个类就是自定义消费者都是采用string接收参数，后面可以采用指定统一对象，然后用个type字段区分消息类型，

一、队列持久化的概念队列的声明默认是存放到内存中的，如果rabbitmq重启会丢失，如果想重启之后还存在就要使队列持久化，保存到Erlang自带的Mnesia数据库中，当rabbitmq重启之后会读取该数据库。二、排他简单理解就是在连接关闭时是否会删除队列（无论队列中有没有消息） 三、自动删除

前言我在刚接触使用中间件的时候，发现，中间件的使用并不是最难的，反而是中间件的下载，安装，配置才是最难的。所以，这篇文章我们从头开始学习RabbitMq，真正的从头开始。关于消息队列其实消息队列没有那么神秘，我们这样想一下，用户访问网站，最终是要将数据以HTTP的协议的方式，通过网络传输到主机的某个端口上的。那么，接收数据

确保客户端版本更新后消息不丢失，可以采取以下几种策略：消息持久化：确保消息被存储在可靠的存储介质中，如数据库或磁盘，这样即使客户端或服务端发生故障，消息也不会丢失。对于RabbitMQ等消息队列，需要开启持久化机制，将消息持久化到硬盘上，即使服务重启也能从