19.1 集成lars_reactor模块

  1. 首先我们给dns模块创建一个项目文件夹,与`lars_reactor`并列,在`Lars/`下创建
  1. $mkdir Lars/lars_dns

lars_dns中,我们可以先创建基本的项目必须文件夹和文件,目录结构如下

  1. lars_dns/
  2. ├── bin/
  3. ├── conf/
  4. └── lars_dns.conf
  5. ├── include/
  6. ├── Makefile
  7. └── src/
  8. └── dns_service.cpp

conf/lars_dns.conf

  1. [reactor]
  2. maxConn = 1024
  3. threadNum = 5
  4. ip = 127.0.0.1
  5. port = 7778

src/dns_service.cpp

  1. #include "lars_reactor.h"
  2. int main(int argc, char **argv)
  3. {
  4. event_loop loop;
  5. //加载配置文件
  6. config_file::setPath("conf/lars_dns.conf");
  7. std::string ip = config_file::instance()->GetString("reactor", "ip", "0.0.0.0");
  8. short port = config_file::instance()->GetNumber("reactor", "port", 7778);
  9. //创建tcp服务器
  10. tcp_server *server = new tcp_server(&loop, ip.c_str(), port);
  11. //注册路由业务
  12. //开始事件监听
  13. printf("lars dns service ....\n");
  14. loop.event_process();
  15. return 0;
  16. }

Makefile

  1. TARGET= bin/lars_dns
  2. CXX=g++
  3. CFLAGS=-g -O2 -Wall -Wno-deprecated
  4. BASE=../base
  5. BASE_H=$(BASE)/include
  6. LARS_REACTOR=../lars_reactor
  7. LARS_REACTOR_H =$(LARS_REACTOR)/include
  8. LARS_REACTOR_LIB=$(LARS_REACTOR)/lib -llreactor
  9. OTHER_LIB = -lpthread
  10. SRC= ./src
  11. INC= -I./include -I$(BASE_H) -I$(LARS_REACTOR_H)
  12. LIB= -L$(LARS_REACTOR_LIB) $(OTHER_LIB)
  13. OBJS = $(addsuffix .o, $(basename $(wildcard $(SRC)/*.cpp)))
  14. $(TARGET): $(OBJS)
  15. mkdir -p bin
  16. $(CXX) $(CFLAGS) -o $(TARGET) $(OBJS) $(INC) $(LIB)
  17. %.o: %.cpp
  18. $(CXX) $(CFLAGS) -c -o $@ $< $(INC)
  19. .PHONY: clean
  20. clean:
  21. -rm -f src/*.o $(TARGET)

这里主要注意一下Makefile的编写,我们需要连接libreactor库还有libpthread库等,还有一些头文件的文件目录不要写错。

接下来进行make,我们会在bin/得到dns的可执行程序,并且可以成功运行.

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

19.2 集成mysql模块

  1. 我们需要使用libmysqlclient开发者第三方库,当然可以从mysql官方网站下载与你当前mysql版本匹配的so或者a文件,这里我们提供一个已经编译好的libmysqlclient.a和对应的头文件,代码参见:

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

  1. 我们把`mysql-connector-c`文件夹放在了`Lars/base/`下,作为公共包使用。
  2. 接下来我们要重新修改一下`Makefile`

Lars/lars_dns/Makefile

  1. TARGET= bin/lars_dns
  2. CXX=g++
  3. CFLAGS=-g -O2 -Wall -Wno-deprecated
  4. BASE=../base
  5. BASE_H=$(BASE)/include
  6. LARS_REACTOR=../lars_reactor
  7. LARS_REACTOR_H =$(LARS_REACTOR)/include
  8. LARS_REACTOR_LIB=$(LARS_REACTOR)/lib -llreactor
  9. MYSQL=$(BASE)/mysql-connector-c
  10. MYSQL_H=$(MYSQL)/include
  11. MYSQL_LIB=$(MYSQL)/lib/libmysqlclient.a
  12. OTHER_LIB = -lpthread -ldl
  13. SRC= ./src
  14. INC= -I./include -I$(BASE_H) -I$(LARS_REACTOR_H) -I$(MYSQL_H)
  15. LIB= $(MYSQL_LIB) -L$(LARS_REACTOR_LIB) $(OTHER_LIB)
  16. OBJS = $(addsuffix .o, $(basename $(wildcard $(SRC)/*.cpp)))
  17. $(TARGET): $(OBJS)
  18. mkdir -p bin
  19. $(CXX) $(CFLAGS) -o $(TARGET) $(OBJS) $(INC) $(LIB)
  20. %.o: %.cpp
  21. $(CXX) $(CFLAGS) -c -o $@ $< $(INC)
  22. .PHONY: clean
  23. clean:
  24. -rm -f src/*.o $(TARGET)
  1. 加上mysqlclient库的关联。注意,libmysqlclient.a依赖libdl库, 所以我们在 OTHER_LIB变量中加上`-ldl` 然后我们尝试使用mysql库的接口。

dns_service.cpp

  1. #include "lars_reactor.h"
  2. #include "mysql.h"
  3. int main(int argc, char **argv)
  4. {
  5. event_loop loop;
  6. //加载配置文件
  7. config_file::setPath("conf/lars_dns.conf");
  8. std::string ip = config_file::instance()->GetString("reactor", "ip", "0.0.0.0");
  9. short port = config_file::instance()->GetNumber("reactor", "port", 7778);
  10. //创建tcp服务器
  11. tcp_server *server = new tcp_server(&loop, ip.c_str(), port);
  12. //注册路由业务
  13. //测试mysql接口
  14. MYSQL dbconn;
  15. mysql_init(&dbconn);
  16. //开始事件监听
  17. printf("lars dns service ....\n");
  18. loop.event_process();
  19. return 0;
  20. }
  1. 编译成功,表示我们已经可以调用mysql的接口了。那么现在dns的基础环境我们已经基本搭建好了,接下来就要实现代码了。