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

摘要：用于管理客户端到服务集群之间的连接的主要功能通用连接池支持集群动态更新声明当前使用随机数策略达到动态负载均衡下载导入方法使用示例初始化连接池动态更新服务地址实现各种业务代码打印空闲连接数参考版权声明

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
", err)
        return
    }

    if p == nil {
        log.Printf("p= %#v
", p)
        return
    }

    defer p.Close()

    //动态更新服务地址
    //options.Input()<-&[]string{}

    conn, err := p.Get()
    if err != nil {
        log.Printf("%#v
", err)
        return
    }

    defer p.Put(conn)

    //实现各种业务代码
    //conn.DoSomething()

    //打印空闲连接数
    log.Printf("len=%d
", p.IdleCount())
}

https://github.com/fatih/pool

https://github.com/silenceper/pool

https://github.com/daizuozhuo/rpc-example

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