消息队列选型
消息队列（Message Queue），简称MQ，本质是一个队列，用于存放数据（message），先入先出（FIFO）。主要用于系统解耦、消息缓存。 目前市面上消息队列的实现有很多种，下面调研了kafka/rabbitMQ/rocketMQ，这三种应用都非常广泛，期望从中选出最合适 ...
原文：RocketMQ消息发送的队列选择与容错策略
一个topic有多个队列，分散在不同的broker。producer在发送消息的时候，需要选择一个队列 producer发送消息全局时序图： 队列选择与容错策略结论: 在不开启容错的情况下，轮询队列进行发送，如果失败了，重试的时候过滤失败的Broker 如果开启了容错策略，会通过RocketMQ的预测机制来预测一个Broker是否可用 如果上次失败的Broker可用那么还是会选择该Broker的 ...
2019-04-27 22:46 0 1485 推荐指数：
相关推荐
ELK之消息队列选择redis_kafka_rabbitmq
前言描述 生产初级，Service服务较少，访问量较少，随着业务量的不断增加，日志量成倍增长，然后就遇到了消息队列redis被充爆，不能满足应用的情况。针对此情况，我们来分析下可用的消息多列。 官方推荐消息队列 redis、kafka、rabbitmq。我们现在针对这三种进行比较。 从消息 ...
消息队列（四）--- RocketMQ-消息发送
概述 可靠同步发送 可靠异步发送 单向（oneway）发送 ：只管发送，直接返回，不等待消息服务器的结果，也不注册回调函数，简单地说，就是只管发，不管信息是否发送到了消息服务器中。 发送消息示例 /* * Instantiate ...
消息队列选型分析
作者：朱小厮 （公众号 ：朱小厮的博客） 转载地址：https://mp.weixin.qq.com/s/MiBlHOUXPrsjtKVY1UAc-A 一、前言 消息队列中间件（简称消息中间件）是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成 ...
消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择？
「 预计阅读 6 分钟 」 旁白：这是一篇拖更了N久的文章...0.0（看不见我~） 往期回顾 前端框架 jQuery 和 Vue 如何选择？ 安全框架 Shiro 和 Spring Security 如何选择？ 正文 消息队列（MQ） 在百度百科中 ...
rocketmq发送消息的期间的broker选择
for (; times < timesTotal; times++) { String lastBrokerName = nu ...
消息队列（七）--- RocketMQ延时发送和消息重试（半原创）
问题 Rocketmq 重试是否有超时问题，假如超时了如何解决，是重新发送消息呢？还是一直等待 假如某个 msg 进入了重试队列（%RETRY_XXX%），然后成功消费了 概述 文章介绍了RocketMQ 的重试机制和消息重试的机制。 定时任务 定时任务概述 ...
线程池中的阻塞队列选择
转载:https://zhuanlan.zhihu.com/p/32867181 自从最近的某年某月某天起，线上服务开始变得不那么稳定。在高峰期，时常有几台机器的内存持续飙升，并且无法回收，导致服务 ...