README
¶
rpc2d
项目介绍
rpc2d 双向 RPC 调用，可以实现从服务器 CALLBACK 客户端 API，基于 "net/rpc" 原生库
use: SEE test/server.go 、 test/client.go
NewRpcNodeByConn 函数兼容 gitee.com/rocket049/pipeconn
软件架构
软件架构说明
安装教程
- xxxx
- xxxx
- xxxx
使用说明
type ProviderType
type RpcNode
func Accept(l net.Listener, provider interface{}) (*RpcNode, error)
func NewRpcNode(provider interface{}) *RpcNode
func NewRpcNodeByConn(provider interface{}, conn io.ReadWriteCloser) *RpcNode
func (self *RpcNode) Close()
func (self *RpcNode) Dial(addr string) error
参与贡献
- Fork 本项目
- 新建 Feat_xxx 分支
- 提交代码
- 新建 Pull Request
码云特技
- 使用 Readme_XXX.md 来支持不同的语言，例如 Readme_en.md, Readme_zh.md
- 码云官方博客 blog.gitee.com
- 你可以 https://gitee.com/explore 这个地址来了解码云上的优秀开源项目
- GVP 全称是码云最有价值开源项目，是码云综合评定出的优秀开源项目
- 码云官方提供的使用手册 https://gitee.com/help
- 码云封面人物是一档用来展示码云会员风采的栏目 https://gitee.com/gitee-stars/
Documentation
¶
Overview ¶
rpc2d 双向 RPC 调用，可以实现从服务器 CALLBACK 客户端 API，基于 "net/rpc" 原生库
Index ¶
Constants ¶
View Source
const ( S = byte('S') //Flag : Server Message C = byte('C') //Flag : Client Message E = byte('E') //Flag : Error T = byte('T') //Flag : Timeout )
wrap message( []byte ): "T uint8 + length uint16 + bytes [length]byte". T = S/C/E
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProviderType ¶
ProviderType This is NOT must fit below struct. But this struct can help CALLBACK. See test server.go/client.go
type RpcNode ¶
type RpcNode struct {
Server *rpc.Server
Client *rpc.Client
// contains filtered or unexported fields
}
RpcNode double direction RPC
func NewRpcNode ¶
func NewRpcNode(provider interface{}) *RpcNode
NewRpcNode create new Rpc.Node ,init rpc.Server with service provider
func NewRpcNodeByConn ¶ added in v1.0.8
func NewRpcNodeByConn(provider interface{}, conn io.ReadWriteCloser) *RpcNode
NewRpcNodeByConn connect to remote by io.ReadWriteCloser, and link local server/client,use after NewRpcNode
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.