189 8069 5689

java中PulsarSchema是什么-创新互联

java中Pulsar Schema是什么？一般大家对Schema的了解可能停留在概念的层面上，而对于Schema在Pulsar的使用方法了解相对较少。今天就跟大家聊聊Schemar的使用方法

站在用户的角度思考问题，与客户深入沟通，找到长白网站设计与长白网站推广的解决方案，凭借多年的经验，让设计与互联网技术结合，创造个性化、用户体验好的作品，建站类型包括：网站设计制作、网站设计、企业官网、英文网站、手机端网站、网站推广、域名注册、雅安服务器托管、企业邮箱。业务覆盖长白地区。

一 Pulsar Schema 基本概念
Schema是定义在topic上
Schema的更新策略是在命名空间定义。
以下图片是一个 schema JSON格式的例子
java中Pulsar Schema是什么

字段说明
nameSchema 名称(发现和topic名称相同)
typeSchema 类型,类型常用的JSON格式，其他详见官方文档
schemaSchema 数据是一个由 8 位无符号字节和模式类型特定组成的序列,这一属性可能是内部使用
schemaDefinition具体业务数据结构
properties存放用户自定义属性

二 Schema的生成
通过3种途径生成Topic上的schema
1 producer 生产者
2 consumer 消息者
3 管理API
topic上默认没有schema,以上3种途径谁先访问Topic,就按谁的schema结构做为第一个版本。
三 JAVA 管理 API
1 建立连接
PulsarAdmin admin = PulsarAdmin.builder()              .serviceHttpUrl(url).build();
Schemas schemas=admin.schemas();//获取schemas管理对象
2 查看schmea
指定topic上schema所有版本
List allSchemaInfo=schemas.getAllSchemas("topic名称");
指定topic上schema最新版本
SchemaInfo snedschemaInfo=schemas.getSchemaInfo("topic名称");
3 删除schmea
schemas.deleteSchema("topic名称")
4 创建schema
schemas.createSchema("topic名称",schemaInfo);
关于schemaInfo对象的生成
1)可以通过RecordSchemaBuilder类型
RecordSchemaBuilder recordSchemaBuilder = SchemaBuilder.record("schemaName");
recordSchemaBuilder.field("ww").type(SchemaType.INT32);
SchemaInfo schemaInfo = recordSchemaBuilder.build(SchemaType.JSON);
2)也可以通过Schema
SchemaInfo schemaInfo=Schema.JSON(UserModel.class).getSchemaInfo();
四 schema更新策略
设置schema策略方法
Namespaces namespaces=admin.namespaces();
namespaces.setSchemaAutoUpdateCompatibilityStrategy("命名空间名称", SchemaAutoUpdateCompatibilityStrategy.属性);
是否强制效验schema
namespaces.setSchemaValidationEnforced("命名空间名称", false);

假设你有一个包含三个方案的主题 (V1、V2和V3)，V1 是最老的，V3 是最新的

属性说明检查哪个 schema
Full架构 V3 和 V2 之间向后和向前兼容  (默认策略)最新版本
FullTransitive架构 V3、V2 和 V1 之间向后和向前兼容所有之前的版本
AlwaysCompatible可以更改schema结构,结构不同会产生新版本所有之前的版本
AutoUpdateDisabled禁用更新schema结构无
Backward使用 schema V3 的消费者可以处理生产者使用 schema V3 或 V2 编写的数据最新版本
BackwardTransitive使用 schema V3 的消费者可以处理生产者使用 schema V3、V2 或 V1 编写的数据。所有之前的版本
Forward使用 schema V3 或 V2 的消费者可以处理生产者使用 schema V3 编写的数据。最新版本
ForwardTransitive使用 schema V3、V2 或 V1 的消费者可以处理生产者使用 schema V3 编写的数据所有之前的版本
以上就是Schemar的使用方法介绍，详细使用情况还得要大家自己使用过才能知道具体要领。如果想阅读更多相关内容的文章，欢迎关注创新互联行业资讯频道！

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。


新闻名称：java中PulsarSchema是什么-创新互联
文章位置：http://cdxtjz.cn/article/gpjio.html

其他资讯