如何解决PHP与Avro序列化兼容性问题？使用flix-tech/avro-serde-php库可以！-composer-PHP中文网

如何解决PHP与Avro序列化兼容性问题？使用flix-tech/avro-serde-php库可以！

WBOY

发布： 2025-04-21 09:24:03

原创

437人浏览过

在处理一个需要与 Confluent 平台集成的大型项目时，我遇到了一个棘手的问题：如何确保在 Avro 序列化格式下，模式演变不会影响下游消费者。Confluent 开发的 Schema Registry 能够通过验证模式演变来解决这个问题，但遗憾的是，Confluent 并没有为 PHP 提供官方的 Avro SerDe 包。经过一番研究，我找到了 flix-tech/avro-serde-php 这个库，它不仅实现了 Confluent 的线格式，还集成了 FlixTech 的 Schema Registry 客户端，彻底解决了我的问题。

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

使用 Composer 安装 flix-tech/avro-serde-php 非常简单，只需运行以下命令：

composer require 'flix-tech/avro-serde-php:^2.2'

登录后复制

接下来，我将介绍如何使用这个库来解决 Avro 序列化和反序列化的问题。

首先，需要创建一个缓存的 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 实例，这是与库交互的主要方式，它提供了 encodeRecord 和 decodeMessage 方法来执行序列化和反序列化操作：

立即学习“PHP免费学习笔记（深入）”；

use FlixTech\AvroSerializer\Objects\RecordSerializer;

$recordSerializer = new RecordSerializer(
    $schemaRegistry,
    [
        RecordSerializer::OPTION_REGISTER_MISSING_SCHEMAS => false,
        RecordSerializer::OPTION_REGISTER_MISSING_SUBJECTS => false,
    ]
);

登录后复制

使用 RecordSerializer 可以轻松地编码和解码消息。例如，编码记录：

$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'

登录后复制

此外，flix-tech/avro-serde-php 还提供了多种 Schema Resolver 来管理 Avro 模式。例如，FileResolver 可以从文件中加载模式，CallableResolver 可以使用自定义函数来获取模式，而 DefinitionInterfaceResolver 则通过实现 HasSchemaDefinitionInterface 接口来解析模式。

如果你使用 Symfony Serializer 组件，这个库还提供了相应的集成：

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 模式。

使用 flix-tech/avro-serde-php 库解决了我的 Avro 序列化和反序列化问题，使得我的项目能够顺利与 Confluent 平台集成。它的灵活性和强大功能大大提高了开发效率，确保了模式演变的兼容性。我强烈推荐任何需要在 PHP 中处理 Avro 序列化的开发者使用这个库。

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