Dubbo序列化方案（Kryo、FST、FASTJSON2、ProtoBuf序列化方案的介绍和使用）
序列化简介
序列化是Dubbo在RPC中非常重要的一个组成部分，其核心作用就是把网络传输中的数据，按照特定的格式进行传输。减小数据的体积，从而提高传输效率。
Dubbo制定了Serialization接口，然后有不同的实现。
常见的Dubbo序列化方式
| 序列化方式 | 备注 |
|---|---|
| Hessian | Dubbo协议中默认的序列化实现方案。 |
| Java Serialization | JDK的序列化方式。 |
| Dubbo序列化 | 阿里尚未开发成熟的高效Java序列化实现，目前不建议我们在生产环境使用它。 |
| Json序列化 | 目前有两种实现：一种是采用阿里的fastjson库；一种是采用Dubbo中自己实现的简单json库。 |
| Kryo | Java序列化方式，后续替换Hessian2,是一种非常成熟的序列化实现，已经在Twitter、Groupon、Yahoo以及多个著名开源项目(如Hive、Storm)中广泛使用。 |
| FST | Java序列化方式，后续替换Hessian2，是一种较新的序列化实现，目前还缺乏足够多的成熟使用案例。 |
| 跨语言序列化方式 | ProtoBuf，Thirft,Avro，MsgPack(它更快更小。短整型被编码成一个字节)。 |
不同序列化方式的对比
基于Java的方式序列化对比（没有对比protobuf）下图来自官方文档：
Kryo序列化方式的使用
在父项目的pom文件中添加依赖
<dependency>
<groupId>org.apache.dubbo.extensions</groupId>
<artifactId>dubbo-serialization-kryo</artifactId>
<version>1.0.1</version>
</dependency>
xml形式
provider
在配置文件中书写下面的内容：
<!-- 设置rpc相关的协议 使得可以网络通信 -->
<dubbo:protocol name="dubbo" port="20880" serialization="kryo"/>
启动起来观看效果：
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
在配置文件中添加配置
<dubbo:reference interface="com.sjdwz.service.UserService" id="userService"
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文件中添加依赖
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-serialization-fst</artifactId>
<version>2.7.23</version>
<exclusions>
<exclusion>
<artifactId>dubbo-common</artifactId>
<groupId>org.apache.dubbo</groupId>
</exclusion>
</exclusions>
</dependency>
其他操作类似Kryo序列化方式的使用。
FASTJSON2序列化方式的使用
在父项目的pom文件中添加依赖
<dependency>
<groupId>com.alibaba.fastjson2</groupId>
<artifactId>fastjson2</artifactId>
<version>2.0.23</version>
</dependency>
其他操作类似Kryo序列化方式的使用。
ProtoBuf序列化方式的使用
环境搭建
在父项目的pom文件中增加相关依赖
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>
<version>3.22.2</version>
</dependency>
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java-util</artifactId>
<version>3.22.2</version>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-serialization-protobuf</artifactId>
<version>2.7.23</version>
<exclusions>
<exclusion>
<artifactId>dubbo-common</artifactId>
<groupId>org.apache.dubbo</groupId>
</exclusion>
<exclusion>
<artifactId>dubbo-serialization-api</artifactId>
<groupId>org.apache.dubbo</groupId>
</exclusion>
<exclusion>
<artifactId>protobuf-java</artifactId>
<groupId>com.google.protobuf</groupId>
</exclusion>
<exclusion>
<artifactId>protobuf-java-util</artifactId>
<groupId>com.google.protobuf</groupId>
</exclusion>
</exclusions>
</dependency>
在父项目的pom文件中增加build内容
<build>
<extensions>
<extension>
<groupId>kr.motd.maven</groupId>
<artifactId>os-maven-plugin</artifactId>
<version>1.7.1</version>
</extension>
</extensions>
<plugins>
<plugin>
<groupId>org.xolstice.maven.plugins</groupId>
<artifactId>protobuf-maven-plugin</artifactId>
<version>0.6.1</version>
<configuration>
<protocArtifact>com.google.protobuf:protoc:3.22.2:exe:${os.detected.classifier}</protocArtifact>
<outputDirectory>${basedir}/src/main/java</outputDirectory>
<clearOutputDirectory>false</clearOutputDirectory>
<protocPlugins>
<protocPlugin>
<id>dubbo</id>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-compiler</artifactId>
<version>0.0.2</version>
<mainClass>org.apache.dubbo.gen.dubbo.Dubbo3Generator</mainClass>
</protocPlugin>
</protocPlugins>
</configuration>
<executions>
<execution>
<goals>
<goal>compile</goal>
<goal>compile-custom</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
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文件配置
<!-- 为dubbo起个名字，要做到唯一，可以被注册中心所管理 -->
<dubbo:application name="dubbo-02-provider"/>
<!-- 设置rpc相关的协议 使得可以网络通信 -->
<dubbo:protocol name="dubbo" port="20880" serialization="protobuf"/>
<!-- 创建对象 -->
<bean id="helloService" class="com.sjdwz.service.HelloServiceImpl"/>
<!-- 发布dubbo服务 -->
<dubbo:service interface="com.sjdwz.HelloService" ref="helloService"/>
运行结果如下：
consumer的开发
xml配置
<dubbo:reference interface="com.sjdwz.HelloService" id="helloService"
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")