使用 Chronicle Wire 将 YAML 连接到文件或网络

一则或许对你有用的小广告

欢迎加入小哈的星球 ,你将获得:专属的项目实战 / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论

  • 新项目:《从零手撸:仿小红书(微服务架构)》 正在持续爆肝中,基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...点击查看项目介绍 ;
  • 《从零手撸:前后端分离博客项目(全栈开发)》 2 期已完结,演示链接: http://116.62.199.48/ ;

截止目前, 星球 内专栏累计输出 63w+ 字,讲解图 2808+ 张,还在持续爆肝中.. 后续还会上新更多项目,目标是将 Java 领域典型的项目都整一波,如秒杀系统, 在线商城, IM 即时通讯,权限管理,Spring Cloud Alibaba 微服务等等,已有 2200+ 小伙伴加入学习 ,欢迎点击围观

概述

Chronicle Wire 旨在获得文本协议在易于开发和更快调试方面的优势,但能够切换到性能更高、体积更小的二进制协议,而无需更改代码。

在这篇 文章 中,我研究了使用基于 YAML 的文本格式进行序列化和反序列化可能实现的性能。其中一个不错的功能是您可以使用 YAML 进行测试、调试,但在有意义的地方切换到二进制 YAML。

甚至可以在单个流中混合和匹配。例如,使用 YAML 进行握手,并在确定两端兼容时切换到二进制 YAML 或什至其他格式。

代码是什么样的?

首先你需要有一个缓冲区来写入。这可以是一个 byte[]、一个 ByteBuffer、堆外内存,甚至是您从其他库获得的地址和长度。


 // Bytes which wraps a ByteBuffer which is resized as needed.
Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();

现在您可以选择要使用的格式。由于有线格式本身是无缓冲的,您可以将它们与相同的缓冲区一起使用,但通常使用一种有线格式更容易。


 // Bytes which wraps a ByteBuffer which is resized as needed.
Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();

有很多选项,例如您是否想要像 protobuf 或 SBE 这样的数字字段,或者您想要使用可变(最小)或固定长度(最快)数据值。

要写出一个对象,您可以将其设为可编组并定义可读编组和可写编组,但现在让我们只写一些数据。


 // Bytes which wraps a ByteBuffer which is resized as needed.
Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();

 // Bytes which wraps a ByteBuffer which is resized as needed.
Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();

使用 TextWire 会打印:


 // Bytes which wraps a ByteBuffer which is resized as needed.
Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();

但是,改用 BinaryWire 并写入(以十六进制打印时):


 // Bytes which wraps a ByteBuffer which is resized as needed.
Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();

使用 BinaryWire 可以减少一半的大小和两倍的速度,但是我们可以选择使用 RawWire,它会丢弃所有元数据并且比计划文本快 8 倍。

有关更多 示例和文档,请参阅 Chronicle Wire 的主要自述文件。

使用 Chronicle Wire 的其他示例

结论

虽然二进制协议可以更快,但它们可能更难使用。如果您可以使用文本格式,您可以更快地开发和调试,但如果您可以选择动态切换,则可以在需要时选择性能。

尽管 TextWire 花费的时间少于 5 微秒,但 99.99% 的写入时间都是读取一个 6 字段对象,这对于许多应用程序来说可能已经足够快了。

有用的是,如果需要,可以选择加快速度。 RawWire 在 99.99% 的时间内都在 600 纳秒以下,无需更改代码。

如果需要最大速度,我们有一个 BytesMarshallable 接口和一个精简的 API,在 99.99% 的时间里,它的运行时间小于 220 纳秒。

相关文章