/Library/Java/JavaVirtualMachines/jdk-9.0.4.jdk/Contents/Home/lib/src.zip!/java.base/java/lang/ProcessHandle.java

序 本文主要研究一下java9 gc log参数的迁移。 统一JVM及GC的Logging java9引进了一个统一的日志框架，对gc log的输出进行了统一的配置。 相关JEP(JDK Enhancement Proposal) JEP 158: Unified JVM Logging JEP 264: Platform Logging API and Service JEP 271: Unified GC Logging Xlog语法 {代码...} what 主要是配置t...

在classpath的所有jar(不管是否模块化)共同组成一个unnamed moduleunnamed modules会声明依赖所有的named module，且exports自己的所有包，但是一个named module不能声明依赖unnamed module。如果一个package在named和unnamed模块中都有定义，则使用named中的package。 默认--illegal-access=permit，即允许unnamed modu...

主要用于解决deep reflection问题，open的作用是表示该模块下的所有的包在runtime都允许deep reflection(包括public及private类型)但是编译时期，仅仅允许该module中声明过exports的包可以访问，如果没有exports则该包的类在编译时期不可读

比如sun.security.x509，在java9中归到java.base模块中，但是该模块没有export该package可以通过运行的时候添加--add-exports java.base/sun.security.x509=ALL-UNNAMED来修改exports设定

整个工程跟传统maven多module的工程结构一样，java9的一个module对应maven project的一个module。下面是根目录下的pom文件：

序 本文主要讲述下java9的模块系统的必知必会的知识点。 1.module及modules module module主要分如下两种： main module 包含main方法的module，通过--module或者-m指定 root module 指定模块系统解析的根模块，从根模块解析模块依赖，可以通过--add-modules mod1,mod2来指定 modules unnamed modules java9通过unnamed ...

这里使用的是alpine镜像,应为它比较小,基础镜像就几M,相比ubuntu等要小很多。由于Alpine Linux使用MUSL作为标准C库,而openjdk依赖于GNU标准C库(gclib),因此需要alpine版的jdk9才可以在alpine上运行,但是目前jdk 9还没有正式的alpine镜像,只有有一个early access的版Announcing: Early-Access builds of JDK 9 for Alpine...

reactor-netty-0.7.3.RELEASE-sources.jar!/reactor/ipc/netty/tcp/TcpClient.java

reactor-netty-0.7.3.RELEASE-sources.jar!/reactor/ipc/netty/tcp/TcpClient.java

reactor-netty-0.7.3.RELEASE-sources.jar!/reactor/ipc/netty/tcp/TcpClient.java

reactor-netty-0.7.3.RELEASE-sources.jar!/reactor/ipc/netty/http/client/HttpClient.java

reactor-core-3.1.3.RELEASE-sources.jar!/reactor/core/publisher/FluxSink.java

spring-webflux-5.0.2.RELEASE-sources.jar!/org/springframework/web/reactive/function/client/DefaultWebClientBuilder.java

reactor-core-3.1.3.RELEASE-sources.jar!/reactor/core/publisher/FluxSink.java

reactor-core-3.1.3.RELEASE-sources.jar!/reactor/core/publisher/FluxInterval.java

序 本文主要研究一下webclient的超时时间配置 SO_TIMEOUT 比如这样设置 {代码...} 这个SO_TIMEOUT只适用于OIO，对于NIO不适用 ReadTimeoutHandler {代码...} 这种方式才适用于NIO 客户端输出 {代码...} block(Duration) {代码...} 使用Mono<ClientResponse>的block(Duration)也能起到效果 输出如下 {代码...} 服务...

spring-cloud-gateway-core-2.0.0.M6-sources.jar!/org/springframework/cloud/gateway/filter/factory/RewritePathGatewayFilterFactory.java

spring-webflux-5.0.2.RELEASE-sources.jar!/org/springframework/web/reactive/result/method/annotation/ControllerMethodResolver.java

这里使用ReactiveHttpOutputMessage的writeWith(Publisher<? extends DataBuffer> body)方法，实现边准备数据边导出等待十几秒就弹下载框，之后就server端一边输出，浏览器一边下载，100秒左右下载完毕

利用reactor extra项目中的Retry帮助类，可以轻松指定高级重试策略，比如fixedBackoff，亦或是exponentialBackoff等

序 本文主要研究一下flux的map与flatMap的区别 map {代码...} 这里头的map是纯元素转换 输出 {代码...} flatMap {代码...} 这里的flatMap，将元素转为Mono或Flux，转换操作里头还可以进行异步操作 输出 {代码...} 小结 flatMap的转换Function要求返回一个Publisher，这个Publisher代表一个作用于元素的异步的转换操作；...

注意这里produces = MediaType.APPLICATION_STREAM_JSON_VALUE如果不是application/stream+json则调用端无法滚动得到结果，将一直阻塞等待数据流结束或超时。

使用RequestPart来接收，得到的是FilePartFilePart的content是Flux<DataBuffer>，可以使用DataBufferUtils写到文件或者直接使用transferTo写入到文件

hikari的作者比较倾向于fixed pool design的理念，即建议minimumIdle与maximumPoolSize设置成一样，当做固定连接大小的连接池。作者认为minimumIdle小于maximumPoolSize的话，在流量激增的时候需要额外的连接，此时在请求方法里头再去处理新建连接会造成性能损失，即会导致数据库一方面降低连接建立的速度，另一方面也会...

默认是600000毫秒，即10分钟。如果idleTimeout+1秒>maxLifetime 且 maxLifetime>0，则会被重置为0；如果idleTimeout!=0且小于10秒，则会被重置为10秒。如果idleTimeout=0则表示空闲的连接在连接池中永远不被移除。只有当minimumIdle小于maximumPoolSize时，这个参数才生效，当空闲连接数超过minimumIdle，而且空闲...

从这点来看，中途数据库断开的话，hikari会不断获取数据库链接假设数据库一直没恢复，那么所以请求数据库操作的业务线程将都阻塞connectionTimeout的时间，这个会占用工作线程 hikari只有testOnBorrow功能，是直接一个while循环，在timeout时间内不断borrow连接，validate连接，validate成功才返回或者超时抛出SQLTransi...

用来设置一个connection在连接池中的存活时间，默认是1800000，即30分钟。如果设置为0，表示存活时间无限大。如果不等于0且小于30秒则会被重置回30分钟。

用来设置连接被占用的超时时间，单位为毫秒，默认为0，表示禁用连接泄露检测。如果大于0且不是单元测试，则进一步判断：(leakDetectionThreshold < SECONDS.toMillis(2) or (leakDetectionThreshold > maxLifetime && maxLifetime > 0)，会被重置为0 . 即如果要生效则必须>0，同时满足：不能小于2秒...

默认是5秒HikariCP/2.7.6/HikariCP-2.7.6-sources.jar!/com/zaxxer/hikari/pool/PoolBase.java