#include "stdafx.h" #include "http_service.h" static bool http_get_default(HttpRequest&, HttpResponse& res) { acl::string buf("default: hello world!\r\n"); res.setContentLength(buf.size()); return res.write(buf); } static bool http_get_ok(HttpRequest&, HttpResponse& res) { acl::string buf("ok: hello world!\r\n"); res.setContentLength(buf.size()); return res.write(buf); } static bool http_post_ok(HttpRequest& req, HttpResponse& res) { acl::string buf; if (!req.getBody(buf)) { printf("getBody error!\r\n"); return false; } printf("body: %s\r\n", buf.c_str()); res.setContentLength(buf.size()); return res.write(buf); } static bool http_get_json(HttpRequest&, HttpResponse& res) { acl::json json; acl::json_node& root = json.get_root(); root.add_number("code", 200) .add_text("status", "+ok") .add_child("data", json.create_node() .add_text("name", "value") .add_bool("success", true) .add_number("number", 100)); return res.write(json); } static bool http_get_xml(HttpRequest&, HttpResponse& res) { acl::xml1 xml; acl::xml_node& root = xml.get_root(); root.add_child("test6", true, "text6") .add_child("test61", true, "text61") .add_attr("name61_1", "value61_1") .add_attr("name61_2", "value61_2") .add_attr("name61_3", "value61_3") .add_child("test611", true, "text611") .add_attr("name611_1", "value611_1") .add_attr("name611_2", "value611_2") .add_attr("name611_3", "value611_3") .get_parent() .get_parent() .add_child("test62", true, "text62") .add_attr("name62_1", "value62_1") .add_attr("name62_2", "value62_2") .add_attr("name62_3", "value62_3") .get_parent() .add_attr("name6_1", "value6_1") .add_attr("name6_2", "value6_2") .add_attr("name6_3", "value6_3"); return res.write(xml); } int main(int argc, char* argv[]) { // 初始化 acl 库 acl::acl_cpp_init(); http_service service; // 设置配置参数表 service.set_cfg_int(var_conf_int_tab) .set_cfg_int64(var_conf_int64_tab) .set_cfg_str(var_conf_str_tab) .set_cfg_bool(var_conf_bool_tab); // Register http handlers according different url path service.Get("/", http_get_default) .Get("/ok", http_get_ok) .Post("/ok", http_post_ok) .Get("/json", http_get_json) .Get("/xml", http_get_xml); // 开始运行 if (argc >= 2 && strcmp(argv[1], "alone") == 0) { // 日志输出至标准输出 acl::log::stdout_open(true); // 监听的地址列表,格式:ip|port1,ip|port2,... const char* addrs = "|8888"; printf("listen on: %s\r\n", addrs); // 测试时设置该值 > 0 则指定服务器处理客户端连接过程的 // 会话总数(一个连接从接收到关闭称之为一个会话),当 // 处理的连接会话数超过此值,测试过程结束;如果该值设 // 为 0,则测试过程永远不结束 unsigned int count = 0; // 测试过程中指定线程池最大线程个数 unsigned int max_threads = 100; // 单独运行方式 if (argc >= 3) { service.run_alone(addrs, argv[2], count, max_threads); } else { service.run_alone(addrs, NULL, count, max_threads); } printf("Enter any key to exit now\r\n"); getchar(); } else { #if defined(_WIN32) || defined(_WIN64) // 日志输出至标准输出 acl::log::stdout_open(true); // 监听的地址列表,格式:ip:port1,ip:port2,... const char* addrs = "127.0.0.1:8888"; printf("listen on: %s\r\n", addrs); // 测试时设置该值 > 0 则指定服务器处理客户端连接过程的 // 会话总数(一个连接从接收到关闭称之为一个会话),当 // 处理的连接会话数超过此值,测试过程结束;如果该值设 // 为 0,则测试过程永远不结束 unsigned int count = 0; // 测试过程中指定线程池最大线程个数 unsigned int max_threads = 100; // 单独运行方式 service.run_alone(addrs, NULL, count, max_threads); printf("Enter any key to exit now\r\n"); getchar(); #else // acl_master 控制模式运行 service.run_daemon(argc, argv); #endif } return 0; }