go-pkg/cmux
2
0
Fork 0
mirror of https://github.com/soheilhy/cmux.git synced 2024-11-10 03:31:52 +08:00
Code Issues Projects Releases Wiki Activity

Add Go RPC in the README example

Browse Source
This commit is contained in:
Soheil Hassas Yeganeh 2015-07-30 11:03:07 -04:00
parent 2e42ad4f75
commit 0417b90d39
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
README.md
View File

@ -18,9 +18,11 @@ if err != nil {
// Create a cmux. // Create a cmux.
m := cmux.New(l) m := cmux.New(l)
// Match connections in order. // Match connections in order:
// First grpc, then HTTP, and otherwise Go RPC/TCP.
grpcL := m.Match(cmux.HTTP2HeaderField("content-type", "application/grpc")) grpcL := m.Match(cmux.HTTP2HeaderField("content-type", "application/grpc"))
httpL := m.Match(cmux.Any()) // Any means anything that is not yet matched. httpL := m.Match(cmux.HTTP1Fast())
trpcL := m.Match(cmux.Any()) // Any means anything that is not yet matched.
// Create your protocol servers. // Create your protocol servers.
grpcS := grpc.NewServer() grpcS := grpc.NewServer()
@ -30,9 +32,13 @@ httpS := &http.Server{
Handler: &helloHTTP1Handler{}, Handler: &helloHTTP1Handler{},
} }
trpcS := rpc.NewServer()
s.Register(&ExampleRPCRcvr{})
// Use the muxed listeners for your servers. // Use the muxed listeners for your servers.
go grpcS.Serve(grpcL) go grpcS.Serve(grpcL)
go httpS.Serve(httpL) go httpS.Serve(httpL)
go trpcS.Accept(trpcL)
// Start serving! // Start serving!
m.Serve() m.Serve()