一、消息游标二、异步发送三、严格分发策略四、轮询分发策略五、优化批量确认六、生产者流量控制
分类：
其他好文 时间：
2019-07-01 00:31:02
阅读次数：
91
1、消息队列 “消息队列”是在消息的传输过程中保存消息的容器。消息队列，一般我们会简称它为MQ(Message Queue) 我们先不管消息(Message)这个词，来看看队列(Queue)。 队列是一种先进先出的数据结构。python用list 实现队列。 在Python里边，已经实现了不少的队列 ...
分类：
其他好文 时间：
2019-06-30 19:04:45
阅读次数：
111
发现 zeromq 的 yqueue_t 模板类，其数据存储理念设计得非常妙。借这一理念，按照 STL 的泛型类 queue 的接口标准，我设计了一个线程安全的 单生产者/单消费者（单线程push/单线程pop） FIFO 队列，以此满足更为广泛的应用。 1. 数据存储理念的 ...
分类：
其他好文 时间：
2019-06-30 18:54:29
阅读次数：
115
运行机制 异常 线程 Java程序运行的时候底层也是多线程，除了main，gc也在同时运行。 线程状态： 线程同步（多个线程要访问同一份资源） 1. 同步块 Synchronized(引用类型){} 2. 同步方法 Public synchronized test(){} 线程安全：hashtabl ...
分类：
编程语言 时间：
2019-06-30 11:11:09
阅读次数：
128
return listener 用于处理一些不可路由的消息。 我们的消息生产者，通过指定一个exchange和routingkey，把消息送达到某一个队列中，然后我们的消费者监听队列，进行消费处理操作。 但是在某种情况下，如果我们在发送消息的时候，当前的exchange不存在或者制定的路由key路由 ...
分类：
其他好文 时间：
2019-06-29 19:33:35
阅读次数：
220
重回队列模式，是当投递消息失败时，让该消息重新回到队列的模式，该模式需要手动签收，并需要在消费者中进行判断，调用重回队列的确认模式 消费者 自定义消费者： 生产者： ...
分类：
其他好文 时间：
2019-06-29 19:18:05
阅读次数：
101
高并发场景下生产者产生大量的消息，对于巨量的消息瞬间推送消费端无法处理 rabbitmq提供了服务质量保障功能，即在非自动确认消息的前提下，如果一定数目的消息未被确认，不进行消费新的消息。 使用 basicqos方法。在消费端进行使用。 0 1 false prefetSize：0 prefetCo ...
分类：
其他好文 时间：
2019-06-29 18:57:04
阅读次数：
170
kafka 提供了一个镜像操作工具 kafka-mirror-maker.sh 用于将一个集群中的数据同步到另一个集群中去。 kafka 镜像操作工具的本质是一个消费者，从源集群中待迁移的主题消费数据，然后创建一个生产者，将消费者从源集群中拉取到的数据写入目标集群。 将 host 为host1 的k ...
分类：
其他好文 时间：
2019-06-29 14:47:55
阅读次数：
105
