一：介绍 1.说明原理 A:生产者将信道设置成confirm模式，一旦信道进到confirm模式，所有该信道上发布的消息都会被指派一个唯一的ID（从1开始）。 一旦消息被投递到所有匹配的队列后，broker就会发送一个确认给生产者，并包括了唯一的ID，这样就使得生产者知道消息已经到达目的队列。 B: ...
分类：
其他好文 时间：
2018-03-22 23:52:22
阅读次数：
508
Kafka自0.9.0.0版本引入了配额管理(quota management)，旨在broker端对clients发送请求进行限流(throttling)。目前Kafka支持两大类配额管理： 网络带宽（network bandwidth）配额管理：定义带宽阈值来限制请求发送速率，阈值单位是字节/秒 ...
分类：
其他好文 时间：
2018-03-20 18:07:02
阅读次数：
2014
sql server设置：ALTER DATABASE <DatabaseName> SET ENABLE_BROKER;语句让相应的数据库启用监听服务，以便支持SqlDependency特性 using System;using System.Data;using System.Data.SqlC ...
分类：
数据库 时间：
2018-03-16 18:39:24
阅读次数：
1175
一、最近公司在做队列的技术选型，经过调研，决定使用rocketmq作为整个架构的队列层，我们之前的公司是用RabbitMQ，集群部署参考我之前的文章：RabbitMQ集群部署；rocketmq集群由NameServer和Broker两种角色组成，NameServer是无状态的可以横向部署多台达到消除单点的目的；Broker分多master、多master多slave同步、多master多slave
分类：
其他好文 时间：
2018-03-15 19:54:21
阅读次数：
184
关于rocketmq链接报错Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.2:10911> failed进入/usr/local/rocketmq/bin下，生成broker默认配置模版sh mqbroker -m > broker.
分类：
其他好文 时间：
2018-03-15 15:09:45
阅读次数：
1660
转自：http://wiki.jikexueyuan.com/project/explore-python/Third-Party-Modules/celery.html 在程序的运行过程中，我们经常会碰到一些耗时耗资源的操作，为了避免它们阻塞主程序的运行，我们经常会采用多线程或异步任务。比如，在 ...
分类：
其他好文 时间：
2018-03-12 16:55:42
阅读次数：
217
一、官网教程案例学习 Kafka — 分布式消息队列 消息系统 消息中间件：缓冲于生产与消费中间 缓冲满了，可以进行Kafka的扩容 特性： 水平扩展性、容错性、实时、快 Kafka架构： 理解producer、consumer、broker（缓冲区）、topic（标签） 一个配置文件（server ...
分类：
其他好文 时间：
2018-03-11 17:38:13
阅读次数：
182
【RabbitMQ 服务器】#?在?vhosttest?里面有?exchangetest?和?queuetest?通过?rkeytest?绑定
Broker:?192.168.0.xx
virtual?host:?vhosttest
Exchange:?exchange
分类：
编程语言 时间：
2018-03-09 11:49:51
阅读次数：
308
