sunquakes/jsonrpc4go

A go client and server over http or tcp implementation of JSON-RPC 2.0. Support consul & nacos.

jsonrpc4go's Issues

关于前置func和后置func

你好，项目作者。希望这里能增加两个func，用来预处理rpc请求前置和后置。例如：
注册一个前置func，用来鉴定请求权限。
注册一个后置func，用来记录rpc日志。
等等。。。

tcp server cpu飙升

1.启动服务
s, _ := jsonrpc4go.NewServer("tcp", "127.0.0.1", "3232") 
s.Register(new(IntRpc))
s.Start()
2.请求
result := new(Result)
c, _ := jsonrpc4go.NewClient("tcp", "127.0.0.1", "3232")
err := c.Call(...)

cpu会飙升

tcp客户端接收数据不完整

问题:tcp数据分包后，一次read接收不完整。需要接收多次，每次判断数据中是否有结束符。
文件:client/tcp.go
方法:handleFunc

解决方法

// 定义接收buffer
	var (
		buf = make([]byte, p.Options.PackageMaxLength)
		tmp = make([]byte, 1024)
		num = 0
	)

	// 接收数据
	for {
		n, err := p.Conn.Read(tmp)
		if err != nil {
			return err
		}
		buf = append(buf, tmp[:n]...)
		num = len(buf)
		// 判断是否结束
		if reflect.DeepEqual(buf[num-2:], []byte(p.Options.PackageEof)) {
			break
		}
	}
	// 截取掉结束符
	eofLen := len([]byte(p.Options.PackageEof))
	buf = buf[:num-eofLen]
	// 移除切面填充的0
	buf = bytes.Trim(buf, "\x00")