【Lars教程目錄】

Lars源代碼
https://github.com/aceld/Lars

【Lars系統(tǒng)概述】
第1章-概述
第2章-項目目錄構(gòu)建

【Lars系統(tǒng)之Reactor模型服務器框架模塊】
第1章-項目結(jié)構(gòu)與V0.1雛形
第2章-內(nèi)存管理與Buffer封裝
第3章-事件觸發(fā)EventLoop
第4章-鏈接與消息封裝
第5章-Client客戶端模型
第6章-連接管理及限制
第7章-消息業(yè)務路由分發(fā)機制
第8章-鏈接創(chuàng)建/銷毀Hook機制
第9章-消息任務隊列與線程池
第10章-配置文件讀寫功能
第11章-udp服務與客戶端
第12章-數(shù)據(jù)傳輸協(xié)議protocol buffer
第13章-QPS性能測試
第14章-異步消息任務機制
第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è)務結(jié)構(gòu)搭建
第3章-Report與Dns Client設(shè)計與實現(xiàn)
第4章-負載均衡模塊基礎(chǔ)設(shè)計
第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啟動工具腳本

3) dns serivce模塊目錄構(gòu)建

3.1 集成lars_reactor模塊

? 首先我們給dns模塊創(chuàng)建一個項目文件夾，與lars_reactor并列，在Lars/下創(chuàng)建

$mkdir Lars/lars_dns

在lars_dns中，我們可以先創(chuàng)建基本的項目必須文件夾和文件，目錄結(jié)構(gòu)如下

lars_dns/
    ├── bin/
    ├── conf/
    │   └── lars_dns.conf
    ├── include/
    ├── Makefile
    └── src/
        └── dns_service.cpp

conf/lars_dns.conf

[reactor]
maxConn = 1024
threadNum = 5
ip = 127.0.0.1
port = 7778

src/dns_service.cpp

#include "lars_reactor.h"

int main(int argc, char **argv)
{
    event_loop loop;

    //加載配置文件
    config_file::setPath("conf/lars_dns.conf");
    std::string ip = config_file::instance()->GetString("reactor", "ip", "0.0.0.0");
    short port = config_file::instance()->GetNumber("reactor", "port", 7778);


    //創(chuàng)建tcp服務器
    tcp_server *server = new tcp_server(&loop, ip.c_str(), port);

    //注冊路由業(yè)務
    

    //開始事件監(jiān)聽    
    printf("lars dns service ....\n");
    loop.event_process();

    return 0;
}

Makefile

TARGET= bin/lars_dns
CXX=g++
CFLAGS=-g -O2 -Wall -Wno-deprecated

BASE=../base
BASE_H=$(BASE)/include
LARS_REACTOR=../lars_reactor
LARS_REACTOR_H =$(LARS_REACTOR)/include
LARS_REACTOR_LIB=$(LARS_REACTOR)/lib  -llreactor

OTHER_LIB = -lpthread
SRC= ./src
INC= -I./include -I$(BASE_H) -I$(LARS_REACTOR_H)

LIB= -L$(LARS_REACTOR_LIB) $(OTHER_LIB)


OBJS = $(addsuffix .o, $(basename $(wildcard $(SRC)/*.cpp)))

$(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 $(TARGET)

這里主要注意一下Makefile的編寫，我們需要連接libreactor庫還有l(wèi)ibpthread庫等，還有一些頭文件的文件目錄不要寫錯。

接下來進行make，我們會在bin/得到dns的可執(zhí)行程序,并且可以成功運行.

$ ./bin/lars_dns 
msg_router init...
create 0 thread
create 1 thread
create 2 thread
create 3 thread
create 4 thread
lars dns service ....

3.2 集成mysql模塊

? 我們需要使用libmysqlclient開發(fā)者第三方庫，當然可以從mysql官方網(wǎng)站下載與你當前mysql版本匹配的so或者a文件，這里我們提供一個已經(jīng)編譯好的libmysqlclient.a和對應的頭文件，代碼參見:

https://github.com/aceld/Lars/tree/master/base/mysql-connector-c

? 我們把mysql-connector-c文件夾放在了Lars/base/下，作為公共包使用。

? 接下來我們要重新修改一下Makefile

Lars/lars_dns/Makefile

TARGET= bin/lars_dns
CXX=g++
CFLAGS=-g -O2 -Wall -Wno-deprecated

BASE=../base
BASE_H=$(BASE)/include
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
SRC= ./src
INC= -I./include -I$(BASE_H) -I$(LARS_REACTOR_H) -I$(MYSQL_H)

LIB= $(MYSQL_LIB) -L$(LARS_REACTOR_LIB) $(OTHER_LIB) 


OBJS = $(addsuffix .o, $(basename $(wildcard $(SRC)/*.cpp)))

$(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 $(TARGET)

? 加上mysqlclient庫的關(guān)聯(lián)。注意，libmysqlclient.a依賴libdl庫， 所以我們在 OTHER_LIB變量中加上-ldl， 然后我們嘗試使用mysql庫的接口。

dns_service.cpp

#include "lars_reactor.h"
#include "mysql.h"

int main(int argc, char **argv)
{
    event_loop loop;

    //加載配置文件
    config_file::setPath("conf/lars_dns.conf");
    std::string ip = config_file::instance()->GetString("reactor", "ip", "0.0.0.0");
    short port = config_file::instance()->GetNumber("reactor", "port", 7778);


    //創(chuàng)建tcp服務器
    tcp_server *server = new tcp_server(&loop, ip.c_str(), port);

    //注冊路由業(yè)務
    
    //測試mysql接口
    MYSQL dbconn;
    mysql_init(&dbconn);

    //開始事件監(jiān)聽    
    printf("lars dns service ....\n");
    loop.event_process();

    return 0;
}

? 編譯成功，表示我們已經(jīng)可以調(diào)用mysql的接口了。那么現(xiàn)在dns的基礎(chǔ)環(huán)境我們已經(jīng)基本搭建好了，接下來就要實現(xiàn)代碼了。

關(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)載請注明出處