Dubbo序列化方案(Kryo、FST、FASTJSON2、ProtoBuf序列化方案的介绍和使用)

序列化简介

序列化是Dubbo在RPC中非常重要的一个组成部分,其核心作用就是把网络传输中的数据,按照特定的格式进行传输。减小数据的体积,从而提高传输效率。

Dubbo制定了Serialization接口,然后有不同的实现。

常见的Dubbo序列化方式

序列化方式备注HessianDubbo协议中默认的序列化实现方案。Java SerializationJDK的序列化方式。Dubbo序列化阿里尚未开发成熟的高效Java序列化实现,目前不建议我们在生产环境使用它。Json序列化目前有两种实现:一种是采用阿里的fastjson库;一种是采用Dubbo中自己实现的简单json库。KryoJava序列化方式,后续替换Hessian2,是一种非常成熟的序列化实现,已经在Twitter、Groupon、Yahoo以及多个著名开源项目(如Hive、Storm)中广泛使用。FSTJava序列化方式,后续替换Hessian2,是一种较新的序列化实现,目前还缺乏足够多的成熟使用案例。跨语言序列化方式ProtoBuf,Thirft,Avro,MsgPack(它更快更小。短整型被编码成一个字节)。

不同序列化方式的对比

基于Java的方式序列化对比(没有对比protobuf)下图来自官方文档:

Kryo序列化方式的使用

在父项目的pom文件中添加依赖

org.apache.dubbo.extensions

dubbo-serialization-kryo

1.0.1

xml形式

provider

在配置文件中书写下面的内容:

启动起来观看效果:

dubbo://192.168.96.1:20880/com.sjdwz.service.UserService?anyhost=true&application=dubbo-02-provider&background=false&bind.ip=192.168.96.1&bind.port=20880&deprecated=false&dubbo=2.0.2&dynamic=true&executor-management-mode=isolation&file-cache=true&generic=false&interface=com.sjdwz.service.UserService&methods=login&pid=13136&prefer.serialization=kryo&release=3.2.0&serialization=kryo&side=provider×tamp=1695216749509, dubbo version: 3.2.0, current host: 192.168.96.1

comsumer

在配置文件中添加配置

url="dubbo://192.168.96.1:20880/com.sjdwz.service.UserService?serialization=kryo"/>

运行效果:

Boot的方式

provider

在配置文件中书写下面的内容:

spring:

application:

name: dubbo-04-provider

dubbo:

protocol:

name: dubbo

port: -1

serialization: kryo

consumer

注解

@DubboReference(url = "dubbo://192.168.96.1:20880/com.sjdwz.service.UserService?serialization=kryo")

FST序列化方式的使用

在父项目的pom文件中添加依赖

org.apache.dubbo

dubbo-serialization-fst

2.7.23

dubbo-common

org.apache.dubbo

其他操作类似Kryo序列化方式的使用。

FASTJSON2序列化方式的使用

在父项目的pom文件中添加依赖

com.alibaba.fastjson2

fastjson2

2.0.23

其他操作类似Kryo序列化方式的使用。

ProtoBuf序列化方式的使用

环境搭建

在父项目的pom文件中增加相关依赖

com.google.protobuf

protobuf-java

3.22.2

com.google.protobuf

protobuf-java-util

3.22.2

org.apache.dubbo

dubbo-serialization-protobuf

2.7.23

dubbo-common

org.apache.dubbo

dubbo-serialization-api

org.apache.dubbo

protobuf-java

com.google.protobuf

protobuf-java-util

com.google.protobuf

在父项目的pom文件中增加build内容

kr.motd.maven

os-maven-plugin

1.7.1

org.xolstice.maven.plugins

protobuf-maven-plugin

0.6.1

com.google.protobuf:protoc:3.22.2:exe:${os.detected.classifier}

${basedir}/src/main/java

false

dubbo

org.apache.dubbo

dubbo-compiler

0.0.2

org.apache.dubbo.gen.dubbo.Dubbo3Generator

compile

compile-custom

protobuf文件的编写

在dubbo-01-api模块的main目录新建一个proto文件夹;

注意必须叫这个名字,这样才能被maven插件读取到;

新建一个HelloService.proto的文件,在文件中编写如下内容:

syntax = "proto3";

option java_multiple_files = true;

option java_package = "com.sjdwz";

option java_outer_classname = "HelloServiceProto";

message HelloRequest{

string name = 1;

}

message HelloResponse{

string result = 1;

}

service HelloService{

rpc sayHello(HelloRequest) returns (HelloResponse);

}

服务开发

在protobuf文件中右键

执行此命令:

注意:如果项目中有中文路径可能会报错,需要改成英文目录

可以clean一下把target目录下的内容删掉;

provider的开发

实现生成的service接口

xml文件配置

运行结果如下:

consumer的开发

xml配置

url="dubbo://192.168.96.1:20880/com.sjdwz.HelloService?serialization=protobuf"/>

Java测试类

public class ClientApplication {

public static void main(String[] args) throws IOException {

ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext-consumer.xml");

HelloService hellService = applicationContext.getBean(HelloService.class);

HelloResponse response = hellService.sayHello(HelloRequest.newBuilder().setName("sjdwz").build());

System.out.println("response.getResult() = " + response.getResult());

System.in.read();

}

}

provider的开发——boot配置

spring:

application:

name: dubbo-04-provider

dubbo:

protocol:

name: dubbo

port: -1

serialization: protobuf

consumer的开发——boot配置

@DubboReference(url = "dubbo://192.168.96.1:20880/com.sjdwz.HelloService?serialization=protobuf")

好文链接

评论可见,请评论后查看内容,谢谢!!!
 您阅读本篇文章共花了: