勋章
粉丝
技术能力
- Java
- 数据库
- kafka
- Es
- Flink
- 大数据技术栈
- 微服务
- 消息中间件
-
Java
初级
能力说明：
了解变量作用域、Java类的结构，能够创建带main方法可执行的java应用，从命令行运行java程序；能够使用Java基本数据类型、运算符和控制结构、数组、循环结构书写和运行简单的Java程序。
暂时未有相关云产品技术能力~
公众号: 石臻臻的杂货铺,进滴滴群答疑.每周技术专家轮流值班 szzdzhp001
-
发表了文章 2022-10-25
【kafka运维】Topic的生产和消费运维脚本
1.Topic的发送kafka-console-producer.sh 1.1 生产无key消息 ## 生产者 bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test --producer.config config/producer.properties 1.2 生产有key消息加上属性--property parse.key=true
-
发表了文章 2022-10-24
【kafka运维】ConfigCommand运维脚本
ConfigCommand Config相关操作; 动态配置可以覆盖默认的静态配置; 1 查询配置 Topic配置查询 展示关于Topic的动静态配置 1.1.查询单个Topic配置(只列举动态配置)
-
发表了文章 2022-10-23
【kafka运维】TopicCommand运维脚本(1)
1TopicCommand 1.Topic创建 bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 3 --topic test
-
发表了文章 2022-10-22
Kafka消费者JoinGroupRequest流程解析
当我们启动消费者客户端的时候, 会向协调器 coordinator 发起一个 JoinGroup的请求,表示要加入消费组中。 这个发起请求的地方在 AbstractCoordinator#sendJoinGroupRequest
-
发表了文章 2022-10-21
【kafka原理】kafka Log存储解析以及索引机制
我们在kafka的log文件中发现了还有很多以 __consumer_offsets_的文件夹；总共50个; 由于Zookeeper并不适合大批量的频繁写入操作，新版Kafka已推荐将consumer的位移信息保存在Kafka内部的topic中，即__consumer_offsets topic，并且默认提供了kafka_consumer_groups.sh脚本供用户查看consumer信息。
-
发表了文章 2022-10-20
多图详解kafka生产者消息发送过程
今天我们来通过源码来分析一下,生产者发送一条消息的所有流程~~~ 生产者客户端代码
-
发表了文章 2022-10-19
国产CPU执行SPL实现数据库运算的性能实用性测试
任务背景 国际大环境就不用多说了。 对于数据库类的关键业务，全国产技术（国产CPU+国产数据库）和国外主流技术在性能上相比还有不小的差距，经常需要借助分布式技术使用数倍的硬件才能获得类似的效果。
-
发表了文章 2022-10-18
多图详解kafka生产者消息发送过程
作者：石臻臻, CSDN博客之星Top5、Kafka Contributor 、nacos Contributor、华为云 MVP ,腾讯云TVP, 滴滴Kafka技术专家 、 KnowStreaming。 KnowStreaming 是滴滴开源的Kafka运维管控平台, 有兴趣一起参与参与开发的同学,但是怕自己能力不够的同学,可以联系我,当你导师带你参与开源！ 。 生产者客户端代码
-
发表了文章 2022-10-17
接口测试这件小事
伴随着对接口测试的认知升级，是从测试工程师到测试架构师完成蜕变的过程，因此，想和大家聊一下“接口测试这件小事”，以及分享一下我和接口测试之间的爱恨纠葛。
-
发表了文章 2022-10-17
Kafka消费组/者协调器的介绍
什么是协调器 协调器是用于协调多个消费者之间能够正确的工作的一个角色, 比如计算消费的分区分配策略，又或者消费者的加入组与离开组的处理逻辑, 有一点类似Kafka种的控制器的角色。
-
发表了文章 2022-10-16
Kafka监控与指标之UnderReplicatedPartitions
Kafka监控 Kafka 使用 Yammer Metrics 在服务器中报告指标,Java 客户端使用 Kafka Metrics，这是一个内置的指标注册表. 两者都通过 JMX 公开指标 启用JMX并上报指标 Kafka 默认禁用远程 JMX，Kafka启动JMX方式
-
发表了文章 2022-10-13
【kafka问题】记一次kafka消费者未接收到消息问题
出现了这样一个问题, A说他的kafka消息发送了; B说它没有接收到; 那么问题来了： • A的消息是否发送了？ • 如果A的消息发送成功了; B为何没有消费到？ 好,带着上面的问题,我们来一步步排查一下问题所在
-
发表了文章 2022-10-12
多图详解kafka生产者消息发送过程
1构造KafkaProducer KafkaProducer通过解析producer.propeties文件里面的属性来构造自己。 例如 ：分区器、Key和Value序列化器、拦截器、RecordAccumulator消息累加器 、元信息更新器、启动发送请求的后台线程
-
发表了文章 2022-10-10
SPL工业智能：原料与产品的拟合
工业生产活动的目标是利用原料生产产品，从而产生利润。原料经过一系列加工过程，包括物理反应和化学反应，最终形成产品，生产的理想状态是原料到产品的转换率是确定的，工厂想生产多少产品就知道需要准备多少原料，提高生产效率。 许多工艺原理和生产经验都表明，在简化情况下，可以认为原料用量和产品产量之间近似是线性关系。这样，每一种原料和每一种产品之间都会有一个与原料用量无关的恒定转换率，在化工界称为收率
-
发表了文章 2022-10-07
【Redis】三、Redis整数集合和压缩列表
整数集合(intset)是集合建的底层实现之一,当一个集合只包括整数值的元素，并且这个集合的元素数量不多时,Redis就会用整数集合作为集合建的底层实现
-
发表了文章 2022-10-06
【Redis】二、Redis中字典结构
Redis的字典使用哈希表作为底层实现，一个哈希表里面有多个哈希表节点,而每个哈希表节点保存了字典中的一个键值对（key-value）
-
发表了文章 2022-10-04
【Redis】一、Redis的简单动态字符串SDS
Redis没有直接使用C语言传统的字符串表示(以空字符 \0 结尾的字符数组)，而是构建了一种名为简单动态字符串SDS的抽象类型，并将SDS用作Redis的默认字符串表示。
-
发表了文章 2022-10-02
【Jvm】Jvm类加载机制
类加载时机 虚拟机把描述类的数据从 Class 文件加载到内存，并对数据进行校验、转换解析和初始化，最终形成可以被虚拟机直接使用的 Java 类型，这就是虚拟机的类加载机制。 在Java语言里面，类型的加载、连接和初始化过程都是在程序运行期间完成的
-
发表了文章 2022-09-27
怎么样在应用中实现自助报表功能
自助报表需求已经是越来越普遍，各行业的应用软件中，不管是主动还是被动，都在思考并在努力实现自助报表功能 这样做对于用户来说，可以自由灵活的去分析了解数据，不再拘泥于固定格式的数据报表，方便灵活、体验更好的同时，也能盘活更多数据的价值
-
发表了文章 2022-09-26
【Mybatis】Mybatis generator如何修改Mapper.java文件
我写的代码生成插件Gitee地址同样是在扩展 Mybatis generator插件的时候，有这样一个需求是需要在生成的，那么 如何修改Mapper.java文件？ 跟着Mybatis generator 源码去找一找 哪里可以扩展
-
发表了文章 2022-09-25
【Log日志】logback.xml动态配置属性值(包括接入的第三方配置)
1如何动态配置Logback的存放路径 我们在开发过程中,会使用到logback.xml 配置来管理日志文件; 比如
-
发表了文章 2022-09-22
【Kafka】编译 Kafka 源码并搭建源码环
搭建源码环境可以看这篇文章：编译 Kafka 源码并搭建源码环境 上面有个地方注意,启动的时候,可以传入VM参数来指定 kafka.log.dir 路径(存放各种日志的路径)
-
发表了文章 2022-09-21
【kafka原理】 消费者偏移量__consumer_offsets_相关解析
我们在kafka的log文件中发现了还有很多以 __consumer_offsets_的文件夹；总共50个; 由于Zookeeper并不适合大批量的频繁写入操作，新版Kafka已推荐将consumer的位移信息保存在Kafka内部的topic中，即__consumer_offsets topic，并且默认提供了kafka_consumer_groups.sh脚本供用户查看consumer信息。 __consumer_offsets 是 kafka 自行创建的，和普通的 topic 相同。它存在的目的之一就是保存 consumer 提交的位移。__consumer_offsets 的每条消息格
-
发表了文章 2022-09-20
SPL 工业智能：识别指定工况
1问题提出 工业生产过程中会产生大量的数据，比如电压、温度、流量等等，不同的工况条件下，数据的走势不同，比如产量稳定时，流量走势平稳，产量增加时，流量势必也会增加，体现在图像上就是流量曲线上升。 比如下图：
-
发表了文章 2022-09-19
【kafka原理】kafka Log存储解析以及索引机制
本文设置到的配置项有 名称 描述 类型 默认 num.partitions topic的默认分区数 int 1 log.dirs 保存日志数据的目录。如果未设置，则使用log.dir中的值 string /tmp/kafka-logs offsets.topic.replication.factor offset topic复制因子（ps：就是备份数，设置的越高来确保可用性）。为了确保offset topic有效的复制因子，第一次请求offset topic时，活的broker的数量必须最少最少是配置的复制因子数。 如果不是，offset topic将创建失败或获取最小的复制因子（活着的bro
-
发表了文章 2022-09-18
Kafka生产者客户端几种异常Case详解
1生产者UserCallBack异常 异常日志 ERROR Error executing user-provided callback on message for topic-partition 'Topic1-0' (org.apache.kafka.clients.producer.internals.ProducerBatch) 通常还会有具体的异常栈信息 异常源码 ProducerBatch#completeFutureAndFireCallbacks
-
发表了文章 2022-09-17
Spring源码解析(十一)Spring扩展接口InstantiationAwareBeanPostProcessor解析
之前我们有分析BeanPostProcessor接口,今天要分析的InstantiationAwareBeanPostProcessor是继承了BeanPostProcessor接口的; Part1InstantiationAwareBeanPostProcessor InstantiationAwareBeanPostProcessor代表了Spring的另外一段生命周期：实例化。先区别一下Spring Bean的实例化和初始化两个阶段的主要作用： 1、实例化----实例化的过程是一个创建Bean的过程，即调用Bean的构造函数，单例的Bean放入单例池中
-
发表了文章 2022-09-13
Spring源码解析(十)分析一个Spring循环引用失败的问题
1前言: 之前我们有分析过Spring是怎么解决循环引用的问题,主要思路就是三级缓存；Spring在加载beanA的时候会先调用默认的空构造函数(在没有指定构造函数实例化的前提下)得到一个空的实例引用对象，这个时候没有设置任何值，但是Spring会用缓存把它给提前暴露出来，让其他依赖beanA的bean可以持有它提前暴露的引用；比如 a 依赖b ，b依赖a，并且他们都是通过默认方法实例化，那么简单流程是这样的： 1. ioc实例化a,a提前暴露自己的，然后填充属性值，在填充属性值的时候发现有个对象b,这个时候去容器里面取到b的引用，发现b还没有被创建，那么就走实例化b的流程；
-
发表了文章 2022-09-12
Spring源码分析(九)lazy-init 在Spring中是怎么控制加载的
ApplicationContext实现的默认行为就是在启动时将所有singleton bean提前进行实例化（也就是依赖注入）。提前实例化意味着作为初始化过程的一部分，ApplicationContext实例会创建并配置所有的singleton bean。通常情况下这是件好事，因为这样在配置中的任何错误就会即刻被发现（否则的话可能要花几个小时甚至几天）。
-
发表了文章 2022-09-12
Spring源码分析(八)Spring 所有BeanFactoryPostProcessor扩展接口
这一篇分析的不错，我就不分析这个接口了;偷个懒0.0Spring的BeanFactoryPostProcessor和BeanPostProcessor
-
发表了文章 2022-09-07
SPL工业智能：发现时序数据的异常
工业生产过程中会产生大量的数据，比如电压、温度、流量等等，它们随时间推移而不断产生，这些数据在多数情况下是正常的，否则生产无法正常进行；少数情况下，数据是异常的，生产效率会降低甚至发生事故。
-
发表了文章 2022-09-06
Spring源码分析(六)FactoryBean 接口解析
说道FactoryBean，不少人会拿它跟BeanFactory作比较，但是实际上他们没有多大关系；我们简单介绍一下两者 Part1一、BeanFactory和FactoryBean区别 1BeanFactory BeanFactory：这就是一个Factory，是一个IOC容器或者叫对象工厂，它里面存着很多的bean。例如默认的实现方式DefaultListableBeanFactory；我们把IOC容器可以比作一个水桶，IOC容器里面的所有bean就是装的水； ##FactoryBean
-
发表了文章 2022-09-05
Spring源码解析(五)Spring 加载bean 依赖注入
开始这篇文章之前，我们简单回顾一下前面几篇文章的内容 至此，我们分析过后，可以简单的归纳一下Spring IOC容器的过程一、Resource定位过程 这个Resource定位指的的是BeanDefinition的资源定位，他由ResourceLoader通过统一的Resource接口来完成，这个Resource对各种形式的BeanDefinition的使用都提供了统一接口，
-
发表了文章 2022-08-31
Spring源码解析(四)Spring是怎么处理BeanDefinition的？
上一篇文章中分析了 BeanDefinition是怎么被解析出来的，在这一篇文章中我们主要看下 解析完了之后所做的事情； 1一、DefaultBeanDefinitionDocumentReader 源码入口 DefaultBeanDefinitionDocumentReader #processBeanDefinition(Element ele, BeanDefinitionParserDelegate delegate)
-
发表了文章 2022-08-30
Spring源码分析(三)Spring是如何把元素解析成BeanDefinition对象的
spring中解析元素最重要的一个对象应该就属于 BeanDefinition了；这个Spring容器中最基本的内部数据结构；它让xml文件中所有的配置有了一个归属的地方；在xml中存在的配置都能在BeanDefinition找到对应的属性；我们今天来看看BeanDefinition是如何被创建的
-
发表了文章 2022-08-29
Spring源码分析(二)Spring怎么扩展解析xml接口的
1自定义Spring配置 https://blog.csdn.net/bingduanlbd/article/details/38770685 2BeanDefinitionParserDelegate 在DefaultBeanDefinitionDocumentReader处理Document元素时,将Document文档内元素具体解析工作委托给BeanDefinitionParserDelegate类来处理,默认BeanDefinitionParserDelegate会处理”http://www.springframework.org/schema/beans“命名空间下元素及其属性,查看
-
发表了文章 2022-08-29
Sring源码解析(一)Spring是怎么读取配置Xml文件的
1#Spring读取配置文件 ##Document 在XmlBeanDefinitionReader.doLoadBeanDefinitions(InputSource inputSource, Resource resource)方法中将Xml文件转换成Document对象;Document doc = doLoadDocument(inputSource, resource);
-
发表了文章 2022-08-28
【Mybatis】Mybatis generator自动生成插件如何修改Mapper.xml 的命名空间namespace
这也是在扩展 Mybatis generator 的时候遇到的问题，记录一下； 在上一篇文章 如何继承Mybatis中的Mapper.xml文件很重要的一点就是要让两个Mapper.xml文件的命名空间相同，这样才能够实现继承； 那么既然是自动生成插件，在生成原始 Mapper.xml的时候，我要如何去修改他的命名空间呢？ 例如
-
发表了文章 2022-08-27
【Mybatis】如何继承Mybatis中的Mapper.xml文件
最近在写一个 Mybatis 代码自动生成插件，用的是Mybatis来扩展，其中有一个需求就是 生成javaMapper文件和 xmlMapper文件的时候 希望另外生成一个扩展类和扩展xml文件。原文件不修改，只存放一些基本的信息，开发过程中只修改扩展的Ext文件 形式如下：SrcTestMapper.java
-
发表了文章 2022-08-26
【Nacos源码之配置管理 七】服务端增删改配置数据之后如何通知集群中的其他机器
在后台管理界面可以直接增删改查所有的配置数据,那么问题来了 1. [x] 增删改数据这个操作,除了落库,还做了哪些操作？ 1新增配置数据 打开后台新建一个配置
-
发表了文章 2022-08-25
【Nacos源码之配置管理 六】集群模式下服务器之间是如何互相感知的
我们用Nacos当配置中心的时候,上一篇文章中【Nacos源码之配置管理 五】为什么把配置文件Dump到磁盘中 知道了,所有的配置文件都会Dump到服务器的本地磁盘中, 那么集群模式下: • [x] 服务器之间如何彼此感知发现的？ • [x] 当某一台机器宕机挂掉之后怎么处理的？ • [x] 如何获取本地Ip • [x] 获取服务器列表 • [x] 服务器列表健康检查 阅读完本文,会带你对上面的问题有个很清晰的认知；
-
发表了文章 2022-08-25
【Nacos源码之配置管理 五】为什么把配置文件Dump到磁盘中
上一篇文章 【Nacos源码之配置管理 四】DumpService如何将配置文件全部Dump到磁盘中 分析了Nacos将配置文件Dump的磁盘中,那我为什么要Dump到磁盘中呢？这样做有什么好处？哪些地方读取了磁盘中的文件？带着这些问题,我们去源码中一探究竟
-
发表了文章 2022-08-24
接口自动化测试实践指导（下）：接口自动化测试断言设置思路
接口自动化测试实践指导（下）：接口自动化测试断言设置思路
-
发表了文章 2022-08-23
【Nacos源码之配置管理 四】DumpService如何将配置文件全部Dump到磁盘中
本文分析一下,Nacos在启动的时候是怎么将所有的配置文件信息 Dump到磁盘上的; 读完本文,你将了解到以下知识 • [x] 项目启动之初Dump配置数据的流程 • [x] 如何快速启动(isQuickStart：快速启动不用全量Dump配置信息) • [x] DiskUtil.heartBeatFile 这个心跳文件的作用 • [x] 全量Dump执行器DumpAllProcessor • [x] AggrWhitelist这个类是作用是什么 • [x] ClientIpWhiteList作用是什么 • [x] SwitchService作用是什么 • [x] Dump配置数据的事件通知
-
发表了文章 2022-08-21
【Nacos源码之配置管理 三】TaskManager 任务管理的使用
因为Nacos中有很多地方使用了这个TaskManager,所以我们得先了解一下这个类是干啥用的,方便后面阅读源码时候不会吃力; 先说结论:TaskManager 可以看成是一个待执行的任务集合,用于处理一定要执行成功的任务 单线程的方式处理任务，保证任务一定被成功处理; 如果执行失败了,任务会被重新放入集合中等待下一次被消费;
-
发表了文章 2022-08-20
【Nacos源码之配置管理 二】Nacos中的事件发布与订阅--观察者模式
EventDispatcher在Nacos中是一个事件发布与订阅的类,也就是我们经常使用的Java设计模式——观察者模式 一般发布与订阅主要有三个角色 • 事件: 表示某些类型的事件动作,例如Nacos中的 本地数据发生变更事件 LocalDataChangeEvent • 事件源 : 事件源可以看成是一个动作,某个事件发生的动作,例如Nacos中本地数据发生了变更,就会通知给所有监听该事件的监听器 • 事件监听器： 事件监听器监听到事件源之后,会执行自己的一些业务处理,监听器必须要有回调方法供事件源回调 一个监听器可以监听多个事件,一个事件也可以被多个监听器监听 那我们看看这个类中的角
-
发表了文章 2022-08-19
【Nacos源码之配置管理 一】阅读源码第一步,本地启动Nacos
在我们去阅读Nacos源码之前,我们得先了解Nacos是干嘛的,以及怎么用,这样有利于我们更容易去理解源码; 查看Nacos的官方文档,我们知道Naocs主要有以下特性: • 配置中心 • 服务注册与发现 • ... Nacos有给我们提供管理界面,用来方便配置数据;我们先把整个Nacos源码克隆下来,本地启动;熟悉一下如何使用它
-
发表了文章 2022-08-18
呕心沥血20万字《Kafka运维与实战宝典》免费开放下载了
呕心沥血20万字《Kafka运维与实战宝典》免费开放下载了
-
发表了文章 2022-08-15
Kafka的灵魂伴侣Logi-KafkaManger(1)之集群的接入及相关概念讲解
Kafka的灵魂伴侣Logi-KafkaManger(1)之集群的接入及相关概念讲解
-
发表了文章 2022-08-15
【jvm】通过JDBC为例谈谈双亲委派模型的破坏
双亲委派模型并不是一个强制约束模型,而是java设计者推荐给开发者的类加载实现方式；但是也会有例外; 今天我们主要来讲一讲 类似于SPI这种设计导致的双亲委派模型被“破坏”的情况;
-
发表了文章
2024-10-16
写代码还有专业的编程显示器？
-
发表了文章
2024-05-15
Apollo开放平台9.0让自动驾驶开发者轻松上手
-
发表了文章
2023-09-19
Rocketmq并发和顺序消费的失败重试机制
-
发表了文章
2023-09-12
寻找协调器FindCoordinatorRequest请求流程
-
发表了文章
2023-09-11
图解Kafka消费者客户端分区分配策略
-
发表了文章
2023-08-21
人工智能引领图文扫描新趋势
-
发表了文章
2023-05-31
专业的知识图谱应用门槛正在被不断降低
-
发表了文章
2023-03-05
【git】将本地代码推送到远程git仓库
-
发表了文章
2023-03-01
自动化测试工具加入黑科技带来新纪元
-
发表了文章
2023-02-24
【kafka】常用命令汇总
-
发表了文章
2023-02-18
开源SPL助力JAVA处理公共数据文件（txt/csv/json/xml/xsl）
-
发表了文章
2023-02-16
关系型数据库的架构演变
-
发表了文章
2023-02-08
可路由计算引擎实现前置数据库
-
发表了文章
2023-02-04
一图全解Kafka在zookeeper中的数据结构
-
发表了文章
2023-01-30
接口测试这件小事
-
发表了文章
2023-01-25
如何用Know Streaming来查询Kafka的消息
-
发表了文章
2023-01-22
如何快速优雅的用Know Streaming创建Topic
-
发表了文章
2023-01-19
开源SPL强化MangoDB计算
-
发表了文章
2023-01-15
【面试题】Java 2个(多个)大整数相加如何实现
-
发表了文章
2023-01-12
【Kafka】编译 Kafka 源码并搭建源码环
