【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)工具腳本
11) API初始化接口(V0.8)
? 我們每次在使用get_host,get_route的時(shí)候歉摧，首次拉取一定是不成功的，因?yàn)榈谝皇状卫。琣gent server并沒(méi)有對(duì)當(dāng)前的modid/cmdid的route信息做本地緩存颅眶，所以我們可以提供一個(gè)初始化的接口熙侍，在初始化過(guò)程中蚪腐，首先對(duì)當(dāng)前的modid/cmdid全部進(jìn)行獲取箫津，也就是調(diào)用一次get_route()方法婿崭。來(lái)讓agent針對(duì)當(dāng)前modid/cmdid向dns service拉取下來(lái)對(duì)應(yīng)的host信息俭嘁。
api/cpp/lars_api/lars_api.cpp
//lars 系統(tǒng)初始化注冊(cè)modid/cmdid使用(首次拉取)(初始化使用躺枕，只調(diào)用一次即可)
int lars_client::reg_init(int modid, int cmdid)
{
route_set route;
int retry_cnt = 0;
while (route.empty() && retry_cnt < 3) {
get_route(modid, cmdid, route);
if (route.empty() == true) {
usleep(50000); // 等待50ms
}
else {
break;
}
++retry_cnt;//嘗試3次
}
if (route.empty() == true) {
return lars::RET_NOEXIST;//3
}
return lars::RET_SUCC; //0
}
然后我們?cè)谑褂胠ars api進(jìn)行開發(fā)的時(shí)候，采用如下步驟
api/cpp/example/example.cpp
#include "lars_api.h"
#include <iostream>
void usage()
{
printf("usage: ./example [modid] [cmdid]\n");
}
int main(int argc, char **argv)
{
int ret = 0;
if (argc != 3) {
usage();
return 1;
}
int modid = atoi(argv[1]);
int cmdid = atoi(argv[2]);
lars_client api;
std::string ip;
int port;
//1. lars_api 初始化(只調(diào)用一次)
ret = api.reg_init(modid, cmdid);
if (ret != 0) {
std::cout << "modid " << modid << ", cmdid " << cmdid << " still not exist host, after register, ret = " << ret << std::endl;
}
//2. 獲取modid/cmdid下全部的host的ip+port
route_set route;
ret = api.get_route(modid, cmdid, route);
if (ret == 0) {
std::cout << "get route succ!" << std::endl;
for (route_set_it it = route.begin(); it != route.end(); it++) {
std::cout << "ip = " << (*it).first << ", port = " << (*it).second << std::endl;
}
}
//3. 獲取一個(gè)host的ip+port
int cnt = 0;
ret = api.get_host(modid, cmdid, ip, port);
if (ret == 0) {
std::cout << "host is " << ip << ":" << port << std::endl;
//上報(bào)調(diào)用結(jié)果 0 表示成功兄淫， 1 表示過(guò)載
//這里為了測(cè)試結(jié)果屯远，隨機(jī)添加過(guò)載記錄
if (cnt % 3 == 0) {
api.report(modid, cmdid, ip, port, 1);
}
else {
api.report(modid, cmdid, ip, port, 0);
}
}
return 0;
}
關(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)注明出處
