序列化

    • form
    • json
    • protobuf
    • xml
    • yaml
    1. // https://github.com/go-kratos/kratos/blob/main/encoding/json/json.go
    2. package json
    4. import (
    5.     "encoding/json"
    6.     "reflect"
    8.     "github.com/go-kratos/kratos/v2/encoding"
    9.     "google.golang.org/protobuf/encoding/protojson"
    10.     "google.golang.org/protobuf/proto"
    11. )
    13. // Name is the name registered for the json codec.
    14. const Name = "json"
    16. var (
    17.     // MarshalOptions is a configurable JSON format marshaller.
    18.     MarshalOptions = protojson.MarshalOptions{
    19.     }
    20.     // UnmarshalOptions is a configurable JSON format parser.
    21.     UnmarshalOptions = protojson.UnmarshalOptions{
    23.     }
    24. )
    26. func init() {
    27.     encoding.RegisterCodec(codec{})
    28. }
    30. // codec is a Codec implementation with json.
    31. type codec struct{}
    33. func (codec) Marshal(v interface{}) ([]byte, error) {
    34.     switch m := v.(type) {
    35.     case json.Marshaler:
    36.         return m.MarshalJSON()
    37.     case proto.Message:
    38.         return MarshalOptions.Marshal(m)
    39.     default:
    40.         return json.Marshal(m)
    41.     }
    42. }
    44. func (codec) Unmarshal(data []byte, v interface{}) error {
    45.     switch m := v.(type) {
    46.     case json.Unmarshaler:
    47.         return m.UnmarshalJSON(data)
    48.     case proto.Message:
    50.         rv := reflect.ValueOf(v)
    51.         for rv := rv; rv.Kind() == reflect.Ptr; {
    52.             if rv.IsNil() {
    53.                 rv.Set(reflect.New(rv.Type().Elem()))
    54.             }
    55.             rv = rv.Elem()
    56.         }
    57.         if m, ok := reflect.Indirect(rv).Interface().(proto.Message); ok {
    58.             return UnmarshalOptions.Unmarshal(data, m)
    59.         }
    60.         return json.Unmarshal(data, m)
    61.     }
    62. }
    64. func (codec) Name() string {
    65.     return Name
    66. }

    注册 Codec

    获取 Codec

    1. jsonCodec := encoding.GetCodec("json")

    序列化

    反序列化

    1. // 直接使用内置 Codec 时需要 import _ "github.com/go-kratos/kratos/v2/encoding/json"
    2. jsonCodec := encoding.GetCodec("json")
    3. type user struct {
    4.     Name string
    5.     Age string
    6.     state bool
    7. }
    8. u := &user{}
    9. jsonCodec.Unmarshal([]byte(`{"Name":"kratos","Age":"2"}`), &u)
    11. // 输出：&{kratos 2 false}