19.1 集成lars_reactor模块
首先我们给dns模块创建一个项目文件夹,与`lars_reactor`并列,在`Lars/`下创建
$mkdir Lars/lars_dns
在lars_dns中,我们可以先创建基本的项目必须文件夹和文件,目录结构如下
lars_dns/├── bin/├── conf/│ └── lars_dns.conf├── include/├── Makefile└── src/└── dns_service.cpp
conf/lars_dns.conf
[reactor]maxConn = 1024threadNum = 5ip = 127.0.0.1port = 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);//创建tcp服务器tcp_server *server = new tcp_server(&loop, ip.c_str(), port);//注册路由业务//开始事件监听printf("lars dns service ....\n");loop.event_process();return 0;}
Makefile
TARGET= bin/lars_dnsCXX=g++CFLAGS=-g -O2 -Wall -Wno-deprecatedBASE=../baseBASE_H=$(BASE)/includeLARS_REACTOR=../lars_reactorLARS_REACTOR_H =$(LARS_REACTOR)/includeLARS_REACTOR_LIB=$(LARS_REACTOR)/lib -llreactorOTHER_LIB = -lpthreadSRC= ./srcINC= -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: cleanclean:-rm -f src/*.o $(TARGET)
这里主要注意一下Makefile的编写,我们需要连接libreactor库还有libpthread库等,还有一些头文件的文件目录不要写错。
接下来进行make,我们会在bin/得到dns的可执行程序,并且可以成功运行.
$ ./bin/lars_dnsmsg_router init...create 0 threadcreate 1 threadcreate 2 threadcreate 3 threadcreate 4 threadlars dns service ....
19.2 集成mysql模块
我们需要使用libmysqlclient开发者第三方库,当然可以从mysql官方网站下载与你当前mysql版本匹配的so或者a文件,这里我们提供一个已经编译好的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_dnsCXX=g++CFLAGS=-g -O2 -Wall -Wno-deprecatedBASE=../baseBASE_H=$(BASE)/includeLARS_REACTOR=../lars_reactorLARS_REACTOR_H =$(LARS_REACTOR)/includeLARS_REACTOR_LIB=$(LARS_REACTOR)/lib -llreactorMYSQL=$(BASE)/mysql-connector-cMYSQL_H=$(MYSQL)/includeMYSQL_LIB=$(MYSQL)/lib/libmysqlclient.aOTHER_LIB = -lpthread -ldlSRC= ./srcINC= -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: cleanclean:-rm -f src/*.o $(TARGET)
加上mysqlclient库的关联。注意,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);//创建tcp服务器tcp_server *server = new tcp_server(&loop, ip.c_str(), port);//注册路由业务//测试mysql接口MYSQL dbconn;mysql_init(&dbconn);//开始事件监听printf("lars dns service ....\n");loop.event_process();return 0;}
编译成功,表示我们已经可以调用mysql的接口了。那么现在dns的基础环境我们已经基本搭建好了,接下来就要实现代码了。
