| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171 |
- // Copyright (c) 2012, 2013 Ugorji Nwoke. All rights reserved.
- // Use of this source code is governed by a BSD-style license found in the LICENSE file.
- /*
- High Performance, Feature-Rich Idiomatic Go encoding library for msgpack and binc .
- Supported Serialization formats are:
- - msgpack: [https://github.com/msgpack/msgpack]
- - binc: [http://github.com/ugorji/binc]
- To install:
- go get github.com/ugorji/go/codec
- The idiomatic Go support is as seen in other encoding packages in
- the standard library (ie json, xml, gob, etc).
- Rich Feature Set includes:
- - Simple but extremely powerful and feature-rich API
- - Very High Performance.
- Our extensive benchmarks show us outperforming Gob, Json and Bson by 2-4X.
- This was achieved by taking extreme care on:
- - managing allocation
- - stack frame size (important due to Go's use of split stacks),
- - reflection use
- - recursion implications
- - zero-copy mode (encoding/decoding to byte slice without using temp buffers)
- - Correct.
- Care was taken to precisely handle corner cases like:
- overflows, nil maps and slices, nil value in stream, etc.
- - Efficient zero-copying into temporary byte buffers
- when encoding into or decoding from a byte slice.
- - Standard field renaming via tags
- - Encoding from any value
- (struct, slice, map, primitives, pointers, interface{}, etc)
- - Decoding into pointer to any non-nil typed value
- (struct, slice, map, int, float32, bool, string, reflect.Value, etc)
- - Supports extension functions to handle the encode/decode of custom types
- - Support Go 1.2 encoding.BinaryMarshaler/BinaryUnmarshaler
- - Schema-less decoding
- (decode into a pointer to a nil interface{} as opposed to a typed non-nil value).
- Includes Options to configure what specific map or slice type to use
- when decoding an encoded list or map into a nil interface{}
- - Provides a RPC Server and Client Codec for net/rpc communication protocol.
- - Msgpack Specific:
- - Provides extension functions to handle spec-defined extensions (binary, timestamp)
- - Options to resolve ambiguities in handling raw bytes (as string or []byte)
- during schema-less decoding (decoding into a nil interface{})
- - RPC Server/Client Codec for msgpack-rpc protocol defined at:
- http://wiki.msgpack.org/display/MSGPACK/RPC+specification
- Extension Support
- Users can register a function to handle the encoding or decoding of
- their custom types.
- There are no restrictions on what the custom type can be. Extensions can
- be any type: pointers, structs, custom types off arrays/slices, strings,
- etc. Some examples:
- type BisSet []int
- type BitSet64 uint64
- type UUID string
- type MyStructWithUnexportedFields struct { a int; b bool; c []int; }
- type GifImage struct { ... }
- Typically, MyStructWithUnexportedFields is encoded as an empty map because
- it has no exported fields, while UUID will be encoded as a string,
- etc. However, with extension support, you can encode any of these
- however you like.
- We provide implementations of these functions where the spec has defined
- an inter-operable format. For msgpack, these are Binary and
- time.Time. Library users will have to explicitly configure these as seen
- in the usage below.
- Usage
- Typical usage model:
- var (
- mapStrIntfTyp = reflect.TypeOf(map[string]interface{}(nil))
- sliceByteTyp = reflect.TypeOf([]byte(nil))
- timeTyp = reflect.TypeOf(time.Time{})
- )
-
- // create and configure Handle
- var (
- bh codec.BincHandle
- mh codec.MsgpackHandle
- )
- mh.MapType = mapStrIntfTyp
-
- // configure extensions for msgpack, to enable Binary and Time support for tags 0 and 1
- mh.AddExt(sliceByteTyp, 0, mh.BinaryEncodeExt, mh.BinaryDecodeExt)
- mh.AddExt(timeTyp, 1, mh.TimeEncodeExt, mh.TimeDecodeExt)
- // create and use decoder/encoder
- var (
- r io.Reader
- w io.Writer
- b []byte
- h = &bh // or mh to use msgpack
- )
-
- dec = codec.NewDecoder(r, h)
- dec = codec.NewDecoderBytes(b, h)
- err = dec.Decode(&v)
-
- enc = codec.NewEncoder(w, h)
- enc = codec.NewEncoderBytes(&b, h)
- err = enc.Encode(v)
-
- //RPC Server
- go func() {
- for {
- conn, err := listener.Accept()
- rpcCodec := codec.GoRpc.ServerCodec(conn, h)
- //OR rpcCodec := codec.MsgpackSpecRpc.ServerCodec(conn, h)
- rpc.ServeCodec(rpcCodec)
- }
- }()
-
- //RPC Communication (client side)
- conn, err = net.Dial("tcp", "localhost:5555")
- rpcCodec := codec.GoRpc.ClientCodec(conn, h)
- //OR rpcCodec := codec.MsgpackSpecRpc.ClientCodec(conn, h)
- client := rpc.NewClientWithCodec(rpcCodec)
- Representative Benchmark Results
- A sample run of benchmark using "go test -bi -bench=.":
- ..............................................
- BENCHMARK INIT: 2013-09-30 14:18:26.997930788 -0400 EDT
- To run full benchmark comparing encodings (MsgPack, Binc, JSON, GOB, etc), use: "go test -bench=."
- Benchmark:
- Struct recursive Depth: 1
- ApproxDeepSize Of benchmark Struct: 4694 bytes
- Benchmark One-Pass Run:
- v-msgpack: len: 1600 bytes
- bson: len: 3025 bytes
- msgpack: len: 1560 bytes
- binc: len: 1187 bytes
- gob: len: 1972 bytes
- json: len: 2538 bytes
- ..............................................
- PASS
- Benchmark__Msgpack__Encode 50000 69408 ns/op 15852 B/op 84 allocs/op
- Benchmark__Msgpack__Decode 10000 119152 ns/op 15542 B/op 424 allocs/op
- Benchmark__Binc_____Encode 20000 80940 ns/op 18033 B/op 88 allocs/op
- Benchmark__Binc_____Decode 10000 123617 ns/op 16363 B/op 305 allocs/op
- Benchmark__Gob______Encode 10000 152634 ns/op 21342 B/op 238 allocs/op
- Benchmark__Gob______Decode 5000 424450 ns/op 83625 B/op 1842 allocs/op
- Benchmark__Json_____Encode 20000 83246 ns/op 13866 B/op 102 allocs/op
- Benchmark__Json_____Decode 10000 263762 ns/op 14166 B/op 493 allocs/op
- Benchmark__Bson_____Encode 10000 129876 ns/op 27722 B/op 514 allocs/op
- Benchmark__Bson_____Decode 10000 164583 ns/op 16478 B/op 789 allocs/op
- Benchmark__VMsgpack_Encode 50000 71333 ns/op 12356 B/op 343 allocs/op
- Benchmark__VMsgpack_Decode 10000 161800 ns/op 20302 B/op 571 allocs/op
- ok ugorji.net/codec 27.165s
- To run full benchmark suite (including against vmsgpack and bson),
- see notes in ext_dep_test.go
- */
- package codec
|