李新的博客

MySQL主从同步(STATEMENT模式),剖析Binlog内容(三)

(1). 需求在binlog_format模式为:STATEMENT模式下测试,对slave binlog进行回退,查看是否会靠成脏数据的可能性.

MySQL主从同步(ROW模式),剖析Binlog内容(二)

(1). 需求在binlog_format模式为:ROW模式下测试,对slave binlog进行回退,查看是否会靠成脏数据的可能性.

Docker 概念

(1). Repositories 仓库是存储镜像(image)的地方.可以类比:Maven仓库一样,专门存储jar包的地方.

Docker 四种网络模型

(1) 注意,以下内容皆参考如下链接

Docker 安装MySQL

(1). 查看可用的MySQL版本 https://hub.docker.com/_/mysql?tab=tags&page=1&ordering=name

Docker Images 相关命令

(1). 仓库注册账号(略)

Docker /var/run/docker.sock

(1). /var/run/docker.sock /var/run/docker.sock是docker的守护进程(Docker daemon),它负责与Docker容器进行通信.

Docker DockerFile

(1). Dockerfile是什么? Dockerfile是一个文本文件,里面实际就是:制作镜像的一堆指令集.可以根据Dockerfile文件,自动化构建出镜像(Image).

Docker 自制JDK1.8镜像

(1). 项目目录 jdk-8u271-linux-x64.tar.gz是在Oracle官网下载的.

Docker Container 相关命令(2)

(1). 准备工作(下载Nginx镜像) “Nginx”

Docker Container 相关命令(1)

(1). 容器(Container) 容器(Container)是由Image派生而来的.

Reactor Stream源码(Schedulers)

(1).Schedulers//1. 创建线程Schedulers.newElastic("selfTrade-thread")(2).Schedulers.newElastic// 1. public static Scheduler newE...

Reactor Stream OOM

注意:代码和分析日志都是经过处理了的

Reactor Stream接口分析

(1).Publisher```package org.reactivestreams;

Reactor Stream源码(Flux.subscribe)

(1).案例Flux.just("1","2") .subscribe(c->{ System.out.println("consumer:" + c); });(2).Flux.subscribepubl...

Reactor Stream源码(Flux.just)

(1).Flux类关系图```// 注意该类是抽象类public abstract class Flux // 实现了reactor.core.CorePublisher // CoreP...

Netty源码(ServerBootstrap)

(1).ServerBootstrap继承关系```io.netty.bootstrap.ServerBootstrap extends io.netty.bootstrap.AbstractBootstrap

Netty源码(NioServerSocketChannel)

(1).NioServerSocketChannel 类结构图

Netty源码(IdleStateHandler)

(1).IdleStateHandlerpackage io.netty.handler.timeout;public class IdleStateHandler extends ChannelDuplexHandler { /...

Netty源码(EventLoopGroup)

(1).NioEventLoopGroup继承关系图(2).new NioEventLoopGroupEventLoopGroup bossGroup = new NioEventLoopGroup(1);(3).NioEventLoopGrou...

Netty EventLoopGroup接口分析

(1).查看NioEventLoopGroup实现关系```// 注意EventExecutorGroup// 实现:java底层的:ScheduledExecutorService和Iterable// 意味着有遍历和定时调度功能io.nett...

Netty源码(EventLoop)

(1).NioEventLoopGroup.newChildprotected EventLoop newChild(Executor executor, Object... args) throws Exception { // args...

Netty源码(EventLoop如何处理READ事件)

(1).Netty又是如何处理读写请求的呢? 代码的入口在:ServerBootstrap$ServerBootstrapAcceptor.channelRead处.

Netty源码(EventLoop如何处理ACCEPT事件)

(1).BossGroup(NioEventLoop)初始化完成了,是怎么接受请求(ACCEPT事件),并把请求分发给:WorkGroup(NioEventLoop)的呢? 答案在:NioEventLoop.run()方法里.

Netty源码(ChannelPipeline)

(1).ChannelPipeline说ChannelPipeline时,不得不说下以下几个接口: io.netty.channel.ChannelPipeline io.netty.channel.ChannelHandlerCo...

Spring WebFlux源码(NettyWebServer)

(1).查看WebServer声明```package org.springframework.boot.web.server;

Spring WebFlux Hello World

(1).pom.xml配置```<?xml version=”1.0” encoding=”UTF-8”?> 4.0.0 help.lixin springwebflux-demo jar 1.1.0 springwebflux ${...

Spring WebFlux Hello World(Function)