1.发送测试消息bin/mqadmin checkMsgSendRT -n 192.168.x.x:9876 -t topic_online_test -s 1024Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; s...
from queue import Queue import random import threading import time
>>>producer = gevent.spawn(producer, queue)
在并发编程中，如果生产者的处理速度很快，而消费者的处理速度很慢，那么生产者就必须等待消费者处理完，才能继续生产数据。同样，如果消费者的处理能力大于生产者，那么消费者就必须等待生产者。...
死锁是指两个或两个以上的进程或线程在执行过程中，因争夺资源而造成的一种互相等待的现象，若无外力作用，它们都将无法推进下去。
Channelchannel.exchangeDeclare()：type：有direct、fanout、topic三种durable：true、false true：服务器重启会保留下来Exchange。警告：仅设置此选项，不代表消息持久化。即不保证重启后消息还在。原文：true if we are decl......
@RabbitListener注解指定目标方法来作为消费消息的方法，通过注解参数指定所监听的队列或者Binding。
今天在新的服务器上安装了一个pip install pika，然后连接mq的程序就报错了
当需要创建的子进程数量不多时，可以直接利用multiprocessing中的Process动态成生多个进程，但如果是上百甚至上千个目标，手动的去创建进程的工作量巨大，此时就可以用到multiprocessing模块提供的Pool方法。...
Process并不能像线程那样共享全局变量，那么它们之间如果有传递值的需求，那么该怎么办呢？ 对于这种需求，操作系统提供了很多机制来实现进程间的通信，例如队列Queue...
