golang通用连接池,支持GRPC,RPC,TCP

cccccc_5538 · · 702 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

pool

项目地址 https://github.com/flyaways/pool

Pool 用于管理客户端到服务集群之间的连接.

Pool的主要功能:

  • 通用连接池 - Pool for GRPC,RPC,TCP.support RPC timeout.

  • 支持集群 - Connet to Cluster.

  • 动态更新 - Danamic update targets.

Pool runs on Linux, Mac OS X, and Windows.

声明:当前使用随机数策略达到动态负载均衡.

下载


go get -u gopkg.in/flyaways/pool.v1

导入方法


import "gopkg.in/flyaways/pool.v1"

使用示例


package main

import (

"log"

"time"

"gopkg.in/flyaways/pool.v1"

"google.golang.org/grpc"

)

func main() {

options := &pool.Options{

InitTargets:  []string{"127.0.0.1:8080"},

InitCap:      5,

MaxCap:      30,

DialTimeout:  time.Second * 5,

IdleTimeout:  time.Second * 60,

ReadTimeout:  time.Second * 5,

WriteTimeout: time.Second * 5,

}

    //初始化连接池

p, err := pool.NewGRPCPool(options, grpc.WithInsecure())

if err != nil {

log.Printf("%#v\n", err)

return

}

if p == nil {

log.Printf("p= %#v\n", p)

return

}

defer p.Close()

//动态更新服务地址

//options.Input()<-&[]string{}

conn, err := p.Get()

if err != nil {

log.Printf("%#v\n", err)

return

}

defer p.Put(conn)

//实现各种业务代码

//conn.DoSomething()

    //打印空闲连接数

log.Printf("len=%d\n", p.IdleCount())

}

参考

版权声明

  • The MIT License (MIT) - see LICENSE for more details

有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:cccccc_5538

查看原文:golang通用连接池,支持GRPC,RPC,TCP

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

702 次点击  
加入收藏 微博
上一篇:helloworld
下一篇:goquery的使用
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传