您好,登錄后才能下訂單哦!
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)從庫的利用率最大化。
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)
免責(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)容。