Pulsar 2.5.0 之 Schema 入门
官网原文标题《Get started》
翻译时间：2020-02-14
官网原文地址： http://pulsar.apache.org/docs/en/schema-get-started/
译者：本章介绍 Pulsar schema 并解释它们为什么重要
Schema 注册表
类型安全在任何围绕消息总线（如Pulsar）构建的应用程序中都非常重要。生产者和消费者需要某种机制来协调主题级别的类型，以避免出现各种潜在的问题。例如，序列化和反序列化问题。应用程序通常采用以下方法之一来保证消息传递中的类型安全。这两种方法都可以在Pulsar中使用，您可以自由地采用其中一种或另一种，也可以根据每个主题进行混合和匹配。
客户端方法
生产者和消费者不仅负责序列化和反序列化消息（由原始字节组成），而且还“知道”哪些类型通过哪些主题进行传输。如果生产者发送主题为“主题1”的温度传感器数据，则该主题的消费者如果试图将该数据解析为湿度传感器读数，将遇到麻烦。生产者和消费者可以发送和接收由原始字节数组组成的消息，并在“带外”的基础上将所有类型安全强制留给应用程序。
服务器端方法
生产者和消费者通知系统哪些数据类型可以通过主题进行传输。通过这种方法，消息传递系统强制执行类型安全，并确保生产者和消费者保持同步。Pulsar有一个内置的schema注册表，它允许客户端按主题上传数据schema。这些schema指示哪些数据类型被识别为对该主题有效。
为什么使用 schema
当schema启用时，Pulsar会解析数据，它以字节作为输入，以字节作为输出。为了理解字节数据含义，需要解析数据，并且可能会遇到解析异常，这些异常主要发生在以下情况：
字段不存在
字段类型已更改（例如，“string”更改为“int”）
为了防止和克服这些异常，例如，可以在分析错误时捕获异常，这使得代码很难维护；也可以采用schema管理系统来执行schema演化，而不是中断下游应用程序，并在所使用的语言中强制类型安全性达到最大扩展，Pulsar schema就是解决方案。
Pulsar schema允许您在构造和处理从简单类型（如“string”）到复杂的应用程序特定类型的消息时，使用特定语言数据类型。
示例
您可以使用User类定义发送到 Pulsar主题的消息
public class User {
String name;
int age;
}
当使用User类构造生产者时，可以按如下所示指定 schema或不指定 schema
不使用schema
如果在不指定schema的情况下构造生产者，则生产者只能生成“byte[]”类型的消息。如果有POJO类，则在发送消息之前需要将POJO序列化为字节
示例
Producer<byte[]> producer = client.newProducer()
.topic(topic)
.create();
User user = new User(“Tom”, 28);
byte[] message = … // serialize the `user` by yourself;
producer.send(message);
使用 schema
如果您通过指定schema来构造生产者，则可以直接将类发送到主题，而不必担心如何将pojo序列化为字节。
示例
本例使用JSONSchema构造一个producer，您可以直接将User类发送到主题，而不必担心如何将其序列化为字节。
Producer<User> producer = client.newProducer(JSONSchema.of(User.class))
.topic(topic)
.create();
User user = new User(“Tom”, 28);
producer.send(user);
温馨提示
使用schema构造生产者时，不需要将消息序列化为字节，而Pulsar schema在后台执行此任务。
