搜索[源码学习]结果-低调大师优秀个人博客

精选列表

搜索[源码学习]，共10000篇文章

JUC并发组件CountDownLatch源码分析

前提之前已经花了大量时间分析同步器框架AQS的源码实现，这篇文章分析一下CountDownLatch的源码实现，本文参看的JDK源码为JDK11，其他版本不一定适合。

2020-08-30

深入理解 WebSecurityConfigurerAdapter【源码篇】

松哥原创的 Spring Boot 视频教程已经杀青，感兴趣的小伙伴戳这里-->Spring Boot+Vue+微人事视频教程我们继续来撸 Spring Security 源码，今天来撸一个非常重要的

2020-07-29

深入理解 AuthenticationManagerBuilder 【源码篇】

松哥原创的 Spring Boot 视频教程已经杀青，感兴趣的小伙伴戳这里-->Spring Boot+Vue+微人事视频教程咱们继续来撸 Spring Security 源码。

2020-07-23

深入理解 HttpSecurity【源码篇】

因此我们有必要从源码的角度来理解下 HttpSecurity 到底干了啥？

2020-07-22

深入理解 SecurityConfigurer 【源码篇】

松哥原创的 Spring Boot 视频教程已经杀青，感兴趣的小伙伴戳这里-->Spring Boot+Vue+微人事视频教程我们来继续撸 Spring Security 源码。

2020-07-21

以3.11.4为基础 Cassandra 启动流程从bin下面的cassandra脚本开始进去看，会涉及到cassandra-env.sh进行进程启动的一些参数设置比如堆上内存分配，日志参数配置，基本环境设置等，我们直接看到启动的进程，也就是launch_service 这个函数,然后看到里面的exec 执行JAVA的进程，也就是class（launch_service参数传进来的classname为org.apache.cassandra.service.CassandraDaemon类）；大概的流程是： cassandra -> lauch_service -> JAVA启动org.apache.cassandra.service.CassandraDaemon；接下来就是看到org.apache.cassandra.service.CassandraDaemon这个类，直接在这个类里面通过main函数找到启动的入口： public static void main(String[] args) { instance.activate(); } 在active函数里面有3个主要要看的函数： // Do not put any references to DatabaseDescriptor above the forceStaticInitialization call. try { applyConfig(); MBeanWrapper.instance.registerMBean(new StandardMBean(new NativeAccess(), NativeAccessMBean.class), MBEAN_NAME, MBeanWrapper.OnException.LOG); if (FBUtilities.isWindows) { // We need to adjust the system timer on windows from the default 15ms down to the minimum of 1ms as this // impacts timer intervals, thread scheduling, driver interrupts, etc. WindowsTimer.startTimerPeriod(DatabaseDescriptor.getWindowsTimerInterval()); } setup(); String pidFile = System.getProperty("cassandra-pidfile"); if (pidFile != null) { new File(pidFile).deleteOnExit(); } start(); } catch (Throwable e) { boolean logStackTrace = e instanceof ConfigurationException ? ((ConfigurationException)e).logStackTrace : true; System.out.println("Exception (" + e.getClass().getName() + ") encountered during startup: " + e.getMessage()); if (logStackTrace) { if (runManaged) logger.error("Exception encountered during startup", e); // try to warn user on stdout too, if we haven't already detached e.printStackTrace(); exitOrFail(3, "Exception encountered during startup", e); } else { if (runManaged) logger.error("Exception encountered during startup: {}", e.getMessage()); // try to warn user on stdout too, if we haven't already detached System.err.println(e.getMessage()); exitOrFail(3, "Exception encountered during startup: " + e.getMessage()); } } applyConfig();主要是用来初始化cassandra.yaml配置文件里的基本的配置，setup主要是做一些单节点初始化的时候的一些初始化工作，比如load本地的sstable元信息到内存，清除无用的sstable文件，启动的时候没有commit的transaction 执行或回滚，commitlog 的启动以及回放，集群元信息的效验，启动compaction，启动7000端口内部交流server等等事情； start函数主要是启动9042的client监听端口，主要是netty的server，当然如果是thrift的话，也启动9160 端口服务；

2020-03-22

源码分析RocketMQ ACL实现机制

有关RocketMQ ACL的使用请查看上一篇《RocketMQ ACL使用指南》，本文从源码的角度，分析一下RocketMQ ACL的实现原理。

2019-09-09

使用 Docker 构建 Nebula Graph 源码

开发环境构建 Nebula Graph 依赖较多，且一些第三方库需本地编译安装，为了方便开发者本地编译项目源码， Nebula Graph 官方为大家提供了一个预安装所有依赖的 docker 镜像)。

2019-09-05

Giraph源码分析（六）——Edge 分析

1.在Vertex类中，顶点的存储方式采用邻接表形式。每个顶点有 VertexId、VertexValue、OutgoingEdges和Halt，boolean型的halt变量用于记录顶点的状态，false时表示active，true表示inactive状态。片段代码如下。 2.org.apache.giraph.edge.Edge 接口，用于存储顶点的边，每条边包含targetVertexId和edgeValue两个属性。类关系图如下： Giraph默认使用DefaultEdge类存储边，该类中有两个变量： I targetVertexId和 E value，I为顶点ID的类型，E为边的类型。注意，DefaultEdge类同时继承ReusableEdge接口，在ReusableEdge类的定义中，有如下说明文字：A complete edge, the target vertex and the edge value. Can only be one edge with a destination vertex id per edge map. This edge can be reused, that is you can set it's target vertex ID and edge value. Note: this class is useful for certain optimizations, but it's not meant to be exposed to the user. Look at MutableEdge instead. 从上述说明文字可知，edge可以被重用，只需要修改targetVertexId和value的值就行。即每个Vertex若有多条出边，只会创建一个DefaultEdge对象来存储边。3.org.apache.giraph.edge.OutEdges 用于存储每个顶点的out-edges。从Vertex类的定义可知，顶点的每条边都被存储在OutEdges类型的edge对象中，OutEdges接口的关系图如下： Giraph默认的使用ByteArrayEdges，每个顶点的所有边都被存储在byte[ ]中。当顶点向它的出边发送消息时，需要遍历Vertex类中的edges对象。示例代码如下：注意：由DefaultEdge的定义可知，遍历getEdges时，返回的Edge对象时同一个对象，只是该对象中值改变了。下面继续查看代码来证明此观点。查看ByteArrayEdges类的iterator()方法，如下：返回的是内部类ByteArrayEdgeIterator对象，定义如下：总结：当顶点的出度很大时，此优化甚好，能很好的节约内存。如UK-2005数据中，顶点的最大出度为 5213。假设顶点1的出度顶点有<2 , 0.4>，<3 , 7.8> ，<5 , 6.4> 。如下代码：输出结果为：[ 2 ][ 3 , 3 ][ 5 , 5 , 5 ]并非是希望的 [ 2 , 3 , 5 ]

2019-08-11

Giraph源码分析（三）—— 消息通信

由前文知道每个BSPServiceWorker有一个WorkerServer对象，WorkerServer对象里面又有ServerData对象，作为数据实。ServerData中包含该Worker的partitionStore、edgeStore、incomingMessageStore、currentMessageStore、聚集值等。其中incomingMessageStore对象为MessageStoreByPartition(接口)类型，也就是说消息时按照分区来存储的。MessageStoreByPartition接口的关系图如下：在SimpleMessageStore抽象类中，有一个ConcurrentMap>类型的变量map，用来存储消息。第一层是pairtitionID到发送到该partition消息的映射；第二层是VertexID 到发送给该Vertex的消息队列。《Giraph通信模块分析》：http://my.oschina.net/skyaugust/blog/95182 每个顶点的消息列表具体为ExtendedDataOutput类型，它继承DataOutput接口，增加了几个方法而已。每个消息是以字节形式写入到ExtendedDataOutput对象中的。发送消息时，采用异步式通信。图顶点的计算处理与消息通信并发执行，在计算过程中就可以发送消息，将大规模消息发送分散在不同的时间段，避免瞬时网络通信阻塞，但是接受端需要额外的空间，存储临时接收到的消息，相当于空间换时间。而集中式通信，图顶点的计算处理与消息通信串行进行，在计算完毕后，统一发送消息，控制和实现方式简单，可在发送端对消息进行最大程度优化，但容易造成瞬时间的网络通信阻塞以及增加发送端的消息存储开销。不同Worker间的消息通信使用RPC方式，具体为Netty。同一Worker内，连续两次迭代的消息直接通过内存操作，把要发送的消息直接复制到Worker的incomingMessageStore中。下面详述消息的存储格式和发送机制。 Giraph使用Cache来缓存消息，当消息达到一定阈值后，一次性发送。既按照bulk模式进行，不会一条一条信息发送。向某个顶点发送的消息是按照 pair存储在ByteArrayVertexIdData中（实际为ByteArrayVertexIdMessages类型）。介绍如下： org.apache.giraph.utils.ByteArrayVertexIdData 功能：把<顶点ID，data> Pair 存储在一个 byte数组中。里面有 ExtendedDataOutput对象用来存储数据。该类中还有一个内部类：VertexIdDataIterator，该内部类继承 VertexIdIterator类。 org.apache.giraph.comm.SendCache用来缓存发送的信息，然后以“Bulk”模式发送。在Giraph中，每个Worker上可以对应多个分区。消息缓存的阈值是以Worker为单位计算，而不是Partition。 SendCache中有ByteArrayVertexIdData[ ] dataCache数组用来存储发送给每个Partition的消息；有int[ ] dataSizes数组用于记录向每个Worker发送的消息大小，若大于MAX_MSG_REQUEST_SIZE（默认为512KB）就把此Worker上的所有Partition缓存的消息发送到给该Worker，同一Worker内消息也是如此缓存；有int[ ] initBufferSizes数组用于记录每个Worker上的每个Partition的初始化ByteArrayVertexIdData中ExtendedDataOutput对象的大小，同一Worker上的所有Partition初始值相同，该值为平均值。记MAX_MSG_REQUEST_SIZE（message request size）值为M，该Worker上有P个 partitions，ADDTITIONNAL_MSG_REQUEST_SIZE（比平均值大的因子）默认为0.2f，记为A。则每个Partition的初始大小为：M*(1+A) / P . 由前文知道，每个Worker都有一个NettyWorkerClientRequestProcessor用来发送消息。该类中有SendMessageCache对象用来缓存向外发送的信息。NettyWorkerClientRequestProcessor类中的sendMessageRequest(I,M) 方法如下，用于向某个顶点destVertexId发送消息message。方法解释：首先根据destVertexId得到对应的partitionId和WorkerInfo，然后把消息add到SendMessageCache中，并返回向该顶点所属Worker发送的消息大小workerMessageSize。若该值大于默认值512KB，则把此Worker对应的所有Partition消息从SendMessageCache中删除，把删除的消息赋值给workerMessages，其类型为PairList> ，key为partitionId，value为发送给该partition的消息列表，最后调用doRequest()方法发送信息。doRequest()方法如下：可以看到在发送消息时，先判断是否在同一Worker上。如果是的话，调用SendWorkerMessagesRequest的doRequest发送消息；否则使用WorkerClient（底层使用Netty）进行消息发送。下面着重讨论同一Worker内的机制。 org.apache.giraph.comm.requests.SendWorkerMessagesRequest类中的doRequest方法如下：参数为该Worker的ServerData，代码中的partitionVertexData实际为PairList>workerMessages。遍历来添加到ServerData中的incomingMessageStore中。 ByteArrayMessagesPerVertexStore类中的addPartitionMessages()方法如下：当用户使用了Combiner，incomingMessageStore对应的类型则为OneMessagePerVertexStore，该类为每个顶点只存储一个消息，而非消息队列。结构如下图：当添加一条消息时，会把顶点已对应的消息和要添加的消息调用combine()方法进行合并，然后存储在上述结构图中。addPartitionMessages()方法如下：在ComputeCallable中的call()方法调用computePartition(Partition)计算完所有Partition上的顶点后，调用WorkerClientRequestProcessor.flush()方法把所有剩余的消息发送出去。

2019-07-24

jdk11 CountDownLatch源码分析

@[toc] 概述 CountDownLatch也是利用的AQS队列，关于AQS队列的讲述请参考前面两篇文章： jdk11源码-ReentrantLock源码 jdk11源码--ReentrantReadWriteLock

2019-07-23

Android ClassLoader加载过程源码分析

这里我们会从Android中ClassLoader等相关类的源码入手，更好的理解和学习动态加载类的原理。

2019-07-15

Kylin页面System操作源码解读

源码结构前端源码： angular：下面为自定义方法： * Method type is PUT * Additional Query parameter action=config is sent

2019-06-20

go源码解析-Println的故事

本文主要通过平常常用的go的一个函数，深入源码，了解其底层到底是如何实现的。 Println Println函数接受参数a，其类型为…interface{}。

2019-06-13

Flink 闭包清除源码分析

String, String>() { @Override public String map(String value) throws Exception { return null; } }); 跟进源码查看

2019-06-05

Eureka 源码分析之 Eureka Client

源码分析基于Spring Cloud的 eureka 的 client 端在启动类上加上 @EnableDiscoveryClient 注解，就可以用 NetFlix 提供的 Eureka client

2019-06-03

DRF-Tracking模块源码分析

DRF-Tracking模块源码分析一、drf-tracking是什么？ drf-tracking是为DRF的view访问提供一个日志记录模块。使用mixin的方式无缝的和DRF相结合。

2019-06-02

kubernetes controller源码解读之StatefulSet

1. StatefulSet应用场景说明 Deployment部署的无状态应用，应用的各个实例是相互独立的。但是在实际应用中存在如下需求: 应用的各个实例之间有一定依赖关系。如多个实例组成一个集群(比如ETCD集群)，实例之间需要通过通信选出leader。这就要求各个实例的网络地址必须固定(不管是实例重启，还是热迁移到别的节点等实例的网络地址都必须保持不变)，否则就无法组成稳定集群。应用的实例和存储数据需要绑定。比如部署mysql集群(主备模式)，两个实例通过 sharding来保存数据，所以访问这两个实例是分库之后不同的数据。而用户会要求访问两个实例返回数据是稳定的，也就是要求实例和存储数据必须要绑定(不管是实例是重启，或者迁移到其他节点)，实例对应的 storage必须固定。应用的各实例启动需要遵循一定的顺序。比如首先启动的实例必

2019-05-12

kubernetes controller源码解读之DaemonSet

1. 适用场景通过 DaemonSet部署的应用(Pod)主要用于满足如下场景: 类似守护进程，每个节点保证部署一个应用能跟随节点的新增/移除，自动创建/删除守护应用可以方便的对守护应用进行版本升级或者回滚实际应用场景中，每个节点都需要的agent类型组件(如日志收集组件fluentd等)，一般都采用DaemonSet方式部署。 2. DaemonSet资源定义单个 DaemonSet资源的定义结构( DaemonSet的yam定义需要遵守该结构)如下: type DaemonSet struct { metav1.TypeMeta metav1.ObjectMeta Spec DaemonSetSpec Status DaemonSetStatus } DaemonSets Controller将根据 D

2019-05-12

iOS 短视频源码开发MPMoviePlayerController

文：布谷惠泽/来源：山东布谷鸟网络 MPMoviePlayerController用来播放视频，在iOS9之后被弃用(iOS9之后苹果推荐我们使用AVPlayer，AVPlayer相对复杂但灵活)，由于APP往往要兼容iOS9之前的版本，所有MPMoviePlayerController还是很重要的。在我的另一篇文章中分享了一个基于MPMoviePlayerController的播放器，大家可以看看，目前还不完整。小伙伴们可以关注一下我的简书。谢谢 MPMoviePlayerController的简单使用需要添加这个框架MediaPlayer.framework #import <MediaPlayer/MediaPlayer.h> #pragma mark - 本地 NSString* _moviePath=[[NSBundle mainBundle]pathForResource:@"popeye" ofType:@"mp4"]; self.player=[[MPMoviePlayerController alloc]initWithContentURL:[NSURL fileURLWithPath:_moviePath]]; [self.view addSubview:self.player.view]; self.player.view.frame=CGRectMake(0, 0, self.view.frame.size.width, CGRectGetWidth(self.view.frame)*(9.0/16.0)); self.player.movieSourceType = MPMovieSourceTypeFile;// 播放本地视频时需要这句 // self.player.controlStyle = MPMovieControlStyleNone;// 不需要进度条 self.player.shouldAutoplay = YES;// 是否自动播放（默认为YES） // self.player.scalingMode=MPMovieScalingModeAspectFill; [self.player prepareToPlay];//缓存 // [self.player play];//可以不加这句 #pragma mark - 网络 NSURL* url = [NSURL URLWithString:@"https://clips.vorwaerts-gmbh.de/big_buck_bunny.mp4"]; _player = [[MPMoviePlayerController alloc] initWithContentURL:url]; [self.view addSubview:self.player.view]; self.player.view.frame=CGRectMake(0, 0, self.view.frame.size.width, CGRectGetWidth(self.view.frame)*(9.0/16.0)); [self.player prepareToPlay]; [self.player play]; #pragma mark - 直播 NSURL* url = [NSURL URLWithString:@"http://live.hkstv.hk.lxdns.com/live/hks/playlist.m3u8"]; _player = [[MPMoviePlayerController alloc] initWithContentURL:url]; [self.view addSubview:self.player.view]; self.player.view.frame=CGRectMake(0, 0, self.view.frame.size.width, CGRectGetWidth(self.view.frame)*(9.0/16.0)); self.player.controlStyle=MPMovieSourceTypeStreaming;//直播 [self.player prepareToPlay]; // [self.player play]; MPMoviePlayerController提供了很多通知，这里我就简单的监听2个。我们可以通过监听到的信息做相应的处理。 #pragma mark - Notification //监听视频播放结束 [[NSNotificationCenter defaultCenter]addObserver:self selector:@selector(endPlay) name:MPMoviePlayerPlaybackDidFinishNotification object:nil]; //监听当前视频播放状态 [[NSNotificationCenter defaultCenter]addObserver:self selector:@selector(loadStateDidChange:) name:MPMoviePlayerLoadStateDidChangeNotification object:nil]; #pragma mark - Notification function -(void)endPlay { NSLog(@"播放结束"); } -(void)loadStateDidChange:(NSNotification*)sender { switch (self.player.loadState) { case MPMovieLoadStatePlayable: { NSLog(@"加载完成,可以播放"); } break; case MPMovieLoadStatePlaythroughOK: { NSLog(@"缓冲完成，可以连续播放"); } break; case MPMovieLoadStateStalled: { NSLog(@"缓冲中"); } break; case MPMovieLoadStateUnknown: { NSLog(@"未知状态"); } break; default: break; } } #pragma mark - dealloc - (void)dealloc { [[NSNotificationCenter defaultCenter]removeObserver:self]; }

2019-04-29

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。