Consumer and Producer

包路径: github.com/caicloud/nirvana/service

在 HTTP 请求中，Content-Type 说明了请求和响应中的数据类型。为了根据 Content-Type 自动处理数据转换，Nirvana 提供了 Consumer 和 Producer 接口。其中 Consumer 用于将请求体中的数据转换为业务函数需要的类型，而 Producer 则负责将业务函数的返回结果写入到响应体中。

Nirvana 默认提供的 Consumers：

Nirvana 默认提供的 Producers：

添加 Consumer 和 Producer

在业务的实际场景中，默认提供的 Consumers 和 Producers 可能不能满足实际使用需求。因此 Nirvana 的 service 包提供了相应的工具用于注册用户自己的 Consumer 和 Producer。

注册 Consumer

Consumer 需要实现接口：

// Consumer handles specifically typed data from a reader and unmarshals it into an object.
type Consumer interface {
    // ContentType returns a HTTP MIME type.
    ContentType() string
    // Consume unmarshals data from r into v.
    Consume(r io.Reader, v interface{}) error
}

实现了这个接口后，通过 service 的注册方法即可注册 Consumer：

if err := service.RegisterConsumer(consumer); err != nil {
    log.Fatal(err)
}

在接收到 Content-Type 与 consumer 一致的请求，并且业务函数需要从请求中取得请求体的时候，就会调用这个 Consumer 去读取数据并进行类型转换。

注册 Producer

Producer 需要实现接口：

// Producer marshals an object to specifically typed data and write it into a writer.
type Producer interface {
    // ContentType returns a HTTP MIME type.
    ContentType() string
    // Produce marshals v to data and write to w.
    Produce(w io.Writer, v interface{}) error
}

实现了这个接口后，通过 service 的注册方法即可注册 Producer：

if err := service.RegisterProducer(producer); err != nil {
    log.Fatal(err)
}

在需要生成 Conetent-Type 于 producer 一致的响应，并且业务函数需要返回数据的时候，就会调用这个 producer 将类型转换为字节数据写入到响应体中。

快速生成 Consumer 和 Producer 的工具

通常情况下，我们需要快速添加一些 Consumers 和 Producers，并且他们的行为和 application/octet-stream 一致的时候，那么可以直接使用工具方法：

serializer := NewSimpleSerializer(contentType)

if err := service.RegisterConsumer(serializer); err != nil {
    log.Fatal(err)
}

if err := service.RegisterProducer(serializer); err != nil {
    log.Fatal(err)
}