MQ全称为Message Queue, 是一种分布式应用程序的的通信方法，它是消费-生产者模型的一个典型的代表，producer往消息队列中不断写入消息，而另一端consumer则可以读取或者订阅队列中的消息。RabbitMQ是MQ产品的典型代表，是一款基于AMQP协议可复用的企业消息系统。业务上， ...
分类：
其他好文 时间：
2018-11-20 23:34:30
阅读次数：
399
import threading,timeimport queueq = queue.Queue(maxsize=10)def Producer(name): count = 1 while True: q.put("骨头%s" % count) print("生产了骨头",count) count ...
分类：
其他好文 时间：
2018-11-18 18:18:22
阅读次数：
225
MQ全称为Message Queue, 是一种分布式应用程序的的通信方法，它是消费-生产者模型的一个典型的代表，producer往消息队列中不断写入消息，而另一端consumer则可以读取或者订阅队列中的消息。RabbitMQ是MQ产品的典型代表，是一款基于AMQP协议可复用的企业消息系统。业务上， ...
分类：
其他好文 时间：
2018-11-15 14:34:43
阅读次数：
113
队列实现生产-多线程消费 先看代码 Python队列使用的是queue模块，多线程使用的是threading模块 生产者：Producer类，不断的向队列中添加元素，这里是添加数字1-30. 消费者：Customer类，创建4个线程，然后不断的从队列中取出元素进行“消费”。 这里有两个注重点： 1） ...
分类：
编程语言 时间：
2018-11-14 20:56:47
阅读次数：
674
案例： Springboot 对RabbitMQ的支持 公共的pom： Producer： controller config producer yml: 启动类： Producer启动时候不会创建这个交换机哦，懒加载 启动后： Consumer: EmailConsumer： SMSConsume ...
分类：
编程语言 时间：
2018-11-12 14:48:41
阅读次数：
175
一个典型的Kafka集群中包含若干Producer（可以是web前端产生的Page View，或者是服务器日志，系统CPU、Memory等），若干broker（Kafka支持水平扩展，一般broker数量越多，集群吞吐率越高），若干Consumer Group，以及一个Zookeeper集群。Kafka通过Zookeeper管理集群配置，选举leader，以及在Consumer Group发生变化时进行rebalance。Producer使用push模式将消息发布到broker，Consumer使用pull模式从broker订阅并消费消息。
分类：
其他好文 时间：
2018-11-10 23:53:56
阅读次数：
231
pom： 创建连接的工具类： Producer类 运行结果 模拟get message producer跟consumer基本类似 运行后的结果： ...
分类：
其他好文 时间：
2018-11-10 20:13:32
阅读次数：
150
发布订阅模式与前面的点对点模式很类似，简直一毛一样 注意：发布订阅模式 先启动消费者 公用pom： 与上一篇博客类似的：改改就欧克了 猜猜都知道该怎么玩 yml： config producer 创建producer maven SpringBoot 默认开启点对点的！！！！ 订阅模式需要手动！！！ ...
分类：
编程语言 时间：
2018-11-10 10:47:50
阅读次数：
169
没有版本号，表示springboot已经整合好了 项目结构： yml： config： producer 启动类： 运行： 一直在增加 思路总结： queue 注入到springboot容器， 然后producer 去取出来 spring定时任务 5s定时写入消息 然后创建另外一个Consumer ...
分类：
编程语言 时间：
2018-11-10 10:42:05
阅读次数：
175
#include<string>#include<iostream>#include<process.h>#include<windows.h>#include <stdlib.h>#include<time.h>#include<list>using namespace std;HANDLE em ...
分类：
编程语言 时间：
2018-11-06 22:33:38
阅读次数：
144
