這篇文章將為大家詳細(xì)講解有關(guān)Pulsar Schema是什么意思，小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。
10年積累的成都網(wǎng)站制作、網(wǎng)站建設(shè)經(jīng)驗(yàn)，可以快速應(yīng)對(duì)客戶對(duì)網(wǎng)站的新想法和需求。提供各種問(wèn)題對(duì)應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識(shí)你，你也不認(rèn)識(shí)我。但先網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程，更有山城免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。
一 Pulsar Schema 基本概念
Schema是定義在topic上
Schema的更新策略是在命名空間定義。
以下圖片是一個(gè) schema JSON格式的例子
| 字段 | 說(shuō)明 |
|---|---|
| name | Schema 名稱(發(fā)現(xiàn)和topic名稱相同) |
| type | Schema 類型,類型常用的JSON格式，其他詳見(jiàn)官方文檔 |
| schema | Schema 數(shù)據(jù)是一個(gè)由 8 位無(wú)符號(hào)字節(jié)和模式類型特定組成的序列,這一屬性可能是內(nèi)部使用 |
| schemaDefinition | 具體業(yè)務(wù)數(shù)據(jù)結(jié)構(gòu) |
| properties | 存放用戶自定義屬性 |
二 Schema的生成
通過(guò)3種途徑生成Topic上的schema
1 producer 生產(chǎn)者
2 consumer 消息者
3 管理API
topic上默認(rèn)沒(méi)有schema,以上3種途徑誰(shuí)先訪問(wèn)Topic,就按誰(shuí)的schema結(jié)構(gòu)做為第一個(gè)版本。
三 JAVA 管理 API
1 建立連接
PulsarAdmin admin = PulsarAdmin.builder() .serviceHttpUrl(url).build();
Schemas schemas=admin.schemas();//獲取schemas管理對(duì)象
2 查看schmea
指定topic上schema所有版本
List
指定topic上schema最新版本
SchemaInfo snedschemaInfo=schemas.getSchemaInfo("topic名稱");
3 刪除schmea
schemas.deleteSchema("topic名稱")
4 創(chuàng)建schema
schemas.createSchema("topic名稱",schemaInfo);
關(guān)于schemaInfo對(duì)象的生成
1)可以通過(guò)RecordSchemaBuilder類型
RecordSchemaBuilder recordSchemaBuilder = SchemaBuilder.record("schemaName");
recordSchemaBuilder.field("ww").type(SchemaType.INT32);
SchemaInfo schemaInfo = recordSchemaBuilder.build(SchemaType.JSON);
2)也可以通過(guò)Schema
SchemaInfo schemaInfo=Schema.JSON(UserModel.class).getSchemaInfo();
四 schema更新策略
設(shè)置schema策略方法
Namespaces namespaces=admin.namespaces();
namespaces.setSchemaAutoUpdateCompatibilityStrategy("命名空間名稱", SchemaAutoUpdateCompatibilityStrategy.屬性);
是否強(qiáng)制效驗(yàn)schema
namespaces.setSchemaValidationEnforced("命名空間名稱", false);
假設(shè)你有一個(gè)包含三個(gè)方案的主題 (V1、V2和V3)，V1 是最老的，V3 是最新的
| 屬性 | 說(shuō)明 | 檢查哪個(gè) schema |
|---|---|---|
| Full | 架構(gòu) V3 和 V2 之間向后和向前兼容 (默認(rèn)策略) | 最新版本 |
| FullTransitive | 架構(gòu) V3、V2 和 V1 之間向后和向前兼容 | 所有之前的版本 |
| AlwaysCompatible | 可以更改schema結(jié)構(gòu),結(jié)構(gòu)不同會(huì)產(chǎn)生新版本 | 所有之前的版本 |
| AutoUpdateDisabled | 禁用更新schema結(jié)構(gòu) | 無(wú) |
| Backward | 使用 schema V3 的消費(fèi)者可以處理生產(chǎn)者使用 schema V3 或 V2 編寫的數(shù)據(jù) | 最新版本 |
| BackwardTransitive | 使用 schema V3 的消費(fèi)者可以處理生產(chǎn)者使用 schema V3、V2 或 V1 編寫的數(shù)據(jù)。 | 所有之前的版本 |
| Forward | 使用 schema V3 或 V2 的消費(fèi)者可以處理生產(chǎn)者使用 schema V3 編寫的數(shù)據(jù)。 | 最新版本 |
| ForwardTransitive | 使用 schema V3、V2 或 V1 的消費(fèi)者可以處理生產(chǎn)者使用 schema V3 編寫的數(shù)據(jù) | 所有之前的版本 |
關(guān)于“Pulsar Schema是什么意思”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。
重慶分公司
重慶分公司
