消费端限流什么是消费端限流假设一个场景, 首先, 我们RabbitMQ服务器有上万条消息未处理的消息, 我们随机打开一个消费者客户端, 会出现下面情况巨量的消息瞬间全部推送过来, 但是我们单个客户端无法同时处理这么多数...
所有发送到direct exchange 的消息被转发到Routekey中指定的Queue
所谓Shovel就是我们可以把消息进行不同数据中心的复制工作,可以跨地域的让两个mq集群互联。
这种广播模式很像,就是生产者把通知的内容都录音到电台(exange)里,消费者如果想要听到,必须使用该频率的耳机(queue 绑定 exange)去听才能收到。所有消费者只要通过一个队列进行绑定,那么都能听到,都能消费该信息,这就是广播模...
这是第二种模型 (Work Queue),任务模型,当消息处理比较耗时的时候,生产者发送消息的速度远远大于消费的速度,长此以往,消息就会堆积的越来越多,无法及时处理,可以使用work模型,让多个消费者绑定到一个队列,共同消费队列中的消息...