如何解决PHP中Avro序列化和反序列化的问题？使用mateusjunges/avro-serde-php可以！-composer-PHP中文网

如何解决PHP中Avro序列化和反序列化的问题？使用mateusjunges/avro-serde-php可以！

PHPz

发布： 2025-05-03 10:04:03

原创

535人浏览过

最近，我在开发一个涉及大数据处理的 PHP 项目时，遇到了一个棘手的问题：如何高效地在 PHP 中进行 Avro 格式的数据序列化和反序列化。特别是在使用 Confluent Platform 时，如何确保数据在不同服务间的兼容性成为了一个挑战。为了解决这个问题，我尝试了多种方法，最终发现了 mateusjunges/avro-serde-php 这个库，它彻底解决了我的困扰。

可以通过一下地址学习composer：学习地址

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 项目中面临类似的挑战，不妨尝试一下这个库。

以上就是如何解决PHP中Avro序列化和反序列化的问题？使用mateusjunges/avro-serde-php可以！的详细内容，更多请关注php中文网其它相关文章！