read-loadbalance

master-slave(n) 讀庫(kù)集群負(fù)載均衡器(簡(jiǎn)單輪詢(xún))+時(shí)間間隔錯(cuò)峰。
github 地址：https://github.com/Plen-wang/read-loadbalance

公司主營(yíng)業(yè)務(wù)：成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站、移動(dòng)網(wǎng)站開(kāi)發(fā)等業(yè)務(wù)。幫助企業(yè)客戶(hù)真正實(shí)現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競(jìng)爭(zhēng)能力。創(chuàng)新互聯(lián)是一支青春激揚(yáng)、勤奮敬業(yè)、活力青春激揚(yáng)、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊(duì)。公司秉承以“開(kāi)放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對(duì)我們的高要求，感謝他們從不同領(lǐng)域給我們帶來(lái)的挑戰(zhàn)，讓我們激情的團(tuán)隊(duì)有機(jī)會(huì)用頭腦與智慧不斷的給客戶(hù)帶來(lái)驚喜。創(chuàng)新互聯(lián)推出津市免費(fèi)做網(wǎng)站回饋大家。

使用場(chǎng)景

1.一般我們會(huì)有多個(gè)從庫(kù)，需要在從庫(kù)的讀取上做負(fù)載均衡。
2.在數(shù)倉(cāng)拉取數(shù)據(jù)的時(shí)候經(jīng)常對(duì)產(chǎn)線(xiàn)DB造成影響，所以會(huì)獨(dú)立一個(gè)從庫(kù)專(zhuān)門(mén)用來(lái)拉取，但是這個(gè)從庫(kù)的利用率非常低。
數(shù)倉(cāng)拉取數(shù)據(jù)一般在業(yè)務(wù)低峰期進(jìn)行，iops峰值較高，但是持續(xù)時(shí)間很短。我們可以錯(cuò)開(kāi)這個(gè)時(shí)間段，讓這臺(tái)從庫(kù)的利用率最大化。

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/MySQL"
    "github.com/gocraft/dbr"
    "github.com/read-loadbalance/lb"
    "log"
)

var slaveLB *lb.SlaveLoadBalancer

func main() {
    //構(gòu)造數(shù)據(jù)源
    creator := func() *sql.DB {
        dsn := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=%s&autocommit=1", "root", 123456, "localhost", 3306, "test", "utf8mb4")
        conn, er := sql.Open("mysql", dsn)
        if er != nil {
            log.Fatalf("create db conn error:%v", er.Error())
        }
        return conn
    }

    slave1 := creator()
    slave2 := creator()

    //構(gòu)造slave-lb
    slaveLB = lb.BuildSlaveLoadBalancer(1, 2, 1, slave1, slave2)

    //獲取數(shù)據(jù)源
    _, _, conn := slaveLB.GetPollingNode()

    //放入任意orm中，這里舉例dbr
    orm := &dbr.Connection{DB: conn}
    orm.NewSession(nil).SelectBySql("select id from tb_orders limit 1")

}

作者：王清培（趣頭條 Tech Leader）