【Lars教程目錄】
Lars源代碼
https://github.com/aceld/Lars
【Lars系統(tǒng)概述】
第1章-概述
第2章-項(xiàng)目目錄構(gòu)建
【Lars系統(tǒng)之Reactor模型服務(wù)器框架模塊】
第1章-項(xiàng)目結(jié)構(gòu)與V0.1雛形
第2章-內(nèi)存管理與Buffer封裝
第3章-事件觸發(fā)EventLoop
第4章-鏈接與消息封裝
第5章-Client客戶端模型
第6章-連接管理及限制
第7章-消息業(yè)務(wù)路由分發(fā)機(jī)制
第8章-鏈接創(chuàng)建/銷毀Hook機(jī)制
第9章-消息任務(wù)隊(duì)列與線程池
第10章-配置文件讀寫功能
第11章-udp服務(wù)與客戶端
第12章-數(shù)據(jù)傳輸協(xié)議protocol buffer
第13章-QPS性能測(cè)試
第14章-異步消息任務(wù)機(jī)制
第15章-鏈接屬性設(shè)置功能
【Lars系統(tǒng)之DNSService模塊】
第1章-Lars-dns簡(jiǎn)介
第2章-數(shù)據(jù)庫(kù)創(chuàng)建
第3章-項(xiàng)目目錄結(jié)構(gòu)及環(huán)境構(gòu)建
第4章-Route結(jié)構(gòu)的定義
第5章-獲取Route信息
第6章-Route訂閱模式
第7章-Backend Thread實(shí)時(shí)監(jiān)控
【Lars系統(tǒng)之Report Service模塊】
第1章-項(xiàng)目概述-數(shù)據(jù)表及proto3協(xié)議定義
第2章-獲取report上報(bào)數(shù)據(jù)
第3章-存儲(chǔ)線程池及消息隊(duì)列
【Lars系統(tǒng)之LoadBalance Agent模塊】
第1章-項(xiàng)目概述及構(gòu)建
第2章-主模塊業(yè)務(wù)結(jié)構(gòu)搭建
第3章-Report與Dns Client設(shè)計(jì)與實(shí)現(xiàn)
第4章-負(fù)載均衡模塊基礎(chǔ)設(shè)計(jì)
第5章-負(fù)載均衡獲取Host主機(jī)信息API
第6章-負(fù)載均衡上報(bào)Host主機(jī)信息API
第7章-過(guò)期窗口清理與過(guò)載超時(shí)(V0.5)
第8章-定期拉取最新路由信息(V0.6)
第9章-負(fù)載均衡獲取Route信息API(0.7)
第10章-API初始化接口(V0.8)
第11章-Lars Agent性能測(cè)試工具
第12章- Lars啟動(dòng)工具腳本
9) 定期拉取最新路由信息(V0.6)
- 當(dāng)agent首次連接到dns service時(shí)，將全部的
load_balance均設(shè)置為NEW狀態(tài)。如果dns service重新啟動(dòng)指攒，或者斷開鏈接重連米罚，都會(huì)將之前的拉去中或者沒(méi)拉取的load_balance狀態(tài)都設(shè)置為NEW狀態(tài)，只有NEW狀態(tài)的load_balance才能定期自動(dòng)拉取.
lars_loadbalance_agent/src/dns_client.cpp
//========================================================
static void conn_init(net_connection *conn, void *args)
{
for (int i = 0; i < 3; i++) {
r_lb[i]->reset_lb_status();
}
}
//========================================================
void *dns_client_thread(void* args)
{
printf("dns client thread start\n");
event_loop loop;
//1 加載配置文件得到dns service ip + port
std::string ip = config_file::instance()->GetString("dnsserver", "ip", "");
short port = config_file::instance()->GetNumber("dnsserver", "port", 0);
//2 創(chuàng)建客戶端
tcp_client client(&loop, ip.c_str(), port, "dns client");
//3 將thread_queue消息回調(diào)事件，綁定到loop中
dns_queue->set_loop(&loop);
dns_queue->set_callback(new_dns_request, &client);
//4 設(shè)置當(dāng)收到dns service回執(zhí)的消息ID_GetRouteResponse處理函數(shù)
client.add_msg_router(lars::ID_GetRouteResponse, deal_recv_route);
//========================================================
//5.設(shè)置鏈接成功/鏈接斷開重連成功之后，通過(guò)conn_init來(lái)清理之前的任務(wù)
client.set_conn_start(conn_init);
//========================================================
//啟動(dòng)事件監(jiān)聽
loop.event_process();
return NULL;
}
lars_loadbalance_agent/src/route_lb.cpp
//將全部的load_balance都重置為NEW狀態(tài)
void route_lb::reset_lb_status()
{
pthread_mutex_lock(&_mutex);
for (route_map_it it = _route_lb_map.begin();
it != _route_lb_map.end(); it++) {
load_balance *lb = it->second;
if (lb->status == load_balance::PULLING) {
lb->status = load_balance::NEW;
}
}
pthread_mutex_unlock(&_mutex);
}
- 增加配置文件參數(shù)update_timeout, 表示一個(gè)NEW狀態(tài)的load_balance下的modid/cmdid節(jié)點(diǎn)應(yīng)該經(jīng)歷多長(zhǎng)時(shí)間進(jìn)行一次刷新拉取。
lars_loadbalance_agent/conf/lars_lb_agent.conf
;對(duì)于每個(gè)NEW狀態(tài)的modid/cmdid珊豹，多久更新一下本地路由,秒
update_timeout=15
lars_loadbalance_agent/include/main_server.h
struct load_balance_config
{
//...
//對(duì)于每個(gè)NEW狀態(tài)的modid/cmdid，多久更新一下本地路由,秒
long update_timeout;
};
lars_loadbalance_agent/src/main_server.cpp
static void init_lb_agent()
{
//1. 加載配置文件
config_file::setPath("./conf/lars_lb_agent.conf");
//...
//...
lb_config.update_timeout = config_file::instance()->GetNumber("loadbalance", "update_timeout", 15);
//...
}
- 給
load_balance設(shè)置最后update時(shí)間參數(shù),及最后一次從dns service拉取下來(lái)更新host_map的時(shí)間.然后在route_lb每次執(zhí)行get_host的時(shí)候榕订，對(duì)每個(gè)已經(jīng)存在的host節(jié)點(diǎn)做最后時(shí)間超時(shí)檢查店茶，如果超時(shí)，則重新從 dns service中拉取卸亮。
lars_loadbalance_agent/include/load_balance.h
/*
* 負(fù)載均衡算法核心模塊
* 針對(duì)一組(modid/cmdid)下的全部host節(jié)點(diǎn)的負(fù)載規(guī)則
*/
class load_balance {
public:
load_balance(int modid, int cmdid):
status(PULLING),
last_update_time(0),
_modid(modid),
_cmdid(cmdid)
{
//load_balance 初始化構(gòu)造
}
// ...
long last_update_time; //最后更新host_map時(shí)間戳
private:
// ...
};
lars_loadbalance_agent/src/load_balance.cpp
//根據(jù)dns service遠(yuǎn)程返回的結(jié)果忽妒，更新_host_map
void load_balance::update(lars::GetRouteResponse &rsp)
{
long current_time = time(NULL);
//...
//...
//更新最后update時(shí)間
last_update_time = current_time;
//重置狀態(tài)為NEW
status = NEW;
}
? load_balance每次調(diào)用update()都記錄一次最后的更新時(shí)間，并標(biāo)記為NEW表示當(dāng)前modid/cmdid沒(méi)有在PULLING,可以再更新兼贸。
lars_loadbalance_agent/src/route_lb.cpp
//agent獲取一個(gè)host主機(jī)段直，將返回的主機(jī)結(jié)果存放在rsp中
int route_lb::get_host(int modid, int cmdid, lars::GetHostResponse &rsp)
{
int ret = lars::RET_SUCC;
//1. 得到key
uint64_t key = ((uint64_t)modid << 32) + cmdid;
pthread_mutex_lock(&_mutex);
//2. 當(dāng)前key已經(jīng)存在_route_lb_map中
if (_route_lb_map.find(key) != _route_lb_map.end()) {
//2.1 取出對(duì)應(yīng)的load_balance
load_balance *lb = _route_lb_map[key];
if (lb->empty() == true) {
//存在lb 里面的host為空，說(shuō)明正在pull()中溶诞，還沒(méi)有從dns_service返回來(lái),所以直接回復(fù)不存在
assert(lb->status == load_balance::PULLING);
rsp.set_retcode(lars::RET_NOEXIST);
}
else {
ret = lb->choice_one_host(rsp);
rsp.set_retcode(ret);
// =================================================
//超時(shí)重拉路由
//檢查是否要重新拉路由信息
//若路由并沒(méi)有處于PULLING狀態(tài)鸯檬，且有效期已經(jīng)超時(shí)，則重新拉取
if (lb->status == load_balance::NEW && time(NULL) - lb->last_update_time > lb_config.update_timeout) {
lb->pull();
}
// =================================================
}
}
//3. ...
// ...
pthread_mutex_unlock(&_mutex);
return ret;
}
關(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)作者允許請(qǐng)勿轉(zhuǎn)載, 如果轉(zhuǎn)載請(qǐng)注明出處
