一、简介
tornado-celery是用于Tornado web框架的非阻塞 celery客户端。
通过tornado-celery可以将耗时任务加入到任务队列中处理,
在celery中创建任务,tornado中就可以像调用AsyncHttpClient一样调用这些任务。
?
Celery中两个基本的概念:Broker、Backend
Broker : 其实就是一开始说的 消息队列 ...
分类:
其他好文 时间:
2014-12-15 23:38:30
阅读次数:
477
目前业界有很多MQ产品,我们作如下对比:
RabbitMQ
是使用Erlang编写的一个开源的消息队列,本身支持很多的协议:AMQP,XMPP, SMTP, STOMP,也正是如此,使的它变的非常重量级,更适合于企业级的开发。同时实现了一个经纪人(Broker)构架,这意味着消息在发送给客户端时先在中心队列排队。对路由(Routing),负载均衡(Load balance)或者数据持久化都...
分类:
其他好文 时间:
2014-12-14 13:20:14
阅读次数:
227
rabbitmqctl [-n node] [-q] {command} [command options...]
1.停Server
rabbitmqctl stop
2.查看状态
rabbitmqctl status
其他常用项
sudo rabbitmqctl list_queues
sudo rabbitmqctl list_exchanges
sudo rabbi...
分类:
其他好文 时间:
2014-12-12 19:13:57
阅读次数:
147
主要的核心类如下:KafkaServer:根据相关的上下文,创建KafkaServer对象,负责启动broker对象启动过程zkClient初始化=>logManagerstart()=>socketServer
start()=>requestHandlerPool初始化=>replicaManagerstart()=>
kafkaControllerstart()=>topicConfigMa..
分类:
其他好文 时间:
2014-12-03 14:27:44
阅读次数:
208
主要的核心类如下:controller:根据相关的上下文,创建KafkaController对象,引入多个监听器监听broker,topic,partition以及副本的状态变化。ZookeeperLeaderElector:主要负责选举当前broker为lead的过程,同时,如果出现异常情况转移lead选举权。ReplicaStateMachine:主要..
分类:
其他好文 时间:
2014-12-02 12:02:38
阅读次数:
225
SQLServer环形缓冲区(RingBuffer)--RING_BUFFER_MEMORY_BROKER诊断内部内存压力内存Broker内存Broker的职责是根据其需求在大内存消费者之间分配内存。内存Broker是一种SQLOS的组件,但是与缓冲池紧密结合。此外,内存Broker只会将缓冲池的内存管理器所控制的内存考虑在内。内..
分类:
数据库 时间:
2014-11-28 18:28:34
阅读次数:
316
Oracle 11g Data Guard Broker操作笔记...
分类:
数据库 时间:
2014-11-27 18:33:40
阅读次数:
393
RMI使用的是同步通信,JMS使用的是异步通信。 JMS中有两个主要的概念:消息代理(message broker)和目的地(destination)。 同步通信的缺点,这也是使用JMS所能够解决的: 运行apache-activemq-5.10.0-bin[1]\...
分类:
编程语言 时间:
2014-11-27 15:58:16
阅读次数:
204
what is mosquitto?check this out!http://mosquitto.orgwhat is MQTT?check this out.http://mqtt.orgsudo apt-get install libc-ares-dev libc-ares2 -ywget -...
分类:
系统相关 时间:
2014-11-23 18:57:35
阅读次数:
312
broker.id整数,建议根据ip区分 log.dirskafka存放消息文件的路径,默认/tmp/kafka-logsportbroker用于接收producer消息的端口 zookeeper.connnectzookeeper连接格式为 ip1:port,ip2:port,ip3:portme...
分类:
其他好文 时间:
2014-11-23 14:25:35
阅读次数:
210