elastic-job源码 机制elastic
RocketMQ之消息发送源码分析
一、概述 负责生产消息，一般由业务系统负责生产消息。一个消息生产者会把业务应用系统里产生的消息发送到broker服务器。 RocketMQ支持三种消息发送方式： 同步消息发送(sync)：当Producer发送消息到Broker时会同步等待消息处理结果； 异步消息发送(async)：当Produce ......
RocketMQ之消息接收源码分析
一、概述 对于任何一款消息中间件而言，消费者客户端一般有两种方式从消息中间件获取消息并消费： Push方式：由消息中间件(MQ消息服务器代理)主动地将消息推送给消费者；采用Push方式，可以尽可能实时地将消息发送给消费者进行消费。但是，在消费者的处理消息的能力较弱的时候(比如，消费者端的业务系统处理 ......
一种通过注入机制获取资源的方法
目的：从地图网站上获取瓦片文件，但直接访问图片地址显示被禁止。需要绕开这个禁止。 方法：通过在页面脚本中进行注入，在加载资源的时候，直接将资源下载到本地下载文件夹中 关键： 1、注入方法，将原事件函数指向新变量，用自己的函数替代，并执行原函数以保证程序正常运行； 2、新变量仍在原对象中，保证闭包的局 ......
聊聊怎样快速去阅读JDK源码？
1. 前言 之前断断续续读过一部分 JDK 常用类的源码，这里想把过程中的一些心得和方法记录下来，如果能帮到需要的小伙伴就再好不过了！ 本文主要分享一下我的阅读工具和阅读顺序。 PS: 由于当前主流使用的 JDK 版本仍是 1.8，因此源码阅读主要是 1.8 版本，有些地方可以参考 1.7。 2. ......
[HiBench] 安装HiBench，测试在Spark上跑PageRank与修改源码测试
[HiBench] 安装HiBench，测试在Spark上跑PageRank与修改源码测试 背景：我想在HiBench上测试在Spark上跑PageRank性能，并想要修改PageRank的源码进行测试。本来，HiBench在README里写的已经挺清楚的了，直接照着做就行。奈何我用的服务器没有珂学 ......
forms组件与源码分析、modelform组件
一、forms组件 forms组件介绍 我们之前在HTML页面中利用form表单向后端提交数据时，都会写一些获取用户输入的标签并且用form标签把它们包起来. 与此同时我们在好多场景下都需要对用户的输入做校验，比如校验用户是否输入，输入的长度和格式等正不正确... 如果用户输入的内容有错误就需要在页 ......
django视图层与cbv源码分析
一、视图层之必会三板斧 之前我们简单学习了三板斧的使用，这里我们进行一些深入的了解。 视图函数不写返回值会报错，报错信息如下： 这里就引出了今天的话题。这里我们需要记住一个定论：用来处理请求的视图函数都必须返回HttpResponse对象 在之前学习的时候我们对HttpResponse的作用仅限于知 ......
RocketMQ之通信机制
一、概述 RocketMQ消息队列集群主要包括NameServer、Broker(Master/Slave)、Producer、Consumer4个角色，基本通讯流程如下： Broker启动后需要完成一次将自己注册至NameServer的操作；随后每隔30s时间定时向NameServer上报Topi ......
RocketMQ之重试机制
一、概述 Producer对发送失败的消息进行重新发送的机制，称为消息发送重试机制，也称为消息重投机制。 对于消息重投，需要注意以下几点： 生产者在发送消息时，若采用同步或异步发送方式，发送失败会重试，但oneway消息发送方式发送失败是没有重试机制的; 只有普通消息具有发送重试机制，顺序消息是没有 ......
spring-transaction源码分析(2)EnableTransactionManagement注解
概述(Java doc) 该注解开启spring的注解驱动事务管理功能，通常标注在@Configuration类上面用于开启命令式事务管理或响应式事务管理。 @Configuration @EnableTransactionManagement public class AppConfig { @B ......
spring-transaction源码分析(1)概述和事务传播级别
spring-tx概述 spring-tx包使用注解驱动和AOP通知将事务开启、提交/回滚、以及复杂的传播机制封装了起来，开发者不再需要编写事务管理的代码，而是可以只关注自己的业务逻辑。 本文将简单介绍spring-tx使用步骤以及七种事务传播级别。 后续文章会阅读源码，深入分析spring-tx ......
php垃圾回收机制
标量的区别 php7不在计数 refcount都是为0 <?php $a = 1; xdebug_debug_zval('a'); echo PHP_EOL; $b = $a; xdebug_debug_zval('a'); 结果： a: (refcount=0, is_ref=0)=1 a: (r ......
Triton 源码初步研读
一、核心接口形态 def jit( fn: Optional[T] = None, *, version=None, do_not_specialize: Optional[Iterable[int]] = None, debug: Optional[bool] = None, ) -> Union ......
CINN 中子图编译缓存机制
采用 「问-答」形式记录研读 CINN 开源框架的笔记 Q：CINN中子图编译的入口是在哪里？ for (const auto& node_vec : clusters) { // < 逐个遍历每个子图 // Classify var node to inputs, outputs, and int ......
CyclicBarrier源码分析
1、CyclicBarrier的介绍 CyclicBarrier 被称为栅栏，允许一组线程相互等待，直到这一组线程都准备完毕，放行，程序方可继续执行。 就好像做摩天轮，游乐园规定，至少有9个游客乘坐摩天轮，管理员才可以启动摩天轮，游客数和管理员少一个条件，摩天轮都不会启动。 2、CyclicBarr ......
ConditionObject源码分析
ConditionObject是AbstractQueuedSynchronizer(AQS)实现的内部类，类图如下： 1、Condition接口 ConditionObject实现了Condition接口。先来看看Codition接口。 Codition中主要定义了挂起线程和唤醒线程的接口方法。C ......
java基于springboot+vue的校园新闻网站、校园新闻管理系统，附源码+数据库+文档+PPT，适合毕业设计
1、项目介绍 校园新闻网站的主要使用者分为管理员和用户，实现功能包括管理员：首页、个人中心、用户管理、新闻类型管理、校园新闻管理、留言板管理、论坛交流、系统管理，用户前台：首页、校园新闻、论坛交流、留言反馈、个人中心、后台管理等功能。由于本网站的功能模块设计比较全面，所以使得整个校园新闻网站信息管理 ......
C++中的多线程编程和同步机制
C++中的多线程编程和同步机制使得程序员可以利用计算机的多核心来提高程序的运行效率和性能。本文将介绍多线程编程和同步机制的基本概念和使用方法。 多线程编程基础 在C++中，使用<thread>库来创建和管理线程。线程可以通过函数、成员函数或者Lambda表达式来实现。以下是一个使用Lambda表达式 ......
类加载机制和Bean的生命周期
类加载机制和Bean的生命周期是Java中非常重要的两个概念，它们分别对应了Java类的加载和对象的创建、初始化、销毁等过程。 类加载机制是指当Java程序需要使用某个类时，JVM会通过类加载器将该类加载到内存中，并对该类进行初始化。类加载器会按照一定的顺序查找类文件，并加载到内存中。类加载机制可以 ......
java基于springboot+vue的垃圾分类管理系统，附源码+文档+PPT+数据库
1、项目介绍 垃圾分类网站的主要使用者分为管理员和用户、垃圾分类管理员，实现功能包括管理员：首页、个人中心、用户管理、垃圾分类管理员管理、垃圾分类管理、垃圾类型管理、垃圾图谱管理、系统管理，垃圾分类管理员；首页、个人中心、用户管理、垃圾分类管理员管理、垃圾分类管理、垃圾类型管理、垃圾图谱管理，用户前 ......
关于java反射机制基础资料
Java 的反射机制允许在程序运行期间，借助反射 API 获取类的内部信息，并能直接操作对象的内部属性及方法。 Java 反射机制提供的功能： 在运行时，使用反射分析类的能力，获取有关类的一切信息（类所在的包、类实现的接口、标注的注解、类的数据域、类的构造器、类的方法等） 在运行时，使用反射分析对象 ......
MASA MinimalAPI源码解析：为什么我们只写了一个app.MapGet,却生成了三个接口
源码解析：为什么我们只写了一个app.MapGet,却生成了三个接口 1.ServiceBase 1.AutoMapRoute 源码如下： AutoMapRoute自动创建map路由，MinimalAPI会根据service中的方法，创建对应的api接口。 比如上文的一个方法： public asy ......
Go源码阅读——github.com/medcl/esm
esm（An Elasticsearch Migration Tool）—— main.go https://github.com/medcl/esm 阅读源码，我没啥好方法和好习惯，唯 "莽 "。 一、main.go func main(){} // 该方法用于基于源索引的刷新设置来还原目标索引的 ......
Fart脱壳-源码分析
源码分析 首先看java代码,在APP启动时候反射了DexFile.java中三个方法,分别是 getClassNameList defineClassNative dumpMethodCode 其中前面两个方法是android自带的,dumpMethodCode方法是fart自己添加的 // fr ......
直播app源码，根据页面滚动高亮显示目录的侧边栏
直播app源码，根据页面滚动高亮显示目录的侧边栏 父组件代码如下（示例）： <template> <div class="demo"> <div class="container" style=" " v-for="item in navLists" :key="item">{{item}}</di ......
Kubernetes API 安全机制详解
作为后台支撑，Kubernetes优势明显，咪付的蓝牙过闸系统和全态识别AI系统的后台支撑采用了Kubernetes。Kubernetes平台稳定运行一个重要因素是安全性的有效保障，其中API的访问安全是一个重要方面，本文讲解Kubernetes如何保证API访问的安全性。 本篇文章包含以下内容： ......
从源码深入理解读写锁(golang-RWMutex)
环境：go 1.19.8 在读多写少的情况下，即使一段时间内没有写操作，大量并发的读访问也不得不在Mutex的保护下变成串行访问，这种情况下，使用Mutex，对性能影响比较大。 所以就要区分读写操作。如果某个读操作的g持有了锁，其他读操作的g就不必等待了，可以并发的访问共享变量，这样就可以将串行的读 ......
Opal 教程之二 SipIM 例子源码分析
在互联网上.极少有关于Opal的中文教程.因此敝人决定把学习Opal的过程记录下来勉励自己.抑或给后来者留下一些入门的资料.最近感觉学习Opal已经慢慢摸出了门道.前几个星期.摸索在 VS2005编译Opal 花了我好多天的时间.把我的耐心都磨得差不多快要放弃研究Opal.作为初学者.学习的难度被一 ......
RocketMQ笔记(十一)：消息存储删除机制
RocketMQ的消息采用文件进行持久化存储。 1、存储目录详情 RocketMQ中默认文件存储位置/root/store，文件详情如下 commitLog：消息存储目录 config：运行期间一些配置信息 consumerqueue：消息消费队列存储目录 index：消息索引文件存储目录 chec ......