最近，我在开发一个涉及大数据处理的 php 项目时，遇到了一个棘手的问题：如何高效地在 PHP 中进行 Avro 格式的数据序列化和反序列化。特别是在使用 Confluent Platform 时，如何确保数据在不同服务间的兼容性成为了一个挑战。为了解决这个问题，我尝试了多种方法，最终发现了 mateusjunges/avro-serde-php 这个库，它彻底解决了我的困扰。
mateusjunges/avro-serde-php 是一个专门为 PHP 设计的 Avro 序列化和反序列化库，它与 Confluent Schema Registry 完美集成，确保了数据的兼容性和高效处理。使用 composer 安装这个库非常简单：
composer require 'mateusjunges/avro-serde-php:^1.6'
首先，我们需要创建一个缓存的 Schema Registry 客户端，以避免每次序列化或反序列化时都进行 http 请求：
use FlixTechSchemaRegistryApiRegistryCacheAvroObjectCacheAdapter; use FlixTechSchemaRegistryApiRegistryCachedRegistry; use FlixTechSchemaRegistryApiRegistryPromisingRegistry; use GuzzleHttpClient; $schemaRegistryClient = new CachedRegistry( new PromisingRegistry( new Client(['base_uri' => 'registry.example.com']) ), new AvroObjectCacheAdapter() );
接下来，我们构建一个 RecordSerializer 实例，它是与这个库交互的主要方式：
use FlixTechAvroSerializerObjectsRecordSerializer; $recordSerializer = new RecordSerializer( $schemaRegistry, [ RecordSerializer::OPTION_REGISTER_MISSING_SCHEMAS => false, RecordSerializer::OPTION_REGISTER_MISSING_SUBJECTS => false, ] );
使用 RecordSerializer 进行编码非常简单：
立即学习“PHP免费学习笔记（深入）”；
$subject = 'my-topic-value'; $avroSchema = AvroSchema::parse('{"type": "string"}'); $record = 'Test message'; $encodedBinaryAvro = $recordSerializer->encodeRecord($subject, $avroSchema, $record);
同样，解码消息也非常方便：
$record = $recordSerializer->decodeMessage($encodedBinaryAvro); echo $record; // 'Test message'
此外，mateusjunges/avro-serde-php 还提供了多种 Schema Resolver 来管理 Avro 模式。例如，FileResolver 可以从文件中加载模式，而 CallableResolver 则提供了更高的灵活性。此外，还可以使用 ChainResolver 来组合多个解析器，以满足不同需求。
对于 symfony 用户，这个库还提供了与 Symfony Serializer 组件的集成，使得在 Symfony 项目中使用 Avro 序列化变得更加简单：
use FlixTechAvroSerializerIntegrationsSymfonySerializerAvroSerDeEncoder; use FlixTechAvroSerializerObjectsDefaultRecordSerializerFactory; use SymfonyComponentSerializerNormalizerGetSetMethodNormalizer; use SymfonyComponentSerializerSerializer; $recordSerializer = DefaultRecordSerializerFactory::get( getenv('SCHEMA_REGISTRY_HOST') ); $normalizer = new GetSetMethodNormalizer(); $encoder = new AvroSerDeEncoder($recordSerializer); $symfonySerializer = new Serializer([$normalizer], [$encoder]);
最后，这个库还提供了 Schema Builder 和 Schema Generator 功能，使得在 PHP 中定义和生成 Avro 模式变得更加直观和高效。
使用 mateusjunges/avro-serde-php 库，我不仅解决了 Avro 序列化和反序列化的难题，还极大地提升了项目的开发效率和数据处理的兼容性。如果你也在 PHP 项目中面临类似的挑战，不妨尝试一下这个库。
