溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

golang 簡單的讀負(fù)責(zé)均衡

發(fā)布時(shí)間:2020-07-27 01:09:01 來源:網(wǎng)絡(luò) 閱讀:194 作者:王清培 欄目:編程語言

read-loadbalance

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

使用場景

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

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)

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI