在处理一个需要与 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库可以！的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/171678.html
微信扫一扫 
支付宝扫一扫 
