转载请注明出处：http://blog.csdn.net/mxway/article/details/44569831
本篇文章是在飞鸽传书源码v2.06的基础上进行分析的
飞鸽传书是一款工作在局域网的软件，支持局域网里不同设备之间的消息发送及文件的传输（消息发送使用udp，文件传输使用tcp）。
发送消息及文件传输是在飞鸽传书的发送对话框中进行，而发送对话框的打开是通过双击拖盘（win7系统）到任务栏的图标。而拖盘到任务栏的这个图标就是飞鸽传书的主窗口，对应的源...
摘自：https://www.cnblogs.com/lifullmoon/p/14015075.html该系列文档是本人在学习 Mybatis 的源码过程中总结下来的，可能对读者不太友好，请结合我的源码注释（Mybatis源码分析 GitHub 地址、Mybatis-Spring 源码分析 GitHub 地址、Spring-Boot-Starter 源码分析 GitHub 地址）进行阅读
MyBatis 版本：3.5.2
MyBatis-Spring 版本：2.0.3
MyBatis-Spring-Boot-Starter 版本：2.1.4MyBatis的初始化
在MyBatis初始化过程中，大致会有...
xxl-job
系统说明
安装
安装部署参考文档：分布式任务调度平台xxl-job
功能
定时调度、服务解耦、灵活控制跑批时间（停止、开启、重新设定时间、手动触发）
XXL-JOB是一个轻量级分布式任务调度平台，其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线，开箱即用
概念
1、执行器列表：一个执行器是一个项目
2、任务：一个任务是一个项目中的 JobHandler
3、一个xxl-job服务可以有多个执...
1. 简介上一篇文章分析了集群容错的第一部分 – 服务目录 Directory。服务目录在刷新 Invoker 列表的过程中，会通过 Router 进行服务路由。上一篇文章关于服务路由相关逻辑没有细致分析，一笔带过了，本篇文章将对此进行详细的分析。首先，先来介绍一下服务目录是什么。服务路由包含一条路由规则，路由规则决定了服务消费者的调用目标，即规定了服务消费者可调用哪些服务提供者。Dubbo 目前提供了三种服务路由实现，分别为条件路由...
SubjectDao subjectDao=sqlSession.getMapper(SubjectDao.class);对应的源码为：1 @Override
2 public <T> T getMapper(Class<T> type) {
3 return configuration.<T>getMapper(type, this);
4 }1 public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
2 return mapperRegistry.getMapper(type, sqlSession);
3 } 1 @SuppressWarnings("unchecked")2 public <T> T getMapper(Class<T> type, SqlSess...
1 protected void afterRefresh(ConfigurableApplicationContext context,2 ApplicationArguments args) {3 callRunners(context, args);4 }5 6 private void callRunners(ApplicationContext context, ApplicationArguments args) {7 List<Object> runners = new ArrayList<Object>();8 runners.addAll(context.getBeansOfType(ApplicationRunner.class).values());9 ru...
一、整体设计dubbo整体设计以及调用用链路参照官网?http://dubbo.apache.org/zh-cn/docs/dev/design.html
二、dubbo的注册中心1、注册中心参照官网 ?http://dubbo.apache.org/zh-cn/docs/user/references/registry/introduction.html；2、zk注册中心详解2.1、目录结构+- dubbo+- com.demo.service.HelloService+- consumers+- consumer://192.168.1.102/com.demo.service.HelloService?application=dubbo-demo-annotation-consumer...
ForkJoinPool
ForkJoinPool 是一个运行 ForkJoinTask 任务、支持工作窃取和并行计算的线程池
核心参数+创建实例// 工作者线程驻留任务队列索引位static final int SWIDTH = 16; // 低 16 位掩码static final int SMASK = 0xffff; // 最大并行度：#workers - 1static final int MAX_CAP = 0x7fff; // 最大工作队列数、提交队列数static final int SQMASK = 0x007e; // 工作者线...
首先,我们在3.1 spring5源码系列--循环依赖 之 手写代码模拟spring循环依赖 中手写了循环依赖的实现. 这个实现就是模拟的spring的循环依赖. 目的是为了更容易理解spring源码.
下面我们就进入正题, 看看spring的循环依赖源码.
一、getBean整体流程
目标很明确了, 就是要看看spring如何解决循环依赖的.
代码入口是refresh()#finishBeanFactoryInitialization(beanFactory);
二、拆解研究流程中的每一步
调用方法beanFactory.preI...
第一部分：项目结构
user_info表：只有id和username两个字段
User实体类:
public class User {private String username;private String password;public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}
}mapper:UserMapper 为根据id查询用户...
ArrayList概述??1. ArrayList是可以动态扩容和动态删除冗余容量的索引序列，基于数组实现的集合。??2. ArrayList支持随机访问、克隆、序列化，元素有序且可以重复。??3. ArrayList初始默认长度10，使用Object[]存储各种数据类型。ArrayList数据结构??数据结构是集合的精华所在，数据结构往往也限制了集合的作用和侧重点，了解各种数据结构是我们分析源码的必经之路。??ArrayList的数据结构如下：ArrayList源码分析
/** 用数组实现的...
SparkRdd实现单词统计 源码分析
1 手写单词统计
//设置任务名字 local本地模式
val conf=new SparkConf().setAppName("WC").setMaster("local")
//通向spark集群的入口
val sc =new SparkContext(conf)
// sc.textFile(args(0)).flatMap(_.split(" ")).map((_,1)).reduceByKey(_+_).sortBy(_._2,false).saveAsTextFile(args(1))
2 本地Debug调试信息
3 本地debug调试
(1) MapPartitionsRDD[7] at sortBy at
SparkWordCou...
一、简要介绍
ABP vNext 框架本身就是围绕着 DDD 理念进行设计的，所以在 DDD 里面我们能够见到的实体、仓储、值对象、领域服务，ABP vNext 框架都为我们进行了实现，这些基础设施都存放在 Volo.Abp.Ddd.Domain 项目当中。
本篇文章将会侧重于理论讲解，但也只是一个抛砖引玉的作用，关于 DDD 相关的知识可以阅读 Eric Evans 所编写的 《领域驱动设计：软件核心复杂性应对之道》。PS：
该书也是目前我正在阅读的 DDD 理论书籍，因为...
提供端接收请求class NettyServerHandler extends ChannelDuplexHandler
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {NettyChannel channel = NettyChannel.getOrAddChannel(ctx.channel(), url, handler);try {handler.received(channel, msg);} finally {NettyChannel.removeChannelIfDisconnected(ctx.channel());}
}
获取或者创建新的netty包装通道，后续发送响应需要使用网络通道stat...
1.首先 我们进入这个initial（）里面看下他内部是怎么实现的。
2.我们进入里面看到他实现了3个方法，一个认证，权限频率
3.我们首先看下认证组件发生了什么
权限：
啥都没返回，self.permission 条件不执行了。
4.频率组件
小总结一下
继续：
