提供端接收请求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.频率组件 小总结一下 继续：
目录 认证组件 权限组件 频率组件 认证组件 通过dispath方法，进入三大认证：首先看一下请求模块，进入request进入get_authenticators 方法可以知道，请求模块二次封装request对象，包含解析模块，还将认证类们的对象存储在请求对象中。 进入三大认证遍历一个个认证器，完成一个个认证类，每一个配置的认证类都要调用authenticate方法完成认证。返回值是user和auth组成的元组。权限组件频率组件 通过dispatch方法 进入频率组件然后...
概述 Semaphore 是并发包中的一个工具类，可理解为信号量。通常可以作为限流器使用，即限制访问某个资源的线程个数，比如用于限制连接池的连接数。 打个通俗的比方，可以把 Semaphore 理解为一辆公交车：车上的座位数（初始的“许可” permits 数量）是固定的，行驶期间如果有人上车（获取许可），座位数（许可数量）就会减少，当人满的时候不能再继续上车了（获取许可失败）；而有人下车（释放许可）后就空出了一些座位，其他...
bean类的静态属性是不能通过spring自动依赖注入的，这个从spring的源码可以看出来，spring在进行bean的属性注入时，有以下判断条件，如果属性是用static修饰的，就不能自动注入。可以使用如下方式进行值的注入，方法也不能使用static修饰： private static String aStr; @Value("${spring.a}") private void setAstr(String a) { aStr = a; }
一、Callable 我们知道启动线程有以下两种方式（jdk源码注释中官方定义只有两种启动方式，callable不算线程启动方式） 原文链接：http://www.studyshare.cn/blog-front/blog/details/1141 (1)、new Thread().start() (2)、new Thread(new Runnable()).start(); 以上两种方式中的run()方法的返回值是void类型，即没有返回值，如果我们需要在业务线程中执行业务代码后需要将结果进行返回怎么办呢？即使用Callable，如下：?二、调用方...
1. ProducerIntercptor对消息进行拦截 2. Serialzer对key和value进行序列化 3. Partitioner对消息选择合适的分区 4. RecordAccumulator收集消息，实现批量发送 5. Sender从RecordAccumulator获取消息 6 构造ClientRequest 7 将ClientRequest交给Network,准备发送 8 Network将请求放入KafkaChannel的缓存 9 发送请求 10 收到响应，调用ClientRequest 11 调用RecordBatch的回调函数，最终调用到每一个消息上注册的回调函数 在这里主要...
"Flink SQL UDF不应有状态" 这个技术细节可能有些朋友已经知道了。但是为什么不应该有状态呢？这个恐怕大家就不甚清楚了。本文就带你一起从这个问题点入手，看看Flink SQL究竟是怎么处理UDF，怎么生成对应的SQL代码。[源码分析]从"UDF不应有状态" 切入来剖析Flink SQL代码生成 (修订版)目录[源码分析]从"UDF不应有状态" 切入来剖析Flink SQL代码生成 (修订版)1. 缩减版2. 完整版1. 注册UDF2. LogicalFilter3. FilterToCalcRule4. L...
源码注释// Zepto.js // (c) 2010-2015 Thomas Fuchs // Zepto.js may be freely distributed under the MIT license. // // Some code (c) 2005, 2013 jQuery Foundation, Inc. and other contributors;(function($){var slice = Array.prototype.slicefunction Deferred(func) {//元组：描述状态、状态切换方法名、对应状态执行方法名、回调列表的关系//tuple引自C++/python，和list的区别是，它不可改变 ，用来...
目录 Flask请求上下文源码分析 Flask请求上下文源码分析 from flask import Flaskapp = Flask(__name__)if __name__ == '__main__':app.run() 分析入口app.run(),点入查看源码： from werkzeug.serving import run_simpletry:run_simple(host, port, self, **options)#这里的self是app自己 run_simple是werkzeug内部的方法，在run_simple执行时会将app加括号调用从而执行app的__call__方法，来看__call__源码： def __call__(sel...
ArrayList源码分析---JDK1.8 一. ArrayList的数据结构二. ArrayList源码分析①. 继承关系②. 类中的属性③. 构造方法④. 核心方法1. add(E e)__有四个方法，我仔细分析一个2. ensureCapacityInternal(size + 1) 确定内部容量的方法3. calculateCapacity() 主要看list是不是初始的时候是空参构造函数4. 还是确保明确的容量 ensureExplicitCapacity(int minCapacity)5. grow(int minCapacity) 扩容机制——重点(看我的注释)6.hugeCap...
目录窗口尺寸 概述 窗口Size消息的处理 用户调整Size消息的处理调整窗口大小 程序调整窗口大小 wxScrolledWindow设置窗口大小获取TextCtrl控件最合适大小窗口尺寸 概述类型 说明Size 当前窗口实际大小，通过wxWindow::SetSize()获取；Client Size 客户区大小；Best Size 最合适的大小，用户可以实现wxWindow::DoGetBestSize()方法，自定义返回最合适的大小；Best Client Size 最合适的客户区大小，用户可以实现DoGetBestClientSize...
PoolingHttpClientConnectionManager是一个HttpClientConnection的连接池，可以为多线程提供并发请求服务。主要作用就是分配连接，回收连接等。同一个route的请求，会优先使用连接池提供的空闲长连接。 源码版本4.5.2，因为代码太多，很多不是自己关心的，为免看起来费力，这里代码贴的不全。省略代码的地方用省略号标注。 配置说明 <bean id="ky.pollingConnectionManager" class="org.apache.http.impl.conn.PoolingHttpCl...
JDK1.8 ArrayList源码分析--jdk1.8LinkedList源码分析--jdk1.8HashMap源码分析--jdk1.8 HashMap概述??1. HashMap是可以动态扩容的数组，基于数组、链表、红黑树实现的集合。??2. HashMap支持键值对取值、克隆、序列化，元素无序，key不可重复value可重复，都可为null。??3. HashMap初始默认长度16，超出扩容2倍，填充因子0.75f。??4.HashMap当链表的长度大于8的且数组大小大于64时，链表结构转变为红黑树结构。HashMap数据结构??数...
Beego.Run() 首先我们了解，使用beego框架来新建项目bee run后，会生成一个main.go函数，并通过beego.Run来运行服务 beego.Run()之后我们通过ctrl+点击进入他的源代码：beego.go中的Run() func Run(params ...string) {if len(params) > 0 && params[0] != "" {BeeApp.Run(params[0])}BeeApp.Run("") }可以看到，是根据参数设置，调用beeapp.Run()函数实现，所以我们再次找到它的源代码： 我们首先看到BeeApp是一个HttpServer： va...