Lettuce is a fully non-blocking Redis client built with netty providing Reactive, Asynchronous and Synchronous Data Access .
RedisURI [host=’localhost’, port=6379] 连接的封装，用于解析database password 等基础参数，还有集群，Sentinel 配置解析。
DefaultEndpoint 通信 channel 的封装。除了提供 channel.write，还具备重连和重试的能力。
RedisClient 负责构造和初始化Netty，thread-safe，reuse this instance as much as possible。
ClientResources 管理（初始化和持有） EventExecutorGroup， Timer， EventBus 等资源。不需要重复创建。
/**
* lettuce 与 redis-server 通信提供编解码（RESP 协议），监控的实现
* @see io.lettuce.core.ConnectionBuilder#buildHandlers()
*/
protected List<ChannelHandler> buildHandlers() {
List<ChannelHandler> handlers = new ArrayList<>();
handlers.add(new ChannelGroupListener(channelGroup));
// Encodes RedisMessage into bytes following
handlers.add(new CommandEncoder());
// writing redis commands and reading responses from the server. core!!!
handlers.add(new CommandHandler());
// 通过 eventBus 把连接状态相关的事件广播出去。
handlers.add(new ConnectionEventTrigger(connectionEvents, connection, clientResources.eventBus()));
// monitoring the channel and reconnecting when the connection is lost.
if (clientOptions.isAutoReconnect()) {
handlers.add(new ConnectionWatchdog());
}
return handlers;
}
Redis clients use a protocol called RESP (REdis Serialization Protocol) to communicate with the Redis server.
RESP can serialize different data types like integers, strings, and arrays.
RESP uses prefixed-length to transfer bulk data.
In RESP, different parts of the protocol are always terminated with “\r\n” (CRLF).
官方文档 详细介绍协议的定义和每种数据类型的格式。
协议规则非常简单，并且容易解析和阅读。
Simple Strings 用于系统内的回复等，可以理解为常量。
Bulk Strings 用于命令参数，使用binary-safe string，确保输入数据不会因为字符集，操作系统等问题，造成数据读写问题。
Simple String 表示“OK”为 "+OK\r\n"
Bulk Strings 表示“hello”为 "$5\r\nhello\r\n" ＝ 数据类型字符 + 长度 + 间隔符 + 数据 + 间隔符。
Jedis is a Java client for Redis designed for performance and ease of use.
根据协议的规范，可以用任何语言编解码通信数据。如下就是Jedis 对协议规则的实现。
/**
* set("name", "foo") Example
*
* 支持的数据类型: Simple Strings, Errors, Integers, Bulk Strings and Arrays.
* 数据类型的表示：Simple Strings(+), Errors, Integers(:), Bulk Strings($) and Arrays(*)
* 不同的块之间一定要用CRLF间隔(\r\n)
* @see redis.clients.jedis.Protocol#sendCommand
*/
private static void sendCommand(final RedisOutputStream os, final byte[] command, final byte[]... args) {
try {
os.write(ASTERISK_BYTE);// 数组类型，"*" 代表Arrays
os.writeIntCrLf(args.length + 1);// 数组长度：参数(n) + 命令(1)， writeInt，writeCrLf
os.write(DOLLAR_BYTE);// String，"$" 代表Bulk Strings
os.writeIntCrLf(command.length);// 长度
os.write(command);// 操作命令 SET/[83, 69, 84]
os.writeCrLf();// 间隔符号
// 操作参数， args[0]="name".bytes(), args[1]="foo".bytes()
for (final byte[] arg : args) {
os.write(DOLLAR_BYTE);
os.writeIntCrLf(arg.length);
os.write(arg);
os.writeCrLf();
}
} catch (IOException e) {
throw new JedisConnectionException(e);
}
}
A client connects to a Redis server by creating a TCP connection to the port 6379.
Jedis 是直接使用socket 来完成通信。
public void connect() {
// 每次使用前，检查 socket 是否可用
if (!isConnected()) {
try {
// socket 编程Example
socket = new Socket();
socket.connect(new InetSocketAddress(host, port), connectionTimeout);
socket.setSoTimeout(soTimeout);
if (ssl) {
// 启用ssl 模式
if (null == sslSocketFactory) {
sslSocketFactory = (SSLSocketFactory)SSLSocketFactory.getDefault();
}
socket = (SSLSocket) sslSocketFactory.createSocket(socket, host, port, true);
}
// RedisOutputStream 提供buffer 和方便的协议写入方法
outputStream = new RedisOutputStream(socket.getOutputStream());
inputStream = new RedisInputStream(socket.getInputStream());
} catch (IOException ex) {
broken = true;
throw new JedisConnectionException(ex);
}
}
}
通过 SpringMVC Date 参数实例化的配置实例，梳理和分析类型转换在 Spring 框架中的实现过程。
Spring 内置的类型转换实现组件，可以通过以下接口追溯
org.springframework.core.convert.converter.Converter
java.beans.PropertyEditor
org.springframework.beans.TypeConverterDelegate Spring 内部类型转换工具类
org.springframework.core.convert.support.GenericConversionService 类型转换器默认实现，可以直接注入使用。
记录 Mybatis 动态 SQL、字符串替换相关的实现，方便后续源码阅读和借鉴。
| [MyBatis 3 | Dynamic SQL](https://mybatis.org/mybatis-3/dynamic-sql.html) |
One of the most powerful features of MyBatis has always been its Dynamic SQL capabilities. OGNL based expressions.
<select id="findActiveBlogLike" resultType="Blog">
SELECT * FROM BLOG
<!-- 只有在包含的标签返回任何内容时才会插入"WHERE"子句。如果内容以"AND"或"OR"开头，自动会将其去掉。 -->
<where>
<if test="title != null">
AND title like #{title}
</if>
<if test="author != null and author.name != null">
AND author_name like #{author.name}
</if>
</where>
</select>
// org.apache.ibatis.scripting.xmltags.XMLScriptBuilder#initNodeHandlerMap
private void initNodeHandlerMap() {
nodeHandlerMap.put("trim", new TrimHandler());
nodeHandlerMap.put("where", new WhereHandler());
nodeHandlerMap.put("set", new SetHandler());
nodeHandlerMap.put("foreach", new ForEachHandler());
nodeHandlerMap.put("if", new IfHandler());
nodeHandlerMap.put("choose", new ChooseHandler());
nodeHandlerMap.put("when", new IfHandler());
nodeHandlerMap.put("otherwise", new OtherwiseHandler());
nodeHandlerMap.put("bind", new BindHandler());
}
// dynamic SQL in annotated mapper class
@Select("select * from user where name = #{name} ORDER BY ${columnName}")
User findByName(@Param("name") String name);
使用 #{} 语法可以生成 PreparedStatement 属性，参数注解替换为 PreparedStatement参数（占位符？）。防止 SQL 拼接注入等安全问题。
使用 ${} 语法直接将未修改的字符串替换到SQL语句中，MyBatis不会修改或转义字符串。当 SQL 语句中的元数据（即表名或列名）是动态的时，字符串替换非常有用。
一切要从 Testing your GitHub Pages site locally with Jekyll 说起。跟着官方教程认真学习一番。
尝试不同的技术栈，并且可以让个人主页更加的定制化。
Jekyll is a Ruby Gem（Ruby 模块）。
需要在本地调试验证，需要环境准备，否则直接跳过。
Jekyll on Windows 先安装Ruby，再下载 Jekyll 模块。
一定要选择 Ruby+Devkit 版本。
安装Jekyll 命令 gem install jekyll bundler
Jekyll is a static site generator with built-in support for GitHub Pages.
创建Jekyll 工程命令 jekyll new --skip-bundle . 类似于 vue init； django-admin startproject。会准备一个site 框架。
其中，_posts 就是我们文章源文件的目录。服务运行时，会把markdown 文件转为 html 文件。
最后，原始的Jekyll 工程需要做些修改，才能适用于github-pages。操作参考步骤9-10。creating-a-github-pages-site-with-jekyll
# Run. 浏览器访问：http://localhost:4000
bundle install
bundle exec jekyll serve
必须命名为 <user>.github.io
存储库必须是公共的。如果改为 private, Github Pages 访问404。
GitHub Pages 站点是使用 GitHub Actions 工作流生成和部署的。工作流是默认的，不用做任何修改。
可以通过查询 workflow run history 和日志来排查问题