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