最近，我在开发一个涉及大数据处理的 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 FlixTech\SchemaRegistryApi\Registry\Cache\AvroObjectCacheAdapter;
use FlixTech\SchemaRegistryApi\Registry\CachedRegistry;
use FlixTech\SchemaRegistryApi\Registry\PromisingRegistry;
use GuzzleHttp\Client;
$schemaRegistryClient = new CachedRegistry(
new PromisingRegistry(
new Client(['base_uri' => 'registry.example.com'])
),
new AvroObjectCacheAdapter()
);接下来，我们构建一个 RecordSerializer 实例，它是与这个库交互的主要方式：
use FlixTech\AvroSerializer\Objects\RecordSerializer;
$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 FlixTech\AvroSerializer\Integrations\Symfony\Serializer\AvroSerDeEncoder;
use FlixTech\AvroSerializer\Objects\DefaultRecordSerializerFactory;
use Symfony\Component\Serializer\Normalizer\GetSetMethodNormalizer;
use Symfony\Component\Serializer\Serializer;
$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 项目中面临类似的挑战，不妨尝试一下这个库。
