Drogon：现代C++高性能Web应用框架

icy 昨天 10 抢沙发

默认

摘要： Drogon：现代C++高性能Web应用框架概述 Drogon是一个基于C++17/20的现代化、高性能Web应用框架，采用异步非阻塞设计理念，专为构建高性能的HTTP应用和AP...

Drogon：现代C++高性能Web应用框架

概述

Drogon是一个基于C++17/20的现代化、高性能Web应用框架，采用异步非阻塞设计理念，专为构建高性能的HTTP应用和API服务而设计。该项目由中国的开发者团队创建并维护，已经成为C++ Web开发领域的重要选择之一。

核心特性

1. 异步非阻塞架构

Drogon采用事件驱动、异步非阻塞的IO模型，能够高效处理大量并发连接，特别适合需要高吞吐量的应用场景。

2. 内置ORM支持

框架提供了强大的对象关系映射（ORM）功能，支持多种数据库（MySQL、PostgreSQL、SQLite等），简化了数据库操作。

3. 模板引擎

内置基于C++的模板引擎，支持模板继承、局部模板等高级特性，同时保持高性能。

4. 插件系统

灵活的插件架构允许开发者轻松扩展框架功能，满足特定业务需求。

5. 跨平台支持

支持Linux、macOS、Windows等多种操作系统，具有良好的可移植性。

安装与配置

安装依赖

text

# Ubuntu/Debian
sudo apt-get install git gcc g++ cmake libjsoncpp-dev \
    libssl-dev uuid-dev zlib1g-dev libc-ares-dev

# CentOS/RHEL
sudo yum install git gcc gcc-c++ cmake3 jsoncpp-devel \
    openssl-devel libuuid-devel zlib-devel c-ares-devel

编译安装

text

git clone https://github.com/drogonframework/drogon.git
cd drogon
git submodule update --init
mkdir build
cd build
cmake ..
make && sudo make install

基础示例

1. 简单的HTTP服务器

text

#include <drogon/drogon.h>

int main() {
    // 设置日志级别
    drogon::app().setLogLevel(trantor::Logger::kInfo);
    
    // 添加路由
    drogon::app().registerHandler("/",
        [](const drogon::HttpRequestPtr &req,
           std::function<void(const drogon::HttpResponsePtr &)> &&callback) {
            auto resp = drogon::HttpResponse::newHttpResponse();
            resp->setBody("Hello, Drogon!");
            callback(resp);
        });
    
    // 启动服务器
    drogon::app()
        .setThreadNum(16)  // 设置线程数
        .addListener("0.0.0.0", 8080)
        .run();
    
    return 0;
}

2. RESTful API示例

text

#include <drogon/drogon.h>
#include <json/json.h>

using namespace drogon;

class UserController : public drogon::HttpSimpleController<UserController> {
public:
    void asyncHandleHttpRequest(
        const HttpRequestPtr &req,
        std::function<void(const HttpResponsePtr &)> &&callback) override {
        
        Json::Value json;
        
        if (req->method() == HttpMethod::Get) {
            // GET /users
            json["users"] = Json::arrayValue;
            json["users"].append("Alice");
            json["users"].append("Bob");
            json["status"] = "success";
        } 
        else if (req->method() == HttpMethod::Post) {
            // POST /users
            auto body = req->getJsonObject();
            if (body) {
                json["message"] = "User created";
                json["data"] = *body;
                json["status"] = "success";
            }
        }
        
        auto resp = HttpResponse::newHttpJsonResponse(json);
        callback(resp);
    }
    
    PATH_LIST_BEGIN
    PATH_ADD("/users", Get | Post);
    PATH_LIST_END
};

3. 数据库操作示例

text

#include <drogon/drogon.h>
#include <drogon/orm/DbClient.h>

using namespace drogon;
using namespace drogon::orm;

class UserModel {
public:
    static void getUsers(
        const HttpRequestPtr &req,
        std::function<void(const HttpResponsePtr &)> &&callback) {
        
        auto db = app().getDbClient();
        
        db->execSqlAsync(
            "SELECT * FROM users WHERE age > $1",
            [callback](const Result &result) {
                Json::Value json;
                json["users"] = Json::arrayValue;
                
                for (const auto &row : result) {
                    Json::Value user;
                    user["id"] = row["id"].as<int>();
                    user["name"] = row["name"].as<std::string>();
                    user["age"] = row["age"].as<int>();
                    json["users"].append(user);
                }
                
                auto resp = HttpResponse::newHttpJsonResponse(json);
                callback(resp);
            },
            [callback](const DrogonDbException &e) {
                LOG_ERROR << e.what();
                auto resp = HttpResponse::newHttpResponse();
                resp->setStatusCode(k500InternalServerError);
                callback(resp);
            },
            18  // $1 参数
        );
    }
};

4. WebSocket示例

text

#include <drogon/drogon.h>
#include <drogon/WebSocketController.h>

class WebSocketChat : public drogon::WebSocketController<WebSocketChat> {
public:
    void handleNewMessage(const WebSocketConnectionPtr &wsConnPtr,
                         std::string &&message,
                         const WebSocketMessageType &type) override {
        // 广播消息给所有连接
        for (auto &conn : connections_) {
            if (conn != wsConnPtr) {
                conn->send(message);
            }
        }
    }
    
    void handleNewConnection(const HttpRequestPtr &req,
                            const WebSocketConnectionPtr &wsConnPtr) override {
        connections_.insert(wsConnPtr);
    }
    
    void handleConnectionClosed(const WebSocketConnectionPtr &wsConnPtr) override {
        connections_.erase(wsConnPtr);
    }
    
    PATH_LIST_BEGIN
    PATH_ADD("/chat", Get);
    PATH_LIST_END
    
private:
    std::set<WebSocketConnectionPtr> connections_;
};

配置文件示例

config.json

text

{
    "app": {
        "name": "MyDrogonApp",
        "log_level": "INFO",
        "log_path": "./logs",
        "log_size_limit": 100000000
    },
    "listeners": [
        {
            "address": "0.0.0.0",
            "port": 8080,
            "https": false
        }
    ],
    "db_clients": [
        {
            "name": "default",
            "rdbms": "postgresql",
            "host": "127.0.0.1",
            "port": 5432,
            "dbname": "mydb",
            "user": "myuser",
            "passwd": "mypassword",
            "connection_number": 10,
            "timeout": 5
        }
    ],
    "session": {
        "timeout": 3600,
        "secret": "my-secret-key"
    }
}