RocketMQ消息队列的最佳实践(中)
2.3 消费打印日志如果消息量较少,建议在消费入口方法打印消息,消费耗时等,方便后续排查问题。 public ConsumeConcurrentlyStatus consumeMessage( List<MessageExt> msgs, ConsumeConcurrentlyContext context) { l...

RocketMQ消息队列的最佳实践(上)
1 生产者1.1 发送消息注意事项1 Tags的使用一个应用尽可能用一个Topic,而消息子类型则可以用tags来标识。tags可由应用自行设置,只有生产者在发送消息设置了tags,消费方在订阅消息时才可以利用tags通过broker做消息过滤:message.setTags("TagA");2 Keys的使用每个消息在业务层面的唯一标识码要设置到keys字段,方便日后定位消息丢失问题。服务器会....
RocketMQ/Kafka等消息队列复制的最佳实践
MQ在Pro、Con端,依靠业务代码,配合请求确认机制保证在服务端,采用持久化和复制保证不会丢消息。把消息复制到多节点,可解决丢消息问题保证消息服务的HA所以都会把MQ配置成集群模式,并开启消息复制。那么消息复制需要解决哪些问题呢?1 消息复制的指标期望MQ具备高性能、高可用和数据一致性。很多MQ都声明这些特性全部支持,但都有前置条件。1.1 性能无论采用哪种复制,都需数据被写到多节点后再返回,....
消息队列RocketMQ版计费问题:如何关闭消息队列 RocketMQ 版服务?
消息队列RocketMQ版计费问题:如何关闭消息队列 RocketMQ 版服务?
消息队列RocketMQ版计费问题:没有使用消息队列 RocketMQ 版服务,为什么会扣费?
消息队列RocketMQ版计费问题:没有使用消息队列 RocketMQ 版服务,为什么会扣费?
aliyun上的rocket mq 消息队列用内网连接点 消息访问不了 找不到路由是什么#Java
aliyun上的rocket mq 消息队列用内网连接点 消息访问不了 找不到路由是什么情况?#Java
Apache RocketMQ 消息队列部署与可视化界面安装
一、介绍 Apache RocketMQ是一个分布式、队列模型的消息中间件,具有低延迟、高性能和高可靠、万亿级容量和灵活的可扩展性。核心组件由四部分组成:Name Servers,Brokers,Producer 和 Consumer;它们中的每一个都可以水平扩展,而没有单一的故障节点。 NameServer:是一个几乎无状态的节点,可集群部署,节点之间无任何信息同步 Broker:部署...

滴滴出行基于RocketMQ构建企业级消息队列服务的实践
本文整理自滴滴出行消息队列负责人 江海挺 在Apache RocketMQ开发者沙龙北京站的分享。通过本文,您将了解到滴滴出行: 1. 在消息队列技术选型方面的思考; 2. 为什么选择 RocketMQ 作为出行业务的消息队列解决方案; 3. 如何构建自己的消息队列服务; 4. 在 RocketMQ 上的扩展改造实践; 5. 在 RocketMQ 上的实践经验。 江海挺: 滴滴出行...
滴滴出行基于RocketMQ构建企业级消息队列服务的实践
本文整理自滴滴出行消息队列负责人 江海挺 在Apache RocketMQ开发者沙龙北京站的分享。通过本文,您将了解到滴滴出行: 在消息队列技术选型方面的思考; 为什么选择 RocketMQ 作为出行业务的消息队列解决方案; 如何构建自己的消息队列服务; 在 RocketMQ 上的扩展改造实践; 在 RocketMQ 上的实践经验。 江海挺: 滴滴出行消息队列负责人,Apache Roc...
RocketMq消息队列使用
最近在看消息队列框架 ,alibaba的RocketMQ单机支持1万以上的持久化队列,支持诸多特性, 目前RocketMQ在阿里集团被广泛应用在订单,交易,充值,流计算,消息推送,日志流式处理,binglog分发等场景 比kafka还是有过之无不及,其实kafka文档很丰富 但RocketMQ网上的文章太少,找不到相关的操作教程 于是研究了下源码 做个单机操作的教程,如果你也对此有兴趣不妨共同研....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
阿里中间件
为企业提供高效、稳定、易扩展的中间件产品
+关注