RocketMQ读书笔记7——吞吐量优先的场景
【Broker端进行消息过滤】 在Broker端进行消息过滤，可以减少无效消息发送到Consumer，少占用网络宽带从而提高吞吐量。 【过滤方式1——通过Tag过滤】 [ 关于Tag和Ke ...
原文：RocketMQ读书笔记6——可靠性优先的使用场景
顺序消息 顺序消费是指消息的产生顺序和消费顺序相同。 比如订单的生成 付款 发货，这三个消息必须按顺序处理才可以。 顺序消息的分类 全局顺序消息和部分顺序消息。 上面订单的例子，其实是部分顺序消息，只要保证同一个订单ID的三个消息能顺序消费即可。 全局顺序消息 部分顺序消费 在实际的场景中，更多的是像订单类消息那样，只需要部分有序即可。 MessageQueueSelector Producer ...
2018-12-01 16:09 0 1266 推荐指数：
相关推荐
RocketMQ的可靠性传输
整体 分析： 需确保一发一存一消费这些过程均无消息丢失 利用ACK机制保证每个阶段需要执行的操作成功后，再往下一个阶段推动（放行） 消息处理过程： 由上图分析可知： 消息丢失，可能 ...
RocketMQ如何保证消息的可靠性投递？
要想保证消息的可靠型投递，无非保证如下3个阶段的正常执行即可： 生产者将消息成功投递到broker broker将投递过程的消息持久化下来 消费者能从broker消费到消息 发送端消息重试 roducer向broker发送消息后，没有收到broker的ack时 ...
Consul 学习笔记（三）之 高可靠性
一. 背景 在生产环境中，后台服务众多，当选择使用 consul 做服务治理的时候，所有服务注册到consul 上，若consul 挂掉，会影响整个平台的业务运行，为了保证业务的稳定性，需要consul 不宕机持续对外提供服务，因此要求consul提供高可靠的能力，根据官方文档，需要 ...
Kafka笔记—可靠性、幂等性和事务
这几天很忙，但是我现在给我的要求是一周至少要出一篇文章，所以先拿这篇笔记来做开胃菜，源码分析估计明后两天应该能写一篇。给自己加油~，即使没什么人看。 可靠性 如何保证消息不丢失 Kafka只对“已提交”的消息（committed message）做有限度的持久化保证。 已提交的消息 ...
RocketMQ读书笔记3——消费者
【不同类型的消费者】 DefaultMQPushConsumer 由系统控制读取操作，收到消息后自动调用传入的处理方法来处理。 DefaultMQPullConsumer 读取操作中的大部分功能由使用者自动控制。 【DefaultMQPushConsumer的使用】 [特点 ...
系统可靠性
一、系统可靠性 系统可靠性是系统在规定的时间、环境下，持续完成规定功能的能力，即系统无故障运行的概率。 系统可靠性涉及的概念 （1）平均无故障时间（Mean Time To failures,MTTF） MTTF指系统无故障运行的平均时间，取所有从系统开始正常运行 ...
Kafka可靠性的思考
，Kafka的可靠性问题，有哪些机会可能丢数据？ 从producer，broker，consumer的角度 ...