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

時間 2019-11-09

標籤 golang 通用鏈接支持 grpc rpc tcp 欄目 Go 简体版

原文原文鏈接

pool

https://github.com/flyaways/poolgit

Pool 用於管理客戶端到服務集羣之間的鏈接.github

Pool的主要功能:golang

通用鏈接池 - Pool for GRPC,RPC,TCP.support RPC timeout.
支持集羣 - Connet to Cluster.
動態更新 - Danamic update targets.

Pool runs on Linux, Mac OS X, and Windows.負載均衡

聲明:當前使用隨機數策略達到動態負載均衡.google

下載

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())
}