grpc复用client连接

比眉伴天荒 2024-04-19 10:55 63阅读 0赞

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

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

下面是简易实现：

package delayqueue
    
    import (
    	"google.golang.org/grpc"
    	"sync"
    	"sync/atomic"
    	"unsafe"
    )
    
    var (
    	globalClientConn unsafe.Pointer
    	lck              sync.Mutex
    )
    
    func GetClient(target string) (DelayQueueClient, error) {  //返回需要的client
    	conn, 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 check
    		return (*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
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，63人围观）

还没有评论，来说两句吧...

相关阅读

相关 grpc复用client连接

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

比眉伴天荒/ 2024年04月19日 10:55/ 0 赞/ 64 阅读

相关 Redis连接状况 client list命令

Redis集群服务中，client list命令各个参数详解先来看一段client list的执行结果 127.0.0.1:6379> client list

偏执的太偏执、/ 2023年10月15日 12:26/ 0 赞/ 20 阅读

相关 server和client通过grpc建立连接

一、文件结构 server端和client端分布在两个不同的集群里，可以通过下发mq消息，或者grpc连接传递消息，这里介绍通过grpc建立连接，第一步是创建proto文

刺骨的言语ヽ痛彻心扉/ 2022年12月18日 06:56/ 0 赞/ 213 阅读

相关 grpc 客户端连接请求源码

func main() { conn, err := grpc.Dial(":"+PORT, grpc.WithInsecure())

约定不等于承诺〃/ 2022年12月09日 05:18/ 0 赞/ 240 阅读

相关 grpc client与servre如何交互

对 Client 端调用 Server 端进行抓包去剖析。如图所示 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shad

你的名字/ 2022年12月09日 02:41/ 0 赞/ 177 阅读

相关 mac php 如何安装client,mac下grpc（golang server + php client）实践

目前微服务这么流行，RPC框架也是百花齐放，本文讲述一下mac下grpc的开发环境搭建，其中server端使用golang，客户端使用php。服务端 golang grp

旧城等待，/ 2022年11月18日 04:54/ 0 赞/ 390 阅读

相关 gRPC Client 启动流程

gRPC Client 启动流程 gRPC 启动初始化的流程，使用 Netty 作为底层的实现初始化 Channel Channel 的初始化通过 `Chann

落日映苍穹つ/ 2022年10月22日 02:59/ 0 赞/ 254 阅读

相关 WebSocket Client连接远程WebSocket Server

在[这篇文章][Link 1]中，简单介绍了WebSocket的使用，客户端可以使用了JavaScript向服务发送请求，服务端也可以通过SimpMessagingTempla

水深无声/ 2022年06月06日 00:54/ 0 赞/ 670 阅读

相关 ElasticSearch java API--创建Client连接

package Client; import org.elasticsearch.client.Client; import org.elasticsearch.cli

柔情只为你懂/ 2022年05月15日 03:37/ 0 赞/ 320 阅读

相关 RD Client、TeamViewer连接主机

一、使用RD Client连接远程桌面 1、设置本地主机 ![1242064-20190615025111414-2061699660.png][] 2、查看电脑i

墨蓝/ 2022年01月06日 20:13/ 0 赞/ 835 阅读