Feature

Benchmark

Low Concurrency

High Concurrency

Get started

Install

go get github.com/hslam/rpc

Import

import "github.com/hslam/rpc"

Usage

Examples

syntax = "proto3";package service;message ArithRequest {    int32 a = 1;    int32 b = 2;}message ArithResponse {    int32 pro = 1;}

protoc ./arith.proto --gogofaster_out=./

package servicetypeArithstruct{}func (a*Arith)Multiply(req*ArithRequest,res*ArithResponse)error {res.Pro=req.A*req.Breturnnil}

package mainimport ("github.com/hslam/rpc""github.com/hslam/rpc/examples/codec/pb/service")funcmain() {rpc.Register(new(service.Arith))rpc.Listen("tcp",":9999","pb")}

package mainimport ("fmt""github.com/hslam/rpc""github.com/hslam/rpc/examples/codec/pb/service")funcmain() {conn,err:=rpc.Dial("tcp",":9999","pb")iferr!=nil {panic(err)}deferconn.Close()req:=&service.ArithRequest{A:9,B:2}varres service.ArithResponseiferr=conn.Call("Arith.Multiply",req,&res);err!=nil {panic(err)}fmt.Printf("%d * %d = %d\n",req.A,req.B,res.Pro)}

package mainimport ("fmt""github.com/hslam/rpc""github.com/hslam/rpc/examples/codec/pb/service")funcmain() {trans:=&rpc.Transport{MaxConnsPerHost:1,MaxIdleConnsPerHost:1,Options:&rpc.Options{Network:"tcp",Codec:"pb"},}defertrans.Close()req:=&service.ArithRequest{A:9,B:2}varres service.ArithResponseiferr:=trans.Call(":9999","Arith.Multiply",req,&res);err!=nil {panic(err)}fmt.Printf("%d * %d = %d\n",req.A,req.B,res.Pro)}

package mainimport ("fmt""github.com/hslam/rpc""github.com/hslam/rpc/examples/codec/pb/service")funcmain() {opts:=&rpc.Options{Network:"tcp",Codec:"pb"}client:=rpc.NewClient(opts,":9997",":9998",":9999")client.Scheduling=rpc.LeastTimeSchedulingdeferclient.Close()req:=&service.ArithRequest{A:9,B:2}varres service.ArithResponseiferr:=client.Call("Arith.Multiply",req,&res);err!=nil {panic(err)}fmt.Printf("%d * %d = %d\n",req.A,req.B,res.Pro)}

package mainimport ("context""fmt""github.com/hslam/rpc""github.com/hslam/rpc/examples/codec/pb/service""time")funcmain() {conn,err:=rpc.Dial("tcp",":9999","pb")iferr!=nil {panic(err)}deferconn.Close()req:=&service.ArithRequest{A:9,B:2}varres service.ArithResponseemptyCtx:=context.Background()valueCtx:=context.WithValue(emptyCtx,rpc.BufferContextKey,make([]byte,64))ctx,cancel:=context.WithTimeout(valueCtx,time.Minute)defercancel()err=conn.CallWithContext(ctx,"Arith.Multiply",req,&res)iferr!=nil {panic(err)}fmt.Printf("%d * %d = %d\n",req.A,req.B,res.Pro)}

Output

9 * 2 = 18

License

Author