rocketmq机制
Java SPI机制详解
一、什么是SPI机制 1、SPI（Service Provider Interface）,是JDK内置的一种服务提供发现机制，可以用来启用框架扩展和替换组件，主要被框架的开发人员使用，比如Java.sql.Driver接口，其他不同厂商可以针对同一接口作出不同的实现，MySQL和PostgreSQL ......
JVM类加载机制
JVM的类加载分为5个阶段：加载、验证、准备、解析和初始化。在类初始化完成后可以使用该类的信息，在一个类不再被需要时可以从JVM中卸载 1.加载 指JVM读取Class文件，并根据Class文件描述创建Java.lang.Class对象的过程。类加载过程主要包含将Class文件读取到运行时区域的方法 ......
UI自动化alter框 、等待机制
一、下拉框处理： 网页上的js弹出框一般有三种情况，且识别不了元素，需要使用switch_to.alert（） 进行跳转 情况一： 这时候需要先跳转到此弹窗，才能做到自动化点击确定： driver.find_element(By.XPATH,"//input[@name='alterbutton'] ......
Docker部署RocketMQ
为容器网络互联创建RocketMQ的docker网络 # 后续的name-server,broker,rocketmq-console都会使用该网络 docker network create rocketmq # 创建好网络可以使用docker inspect命令查看网络信息 docker ins ......
OpenStack使用ISO镜像安装虚拟机制作镜像模板（本文底稿原创，由ChatGPT润色）
在OpenStack云平台中，使用ISO镜像安装虚拟机是非常常见的一种方式。本文将介绍如何在OpenStack中使用ISO镜像创建一个虚拟机，并将其制作成模板。 第一步，我们需要将ISO镜像上传到OpenStack中的glance中。glance是OpenStack中的镜像服务，用于管理虚拟机和容器 ......
太坑了，我竟然从RocketMQ源码中扒出了7种导致消息重复消费的原因
大家好，我是三友~~ 在众多关于MQ的面试八股文中有这么一道题，“如何保证MQ消息消费的幂等性”。 为什么需要保证幂等性呢？是因为消息会重复消费。 为什么消息会重复消费？ 明明已经消费了，为什么消息会被再次被消费呢？ 不同的MQ产生的原因可能不一样 本文就以RocketMQ为例，来扒一扒Rocket ......
【分布式技术专题】「分布式技术架构」一文带你厘清分布式事务协议及分布式一致性协议的算法原理和核心流程机制（Paxos篇）
概念简介 Paxos是一种基于消息传递具有高度容错特性的一致性算法，是目前公认的解决分布式一致性问题最有效的算法之一。 发展历史 Paxos算法的发展历史追溯到古希腊，当时有一个名为“Paxos“的小岛， 岛上采用一会的形式通过法令， 议会中议员通过信使进行消息传递，议员与信使都是兼职的，他们随时都 ......
ThreadPool实现机制
Android中阻塞队列的应用有哪些 阻塞队列在 Android 中有很多应用，比如： 线程池：线程池任务的执行就是基于一个阻塞队列，如果线程池任务已满，则任务需要等待阻塞队列中的其他任务完成。 Handler 消息队列：Handler 的消息队列也是一种阻塞队列。handler发送消息时，首先将消 ......
基于 RocketMQ Connect 构建数据流转处理平台
为什么在“双11”抢红包活动及大型数据系统中总是出现 RocketMQ 的身影？ RocketMQ Connect在RocketMQ 生态中扮演什么角色？本文为大家解答上述疑问。同时，介绍 OceanBase 与 RocketMQ 如何集成以及能帮助大家解决哪些问题。 ......
某大厂面试题：说一说Java、Spring、Dubbo三者SPI机制的原理和区别
大家好，我是三友~~ 今天来跟大家聊一聊Java、Spring、Dubbo三者SPI机制的原理和区别。 其实我之前写过一篇类似的文章，但是这篇文章主要是剖析dubbo的SPI机制的源码，中间只是简单地介绍了一下Java、Spring的SPI机制，并没有进行深入，所以本篇就来深入聊一聊这三者的原理和区 ......
.Net DI(Dependency Injection)依赖注入机制
1、简介 DI：Dependency Injection，即依赖注入，他是IOC的具体实现。 在DI中，底层服务对象不再负责依赖关系的创建，而是交由顶端调用进行管理注入 好处：降低组件之间的耦合度，使代码更加灵活 2、实例 我们举个例子，有个User Login的功能，Login需要通过DB验证，D ......
JAVA重试机制多种方式深入浅出
重试机制在分布式系统中，或者调用外部接口中，都是十分重要的。 重试机制可以保护系统减少因网络波动、依赖服务短暂性不可用带来的影响，让系统能更稳定的运行的一种保护机制。 为了方便说明，先假设我们想要进行重试的方法如下： @Slf4j @Component public class HelloServi ......
微信小程序结合php后台实现登录授权机制详解
微信小程序应用的用户登录授权机制相当复杂，官方给出了下面一张流程图来解释： 下面结合这张图来详细讲述下小程序的登录验证授权机制。 首先，小程序应用实现登录验证的前提是需要在微信开放平台注册一个开发者账号，申请到AppID 和 AppSecret。并申请开启“获取用户信息”的权限。 然后 ，在小程序中 ......
通过源码分析RocketMQ主从复制原理
RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件，具有高性能、高可靠、高实时、分布式特点。本篇文章通关源码分析深入地介绍了RocketMQ主从复制原理。 ......
【RocketMQ】DLedger选主源码分析
RocketMQ 4.5版本之前，可以采用主从架构进行集群部署，但是如果master节点挂掉，不能自动在集群中选举出新的Master节点，需要人工介入，在4.5版本之后提供了DLedger模式，使用Raft算法，如果Master节点出现故障，可以自动选举出新的Master进行切换。 Raft协议 R ......
【RocketMQ】Dledger日志复制源码分析
消息存储 在 【RocketMQ】消息的存储一文中提到，Broker收到消息后会调用CommitLog的asyncPutMessage方法写入消息，在DLedger模式下使用的是DLedgerCommitLog，进入asyncPutMessages方法，主要处理逻辑如下： 调用serialize方法 ......
AIR32F103(九) CAN总线的通信和ID过滤机制及实例
CAN 是一种典型的广播式网络, 在实际应用中, 如果只希望接收到特定类型的数据, 就要借助过滤器来实现. AIR32/STM32的CAN控制器包含14个过滤器, 可以设置为 屏蔽模式 或 列表模式 对CAN总线上的报文进行过滤. 当节点希望接收到一种报文时, 可以用屏蔽位模式进行过滤, ......
redis（10）事务和锁机制
Redis事务定义 Redis 事务是一个单独的隔离操作：事务中的所有命令都会序列化、按顺序地执行。事务在执行的过程中，不会被其他客户端发送来的命令请求所打断。 Redis 事务的主要作用就是串联多个命令防止别的命令插队。 Multi、Exec、discard Redis 事务中有 Multi、Ex ......
《深入理解java虚拟机》第七章读书笔记——虚拟机类加载机制
系列文章目录和关于我 一丶虚拟机类加载机制是什么 java虚拟机将描述类的数据从class文件加载到内存,并对数据进行校验，转换解析和初始化，最终形成可用被虚拟机直接使用的java类型。 二丶类加载时机 1.什么时候会触发虚拟机的类类加载昵？ 遇到new（使用new关键字实例化对象），getstat ......
RocketMQ 5.0 vs 4.9.X 图解架构对比
本文作者：李伟，Apache RocketMQ Committer，RocketMQ Python客户端项目Owner ，Apache Doris Contributor，腾讯云数据库开发工程师。 01 RocketMQ 4.9.X架构 在4.9.X中每个组件和组件之间的通信简单说明如下： | 组件 ......
RocketMQ Streams 1.1.0: 轻量级流处理再出发
作为一套全新的流式处理框架，RocketMQ Streams 如何实现流计算拓扑图构建呢？一起来了解下它的实现原理以及数据流转过程和过程中的状态变化吧~ ......
RocketMQ消息短暂而又精彩的一生
大家好，我是三友~~ 这篇文章我准备来聊一聊RocketMQ消息的一生。 不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑： 消息是如何发送的，队列是如何选择的？消息是如何存储的，是如何保证读写的高性能？RocketMQ是如何实现消息的快速查找的？RocketMQ是如何实现高可用的？消 ......
【RocketMQ】消息拉模式分析
RocketMQ有两种获取消息的方式，分别为推模式和拉模式。 推模式 推模式在【RocketMQ】消息的拉取一文中已经讲过，虽然从名字上看起来是消息到达Broker后推送给消费者，实际上还是需要消费向Broker发送拉取请求获取消息内容，推模式对应的消息消费实现类为DefaultMQPushCons ......
Redis缓存何以一枝独秀？(2) —— 聊聊Redis的数据过期、数据淘汰以及数据持久化的实现机制
Redis作为一个非关系型数据库，由于其超高的并发处理性能，及其对缓存场景所提供的系列能力构建，使其成为了集中缓存的绝佳选择。本篇我们聊聊Redis数据管理的能力，如数据过期、数据淘汰、数据持久化等。 ......
【RocketMQ】负载均衡源码分析
RocketMQ在集群模式下，同一个消费组内，一个消息队列同一时间只能分配给组内的某一个消费者，也就是一条消息只能被组内的一个消费者进行消费，为了合理的对消息队列进行分配，于是就有了负载均衡。 接下来以集群模式下的消息推模式DefaultMQPushConsumerImpl为例，看一下负载均衡的过程 ......
【Dubbo3终极特性】「流量治理体系」一文教你如何通过Dubbo-Admin实现动态进行流量隔离机制
背景信息 如果一个应用有多个版本在线上同时运行，部署在不同环境中，如日常环境和特殊环境，则 可以使用标签路由对不同环境中的不同版本进行流量隔离，将秒杀订单流量或不同渠道订单流量路由到特殊环境，将正常的流量路由到日常环境。即使特殊环境异常，本应进入特殊环境的流量也不会进入日常环境，不影响日常环境的使用 ......
Redis+Hbase+RocketMQ 实际使用问题案例分享
##需求 将Hbase数据，解析后推送到RocketMQ。 redis使用list数据类型，存储了需要推送的数据的RowKey及表名。 简单画个流程图就是： ##分析及确定方案 Redis 明确list中元素结构{"rowkey":rowkey,"table":table}解析出rowkey； 一次 ......
【分布式技术专题】「LVS负载均衡」全面透析Web基础架构负载均衡LVS机制的原理分析指南
前提概要 在大规模互联网应用中，负载均衡设备是必不可少的组成部分，源于互联网应用的高并 发和大流量的冲击压力场景下，通常会在服务端部署多个无状态的应用服务器和若干有状态的存储服务器（数据库、缓存等等）实现高可用特点和机制。 LVS的介绍说明 官方站点：http://www.linuxvirtuals ......
Apache RocketMQ 5.0 笔记
RocketMQ 5.0：云原生“消息、事件、流”实时数据处理平台，覆盖云边端一体化数据处理场景。 核心特性 云原生：生与云，长与云，无限弹性扩缩，K8s友好 高吞吐：万亿级吞吐保证，同时满足微服务与大数据场景 流处理：提供轻量、高扩展、高性能和丰富功能的流计算引擎 金融级：金融级的稳定性，广泛用于 ......
Redis持久化机制
全量同步与增量同步的区别 全量同步：就是每天定时（避开高峰期）或者采用一个周期实现将数据拷贝到一个地方也就是Rdb存储。 增量同步：比如采用对行为的操作实现对数据的同步，也就是AOF。 全量与增量的比较：增量同步比全量同步更加消耗服务器的内存，但是能够更加的保证数据的同步。 RDB与AOF实现持久化 ......