一、生产者 使用RocketMQ以三种方式发送消息：可靠的同步，可靠的异步和单向传输。 （1）同步发送消息（可靠的同步传输，适用于重要的短信通知等） (2)异步传输通常用于响应时间敏感的业务场景。 (3)以单向模式发送消息(单向传输用于需要中等可靠性的情况，例如日志收集。) 二、消费者 ...
分类：
其他好文 时间：
2018-11-16 15:05:50
阅读次数：
141
MQ全称为Message Queue, 是一种分布式应用程序的的通信方法，它是消费-生产者模型的一个典型的代表，producer往消息队列中不断写入消息，而另一端consumer则可以读取或者订阅队列中的消息。RabbitMQ是MQ产品的典型代表，是一款基于AMQP协议可复用的企业消息系统。业务上， ...
分类：
其他好文 时间：
2018-11-15 14:34:43
阅读次数：
113
kafka简介 kafka是分布式的消息发布和订阅系统（生产->消费） 特点： 消息持久化：通过o（1）的磁盘数据结构提供数据的持久化（拒绝写入内存操作，直接存入磁盘，小伙伴们都知道写入磁盘会速度会很慢，一定程度上受到了限制，那么kafka是如何操作的呢？kafka通过操作系统的预读、后写的机制进行 ...
分类：
其他好文 时间：
2018-11-15 12:11:06
阅读次数：
204
队列实现生产-多线程消费 先看代码 Python队列使用的是queue模块，多线程使用的是threading模块 生产者：Producer类，不断的向队列中添加元素，这里是添加数字1-30. 消费者：Customer类，创建4个线程，然后不断的从队列中取出元素进行“消费”。 这里有两个注重点： 1） ...
分类：
编程语言 时间：
2018-11-14 20:56:47
阅读次数：
674
第四章、资本主义的发展及趋势 商品经济和价值规律 1、商品经济 是作为自然经济的对立物而产生发展起来的。 自然经济：即自给自足经济，指生产是为了直接满足生产者个人或经济单位的需要，而不是为了交换的经济形式。特点:生产力水平低下，排斥社会分工，生产规模小。 商品经济：是以交换为目的而进行生产的经济形式 ...
分类：
其他好文 时间：
2018-11-14 00:59:24
阅读次数：
366
Rabbitmq学习(一)Rabbitmq初探理论定义消息队列：在消息的传输过程中保存消息的的容器。这是一个较为经典的消费-生产者模型，说起来比较抽象，打个比方：A线程需要给B线程发送消息（A、B线程不一定是在同一台机器上的），A线程先把消息发送到消息队列服务器上，然后B线程去读取或是订阅消息服务器上消息队列中的消息，线程A和B之间并没有进行直接通信。MQ服务器在中间起到中继的作用。适用的应用场景
分类：
其他好文 时间：
2018-11-13 20:27:46
阅读次数：
185
什么是阻塞队列？ 一个支持两个附加操作的队列。这两个附加操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者场景。 非阻塞队列与阻塞队列处理方法对比： 非阻塞队列中几个主要方法有： add（E e）：将元素e插入到队列末尾。成 ...
分类：
编程语言 时间：
2018-11-13 16:19:27
阅读次数：
161
一、面对生产者和消费者的问题，首先我们得明白几点： 生产者：生产数据；消费者：消费数据。消费者在没有数据可供消费的情况下，不能消费；生产者在原数据没有被消费掉的情况下，不能生产新数据。假设，数据空间只有一个。实际上，如果实现了正确的生产和消费，则，两个线程应该是严格的交替执行。synchronize ...
分类：
编程语言 时间：
2018-11-13 03:00:06
阅读次数：
222
1.ActiveMQ队列模式如下图，生产者创建消息到消息中间件，再“均分给消费者”。 2.ActiveMQ主题模式如下图，生产者创建消息到消息中间件，消费者会接受到订阅的主题中所有的消息。在主题模式下，消费者获取不到订阅之前的中间件中的消息。 ...
分类：
其他好文 时间：
2018-11-11 10:31:36
阅读次数：
238
这个可能是消息队列中最重要的队列了，其他的都是在它的基础上进行了扩展。功能实现：一个生产者发送消息，多个消费者获取消息（同样的消息），包括一个生产者，一个交换机，多个队列，多个消费者。 思路解读（重点理解）： （1）一个生产者，多个消费者（2）每一个消费者都有自己的一个队列（3）生产者没有直接发消息 ...
分类：
其他好文 时间：
2018-11-11 00:57:28
阅读次数：
217
