如何使用Ballerina实现可动态维护的HTTP请求路由器？

适用性说明 #

Ballerina完全适配这类动态路由中介场景：

• 它专为集成场景设计，原生提供HTTP服务、消息转发等能力
• 支持并发安全的状态管理，能轻松实现运行时路由规则的增删
• 语法简洁，内置的网络、并发API可以大幅减少开发量

基础代码骨架 #

以下是支持运行时路由规则管理的动态路由器基础实现：

import ballerina/http;
import ballerina/sync;

// 定义路由规则结构：匹配路径（前缀匹配）、目标服务端点
type Route record {
    string pathPrefix;
    string targetEndpoint;
};

// 并发安全的路由存储，使用互斥锁保证多线程下的规则修改安全
sync:Mutex routeMutex = new();
map<Route> routes = {};

// 动态路由器HTTP服务
service /router on new http:Listener(9090) {
    // 处理所有传入的HTTP请求，根据路由规则转发
    resource function post .(http:Request req) returns http:Response|error {
        string reqPath = req.getPath();
        Route? matchedRoute = ();

        // 加锁读取路由规则，避免并发修改导致的不一致
        check routeMutex.lock();
        // 遍历路由，匹配路径前缀
        foreach route in routes.values() {
            if reqPath.startsWith(route.pathPrefix) {
                matchedRoute = route;
                break;
            }
        }
        routeMutex.unlock();

        if matchedRoute is () {
            return http:createResponse(404, body = "No matching route found");
        }

        // 转发请求到目标端点
        http:Client targetClient = check new(matchedRoute.targetEndpoint);
        http:Response res = check targetClient->forward(req);
        return res;
    }

    // 新增路由规则的管理API
    resource function post /routes(Route route) returns http:Response {
        check routeMutex.lock();
        // 用路径前缀作为唯一标识存储路由
        routes[route.pathPrefix] = route;
        routeMutex.unlock();
        return http:createResponse(201, body = "Route added successfully");
    }

    // 删除路由规则的管理API
    resource function delete /routes/[string pathPrefix]() returns http:Response {
        check routeMutex.lock();
        if routes.hasKey(pathPrefix) {
            routes.remove(pathPrefix);
            routeMutex.unlock();
            return http:createResponse(200, body = "Route deleted successfully");
        }
        routeMutex.unlock();
        return http:createResponse(404, body = "Route not found");
    }

    // 查询所有路由规则的管理API
    resource function get /routes() returns http:Response {
        check routeMutex.lock();
        json routesJson = routes.values();
        routeMutex.unlock();
        return http:createResponse(200, body = routesJson);
    }
}

代码说明 #

• 路由存储：使用map<Route>存储规则，配合sync:Mutex保证并发安全，避免运行时修改规则出现数据不一致
• 请求转发：通过http:Client的forward方法直接转发请求，保留原始请求的头、体等信息
• 管理API：提供新增、删除、查询路由的接口，方便运行时动态调整规则

内容的提问来源于stack exchange，提问作者Lakshan Weerasinghe