经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
 RocketMQ

Redis+Hbase+RocketMQ 实际使用问题案例分享

需求 将Hbase数据,解析后推送到RocketMQ。 redis使用list数据类型,存储了需要推送的数据的RowKey及表名。 简单画个流程图就是: 分析及确定方案 Redis 明确list中元素结构{"rowkey":rowkey,"table":table}解析出rowkey...[2023/1/20]

RocketMq深入分析讲解两种削峰方式

RocketMq深入分析讲解两种削峰方式

目录何时需要削峰通过消息队列的削峰方法有两种消费延时控流总结 何时需要削峰 当上游调用下游服务速率高于下游服务接口QPS时,那么如果不对调用速率进行控制,那么会发生很多失败请求 通过消息队列的削峰方法有两种 控制消费者消费速率和生产者投放延时消息,本质都是控制消费速度 通过消费者参数...[2023/1/20]

RocketMQ消息短暂而又精彩的一生

大家好,我是三友~~ 这篇文章我准备来聊一聊RocketMQ消息的一生。 不知你是否跟我一样,在使用RocketMQ的时候也有很多的疑惑: 消息是如何发送的,队列是如何选择的?消息是如何存储的,是如何保证读写的高性能?RocketMQ是如何实现消息的快速查找的?RocketMQ是如何实现高...[2023/1/11]

【RocketMQ】负载均衡源码分析

RocketMQ在集群模式下,同一个消费组内,一个消息队列同一时间只能分配给组内的某一个消费者,也就是一条消息只能被组内的一个消费者进行消费,为了合理的对消息队列进行分配,于是就有了负载均衡。 接下来以集群模式下的消息推模式DefaultMQPushConsumerImpl为例,看一下负载...[2023/1/11]

RocketMQ 在网易云音乐的实践

本文作者:蒋星韬,网易云音乐服务端开发工程师。 云音乐线上场景众多,比如直播、评论、广告,各个业务线都会有消息场景比如发奖券,也会有延迟消息和事务消息场景,以及大数据做埋点数据、数据清洗、离线处理等。 云音乐线上 RocketMQ topic 为 1 万+/天,QPS 流量峰值为150万...[2022/12/12]

【RocketMQ】主从同步实现原理

主从同步的实现逻辑主要在HAService中,在DefaultMe ageStore的构造函数中,对HAService进行了实例化,并在start方法中,启动了HAService: public cla DefaultMe ageStore implements Me ageStore { ...[2022/12/5]

基于 RocketMQ 的 Dubbo-go 通信新范式

本文作者:郝洪范 ,Dubbo-go Committer,京东资深研发工程师。 一、MQ Request Reply特性介绍 什么是 RPC 通信? 如上图所示,类似于本地调用,A 服务响应调用 B 服务的 helloworld 方法需要怎么做?首先,A 服务的 Client Sub ...[2022/12/2]

读 RocketMQ 源码,学习并发编程三大神器

笔者是 RocketMQ 的忠实粉丝,在阅读源码的过程中,学习到了很多编程技巧。 这篇文章,笔者结合 RocketMQ 源码,分享并发编程三大神器的相关知识点。 1 CountDownLatch 实现网络同步请求 CountDownLatch 是一个同步工具类,用来协调多个线程之间的...[2022/11/28]

Prometheus 监测 RocketMQ 最佳实践

本文作者:郭雨杰,阿里云智能技术专家。 Prometheus 集成的 50 多款云产品中,RocketMQ 在可观测方面实现了非常完善的功能,是一个特别具有代表性的云产品。 01 RocketMQ如何接入Prometheus RocketMQ 诞生于阿里内部的核心电商系统,是业务消息...[2022/11/17]

607
2
记录数:9 页数:1/11
 友情链接: NPS
加载更多