栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Dubbo 使用 kryo 序列化

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Dubbo 使用 kryo 序列化

文章目录
  • 前言
  • 为什么用 kryo 做序列化?
  • 怎么使用 Kryo?
    • 1. 引入 Kryo 依赖
    • 2. 增加配置
    • 3. 其他代码
    • 4. 如果增加了自己的序列化类,怎么做?
      • 4.1 需要被序列化的实体
      • 4.2 序列化类的实现
      • 4.3 使用
    • 5. 结果

前言

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

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

为什么用 kryo 做序列化?

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

怎么使用 Kryo? 1. 引入 Kryo 依赖

在你的 springboot 项目中,首先引入 kryo 的 maven 依赖(版本你自己看着办,不一定非要和我用一样的):

        
        
            de.javakaffee
            kryo-serializers
            0.42
        
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> getSerializableClasses() {
        List> 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×tamp=1635152781434&version=1.0.0] deregistered successfully., dubbo version: 2.7.8, current host: 172.173.173.69

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

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/352291.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号