介绍kamailio的dialog模块

2023-11-06 09:44
文章标签 模块 介绍 dialog kamailio

本文主要是介绍介绍kamailio的dialog模块,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

# 介绍kamailio的dialog模块

`kamailio`的`dialog`模块一般有四个作用:

- 读写对话变量
- 跟`uac`模块配合,完成`uac trunk auth`功能
- 统计`early_dialogs`和`active_dialogs`等
- 利用`dialog profile`实现分类统计功能或者实现呼叫限制功能

`dialog`模块的参数可以配置如下:

```
modparam("dialog", "db_url", DBURL)
modparam("dialog", "enable_stats", 1) # 使能统计功能
modparam("dialog", "db_mode", 1)
modparam("dialog", "dlg_flag", DLG_FLAG) # 范围是0:31
modparam("dialog", "dlg_match_mode", 1)
modparam("dialog", "default_timeout", 43200 ) # 12小时,设置dialog超时时间
modparam("dialog", "track_cseq_updates", 1)
modparam("dialog", "profiles_no_value", "total; emergency")
modparam("dialog", "profiles_with_value", "user; type; account")
```

下面这段路由脚本创建对话:

```
route[INVITE] {
    if (is_method("INVITE") && !has_totag()) {
        setflag(DLG_FLAG); # 创建对话,跟dlg_flag参数的值对应起来
        # dlg_manage(); # 调用这个函数也可以创建对话
    }
    return;
}
```

目前对话变量仅支持字符串类型,下面这段代码可以证明这点:

```
$dlg_var(test_i) = 1;
if (!pv_isset("$dlg_var(test_i)")) {
    xerr("route run here, file=$cfg(file) line=$cfg(line)\n");
}

$dlg_var(test_s) = '1';
if (pv_isset("$dlg_var(test_s)")) {
    xinfo("route run here, file=$cfg(file) line=$cfg(line)\n");
}
```

我们知道`avp`变量仅在事务期间有效,如果想在整个对话期间都有效那就需要用到对话变量了

对话变量常见的使用场景可能是写自己的话单,这里给出路由脚本:

```
route[INVITE] {
    if (is_method("INVITE") && !has_totag()) {
        dlg_manage();
        $dlg_var(SetupTime) = $TS;
    }
    return;
}

event_route[dialog:start] {
    $dlg_var(AnswerTime) = $TS;
}

event_route[dialog:end] {
    $dlg_var(EndTime) = $TS;
    $dlg_var(BillSec) = (str)($dlg_var(EndTime) - $dlg_var(AnswerTime));  # 转成字符串类型
    xinfo("+++$dlg_var(BillSec)\n");

    $var(x) = $_s({"Event":"Call_End", "CallID":"$dlg(callid)", "From":"$dlg(from_uri)", "To":"$dlg(to_uri), ");
    $var(x) = $var(x) + $_s("SetupTime":$dlg_var(SetupTime), "AnswerTime":$dlg_var(AnswerTime), "EndTime":$dlg_var(EndTime), "BillSec":$dlg_var(BillSec)});

    xinfo("$var(x)\n");
    # http post
}
```

接下来讨论`uac trunk auth`,流程如下:

```
1. A -> INVITE -> kamailio                     B
2. A              kamailio ->    INVITE     -> B CSeq
3. A              kamailio <-    401(7)     <- B
4. A              kamailio -> INVITE (auth) -> B CSeq+1
5. A              kamailio <-      200      <- B
6. A  <- 200 <-   kamailio
```

把`dialog`模块的`track_cseq_updates`参数配置为1,第四步`CSeq`就会自动加一

模块配置和路由脚本示意如下:

```
#!define UAC_CONTACT_ADDRESS "192.168.1.100:5060"

modparam("uac", "reg_db_url", DBURL)
modparam("uac", "reg_timer_interval", 3)
modparam("uac", "reg_retry_interval", 28)
modparam("uac", "reg_gc_interval", 30)
modparam("uac", "reg_contact_addr", UAC_CONTACT_ADDRESS)
modparam("uac", "auth_realm_avp", "$avp(arealm)")
modparam("uac", "auth_username_avp", "$avp(auser)")
modparam("uac", "auth_password_avp", "$avp(apasswd)")
modparam("uac", "reg_keep_callid", 1)

route[GW] {
    $du = "sip:192.168.1.101:5060";
    t_on_failure("TRUNKAUTH");
    t_relay();
    exit;
}

failure_route[TRUNKAUTH] {
    if (t_is_canceled()) {
        exit;
    }

    if(t_check_status("401|407")) {
        $avp(auser) = "test"; # 实际使用时需从数据库取出用户名和密码
        $avp(apasswd) = "test"; # 同上
        if (uac_auth()) {
            t_relay();
        }
        exit;
    }
}
```

接下来我们讨论`dialog`自带的统计功能

`enable_stats`参数配置为1就可以使能了

这里有二个`shell`命令,都可以查到`dialog`模块的统计:

```shell
kamcmd stats.get_statistics all | grep dialog
```

```shell
kamcmd dlg.stats_active
```

最后我们讨论`dialog profile`方面的问题

比如,`dialog`这样配置模块参数:

```
modparam("dialog", "profiles_no_value", "total; emergency")
modparam("dialog", "profiles_with_value", "user; type; account")
```

那么我们这样写路由:

```
route[INVITE] {
    if (is_method("INVITE") && !has_totag()) {
        dlg_manage();
        set_dlg_profile("total");
    }

    route(LOCATION);
    return;
}
```

现在做一个呼叫测试,6001呼叫6002

```shell
$kamcmd dlg.profile_get_size total
1
```

结果是1

下面这个命令得到的输出更加详细:

```shell
$kamcmd dlg.profile_list total
{
    h_entry: 3702
    h_id: 5131
    ref: 2
    call-id: ef6fcea66f0f40938cc3060226340f39
    from_uri: sip:6002@192.168.100.200
    to_uri: sip:6001@192.168.100.200
    state: 4
    start_ts: 1691650230
    init_ts: 1691650229
    end_ts: 0
    duration: 35
    timeout: 1691693429
    lifetime: 43200
    dflags: 1536
    sflags: 0
    iflags: 0
    caller: {
        tag: fa86e515d20348c6b217ae3bd4efcefc
        contact: sip:6002@192.168.100.172:61224;ob
        cseq: 32127
        route_set:
        socket: udp:192.168.100.200:5060
    }
    callee: {
        tag: 8CC433477696B38087EC8FFAB0858E00
        contact: sip:6001@192.168.100.121:5060;transport=udp
        cseq: 0
        route_set:
        socket: udp:192.168.100.200:5060
    }
    profiles: {
        total
    }
    variables: {
    }
}
```

请注意,`variables`无值

下面是进一步的说明:

- set_dlg_profile("total");  # 没问题,因为profiles_no_value里面已定义total
- set_dlg_profile("emergency"); # 没问题,因为profiles_no_value里面已定义emergency
- set_dlg_profile("total", "$fu");  # 不行,因为profiles_with_value没有定义total
- set_dlg_profile("user", "$fu");  # 没问题,因为profiles_with_value已定义user

分类统计方面我们可以给一个例子:

```
modparam("dialog", "profiles_no_value", "total; local; domestic; international")

route[INVITE] {
    if (is_method("INVITE") && !has_totag()) {
        dlg_manage();
        set_dlg_profile("total"); # 总的呼叫数加一
        if ($tU =~ "^00") {
            set_dlg_profile("international"); # 国际长途呼叫数加一
        } else if ($tU =~ "^0") {
            set_dlg_profile("domestic"); # 国内长途呼叫数加一
        } else {
            set_dlg_profile("local"); # 本地呼叫数加一
        }
    }

    route(LOCATION);
    return;
}
```

至于如何实现呼叫限制功能,网上能查到的资料非常丰富,这里就不再赘述了。
 

这篇关于介绍kamailio的dialog模块的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/355860

相关文章

性能测试介绍

性能测试是一种测试方法,旨在评估系统、应用程序或组件在现实场景中的性能表现和可靠性。它通常用于衡量系统在不同负载条件下的响应时间、吞吐量、资源利用率、稳定性和可扩展性等关键指标。 为什么要进行性能测试 通过性能测试,可以确定系统是否能够满足预期的性能要求,找出性能瓶颈和潜在的问题,并进行优化和调整。 发现性能瓶颈:性能测试可以帮助发现系统的性能瓶颈,即系统在高负载或高并发情况下可能出现的问题

水位雨量在线监测系统概述及应用介绍

在当今社会,随着科技的飞速发展,各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中,水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术,其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成,形成了一个完整的闭环系统。 数据采集单元:这是系统的“眼睛”,

python: 多模块(.py)中全局变量的导入

文章目录 global关键字可变类型和不可变类型数据的内存地址单模块(单个py文件)的全局变量示例总结 多模块(多个py文件)的全局变量from x import x导入全局变量示例 import x导入全局变量示例 总结 global关键字 global 的作用范围是模块(.py)级别: 当你在一个模块(文件)中使用 global 声明变量时,这个变量只在该模块的全局命名空

Hadoop数据压缩使用介绍

一、压缩原则 (1)运算密集型的Job,少用压缩 (2)IO密集型的Job,多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1)为了支持多种压缩/解压缩算法,Hadoop引入了编码/解码器 2)要在Hadoop中启用压缩,可以配置如下参数

深入探索协同过滤:从原理到推荐模块案例

文章目录 前言一、协同过滤1. 基于用户的协同过滤(UserCF)2. 基于物品的协同过滤(ItemCF)3. 相似度计算方法 二、相似度计算方法1. 欧氏距离2. 皮尔逊相关系数3. 杰卡德相似系数4. 余弦相似度 三、推荐模块案例1.基于文章的协同过滤推荐功能2.基于用户的协同过滤推荐功能 前言     在信息过载的时代,推荐系统成为连接用户与内容的桥梁。本文聚焦于

图神经网络模型介绍(1)

我们将图神经网络分为基于谱域的模型和基于空域的模型,并按照发展顺序详解每个类别中的重要模型。 1.1基于谱域的图神经网络         谱域上的图卷积在图学习迈向深度学习的发展历程中起到了关键的作用。本节主要介绍三个具有代表性的谱域图神经网络:谱图卷积网络、切比雪夫网络和图卷积网络。 (1)谱图卷积网络 卷积定理:函数卷积的傅里叶变换是函数傅里叶变换的乘积,即F{f*g}

C++——stack、queue的实现及deque的介绍

目录 1.stack与queue的实现 1.1stack的实现  1.2 queue的实现 2.重温vector、list、stack、queue的介绍 2.1 STL标准库中stack和queue的底层结构  3.deque的简单介绍 3.1为什么选择deque作为stack和queue的底层默认容器  3.2 STL中对stack与queue的模拟实现 ①stack模拟实现

Mysql BLOB类型介绍

BLOB类型的字段用于存储二进制数据 在MySQL中,BLOB类型,包括:TinyBlob、Blob、MediumBlob、LongBlob,这几个类型之间的唯一区别是在存储的大小不同。 TinyBlob 最大 255 Blob 最大 65K MediumBlob 最大 16M LongBlob 最大 4G

FreeRTOS-基本介绍和移植STM32

FreeRTOS-基本介绍和STM32移植 一、裸机开发和操作系统开发介绍二、任务调度和任务状态介绍2.1 任务调度2.1.1 抢占式调度2.1.2 时间片调度 2.2 任务状态 三、FreeRTOS源码和移植STM323.1 FreeRTOS源码3.2 FreeRTOS移植STM323.2.1 代码移植3.2.2 时钟中断配置 一、裸机开发和操作系统开发介绍 裸机:前后台系

Jenkins构建Maven聚合工程,指定构建子模块

一、设置单独编译构建子模块 配置: 1、Root POM指向父pom.xml 2、Goals and options指定构建模块的参数: mvn -pl project1/project1-son -am clean package 单独构建project1-son项目以及它所依赖的其它项目。 说明: mvn clean package -pl 父级模块名/子模块名 -am参数