网络传输和序列化这两部分的功能相对来说是非常通用并且独立的在设计的时候只要能做到比较好的抽象这两部的实现它的通用性是非常强的。

不仅可以用于

RPC

框架中同样可以直接拿去用于实现消息队列或者其他需要互相通信的分布式系统中。

我们先来实现序列化和反序列化部分因为后面的部分会用到序列化和反序列化。

设计实现

首先我们需要设计一个可扩展的通用的序列化接口为了方便使用我们直接使用静态类的方式来定义这个接口严格来说这并不是一个接口

public

SerializeSupport.serialize(myClassObject);

反序列化

SerializeSupport.parse(bytes);通用的序列化实现【推荐】

在讲解序列化和反序列化的时候说过可以使用通用的序列化实现也可以自己来定义专用的序列化实现。

专用的序列化性能最好但缺点是实现起来比较复杂你要为每一种类型的数据专门编写序列化和反序列化方法。

一般的

RPC

框架不像消息队列一样采用性能更好的专用的序列化实现呢这个原因很简单消息队列它需要序列化数据的类型是固定的只是它自己的内部通信的一些命令。

但

RPC

框架它需要序列化的数据是用户调用远程方法的参数这些参数可能是各种数据类型所以必须使用通用的序列化实现确保各种类型的数据都能被正确的序列化和反序列化。

我们这里还是采用专用的序列化实现主要的目的是一起来实践一下如何来实现序列化和反序列化

专用序列化接口定义

Serializer#size(java.lang.Object)}方法的返回值。

*/void

serialize(T

用一个字节标识对象类型每种类型的数据应该具有不同的类型值*/byte

type();/***

方法计算序列化之后的数据长度用于事先来申请存放序列化数据的字节数组type

方法定义每种序列化实现的类型这个类型值也会写入到序列化之后的数据中主要的作用是在反序列化的时候能够识别是什么数据类型的以便找到对应的反序列化实现类getSerializeClass

这个方法返回这个序列化实现类对应的对象类型目的是在执行序列化的时候通过被序列化的对象类型找到对应序列化实现类

序列化实现

是序列化实现类对应的序列化对象的类型它的用途是在序列化的时候通过被序列化的对象类型找到对应的序列化实现类。

typeMap

serializerMap

是序列化实现类的类型用于在反序列化的时候从序列化的数据中读出对象类型然后找到对应的序列化实现类

Map

的作用实现序列化和反序列化这两个方法就很容易了。

这两个方法的实现思路是一样的都是通过一个类型在这两个

Map

LoggerFactory.getLogger(SerializeSupport.class);private

static

ServiceSupport.loadAll(Serializer.class))

{registerType(serializer.type(),

serializer.getSerializeClass(),

serializer,

{}.,serializer.getSerializeClass().getCanonicalName(),serializer.type());}}private

static

eClass);}SuppressWarnings(unchecked)private

static

serializerMap.get(eClass).parse(buffer,

offset,

(eClass.isAssignableFrom(entry.getClass()))

{return

parseEntryType(buffer);SuppressWarnings(unchecked)ClassE

eClass

SerializeException(String.format(Unknown

entry

{SuppressWarnings(unchecked)SerializerE

serializer

serializerMap.get(entry.getClass());if(serializer

null)

SerializeException(String.format(Unknown

entry

entry.getClass().toString()));}byte

bytes

serializer.type();serializer.serialize(entry,

bytes,

StreamSupport.stream(ServiceLoader.load(service).spliterator(),

false).map(ServiceSupport::singletonFilter).findFirst().orElseThrow(ServiceLoadException::new);}public

synchronized

StreamSupport.stream(ServiceLoader.load(service).spliterator(),

false).map(ServiceSupport::singletonFilter).collect(Collectors.toList());}SuppressWarnings(unchecked)private

static

{if(service.getClass().isAnnotationPresent(Singleton.class))

{String

service.getClass().getCanonicalName();Object

singletonInstance

singletonServices.putIfAbsent(className,

service);return

这个静态类调用它的序列化和反序列化方法就可以了不需要依赖任何序列化实现类。

Serializer

entry.getBytes(StandardCharsets.UTF_8).length;}Overridepublic

void

entry.getBytes(StandardCharsets.UTF_8);System.arraycopy(strBytes,

bytes,

strBytes.length);}Overridepublic

String

StandardCharsets.UTF_8);}Overridepublic

byte

Types.TYPE_STRING;}Overridepublic

ClassString

数组做转换的时候一定要指定编码方式确保序列化和反序列化的时候都使用一致的编码我们这里面统一使用

UTF8

编码。

否则如果遇到执行序列化和反序列化的两台服务器默认编码不一样就会出现乱码。

我们在开发过程用遇到的很多中文乱码问题绝大部分都是这个原因

MetadataSerializer用于将注册中心的数据持久化到文件中

/***

bytesentry.entrySet().stream().mapToInt(this::entrySize).sum();}Overridepublic

void

length);buffer.putShort(toShortSafely(entry.size()));entry.forEach((k,v)

{byte

k.getBytes(StandardCharsets.UTF_8);buffer.putShort(toShortSafely(keyBytes.length));buffer.put(keyBytes);buffer.putShort(toShortSafely(v.size()));for

(URI

uri.toASCIIString().getBytes(StandardCharsets.UTF_8);buffer.putShort(toShortSafely(uriBytes.length));buffer.put(uriBytes);}});}private

int

bytese.getKey().getBytes().length

Serialized

bytesuri.toASCIIString().getBytes(StandardCharsets.UTF_8).length;

Serialized

[keyLength];buffer.get(keyBytes);String

key

[uriLength];buffer.get(uriBytes);URI

uri

StandardCharsets.UTF_8));uriList.add(uri);}metadata.put(key,

uriList);}return

Types.TYPE_METADATA;}Overridepublic

ClassMetadata

到这里序列化的部分就实现完成了。

我们这个序列化的实现对外提供服务的就只有一个

SerializeSupport

静态类并且可以通过扩展支持序列化任何类型的数据这样一个通用的实现不仅可以用在我们这个

RPC