【Lars教程目錄】
Lars源代碼
https://github.com/aceld/Lars
【Lars系統(tǒng)概述】
第1章-概述
第2章-項目目錄構(gòu)建
【Lars系統(tǒng)之Reactor模型服務(wù)器框架模塊】
第1章-項目結(jié)構(gòu)與V0.1雛形
第2章-內(nèi)存管理與Buffer封裝
第3章-事件觸發(fā)EventLoop
第4章-鏈接與消息封裝
第5章-Client客戶端模型
第6章-連接管理及限制
第7章-消息業(yè)務(wù)路由分發(fā)機制
第8章-鏈接創(chuàng)建/銷毀Hook機制
第9章-消息任務(wù)隊列與線程池
第10章-配置文件讀寫功能
第11章-udp服務(wù)與客戶端
第12章-數(shù)據(jù)傳輸協(xié)議protocol buffer
第13章-QPS性能測試
第14章-異步消息任務(wù)機制
第15章-鏈接屬性設(shè)置功能
【Lars系統(tǒng)之DNSService模塊】
第1章-Lars-dns簡介
第2章-數(shù)據(jù)庫創(chuàng)建
第3章-項目目錄結(jié)構(gòu)及環(huán)境構(gòu)建
第4章-Route結(jié)構(gòu)的定義
第5章-獲取Route信息
第6章-Route訂閱模式
第7章-Backend Thread實時監(jiān)控
【Lars系統(tǒng)之Report Service模塊】
第1章-項目概述-數(shù)據(jù)表及proto3協(xié)議定義
第2章-獲取report上報數(shù)據(jù)
第3章-存儲線程池及消息隊列
【Lars系統(tǒng)之LoadBalance Agent模塊】
第1章-項目概述及構(gòu)建
第2章-主模塊業(yè)務(wù)結(jié)構(gòu)搭建
第3章-Report與Dns Client設(shè)計與實現(xiàn)
第4章-負(fù)載均衡模塊基礎(chǔ)設(shè)計
第5章-負(fù)載均衡獲取Host主機信息API
第6章-負(fù)載均衡上報Host主機信息API
第7章-過期窗口清理與過載超時(V0.5)
第8章-定期拉取最新路由信息(V0.6)
第9章-負(fù)載均衡獲取Route信息API(0.7)
第10章-API初始化接口(V0.8)
第11章-Lars Agent性能測試工具
第12章- Lars啟動工具腳本
六、Lars-Load Balance Agent負(fù)載代理
1) 簡介
? 一個服務(wù)稱為一個模塊,一個模塊由modid+cmdid來標(biāo)識
modid+cmdid的組合表示一個遠(yuǎn)程服務(wù),這個遠(yuǎn)程服務(wù)一般部署在多個節(jié)點上
LB Agent以UDP方式為業(yè)務(wù)方提供:1、節(jié)點獲取服務(wù);2、節(jié)點調(diào)用結(jié)果上報服務(wù)
1.1 業(yè)務(wù)1-節(jié)點獲取服務(wù):
? 業(yè)務(wù)方每次要向遠(yuǎn)程服務(wù)發(fā)送消息時,先利用modid+cmdid去向LB Agent獲取一個可用節(jié)點,然后向該節(jié)點發(fā)送消息,完成一次遠(yuǎn)程調(diào)用;具體獲取modid+cmdid下的哪個節(jié)點是由LB Agent負(fù)責(zé)的
1.2 業(yè)務(wù)2-節(jié)點調(diào)用結(jié)果上報服務(wù)
? 對LB Agent節(jié)點的一次遠(yuǎn)程調(diào)用后,調(diào)用結(jié)果會匯報給LB Agent,以便LB Agent根據(jù)自身的LB算法來感知遠(yuǎn)程服務(wù)節(jié)點的狀態(tài)是空閑還是過載,進(jìn)而控制節(jié)點獲取時的節(jié)點調(diào)度.

LB Agent擁有5個線程,一個LB算法:
UDP Server服務(wù),并運行LB算法,對業(yè)務(wù)提供節(jié)點獲取和節(jié)點調(diào)用結(jié)果上報服務(wù);為了增大系統(tǒng)吞吐量,使用3個UDP Server服務(wù)互相獨立運行LB算法:modid+cmdid % 3 = i的那些模塊的服務(wù)與調(diào)度,由第i+1個UDP Server線程負(fù)責(zé)
Dns Service Client:是dnsserver的客戶端線程,負(fù)責(zé)根據(jù)需要,向dnsserver獲取一個模塊的節(jié)點集合(或稱為獲取路由);UDP Server會按需向此線程的MQ寫入獲取路由請求,DSS Client將MQ到來的請求轉(zhuǎn)發(fā)到dnsserver,之后將dnsserver返回的路由信息更新到對應(yīng)的UDP Server線程維護(hù)的路由信息中
Report Service Client:是reporter的客戶端線程,負(fù)責(zé)將每個模塊下所有節(jié)點在一段時間內(nèi)的調(diào)用結(jié)果、過載情況上報到reporter Service端,便于觀察情況、做報警;本身消費MQ數(shù)據(jù),UDP Server會按需向MQ寫入上報狀態(tài)請求。
2) 構(gòu)建Lars-Agent項目
2.1 構(gòu)建目錄結(jié)構(gòu)
依次創(chuàng)建如下目錄:
Lars/lars_loadbalance_agent
lars_loadbalance_agent/
├── bin/
├── conf/
│ └── lars_lb_agent.conf
├── include/
├── Makefile
└── src/
其中Makefile如下:
TARGET= bin/lars_lb_agent
CXX=g++
CFLAGS=-g -O2 -Wall -Wno-deprecated
BASE=../base
BASE_H=$(BASE)/include
PROTO = $(BASE)/proto
PROTO_H = $(BASE)/proto
LARS_REACTOR=../lars_reactor
LARS_REACTOR_H =$(LARS_REACTOR)/include
LARS_REACTOR_LIB=$(LARS_REACTOR)/lib -llreactor
MYSQL=$(BASE)/mysql-connector-c
MYSQL_H=$(MYSQL)/include
MYSQL_LIB=$(MYSQL)/lib/libmysqlclient.a
OTHER_LIB = -lpthread -ldl -lprotobuf
SRC= ./src
INC= -I./include -I$(BASE_H) -I$(LARS_REACTOR_H) -I$(MYSQL_H) -I$(PROTO_H)
LIB= $(MYSQL_LIB) -L$(LARS_REACTOR_LIB) $(OTHER_LIB)
OBJS = $(addsuffix .o, $(basename $(wildcard $(SRC)/*.cpp)))
OBJS += $(PROTO)/lars.pb.o
$(TARGET): $(OBJS)
mkdir -p bin
$(CXX) $(CFLAGS) -o $(TARGET) $(OBJS) $(INC) $(LIB)
%.o: %.cpp
$(CXX) $(CFLAGS) -c -o $@ $< $(INC)
.PHONY: clean
clean:
-rm -f src/*.o $(PROTO)/lars.pb.o $(TARGET)
? 實際上reporter、dns相似。
conf/lars_lb_agent.conf
[reporter]
ip = 127.0.0.1
port = 7779
[dnsserver]
ip = 127.0.0.1
port = 7778
? 目前的基本配置文件,因為loadbalance_agent是充當(dāng)reporter和dnsserver的客戶端,所以需要知道對應(yīng)的reporter和dnsserver的ip和port信息。
關(guān)于作者:
作者:Aceld(劉丹冰)
mail: danbing.at@gmail.com
github: https://github.com/aceld
原創(chuàng)書籍gitbook: http://legacy.gitbook.com/@aceld
原創(chuàng)聲明:未經(jīng)作者允許請勿轉(zhuǎn)載, 如果轉(zhuǎn)載請注明出處