Dubbo 使用 kryo 序列化

前言

本文大部分参考官方文档：https://dubbo.apache.org/zh/docsv2.7/user/serialization/

代码部分，是本人自己写的案例中增加配置得到的。因此，写个原创不过分吧。

为什么用 kryo 做序列化？

众所周知，在 RPC 框架中，最最重要，也是最影响性能的地方是序列化和传输协议。
那么对于 Dubbo 而言，本身默认使用的序列化 hessian2 其实也挺好的了。
但还是美中不足。与 Kryo相比，Kryo 的体积更小，而且官方的测试结果也显示， Kryo 更快。也是官方更加推荐使用的。

怎么使用 Kryo？

1. 引入 Kryo 依赖

在你的 springboot 项目中，首先引入 kryo 的 maven 依赖（版本你自己看着办，不一定非要和我用一样的）：

        <!-- 添加序列化依赖 -->
        <dependency>
            <groupId>de.javakaffee</groupId>
            <artifactId>kryo-serializers</artifactId>
            <version>0.42</version>
        </dependency>

2. 增加配置

我这里使用的是属性文件配置：

# 指定使用看 Kryo 做序列化
dubbo.protocol.serialization=kryo
# 自己实现注册（也可以不加）
#dubbo.protocol.optimizer=org.feng.kryo.SerializationOptimizerImpl

3. 其他代码

我是在这个demo的基础上加的：
https://blog.csdn.net/FBB360JAVA/article/details/120847768

4. 如果增加了自己的序列化类，怎么做？

4.1 需要被序列化的实体

package org.feng.entity;

import java.io.Serializable;

public class MyBean implements Serializable {

    private static final long serialVersionUID = 9209554053837563785L;

    private String name;
    private String body;

    public MyBean() {
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getBody() {
        return body;
    }

    public void setBody(String body) {
        this.body = body;
    }

    @Override
    public String toString() {
        return "MyBean{" +
                "name='" + name + '\'' +
                ", body='" + body + '\'' +
                '}';
    }
}

4.2 序列化类的实现

package org.feng.kryo;

import org.apache.dubbo.common.serialize.support.SerializationOptimizer;
import org.feng.entity.MyBean;

import java.util.Collection;
import java.util.LinkedList;
import java.util.List;

public class SerializationOptimizerImpl implements SerializationOptimizer {
    @Override
    public Collection<Class<?>> getSerializableClasses() {
        List<Class<?>> classes = new LinkedList<>();
        // 将自己的bean注册进去
        classes.add(MyBean.class);
        return classes;
    }
}

4.3 使用

在配置中指定这个实现类即可。

5. 结果

The URL[dubbo://172.173.173.69:20880/org.feng.service.DemoStartService?anyhost=true&application=springboot-dubbo-nacos-provider-mytest&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&interface=org.feng.service.DemoStartService&metadata-type=remote&methods=print,sayName&pid=29784&release=2.7.8&revision=1.0.0&serialization=kryo&side=provider&timestamp=1635152781434&version=1.0.0] deregistered successfully., dubbo version: 2.7.8, current host: 172.173.173.69

可以看到，在控制台的日志中，显示使用了 kryo。