grpc复用client连接

以前在调用grpc接口时，总要调用Dial函数来创建一个grpc的ClientConn，如果每次都要创建，那么开销代价是很大的。

grpc的ClientConn对象可以帮我们实现自动重连的机制，并且是并发安全的，因此可以定义一个全局的ClientConn，然后用到的时候就用这个连接。

下面是简易实现：

package delayqueueimport ("google.golang.org/grpc""sync""sync/atomic""unsafe"
)var (globalClientConn unsafe.Pointerlck              sync.Mutex
)func GetClient(target string) (DelayQueueClient, error) {  //返回需要的clientconn, err := GetConn(target)if err != nil {return (DelayQueueClient)(nil), err}return NewDelayQueueClient(conn), nil  //此处调用pb.go文件中生成的创建client的方法
}func GetConn(target string) (*grpc.ClientConn, error) {if atomic.LoadPointer(&globalClientConn) != nil {return (*grpc.ClientConn)(globalClientConn), nil}lck.Lock()defer lck.Unlock()if atomic.LoadPointer(&globalClientConn) != nil { //double checkreturn (*grpc.ClientConn)(globalClientConn), nil}cli, err := newGrpcConn(target)if err != nil {return nil, err}atomic.StorePointer(&globalClientConn, unsafe.Pointer(cli))return cli, nil
}func newGrpcConn(target string) (*grpc.ClientConn, error) {conn, err := grpc.Dial(target,grpc.WithInsecure(),)if err != nil {return nil, err}return conn, nil
}

grpc复用client连接相关推荐

带入gRPC：gRPC Streaming, Client and Server
带入gRPC:gRPC Streaming, Client and Server 原文地址:带入gRPC:gRPC Streaming, Client and Server 项目地址:go-grpc- ...
oracle kepserve,Kepware.KEPServer\KEPServerEX_V5操作简介含opc quick client 连接测试
[实例简介] Kepware.KEPServer\KEPServerEX_V5操作简介含opc quick client 连接测试 3.開魯 KEPServereX的管理視窗請從「開始」->「 ...
VMware View Client 连接服务器，提示身份验证失败，连接服务器时
第一次安装或则重装系统后安装VMware View的时候点击下一步然后连接服务器地址例如:192.168.xx.xxx,点击连接后,在输入账号的时候弹出VMware View Client ...
Paho Java Client 连接阿里云物联网平台
Paho Java Client 连接阿里云物联网平台进入阿里云物联网平台->点击产品->新建点击设备->添加设备查看设备证书,复制记录,后面使用阿里云TCP通信一机一密. ...
vSphere Client连接主机提示远程服务器响应时间过长
问题现象使用VMware vSphere Client连接EXSi主机时,提示"由于远程服务器响应时间过长,请求失败(操作超时)". 解决方法打开Windows注册表,找到HK ...
Prosys OPC Client连接OPC DA
Prosys OPC Client连接OPC DA Prosys OPC 客户端将帮助排除 OPC 连接故障并测试 OPC 服务器. 您可以读写数据.浏览服务器以及导出和导入地址空间. OPC 客户端 ...
TDH Kerberos java client 连接Hyperbase（Hbase）
TDH Kerberos java client 连接Hyperbase(Hbase) 异常信息 SASL authentication failed. The most likely cause i ...
【翻译自mos文章】对于JDBC thin client连接，ORA-28040 and SQLNET.ALLOWED_LOGON_VERSION_CLIENT
对于JDBC thin client连接,ORA-28040 and SQLNET.ALLOWED_LOGON_VERSION_CLIENT的问题来源于: ORA-28040 and SQLNET. ...
Go http client 连接池不复用的问题
当 http client 返回值为不为空,只读取 response header,但不读 body 内容就执行 response.Body.Close(),那么连接会被主动关闭,得不到复用. 测试代 ...
c++排查线程hang住_Kafka学习笔记之kafka高版本Client连接0.9Server引发的血案排查 - 时光飞逝，逝者如斯...
0x00 概述 kafka server虽然原则上是兼容详细的client,但只是高版本的Server端兼容低版本的Client端: 在有高版本Client端连接时,会导致低版本Server集群会ha ...

grpc复用client连接

grpc复用client连接相关推荐

最新文章

热门文章