消息队列
-
RabbitMQ 有几种广播类型?
①fanout:所有bind到此exchange的queue都可以接收消息(纯广播,绑定到RabbitMQ的接受者都能收到消息); ②direct:通过routingKey和exc...
-
如何确保消息正确地发送至RabbitMQ?如何确保消息接收方消费了消息?
发送方确认模式 ①将信道设置成confirm模式(发送方确认模式),则所有在信道上发布的消息都会被指派一个唯一的ID。 ②一旦消息被投递到目的队列后,或者消息被写入磁盘后(可持久化...
-
Kafka如何保证数据的有序性消费?
同一类型的消息,发送到同一个分区 精品推荐 GPT-4 Plus账号大大大降价了!免费AI写作工具!
-
消息堆积问题如何解决?
消息太多,处理不掉,有些消息可能会成为死信 1、【消费者角度】增加多个消费者 2、【消费者角度】单个消费者增加处理速度,比如开线程,会浪费CPU,导致上下文切换 3、【队列角度】扩...
-
如何确保RabbitMQ消息的可靠性?
开启生产者确认机制,确保生产者的消息能到达队列 开启持久化功能,确保消息未消费前在队列中不会丢失 开启消费者确认机制为auto,由spring确认消息处理成功后完成ack 开启消费...
-
rabbitmq 中 vhost 的作用是什么?
vhost 可以理解为虚拟 broker ,即 mini-RabbitMQ server。其内部均含有独立的 queue、exchange 和 binding 等,但最最重要的是,...
-
rabbitmq 的消息是怎么发送的?
首先客户端必须连接到 RabbitMQ 服务器才能发布和消费消息,客户端和 rabbit server 之间会创建一个 tcp 连接,一旦 tcp 打开并通过了认证(认证就是你发送...
-
rabbitmq 集群搭建需要注意哪些问题?
- 各节点之间使用“--link”连接,此属性不能忽略。 - 各节点使用的 erlang cookie 值必须相同,此值相当于“秘钥”的功能,用于各节点的认证。 - 整个集群中必须...
-
rabbitmq 每个节点是其他节点的完整拷贝吗?为什么?
不是,原因有以下两个: 1. 存储空间的考虑:如果每个节点都拥有所有队列的完全拷贝,这样新增节点不但没有新增存储空间,反而增加了更多的冗余数据; 2. 性能的考虑:如果每条消息都需...
-
rabbitmq 集群中唯一一个磁盘节点崩溃了会发生什么情况?
如果唯一磁盘的磁盘节点崩溃了,不能进行以下操作: - 不能创建队列 - 不能创建交换器 - 不能创建绑定 - 不能添加用户 - 不能更改权限 - 不能添加和删除集群节点 唯一磁盘节...
-
rabbitmq 对集群节点停止顺序有要求吗?
RabbitMQ 对集群的停止的顺序是有要求的,应该先关闭内存节点,最后再关闭磁盘节点。如果顺序恰好相反的话,可能会造成消息的丢失
-
使用 kafka 集群需要注意什么?
- 集群的数量不是越多越好,最好不要超过 7 个,因为节点越多,消息复制需要的时间就越长,整个群组的吞吐量就越低。 - 集群数量最好是单数,因为超过一半故障集群就不能用了,设置为单...
-
kafka 有几种数据保留的策略?
kafka 有两种数据保存策略:按照过期时间保留和按照存储的消息大小保留。
-
kafka 可以脱离 zookeeper 单独使用吗?为什么?
kafka 不能脱离 zookeeper 单独使用,因为 kafka 使用 zookeeper 管理和协调 kafka 的节点服务器。