Kamailio如何基于Asterisk IP实现呼叫负载均衡？定制场景咨询

我刚好在生产环境里部署过一模一样的架构，给你梳理下完整的实现步骤，保证能跑通：

1. 先搞定MySQL映射表 #

首先需要在Kamailio关联的MySQL数据库里创建路由映射表，用来存储To字段和Asterisk IP的对应关系。我习惯把表命名为asterisk_to_routing，建表SQL如下：

CREATE TABLE IF NOT EXISTS asterisk_to_routing (
    id INT AUTO_INCREMENT PRIMARY KEY,
    to_user VARCHAR(64) NOT NULL COMMENT 'SIP头To字段的用户部分',
    asterisk_ip VARCHAR(45) NOT NULL COMMENT '目标Asterisk服务器的IP地址',
    priority TINYINT DEFAULT 1 COMMENT '可选：权重值，用于加权负载均衡',
    UNIQUE KEY idx_to_user (to_user)
);

你可以根据需求插入测试数据，比如：

INSERT INTO asterisk_to_routing (to_user, asterisk_ip) VALUES 
('1001', '192.168.1.10'),
('1002', '192.168.1.11'),
('1003', '192.168.1.10');

2. 配置Kamailio核心逻辑 #

接下来修改Kamailio的配置文件（通常是kamailio.cfg），重点处理呼入INVITE请求的路由逻辑：

2.1 加载必要模块 #

首先确保加载了数据库操作和SIP路由相关的模块：

loadmodule "db_mysql.so"
loadmodule "sqlops.so"
loadmodule "rr.so"
loadmodule "sl.so"
loadmodule "pv.so"

2.2 配置数据库连接 #

在配置块里添加MySQL连接信息：

modparam("db_mysql", "dbhost", "127.0.0.1")
modparam("db_mysql", "dbname", "kamailio")
modparam("db_mysql", "dbuser", "kamailio")
modparam("db_mysql", "dbpass", "your_db_password")

2.3 核心路由逻辑 #

在request_route里添加处理呼入INVITE的代码，关键是提取To字段的用户部分、查询数据库、转发到目标Asterisk：

request_route {
    # 只处理呼入的INVITE请求
    if (is_method("INVITE")) {
        # 提取To头的用户部分，存在$tU变量里
        $var(to_user) = $tU;

        # 查询数据库，获取对应的Asterisk IP
        sql_query("SELECT asterisk_ip FROM asterisk_to_routing WHERE to_user='$var(to_user)'", "$var(asterisk_ip)");

        # 如果查询到有效IP
        if ($var(asterisk_ip) != "") {
            # 设置转发目标URI
            $du = "sip:" + $rU + "@" + $var(asterisk_ip);
            # 添加记录路由，保证后续信令能正确返回
            record_route();
            # 转发呼叫
            t_relay();
            exit;
        } else {
            # 如果没查到映射，返回404错误
            sl_send_reply("404", "To User Not Found");
            exit;
        }
    }

    # 其他请求的默认处理（比如ACK、BYE等）
    ...
}

3. 关键注意事项 #

• 权限检查：确保Kamailio的数据库用户有SELECT权限访问asterisk_to_routing表
• 索引优化：给to_user字段加唯一索引，避免重复数据，同时提升查询速度
• 扩展支持：如果需要加权负载均衡，可以修改SQL查询，根据priority字段做加权随机选择（比如用ORDER BY RAND() * priority DESC LIMIT 1）
• 日志调试：开启Kamailio的调试日志，方便排查问题，比如在配置里添加debug=3

4. 测试验证 #

用SIP客户端发起呼叫，设置To字段为你在数据库里配置的值（比如sip:1001@your_kamailio_ip），然后：

1. 查看Kamailio日志，确认是否成功查询到Asterisk IP并转发
2. 查看目标Asterisk的日志，确认是否收到INVITE请求
3. 测试呼叫流程是否正常接通

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