## 11) API初始化接口(V0.8)
我们每次在使用`get_host`,`get_route`的时候,首次拉取一定是不成功的,因为第一首次拉取,agent server并没有对当前的`modid/cmdid`的route信息做本地缓存,所以我们可以提供一个初始化的接口,在初始化过程中,首先对当前的modid/cmdid全部进行获取,也就是调用一次`get_route()`方法。来让agent针对当前`modid/cmdid`向`dns service`拉取下来对应的host信息。
> api/cpp/lars_api/lars_api.cpp
```c
//lars 系统初始化注册modid/cmdid使用(首次拉取)(初始化使用,只调用一次即可)
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
}
```
然后我们在使用lars api进行开发的时候,采用如下步骤
> api/cpp/example/example.cpp
```c
#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 初始化(只调用一次)
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. 获取一个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;
//上报调用结果 0 表示成功, 1 表示过载
//这里为了测试结果,随机添加过载记录
if (cnt % 3 == 0) {
api.report(modid, cmdid, ip, port, 1);
}
else {
api.report(modid, cmdid, ip, port, 0);
}
}
return 0;
}
```
---
### 关于作者:
作者:`Aceld(刘丹冰)`
mail: [danbing.at@gmail.com](mailto:danbing.at@gmail.com)
github: [https://github.com/aceld](https://github.com/aceld)
原创书籍: [https://www.kancloud.cn/@aceld](https://www.kancloud.cn/@aceld)
![](https://img.kancloud.cn/b0/d1/b0d11a21ba62e96aef1c11d5bfff2cf8_227x227.jpg)
>**原创声明:未经作者允许请勿转载, 如果转载请注明出处**
- 一、Lars系统概述
- 第1章-概述
- 第2章-项目目录构建
- 二、Reactor模型服务器框架
- 第1章-项目结构与V0.1雏形
- 第2章-内存管理与Buffer封装
- 第3章-事件触发EventLoop
- 第4章-链接与消息封装
- 第5章-Client客户端模型
- 第6章-连接管理及限制
- 第7章-消息业务路由分发机制
- 第8章-链接创建/销毁Hook机制
- 第9章-消息任务队列与线程池
- 第10章-配置文件读写功能
- 第11章-udp服务与客户端
- 第12章-数据传输协议protocol buffer
- 第13章-QPS性能测试
- 第14章-异步消息任务机制
- 第15章-链接属性设置功能
- 三、Lars系统之DNSService
- 第1章-Lars-dns简介
- 第2章-数据库创建
- 第3章-项目目录结构及环境构建
- 第4章-Route结构的定义
- 第5章-获取Route信息
- 第6章-Route订阅模式
- 第7章-Backend Thread实时监控
- 四、Lars系统之Report Service
- 第1章-项目概述-数据表及proto3协议定义
- 第2章-获取report上报数据
- 第3章-存储线程池及消息队列
- 五、Lars系统之LoadBalance Agent
- 第1章-项目概述及构建
- 第2章-主模块业务结构搭建
- 第3章-Report与Dns Client设计与实现
- 第4章-负载均衡模块基础设计
- 第5章-负载均衡获取Host主机信息API
- 第6章-负载均衡上报Host主机信息API
- 第7章-过期窗口清理与过载超时(V0.5)
- 第8章-定期拉取最新路由信息(V0.6)
- 第9章-负载均衡获取Route信息API(0.7)
- 第10章-API初始化接口(V0.8)
- 第11章-Lars Agent性能测试工具
- 第12章- Lars启动工具脚本