Edge脚本

  1. # VERSION=20.05.06.1
  2. #-------------------------------------------------
  3. # variables
  4. # - CF_INNER_IP x.x.x.x
  5. # - CF_PUBLIC_IP x.x.x.x
  6. # - CF_DB mysql://root@xxx:3306/db
  7. # - CF_HOMER x.x.x.x:9060
  8. # - CF_INFLUXDB_URL http://x.x.x.x:port/write?db=dbName
  9. #------------------------------------------------
  11. log_level=3   #log输出等级
  12. log_stderror=no  #将opensips的标准错误写入日志yes no
  13. log_facility=LOG_LOCAL0  #控制记录工具 默认工具LOG_LOCAL0
  14. children=4  #定义UDP 或者SCTP接口工作子进程
  15. dns_try_ipv6=no  #对ipv6进行查找
  16. auto_aliases=no  #自动别名 默认值on
  17. server_header="Server:WSS" #公司的sip代理
  18. user_agent_header="User-Agent:WSS"  #以UAC发送请求时生成的User-Agent标头字段的主体
  20. listen=udp:192.168.60.101:18627 as 192.168.60.101:18627
  21. listen=tcp:192.168.60.101:18627 as 192.168.60.101:18627
  22. listen=hep_udp:192.168.60.101:9061
  23. #监听以上端口
  25. #设置模块默认加载地址
  26. mpath="/usr/local/lib64/opensips/modules/"
  28. #基于TCP的SIP通信传输模块，仅提供tcp读取和写入
  29. loadmodule "proto_tcp.so"
  30. #基于udp的sip通信传输模块，仅提供udp
  31. loadmodule="proto_udp.so"
  32. #对数据库进行连接
  33. loadmodule="db_mysql.so"
  34. #SIP信令模块
  35. loadmodule="signaling.so"
  36. #无状态回复
  37. loadmodule="sl.so"
  39. #事务
  40. loadmodule="tm.so"
  41. #如果没有最终的请求答复或否定的INVITE答复的ACK到达，则触发超时
  42. modparam("tm", "fr_timeout", 2) 
  44. #记录路由和路由模块
  45. loadmodule "rr.so"
  46. #允许插入两条record-route 默认值1
  47. modparam("rr", "enable_double_rr", 1)
  48. #如果打开，则请求的from-tag会附加到record-route 默认值1
  49. modparam("rr", "append_fromtag", 1)
  51. #通过uri操作模块
  52. loadmodule "uri.so"
  54. #对话框支持模块
  55. loadmodule "dialog.so"
  56. #将对话框的信息从内存中推入数据库 0-no_db ,1-实时任何对话信息更爱理科反映到数据库中，2-延时基于定时器返回数据库，3-仅对话框关闭时才刷新到db
  57. modparam("dialog", "db_mode", 0)
  58. #读取数据库
  59. modparam("dialog", "db_url", "mysql://root:wellcloud@192.168.60.132:3306/core_2_4")
  60. #设置与对话框匹配，0-仅基于DID进行匹配，1-先根据DID尝试匹配，2-基于SIP元素匹配
  61. modparam("dialog","dlg_match_mode",1)
  62. #默认对话框超时时间，毫秒
  63. modparam("dialog","default_timeout",21600)
  64. #设置名称列表默认值为空
  65. modparam("dialog","profiles_with_value","domain")
  68. #最大转接处理器模块
  69. loadmodule "maxfwd.so"
  70. #文本操作模块
  71. loadmodule "textops.so"
  73. #管理接口fifo支持
  74. loadmodule "mi_fifo.so"
  75. #创建用于监听和读取外部命令的FIFO文件名称
  76. modparam("mi_fifo", "fifo_name", "/tmp/opensips_fifo")
  78. #分发器模块
  79. loadmodule "dispatcher.so"
  80. #设置数据库
  81. modparam("dispatcher", "db_url", "mysql://root:wellcloud@192.168.60.132:3306/core_2_4")
  82. #ping的方式，默认值options
  83. modparam("dispatcher", "ds_ping_method", "OPTIONS")
  84. #定义将请求发送到故障网关的时间间隔
  85. modparam("dispatcher", "ds_ping_interval", 5)
  86. #网关设置探测模式时的探测次数 
  87. modparam("dispatcher", "ds_probing_threshhold", 2)
  88. #控制测试哪些网关以查看它们是否可访问
  89. modparam("dispatcher", "ds_probing_mode", 1)
  91. #SIP操作模块
  92. loadmodule "sipmsgops.so"
  93. #NAT遍历help模块
  94. loadmodule "nathelper.so"
  96. #AVP操作模块
  97. loadmodule "avpops.so"
  98. #设置avp数据库
  99. modparam("avpops", "db_url", "mysql://root:wellcloud@192.168.60.132:3306/core_2_4")
  100. #设置avp所在表名
  101. modparam("avpops", "avp_table", "dbaliases")    
  103. #rtp代理模块
  104. #loadmodule "rtpproxy.so"
  105. #modparam("rtpproxy","rtpproxy_sock","udp:CF_INNER_IP:7890")
  107. #rtpengine外部rtp继电器连接器
  108. loadmodule "rtpengine.so"
  109. #连接rtp代理套接字定义
  110. modparam("rtpengine", "rtpengine_sock", "udp:192.168.60.101:7890")    
  112. #SIP前端路径支持
  113. loadmodule "path.so"
  114. #评估第一个Route URI 默认值0
  115. modparam("path", "use_received", 1)      
  117. #嵌入式HTTP服务器
  118. loadmodule "httpd.so"
  119. #管理接口的http支持
  120. loadmodule "mi_http.so"
  122. #多域支持模块
  123. loadmodule "domain.so"
  124. #数据库支持
  125. modparam("domain", "db_url","mysql://root:wellcloud@192.168.60.132:3306/core_2_4")
  126. #数据库模式：0表示不缓存，1表示缓存 默认值0
  127. modparam("domain", "db_mode", 0)
  129. #动态路由
  130. loadmodule "drouting.so"
  131. #是否使用域匹配，默认值是1
  132. modparam("drouting", "use_domain", 1)
  133. #数据库支持
  134. modparam("drouting", "db_url","mysql://root:wellcloud@192.168.60.132:3306/core_2_4")
  136. #HTTP客户端实现
  137. loadmodule "rest_client.so"
  138. #允许最长时间（秒），默认20
  139. modparam("rest_client", "curl_timeout", 5)
  140. #最大连接时间（秒），默认20
  141. modparam("rest_client", "connection_timeout", 3)
  143. #emmm，没找到该模块？
  144. loadmodule "statistics.so"
  146. #HEP协议模块
  147. loadmodule "proto_hep.so"
  148. #指定HEP数据包的目的地和所使用的HEP协议的版本
  149. modparam("proto_hep", "hep_id","[hep_dst] 192.168.40.79:9060;transport=udp;version=3")
  151. #SIPTrace模块
  152. loadmodule "siptrace.so"
  153. #指定跟踪的目的地
  154. modparam("siptrace", "trace_id","[tid]uri=hep:hep_dst")
  156. #设置use_domain域是1
  157. modparam("auth_db|usrloc|uri", "use_domain", 1)
  159. route[r_invite_to_core]{
  161.     if(is_method("INVITE")){
  162.         #$cfg_line当前脚本运行行；$cs CSeq number;$rm request method;$fu From Uri,$tu To Uri
  163.         xlog("$cfg_line-$cs $rm $fu->$tu r_invite_from_out");
  164.         #该函数为当前处理的请求创建对话框。该请求必须是初始请求。B是超时再见
  165.         #如果创建失败，返回500，超时发送bye
  166.         if(!create_dialog("B")){
  167.             xlog("$cfg_line-$cs $rm $fu->$tu exec send_reply 500 Internal Server Error");
  168.             send_reply("500","Internal Server Error");
  169.             exit;
  170.         }
  172.         #如果含有sdp
  173.         if(has_body("application/sdp")){
  174.             xlog("$cfg_line-$cs $rm $fu->$tu exec rtpproxy_offer!");
  175.             #rtpproxy_offer("oc","CF_INNER_IP");
  176.             #重写sdp，使媒体能通过rtp传递。ICE=remove丢弃并且不插入任何ice值
  177.             rtpengine_offer("ICE=remove");
  178.             #记录rtp流
  179.             rtpengine_start_recording();
  180.             t_on_reply();
  181.         }
  183.         #为当前处理的消息设置一个标志
  184.         setflag(10);
  186.         #通过dispatch查找组1，运用0的计算方法
  187.         if(!ds_select_dst("1","0")){
  188.             send_reply("502","Service Unavailable");
  189.             exit;
  190.         }
  191.     }
  197. #判断invite请求是否来自core    
  198. route[r_invite_from_core]{
  200.     if(ds_is_in_list("$si","$sp","1")){
  201.         xlog(" enter in fs callout >>>");
  202.         #just select gateway by request_url
  204.         if(is_method("INVITE") && has_body("appkication/sdp")){
  205.             xlog("exec rtpproxy_offer!");
  206.             #rtpproxy_offer("ro","CF_PUBLIC_IP");
  207.             #重写sdp，使媒体能通过rtp传递。ICE=remove丢弃并且不插入任何ice值
  208.             rtpengine_offer("ICE=remove");
  209.             #记录rtp
  210.             rtpengine_start_recording();
  212.             t_on_reply("r_rw_sdp");
  213.         }
  215.         #交由opensips处理
  216.         t_relay();
  217.         exit;
  218.     }
  219. }
  222. #这部分有点问题
  223. route[r_seq_request]{
  225.     #是否有tag标签，是否不是notify 通知所有用户
  226.     if(has_totag()&&!is_method("NOtIFY")){
  228.         #失去了route，不清楚
  229.         if(loose_route()){
  231.             #没找到,有application/sdp
  232.             if(has_body("application/sdp")){
  234.                 #通过dispatch判断
  235.                 if(ds_is_in_list("$si","$sp","1")){
  236.                     #rtpproxy_offer("ro","CF_PUBLIC_IP");
  237.                     rtpengine_offer("ICE=remove");
  238.                 }else{
  239.                     #rtpproxy_offer("oc","CF_INNER_IP");
  240.                     #重写sdp，使媒体能通过rtp传递。ICE=remove丢弃并且不插入任何ice值
  241.                     rtpengine_offer("ICE_reomver");
  242.                 }
  244.                 #记录
  245.                 rtpengine_start_recording();
  247.                 if(is_method("INVITE")){
  248.                     t_on_reply("r_rw_sdp");
  249.                 }
  250.             }
  252.             #如果是bye，结束rtp代理
  253.             if(is_method("BYE")){
  254.                 #rtpproxy_unforce();
  255.                 rtpengine_delete();
  256.             }
  257.             #该功能对照其所属的对话框（内部数据）检查当前收到的请求。
  258.                 #$DLG_status==null说明没有dialog。
  259.             if($DLG_status!=NULL && !validate_dialog()){
  260.                 xlog("In-Dialog $rm from $si (callid=$ci) is not valid according to dialog\n")
  261.                 #该函数强制对话框中的SIP消息包含ruri，路由头和dst_uri，防止虚假注入的恶意请求如bye
  262.                 fix_route_dialog();
  263.             }
  265.             t_relay();
  266.             exit;
  267.         }else{
  268.             #ACK|BYE方法判段；判段当前是否与事务关联
  269.             if(is_method("ACK|BYE") && t_check_trans()){
  270.                 t_relay();
  271.                 exit;
  272.             }
  273.             #stateless无状态回复
  274.             sl_send_reply("404","Not here");
  275.         }
  277.         exit;
  278.       }
  279. }
  283. route[r_fix_nat_contact]{
  284. #19表示1+2+16，其中1、2、16分别代表了不同的NAT检测条件，重要参考地址
  285.     #https://www.yuque.com/wangdd/opensips/olt40x
  286.     #测试请求是否源于nat
  287.     if(nat_uac_test("19")){
  288.         xlog("find a NAT address,fix it...si=$si sp=$sp rm=$rm");
  289.         #重写URI Contact HF以包含请求的源地址
  290.         #Rewrites the URI Contact HF to contain request's source address
  291.         fix_nated_contact();
  292. }    
  294. route[r_check_ip]{
  296.     #对invite判断；是否来自domain表;
  297.     if(is_method("INVITE")&&!is_from_local()&&!ds_is_in_list("$si","$sp","1")){
  298.         #是否来自某个网关 gateway，-1全部检查，n忽略端口
  299.         if(!is_from_gw("-1","n")){
  300.             xlog("L_ERR","caller is not local and Not in whrite list!");
  301.             #SIP信令模块发送reply，403
  302.             send_reply("403","Forbidden IP");
  303.         }
  304.     }
  305. }  
  308. route[r_cancel]{
  309.     #对cancel方法进行判断
  310.     if(is_method("CANCEL")){
  311.         #判断当前是否与事物transaction关联
  312.         if(t_check_trans()){
  313.             #交由opensips处理
  314.             t_relay();
  315.         }
  316.         exit;
  317.     }
  318. }
  321. route[r_notify]{
  322.     #方法为notify，通知所有用户事件；根据domain表查询；通过dispatcher表查询source IP,source port,组号
  323.     if(is_method("NOTIFY")&&!is_from_local()&&!ds_is_in_list("$si","$sp","1")){
  325.         #是否来自某个网关 gateway，-1全部检查，n忽略端口
  326.         if(!is_from_gw("-1","n")){
  327.             xlog("L_ERR","caller is not local and Not in whrite list!");
  328.             #SIP信令模块发送reply，403
  329.             send_reply("403","Forbidden IP");
  330.         }
  331.     }
  332. }
  334. #对options进行判断，查询服务器的能力    
  335. route[r_options]{
  336.     if(is_method("OPTIONS")){
  337.     #stateless 无状态回复
  338.         sl_send_reply("200","ok");
  339.         exit();
  340.     }
  342. }
  345. #修改User-Agent防止被攻击    
  346. route[r_hide_fs_ua]{
  347. #User-Agent header
  348.     if($ua=~'^FreeSWITCH'){
  349.     #remove head from 
  350.         remove_hf("User-Agent");
  351.         #添加头
  352.         append_hf("User-Agent:WSS\r\n","CSeq");
  353.     }
  355. }
  358. route[r_check_maxfwd]{
  359.     #判断最大转接数
  360.     if(!mf_prcess_maxfwd_head("10")){
  361.         #483 过多转接退出opensips
  362.         sl_send_reply("483","Too Many Hops");
  363.         exit;
  364.     }
  365. }
  368. #对确定地址的数据进行写入数据库操作
  369. rout[r_homer_capture]{
  370.     if(is_method("INVITE|ACK|BYE")){
  371.         xlog("<<<<<<<<<<welcome new request>>>>>>>>>>>>>>");
  372.         #$rm request method, $fu from uri,$tu to uri,$cs Csq number
  373.         xlog("$rm $fu->$tu $cs");
  375.         #sip capture
  376.         $var(enableHomer)="192.168.40.79:9060";
  377.         #has_totag确定是否有头，是否为初始请求
  378.         if($var(enableHomer) && !has_totag()){
  379.             #https://opensips.org/docs/modules/2.4.x/siptrace.html#func_sip_trace
  380.             #在数据库中存储或重新部署当前已处理的SIP消息，事务或对话框
  381.             #指定跟踪位置 的trace_id的名称，
  382.                 #d'/'D'跟踪对话框（m'/'M'跟踪消息，'t'/'T'跟踪交易。），
  383.                 #sip-启用sip消息跟踪；xlog-启用在当前范围内（日志，事务或消息）的xlog消息跟踪；休息-启用休息消息跟踪;
  384.             sip_trace("tid","d,"sip|xlog|rest");
  385.         }
  386.     }
  387. }
  389. #回复路由
  390. onreply_route[r_rw_sdp]{
  391. #修复nat contact头 
  392.   fix_nated_contact();
  393. #如果是bye或者cancel 卸下rtp代理    
  394.   if(is_method("BYE|CANCEL")){
  395.         #rtpproxy_unforce();
  396.         rtpengine_delete();
  397.   }
  398. #如果带有sdp信息
  399.   if(has_body("application/sdp")){
  400.     xlog("onreply_route1  rtpproxy_answer----si=$si");
  401. #如果源地址在记录中
  402.     if(ds_is_in_list("$si","$sp","1")){
  403.       #rtpproxy_answer("ro","CF_PUBLIC_IP");
  404. #重写sdp头，使信息能通过rtp代理
  405.       rtpengine_answer();
  406. #这句代码不知道什么意义
  407.       replace_all("sip:192.168.60.101","sip:192.168.60.101");
  408.     }else{  
  409.       #rtpproxy_answer("oc","CF_INNER_IP");
  410. #这里ifelse好像没什么意义
  411.       rtpengine_answer();
  412.       replace_all("sip:192.168.60.101","sip:192.168.60.101");
  413.     }
  415.   }
  416. }
  419. onreply_route{
  420.   route(r_hide_fs_ua);
  421. }
  423. route{
  424.     #将rport参数添加到第一个Via标头(使sip消息能够正确返回)
  425.     force_rport();
  426.     #对确定的地址进行消息跟踪
  427.     route(r_homer_capture);
  428.     #确定转接是否超过界限，是，退出opensips主机
  429.     route(r_check_maxfwd);
  430.     #修改User-Agent防止被攻击 
  431.     route(r_hide_fs_ua);
  432.     #对options进行无状态回复
  433.     route(r_options);
  434.     #通知所有事件
  435.     route(r_notify);
  436.     #对cancel（取消任何悬而未决的请求）
  437.     route(r_cancel);
  439.     #对invite请求判断是否来自fs
  440.     route(r_check_ip);
  441.     #修复contact头，实现sip信息的nat穿透
  442.     route(r_fix_nat_contact);
  443.     #请求判断？
  444.     route(r_seq_request);
  446.     #记录返回地址
  447.     record_route();
  449.     #判断invite请求是否来自core  
  450.     route(r_invite_from_core);
  451.     #处理发送core的invite请求
  452.     route(r_invite_to_core);
  453.     #
  454.     route(r_register);
  456.     #是否进入opensips操作
  457.     if(!t_relay()){
  458.         xlog("L_ERROR","reply error!!");
  459.         #stateless无协议回复错误
  460.         sl_reply_error();
  461.     }
  462. }

core脚本问题

  1. # VERSION=core-2.4.7.21
  4. log_level=3
  5. log_stderror=yes
  6. log_facility=LOG_LOCAL0
  7. children=4
  8. auto_aliases=no
  9. server_header="Server:WSS"
  10. user_agent_header="User-Agent:WMS"
  12. listen=udp:192.168.40.20:18627
  13. listen=hep_udp:192.168.40.20:9060
  15. mpath="/usr/local/lib64/opensips/modules/"
  16. loadmodule "proto_udp.so"
  17. loadmodule "proto_tcp.so"
  18. loadmodule "signaling.so"
  19. loadmodule "regex.so"
  20. loadmodule "sl.so"
  21. loadmodule "tm.so"
  22. loadmodule "rr.so"
  23. loadmodule "uac.so"
  24. loadmodule "maxfwd.so"
  25. loadmodule "sipmsgops.so"
  26. loadmodule "mi_fifo.so"
  27. loadmodule "dispatcher.so"
  28. loadmodule "rest_client.so"
  29. loadmodule "uri.so"
  30. loadmodule "db_mysql.so"
  31. loadmodule "textops.so"
  32. loadmodule "usrloc.so"
  33. loadmodule "registrar.so"
  34. loadmodule "acc.so"
  35. loadmodule "auth.so"
  36. loadmodule "auth_db.so"
  37. loadmodule "alias_db.so"
  38. loadmodule "domain.so"
  39. loadmodule "topology_hiding.so"
  40. loadmodule "dialog.so"
  41. loadmodule "nathelper.so"
  42. loadmodule "carrierroute.so"
  43. loadmodule "avpops.so"
  44. loadmodule "dialplan.so"
  45. loadmodule "permissions.so"
  46. loadmodule "drouting.so"
  47. loadmodule "group.so"
  48. loadmodule "load_balancer.so"
  49. loadmodule "httpd.so"
  50. loadmodule "mi_http.so"
  51. loadmodule "mi_json.so"
  52. loadmodule "path.so"
  53. loadmodule "exec.so"
  54. loadmodule "statistics.so"
  55. loadmodule "cachedb_local.so"
  56. #loadmodule "cachedb_redis.so"
  57. loadmodule "proto_hep.so"
  58. loadmodule "siptrace.so"
  59. modparam("tm", "fr_timeout", 5)
  60. modparam("tm", "fr_inv_timeout", 60)
  61. modparam("tm", "restart_fr_on_each_reply", 0)
  62. modparam("tm", "onreply_avp_mode", 1)
  63. modparam("dispatcher", "db_url", "mysql://root:111111@192.168.40.191:3306/core_2_4")
  64. modparam("dispatcher", "ds_ping_method", "OPTIONS")
  65. modparam("dispatcher", "ds_ping_interval", 5)
  66. modparam("dispatcher", "ds_probing_threshhold", 2)
  67. modparam("dispatcher", "hash_pvar", "$avp(select_fs_strategy_hash)")
  68. modparam("dispatcher", "ds_probing_mode", 1)
  69. modparam("rr", "append_fromtag", 1)
  70. modparam("mi_fifo", "fifo_name", "/tmp/opensips_fifo")
  71. modparam("mi_fifo", "fifo_mode", 0666)
  72. modparam("uri", "use_uri_table", 0)
  73. modparam("uri", "db_url","mysql://root:111111@192.168.40.191:3306/core_2_4")
  74. modparam("usrloc", "nat_bflag", "NAT")
  75. modparam("usrloc", "working_mode_preset","sql-only")
  76. modparam("usrloc", "db_url","mysql://root:111111@192.168.40.191:3306/core_2_4") # CUSTOMIZE ME
  77. modparam("registrar", "tcp_persistent_flag", "TCP_PERSISTENT")
  78. modparam("registrar", "received_avp", "$avp(received_nh)")
  79. modparam("registrar", "max_contacts", 1)
  80. modparam("registrar", "min_expires", 120)
  81. modparam("registrar", "max_expires", 180)
  82. modparam("registrar", "default_expires", 150)
  83. modparam("registrar", "attr_avp", "$avp(attr)")
  84. modparam("acc", "early_media", 0)
  85. modparam("acc", "report_cancels", 1)
  86. modparam("acc", "detect_direction", 1)
  87. modparam("acc", "db_url","mysql://root:111111@192.168.40.191:3306/core_2_4") # CUSTOMIZE ME
  88. modparam("auth_db", "calculate_ha1", yes)
  89. modparam("auth_db", "password_column", "password")
  90. modparam("auth_db", "db_url","mysql://root:111111@192.168.40.191:3306/core_2_4") # CUSTOMIZE ME
  91. modparam("auth_db", "load_credentials", "")
  92. modparam("alias_db", "db_url","mysql://root:111111@192.168.40.191:3306/core_2_4") # CUSTOMIZE ME
  93. modparam("domain", "db_url","mysql://root:111111@192.168.40.191:3306/core_2_4") # CUSTOMIZE ME
  94. modparam("domain", "db_mode", 0)   # 0: witchout cache, 1: Use caching
  95. modparam("auth_db|usrloc|uri", "use_domain", 1)
  96. modparam("dialog", "dlg_match_mode", 1)
  97. modparam("dialog", "default_timeout", 7200)
  98. modparam("dialog", "db_mode", 0) # 0:no_db, 1:realtime, 2:delayed, 3:shutdown
  99. modparam("dialog", "profiles_with_value", "domain")
  100. modparam("dialog", "db_url","mysql://root:111111@192.168.40.191:3306/core_2_4") # CUSTOMIZE ME
  101. #modparam("dialog", "cachedb_url", "redis://CF_REDIS_DB/")
  102. modparam("nathelper", "natping_interval", 10)
  103. modparam("nathelper", "ping_nated_only", 1)
  104. modparam("nathelper", "received_avp", "$avp(received_nh)")
  105. modparam("carrierroute", "db_url", "mysql://root:111111@192.168.40.191:3306/core_2_4")
  106. modparam("carrierroute", "config_source", "db")
  107. modparam("carrierroute", "use_domain", 1)
  108. modparam("carrierroute", "db_failure_table", "carrierfailureroute")
  109. modparam("avpops", "db_url", "mysql://root:111111@192.168.40.191:3306/core_2_4")
  110. modparam("avpops", "avp_table", "dbaliases")
  111. modparam("dialplan", "db_url", "mysql://root:111111@192.168.40.191:3306/core_2_4")
  112. modparam("drouting", "use_domain", 1)
  113. modparam("drouting", "db_url","mysql://root:111111@192.168.40.191:3306/core_2_4")
  114. modparam("group", "use_domain", 1)
  115. modparam("group", "db_url", "mysql://root:111111@192.168.40.191:3306/core_2_4")
  116. modparam("load_balancer", "db_url", "mysql://root:111111@192.168.40.191:3306/core_2_4")
  117. modparam("load_balancer", "probing_reply_codes", "501, 403")
  118. modparam("load_balancer", "probing_interval", 30)
  119. modparam("rr", "enable_double_rr", 1)
  120. modparam("path", "use_received", 1)
  121. modparam("exec", "time_to_kill", 10)
  122. modparam("rest_client", "curl_timeout", 5)
  123. modparam("statistics", "stat_groups", "wj")
  124. modparam("proto_hep", "hep_id","[hep_dst] 192.168.60.228:9060;transport=udp;version=3")
  125. modparam("siptrace", "trace_id","[tid]uri=hep:hep_dst")
  126. modparam("cachedb_local", "cachedb_url", "local://")
  127. modparam("cachedb_local", "cache_clean_period", 120)
  129. route{
  130.     #在Via头中添加rport参数使sip消息能够正确返回
  131.     force_rport();
  132.     #跟踪记录注册的sip信息
  133.     route(r_siphub_capture);
  134.     #不支持PUBLISH|SUBSCRIBE方法进行
  135.     route(r_not_support);
  136.     #内存溢出提示
  137.     route(r_options);
  138.     #修复notify请求下$rU request username 为空的情况
  139.     route(r_fix_notify);
  140.     #修复nat问题，
  141.     route(r_nat_uac_test);
  142.     #过滤回环
  143.     route(r_max_fwd);
  144.     #匹配现有对话，如果存在对话使用t_repley并结束
  145.     route(r_fix_route_dialog);
  147.     xlog("$cfg_line-$cs $rm $fu->$tu processing \n");
  148.     #处理消息
  149.     route(r_relay_seq_request);
  151.     #为cancel方法，
  152.     if (is_method("CANCEL")) {
  153.         if (t_check_trans())
  154.             t_relay();
  155.         exit;
  156.     }
  158.     #如果过是重传请求则中断脚本
  159.     t_check_trans();
  161.     if (!is_method("REGISTER")) {
  162.         if (is_from_local()) {
  163.             #使用子路由，本地请求入口
  164.             route(r_author_request_from_edge);
  165.         } else {
  166.             # is not from fs, may be from edge
  167.             #非本地请求，调用子路由
  168.             if (!lb_is_destination("$si","$sp","1") ) {
  169.                 route(r_did);
  170.             }
  171.         }
  172.     }
  174.     #抛弃表头
  175.     loose_route();
  177.     #方法是REGISTER|MESSAGE记录返回地址
  178.     if (!is_method("REGISTER|MESSAGE")){
  179.         record_route();
  180.     }
  182.     #方法是INVITE发送消息退出
  183.     if (is_method("INVITE")) {
  184.         if ( !create_dialog("B") ) {
  185.             xlog("create dialog Error \n");
  186.             send_reply("500","Internal Server Error");
  187.             exit;
  188.         }
  189.         route(r_do_accounting);
  190.     }
  192.     #方法是PUBLIST|SUBSCRIBE
  193.     if (is_method("PUBLISH|SUBSCRIBE")){
  194.         sl_send_reply("503", "Service Unavailable");
  195.         exit;
  196.     }
  198.     # handle registerr_registerr_register
  199.     route(r_register);
  201.     if ($rU==NULL) {
  202.         xlog("rU is null \n");
  203.         sl_send_reply("484","Address Incomplete");
  204.         exit;
  205.     }
  207.     #是本地domain表
  208.     if (is_from_local()){
  209.         avp_db_query("SELECT limit_num,trunk_group FROM domain WHERE domain='$fd'","$avp(t_limit);$avp(t_trunk_group)");
  211.         if(is_avp_set("$avp(t_limit)") && $avp(t_limit)>0 ){
  212.             xlog("$fd limit $avp(t_limit) !\n");
  213.             $var(t_domain) = $fd;
  214.             route(r_do_limit, $var(t_domain), $avp(t_limit));
  215.         }
  217.         #记录返回头
  218.         if (is_method("INVITE") && has_body("application/sdp")){
  219.             record_route();
  220.         }
  222.         #回复路由
  223.         t_on_reply("r_delete_trunk_info");
  225.         #平衡配置
  226.         if (!load_balance("1","trunk")) {
  227.             xlog("load_balance failed: check fs is ok\n");
  228.             #无状发送消息
  229.             sl_send_reply("500","Service full.");
  230.             exit;
  231.         }
  233.         t_relay();
  234.     } else {
  235.         $rd = $td;
  237.         #查询本地路由
  238.         if (!lookup("location","m")) {
  240.             #判断数据库中是否存在
  241.             if (!db_does_uri_exist()) {
  242.                 # -1 outbound reg: [56789][0-9]*
  243.                 if($rU=~'^[56789][0-9]+$'){
  244.                     $avp(call_origin_rU)=$rU;
  245.                     route(r_query_route);
  247.                     if(!is_avp_set("$avp(trunk_group)")) {
  248.                         sl_send_reply("402", "no trunk group");
  249.                         exit();
  250.                     }
  251. #移除标头
  252.                     remove_hf("P-Preferred-Identity");
  253.                     remove_hf("P-Asserted-Identity");
  255.                     xlog("begin route... carrier=$avp(carrier) trunk_group=$avp(trunk_group) request_username=$rU host=$avp(host)\n");
  256.                     #通过在初始请求上调用此函数，模块将隐藏拓扑，这意味着它将剥离并还原所有Via，Record-Route和Route标头，并将联系人替换为请求所在接口的IP地址。收到。
  257.                     topology_hiding();
  258.                     #将所有"WSS"替换为Freeswitch
  259.                     replace_all("FreeSWITCH", "WMS");
  260.                     #此函数在给定的载波树中的给定域中搜索在prefix_matching中给定的用户的最长匹配项
  261.                     if(!cr_route("carrier1","$avp(trunk_group)", "$rU", "$rU", "call_id", "$avp(host)")){
  262.                         xlog("L_ERR","cr_route failed! send reply 485.\n");
  263.                         sl_send_reply("485", "route ambiguous!");
  264.                     } 
  265.                     else {
  266.                         #setflag(ACC_DO);
  267.                         #setflag(ACC_MISSED);
  268.                         # In case of failure, re-route the request
  269.                         $avp(outbound_rU) = $rU;
  270.                         route(r_find_real_rU);
  272.                         $var(new_to_same) = "sip:"+ $rU + "@" + $td;
  273.                         #替换to标头中的uri
  274.                         uac_replace_to("$rU", "$var(new_to_same)");
  276.                         #使用failure,reply的分支路由
  277.                         t_on_failure("missed_call");
  278.                         t_on_reply("r_add_trunk_info");
  279.                         route(r_set_edge_ip);
  281.                         t_relay();
  282.                     }
  283.                     exit;
  284.                 }
  285.                 else{
  286.                     xlog("L_WARN","send reply 420 Bad Extension ! $ru\n");
  287.                     send_reply("420","Bad Extension");
  288.                     exit;
  289.                 }
  290.             }
  291.             else{
  292.                 if (is_method("INVITE")) {
  293.                     route(r_ext_bind_phone);
  294.                 }
  296.                 #为当前处理的SIP请求创建SIP事务
  297.                 t_newtran();
  298.                 xlog("L_WARN","404 not found !\n");
  299.                 t_reply("404", "Not Found");
  300.                 exit;
  301.             }
  302.         }
  304.         #
  305.         if (isbflagset(10))
  306.                 setflag(10);
  308.         #如果没有tag
  309.         if(!has_totag() && is_method("INVITE")) {
  310.             #隐藏拓扑
  311.                 topology_hiding();
  312.         }
  314.         replace_all("FreeSWITCH", "WMS");
  315.         route(relay);
  316.     }
  317. }
  320. onreply_route[r_add_trunk_info]{
  322.     if($avp(trunk_group)){
  323.         append_hf("X-trunk-name: $avp(trunk_group)\r\n");
  324.         append_hf("X-calltype: callout\r\n");
  325.     }
  327.     if($avp(host)){
  328.         append_hf("X-th: $avp(host)\r\n");
  329.     }
  331.     if($avp(outbound_tU)){
  332.         append_hf("X-tu: $avp(outbound_tU)\r\n");
  333.     }
  335.     if($avp(x_r_rU)){
  336.         append_hf("X-ru: $avp(x_r_rU)\r\n");
  337.     }
  338. }
  341. route[r_fix_notify]{
  342.     #request Uri username
  343.     if (is_method("NOTIFY") && $rU==NULL) {
  344.         $rU=$tU;
  345.     }
  346. }
  348. route[r_options]{
  349.     #内存超过10M，返回503提示
  350.     if(is_method("OPTIONS")) {
  351.         if ($stat(free_size) < 10240000) {
  352.             sl_send_reply("503", "free_size_limit");
  353.         } else {
  354.             sl_send_reply("200", "ok");
  355.         }
  356.         exit();
  358.     }
  359. }
  361. route[r_nat_uac_test]{
  362.     #解决信令问题，符合1、2、16情况，参考https://www.yuque.com/wangdd/opensips/olt40x
  363.     if (nat_uac_test("19")) {
  364.         if (is_method("REGISTER")) {
  365.             fix_nated_register();
  366.             setbflag(10);
  367.         } else {
  368.             # this function will cause ext cannot drop
  369.             # fix_nated_contact();
  370.             setflag(10);
  371.         }
  372.     }
  373. }
  375. route [r_fix_route_dialog] {
  376.     #是否含有tag标签，是否是本地，是否属于以下方法
  377.     if (has_totag() && is_myself("$rd") && is_method("INFO|INVITE|ACK|BYE|UPDATE|REFER")){
  378.         #匹配现有对话
  379.         if(match_dialog()){
  380.             #会话存在且合法
  381.             if ( $DLG_status!=NULL && !validate_dialog() ){
  382.                 #强制对话框，防止虚假注入的对话请求
  383.                 fix_route_dialog();
  384.             }
  385.             #发送请求
  386.             t_relay();
  387.             exit;
  388.         }
  389.     }
  390. }
  392. #判断数据跳过多
  393. route [r_max_fwd] {
  394.     if (!mf_process_maxfwd_header("10")) {
  395.         sl_send_reply("483","Too Many Hops");
  396.         exit;
  397.     }
  398. }
  400. route [r_relay_seq_request] {
  401. #是否有tag标签，并且不是notify请求
  402.     if (has_totag() && !is_method("NOTIFY")) {
  403.     #将所有WMS替换为FreeSwitch
  404.         replace_all("FreeSWITCH", "WMS");
  405.         #判断route请求是否丢失
  406.         if (loose_route()) {
  407.             xlog("L_INFO","r_relay_seq_request: $rm $ru enter loose route");
  408.             if (is_method("INVITE")) {
  409.                 record_route();
  410.             } else {
  411.                 t_relay();
  412.                 exit;
  413.             }
  414. #检查route头是否与给定正则表达式匹配，判断nat是否开启，开启设置flag为10
  415.         if (check_route_param("nat=yes")){
  416.                 setflag(10);
  417.             }
  418. #调用relay子路由
  419.             route(relay);
  420.         } else {
  421.         #判断是否存在invite事务，且方法为ACK和BYE，发送请求
  422.             if(t_check_trans() && is_method("ACK|BYE")){
  423.                 t_relay();
  424.             } else {
  425.                 exit;
  426.             }
  427.             sl_send_reply("404","Not here");
  428.         }
  429.         exit;
  430.     }
  431. }
  433. #
  434. route[r_author_request_from_edge]{
  435.     route(r_not_register_h5);
  436.     #检查给定的IP和PORT是否属于负载均衡器列表中配置的目标
  437.     if(!lb_is_destination("$si","0","1")){
  439.         if (!proxy_authorize("", "subscriber")) {
  440.             xlog("$cfg_line-$cs $rm $fu->$tu start authorize\n");
  441.             proxy_challenge("", "0");
  442.             exit;
  443.         }
  445.         #Auth whole username
  446.         if($aU =~'^gateway'){
  448.         #删除认证头
  449.             consume_credentials();
  451.             if (!load_balance("1","trunk")) {
  452.                 xlog("L_ERR","load_balance:1,trunk is failed !!,exec sl_send_reply:500 Service full\n");
  453.                 sl_send_reply("500","Service full");
  454.                 exit;
  455.             }
  456.             record_route();
  457.             t_relay();
  458.             exit();
  459.         }else{
  460.             if (!db_check_from()) {
  461.                 sl_send_reply("403","Forbidden auth ID");
  462.                 exit;
  463.             }
  464.             consume_credentials();
  465.         }
  466.     }
  467. }
  469. route[r_did]{
  470. #对数据库进行查询赋值给三个数据
  471.   avp_db_query("SELECT username,domain,select_fs_strategy FROM dbaliases WHERE alias_username='$rU'","$avp(t_username);$avp(t_domain);$avp(select_fs_strategy)");
  472.   # is did number from edge
  473.   #检查是否设置了t_username
  474.   if(is_avp_set("$avp(t_username)")){
  475.     # this will exit
  476.     #赋值
  477.     $avp(select_fs_strategy_hash) = $rU;
  478.     $rU = $avp(t_username);
  479.     xlog("find did corrt_username $avp(t_username) $avp(t_domain) $fu $tu ru=$ru\n");
  480.     #$ru request uri设置该地址
  481.     $ru = "sip:"+$avp(t_username) + "@" + $avp(t_domain) + ";transport="+ $pr;
  482.     xlog("repair after: ru=$ru\n");
  483.     $avp(from_ru) = "sip:"+ $fU + "@" + $avp(t_domain);
  484.     $avp(to_ru) = "sip:"+ $tU + "@" + $avp(t_domain);
  485.     xlog("from_ru=$avp(from_ru) to_ru=$avp(to_ru)\n");
  486.     #替换from标头中的uri部分
  487.     uac_replace_from("$fU" , "$avp(from_ru)");
  488.     #替换to标头红的uri部分
  489.     uac_replace_to("$tU" , "$avp(to_ru)");
  491.     # ces user x-trunkgroup header to set calltype for inbound
  492.     # so do't remove it
  493.     #添加表头
  494.     append_hf("X-trunk-name: $si\r\n");
  495.     append_hf("X-calltype: callin\r\n");
  497. #记录返回地址
  498.     record_route();
  500.     if ($avp(select_fs_strategy) == "d") {
  501.       # 3 meaning fs group
  502.       # 7 hash over hash_pvar
  503.       xlog("$cfg_line <r_did> $rm $fu->$tu selec fs use dispatcher\n");
  504.       #dispatch查找组名中为3的地址
  505.       if (!ds_select_dst("3","7")) {
  506.         send_reply("502","Service Unavailable");
  507.         exit;
  508.           }
  509.       t_relay();
  510.       exit;
  511.     }
  513.     xlog("$cfg_line <r_did> $rm $fu->$tu selec fs use load_balance\n");
  514.     #平衡配置
  515.     if (!load_balance("1","trunk")) {
  516.       xlog("L_ERR","load_balance:1,trunk is failed !!,exec sl_send_reply:500 Service full\n");
  517.       sl_send_reply("500","Service full");
  518.       exit;
  519.     }
  521.     t_relay();
  522.     exit();
  523.   }
  524.   # invite from fs will continue route
  525. }
  527. route [r_register] {
  528.     if (is_method("REGISTER")){
  529. #？
  530.             route(r_register_h5);
  532. #认证auth_code
  533.             $var(auth_code) = www_authorize("", "subscriber");
  534.             if ( $var(auth_code) == -1 || $var(auth_code) == -2 ) {
  535.                 xlog("L_NOTICE","Auth error for $fU@$fd from $si cause $var(auth_code)\n");
  536.             }
  538.             if ( $var(auth_code) < 0 ) {
  539.                 www_challenge("", "0");
  540.                 exit;
  541.             }
  543.         #根据uri表检查数据库
  544.             if (!db_check_to()) {
  545.                 xlog("exec sl_send_reply:403 Forbidden auth ID\n");
  546.                 sl_send_reply("403","Forbidden auth ID");
  547.                 exit;
  548.             }
  550. #设置一个标签
  551.         if ( $pr=="TCP" ||  0 ) setflag(TCP_PERSISTENT);
  552.         $avp(attr)="sip:"+$si+":"+$sp;
  553.         #如果一个文件中存在邮箱present
  554.         if(is_present_hf("X-Enable-Kickout")){
  555.         #移除head from
  556.             remove_hf("X-Enable-Kickout");
  557.             #保存于location表中
  558.             if (!save("location","p1vf")){
  559.                 xlog("exec sl_reply_error\n");
  560.                 sl_send_reply("503","too many registered");
  561.             }
  562.         }
  563.         #如果过注册了来自某个AOR的联系人
  564.         else if (is_contact_registered("location","$fu",,"$ci")) {
  565.             xlog("[r_register] $fu is already, use force register");
  566.             if (!save("location","p1vf")){
  567.                 sl_send_reply("503","failed");
  568.             }
  569.         }
  570.         else{
  571.             if (!save("location","p1v")){
  572.                 xlog("exec sl_reply_error\n");
  573.                 sl_send_reply("503","too many registered");
  574.             }
  575.         }
  577. #$fU ffrom URI username
  578.         if($fU =~"^gateway"){
  579.             xlog("gateway>> update , $ct.fields(uri) si=$si sp=$sp fu=$fu tu=$tu ru=$ru\n");
  581.             $var(rw_uri)=$ct.fields(uri);
  582.             $var(ipstr)=$(var(rw_uri){s.select,1,@});
  583.             $avp(ctip)=$(var(ipstr){s.select,0,;});
  585.                         xlog("gateway>> SELECT id, rewrite_host FROM carrierroute WHERE uri_username='$fU' and  uri_domain='$fd'  and  rewrite_host!='$avp(ctip)'\n");
  587. #数据库查询语句
  588.             avp_db_query("SELECT id, rewrite_host FROM carrierroute WHERE uri_username='$fU' and  uri_domain='$fd'  and  rewrite_host!='$avp(ctip)'","$avp(lid);$avp(old_rh)");
  590.                         xlog("gateway>> update $avp(ctip) fU=$fU uri_domain=$fd lid=$avp(lid), $var(old_rh)\n");
  592. #avp是否设置
  593.             if(is_avp_set("$avp(lid)")){
  594.                                 xlog("gateway>> update rewrite_host : $avp(old_rh) > $avp(ctip)\n");
  595.                 avp_db_query("update carrierroute set rewrite_host='$avp(ctip)' WHERE uri_username='$fU' and  uri_domain='$fd' ");
  596.                                 update_stat("wj:update_gateway_count", "+1");
  597.             }
  598.     }
  599.         exit;
  600.     }
  601. }
  603. route[r_do_limit] {
  604. #将当前对话框插入配置文件
  605.     set_dlg_profile("domain","$param(1)");
  606.     #返回属于配置文件的对话框数
  607.     get_profile_size("domain","$param(1)","$var(domain)");
  609.     xlog("L_INFO","r_do_limit: User $param(1) has $var(domain) ongoing calls so far, limit is $param(2)\n");
  611.     # check within limit
  613.     if( $var(domain)>$param(2) ) {    
  614.         xlog("L_WARN","do_limit: user $param(1) exceeded number of calls [$var(domain)/$param(2)]\n");
  615.         sl_send_reply("487", "Request Terminated: Channel limit exceeded\n");
  616.         exit;
  617.         # terminating this call will automatically remove the call from the profile
  618.     }
  620.     # call was added to the profile without exceeding the limit, simply continue
  621. }
  623. route[r_query_route]{
  624.     xlog("L_INFO","query route fU=$fU rd=$rd\n");
  626.     $var(extNumber)="";
  627.     $var(extRE)="^8[0-9]{3,7}$";
  629.     if ($fU=~$var(extRE)) {
  630.         $var(extNumber)=$fU;
  631.     } else if ($tU=~$var(extRE)) {
  632.         $var(extNumber)=$tU;
  633.         # fix no condition transfer 302 aws vos
  634.         #uac_replace_to("$tU" , "$rU");
  635.     }
  637.     if ($var(extNumber)) {
  638.         avp_db_query("SELECT id,caller_id_dpid,callee_id_dpid,trunk_group FROM wj_v_exten_route WHERE username='$var(extNumber)' and domain='$rd'","$avp(r_id);$avp(caller_id_dpid);$avp(callee_id_dpid);$avp(trunk_group)");
  639.     }
  641.     # query ext route
  642.     xlog("db_query_ext_route_result: $var(extNumber) $avp(r_id);$avp(caller_id_dpid);$avp(callee_id_dpid);$avp(trunk_group)\n");
  644.     # query ext route by tu@t
  645.     if(!is_avp_set("$avp(r_id)")){
  646.     #对数据库进行查询
  647.         avp_db_query("SELECT id,caller_id_dpid,callee_id_dpid,trunk_group FROM wj_v_domain_route WHERE domain='$rd'","$avp(r_id);$avp(caller_id_dpid);$avp(callee_id_dpid);$avp(trunk_group)");
  648.         xlog("db_query_domain_route_result: $avp(r_id);$avp(caller_id_dpid);$avp(callee_id_dpid);$avp(trunk_group)\n");
  649.     }
  651.     xlog("db_query_route_result : $avp(r_id);$avp(caller_id_dpid);$avp(callee_id_dpid);$avp(trunk_group)\n");
  653.     if(is_avp_set("$avp(r_id)")){
  654.         $var(nto)="";
  655.         $var(nfrom)="";
  657.         # change to header
  658.         if ($hdr(bindPhone)) {
  659.         #将尝试根据拨号规则ID等于id的转换规则将src字符串转换为dest字符串
  660.             dp_translate("$avp(callee_id_dpid)","$hdr(bindPhone)/$var(nto)");
  661.         } else if ($tU=~$var(extRE)) {
  662.             dp_translate("$avp(callee_id_dpid)", "$rU/$var(nto)");
  663.         }else {
  664.             dp_translate("$avp(callee_id_dpid)","$tU/$var(nto)");
  665.         }
  667.          xlog("$cfg_line-$cs $rm $fu->$tu in request nto=$var(nto)\n");
  669.         if($var(nto)){
  670.             $var(new_to) = "sip:"+ $var(nto) + "@" + $rd;
  671.             $avp(outbound_tU) = $var(nto);
  672.              xlog("$cfg_line-$cs $rm $fu->$tu in request outbound_tU=$avp(outbound_tU)\n");
  673.             #uac_replace_to("$tU" , "$var(new_to)");
  674.         }
  676.         # change from header
  677.         if ($hdr(displayOrigin)) {
  678.             $var(nfrom)=$hdr(displayOrigin);
  679.         } else {
  680.             dp_translate("$avp(caller_id_dpid)","$fU/$var(nfrom)");
  681.         }
  683.         if($var(nfrom)){
  684.             $var(new_uri) = "sip:" +$var(nfrom)+ "@" + $fd;
  685.             #对from的uri进行替换
  686.             uac_replace_from("$var(nfrom)" , "$var(new_uri)");
  687.         }
  689.         remove_hf("Remote-Party-ID");
  690.         remove_hf("displayOrigin");
  691.         remove_hf("bindPhone");
  692.     }
  693. }
  695. route [r_set_edge_ip] {
  696. #该函数从类似于存储器高速缓存的存储系统中获取属性的值
  697.     cache_fetch("local","cache_$avp(host)", $avp(edge));
  699. #是否判断函数是否存在
  700.     if(is_avp_set("$avp(edge)")){
  701.         xlog("L_INFO","cache_fetch find host $avp(host) $avp(edge), no need sql query");
  702.     }else {
  703.         xlog("L_INFO","cache_fetch host not find, need sql query");
  704.         avp_db_query("SELECT edge_ip  FROM carrierroute WHERE rewrite_host='$avp(host)' and edge_ip is not null order by rand() limit 1","$avp(edge)");
  705.     }
  707.     if(is_avp_set("$avp(edge)")){
  708.         xlog("L_INFO","r_set_edge_ip $ci edge addr is $avp(edge)");
  710.         cache_store("local","cache_$avp(host)", "$avp(edge)");
  712.         if ($avp(edge)=~'^sip') {
  713.             $du=$avp(edge);
  714.         } else {
  715.             # use dispatcher send to edge just for trunk
  716.             xlog("L_INFO", "r_set_edge_ip $ci use dipatcher to select edge");
  717.             if (!ds_select_dst("$avp(edge)","0")) {
  718.                 send_reply("502","Service Unavailable");
  719.                 cache_remove("loacal","cache_$avp(host)");
  720.                 exit;
  721.             }
  722.         }
  723.     }
  724.     else{
  725.         avp_db_query("SELECT attr  FROM location WHERE username='$fU' and domain='$td'","$avp(edge)");
  726.         if(is_avp_set("$avp(edge)")){
  727.             $du=$avp(edge);
  728.         }else{
  729.             xlog("L_ERR","$fU@$td is Not Registed!!\n");
  730.         }
  731.     }
  732. }
  734. route[r_ext_bind_phone]{
  735.     $avp(transfer_num) = $hdr(bindPhone);
  737.     if (!$avp(transfer_num)) {
  738.         avp_db_query("SELECT bind_mobile,bind_mobile_type from subscriber WHERE username='$tU' and domain='$td'","$avp(transfer_num);$avp(bmt)");
  739.         xlog("L_INFO","r_ext_bind_phone bind_mobile=$avp(transfer_num)\n");
  740.     }
  742.     if($avp(bmt)=="disabled"){
  743.         $avp(transfer_num):="";
  744.     }
  746.     if($avp(transfer_num) != "" ){
  747.         $du="sip:"+$si+":"+$sp;
  748.         $ru="sip:"+$avp(transfer_num)+"@"+$Ri+":"+$Rp;
  749.         sl_send_reply("302","LCR Redirect");
  750.         exit;
  751.     }
  752. }
  754. route[relay] {
  755.     xlog("L_INFO","$cfg_line-$cs $rm $fu->$tu: enter route relay \n");
  757.     replace_all("FreeSWITCH", "WMS");
  759.     if(is_present_hf("Remote-Party-ID")){
  760.         remove_hf("Remote-Party-ID");
  761.         }
  763.     if (is_method("INVITE")) {
  764.         t_on_reply("handle_nat");
  765.         t_on_failure("missed_call");
  766.     }
  768.     if (isflagset(10)) {
  769.         add_rr_param(";nat=yes");
  770.     }
  772.     if ($avp(attr)) {
  773.         $du=$avp(attr);
  774.         xlog("L_INFO","$cfg_line-$cs $rm $fu->$tu: get edge address from attr\n");
  775.     } else {
  777.         xlog("L_INFO", "$cfg_line-$cs $rm $fu->$tu: get edge address from database\n");
  779.         avp_db_query("SELECT attr FROM location WHERE username='$tU' and domain='$td'","$avp(edge)");
  781.         if ($avp(edge)) {
  782.             $du=$avp(edge);
  783.         } else {
  784.             xlog("$cfg_line-$cs $rm $fu->$tu: can not get edge address\n");
  785.         }
  787.     }
  789.     if (!t_relay()) {
  790.         xlog("send reply 500 Internal Error!\n");
  791.         send_reply("500","Internal Error");
  792.     };
  793.     exit;
  794. }
  796. onreply_route[handle_nat] {
  797.     route(r_delete_sip_header_to_ext);
  799.     if($rs==302){
  800.         remove_hf("contact");
  801.         $var(movedNum)=$(ct.fields(uri){uri.user});
  802.         $var(new_contact)=$var(movedNum)+"@"+"192.168.40.20:18627";
  803.         append_hf("Contact: <sip:$var(new_contact)>\r\n", "Call-ID");
  804.         exit;
  805.     }
  806. }
  808. failure_route[missed_call] {
  809.     if (t_was_cancelled()) {
  810.         exit;
  811.     }
  812.     xlog("L_ERR","failure_route reply $(err.rcode) - $(err.rreason) -$(err.info) -$(err.class) \n");    
  813.     if (isflagset(12)) {
  814.         xlog("L_ERR","t_reply: 503 Service not available, no more gateways\n");
  815.         t_reply("503", "Service not available, no more gateways");
  816.         exit;
  817.     }
  818. }
  820. local_route {
  821.     if (is_method("BYE") && $DLG_dir=="UPSTREAM") {
  822.     #根据请求进行报告
  823.         acc_db_request("200 Dialog Timeout", "acc");
  824.     }
  825. }
  828. route [r_not_support] {
  829.     if (is_method("PUBLISH|SUBSCRIBE")){
  830.         sl_send_reply("503", "Service Unavailable");
  831.         exit;
  832.     }
  833. }
  835. #记录消息
  836. route[r_do_accounting] {
  837.     $var(enableAcc)=0;
  838.     if($var(enableAcc)){
  839.             do_accounting("db|log", "cdr|missed");
  840.     }    
  841. }
  843. route[r_find_real_rU]{
  844.     xlog("L_INFO","r_find_real_rU $avp(ru_strip)\n");
  845.     $avp(ru_strip)=$(ru{uri.param,s});
  847.     switch ($avp(ru_strip)) {
  848.         case "1":
  849.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,1,0});
  850.         break;
  851.         case "2":
  852.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,2,0});
  853.         break;
  854.         case "3":
  855.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,3,0});
  856.         break;
  857.         case "4":
  858.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,4,0});
  859.         break;
  860.         case "5":
  861.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,5,0});
  862.         break;
  863.         case "6":
  864.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,6,0});
  865.         break;
  866.         case "7":
  867.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,7,0});
  868.         break;
  869.         case "8":
  870.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,8,0});
  871.         break;
  872.         case "9":
  873.             $avp(x_r_rU)=$(avp(call_origin_rU){s.substr,9,0});
  874.         break;
  875.         default:
  876.             xlog("strip $avp(ru_strip) it not support\n");
  877.     }
  878. }
  881. timer_route[wj_cr_reload, 600]{
  882.     if (0 && $stat(wj:update_gateway_count) > 0) {
  883.         xlog("L_INFO", "update_gateway_count: $stat(wj:update_gateway_count)\n");
  884.         #执行外部命令
  885.         exec("opensipsctl fifo cr_reload_routes");
  886.         $stat(wj:update_gateway_count) = 0;
  887.     }
  888. }
  890. timer_route[r_influxdb_monitor, 5] {
  892.     $var(db_url)="";
  894.    if ($var(db_url)) {
  895.         $var(reqbody)="opensips,type=core,ip=192.168.40.20 real_used_size=" + $stat(real_used_size) 
  896.             + ",active_dialogs=" + $stat(active_dialogs)
  897.             + ",inuse_transactions=" + $stat(inuse_transactions)
  898.             + ",waiting_udp=" + $stat(waiting_udp)
  899.             + ",cps_all=" + $stat(wj:cps_all) + ",cps_trunk=" + $stat(wj:cps_trunk);
  901.         $var(rc) = rest_post("","$var(reqbody)","text/plain","$var(body)","$var(ct)","$var(rcode)");
  903.         if (!$var(rc)) {
  904.             xlog("L_ERR", "write to influx db error, please check the influxdb url\n");
  905.         }
  907.         $stat(wj:cps_all) = 0;
  908.         $stat(wj:cps_trunk) = 0;
  909.     }
  910. }
  912. route [r_delete_sip_header_to_ext] {
  913.     remove_hf("X-trunk-name");
  914.     remove_hf("X-trunk-direction");
  915.     remove_hf("X-calltype");
  916.     remove_hf("X-th");
  917.     remove_hf("X-ru");
  918.     remove_hf("X-tu");
  919.     remove_hf("Remote-Party-ID");
  920. }
  922. onreply_route[r_delete_trunk_info]{
  923.     route(r_delete_sip_header_to_ext);
  924. }
  926. #对register表头进行记录
  927. route[r_siphub_capture]{
  928.   if(!is_method("REGISTER") && !has_totag()){
  929.     sip_trace("tid", "d", "sip");
  930.   }
  931. }
  933. #使用
  934. route[r_register_h5]{
  935. #如果邮件中存在标头字段，则返回true &&名称和副名称
  936.   if (is_present_hf("Authorization") && $hdr(Authorization)=~"^webview") {
  938.     if ($hdr(Authorization) == "webview2020") {
  939.       $avp(attr)="sip:"+$si+":"+$sp;
  941. #没有保存在本地
  942.       if (!save("location","p1vf")){
  943.                 sl_send_reply("401","Auth h5 failed");
  944.             }
  946.     } else {
  947.       sl_send_reply("401","Auth h5 failed");
  948.     }
  950.     exit;
  951.   }
  952. }
  953. route[r_not_register_h5]{
  954.   if (is_present_hf("Authorization") && $hdr(Authorization) == "webview2020") {
  955.     remove_hf("Authorization");
  957.     # hand invite
  958.     if (is_method("INVITE") && has_body("application/sdp")){
  959.       xlog("L_INFO", "$cfg_line enter h5 invite $ru");
  961.       record_route();
  963.       # go to fs
  964.       if (!load_balance("1","trunk")) {
  965.           xlog("L_INFO", "load_balance failed: check fs is ok\n");
  966.           sl_send_reply("500","service full");
  967.           exit;
  968.       }
  970.       t_relay();
  971.       exit;
  972.     }
  974.     # hand message
  975.     # todo
  976.     else if (is_method("MESSAGE")) {
  977.       xlog("L_INFO", "$cfg_line enter h5 message $ru");
  978.       route(r_message);
  979.     }
  981.     exit;
  982.   }
  983. }
  984. route[r_message]{
  985.     xlog("$cfg_line $rm $fu $tu $rb \n");
  987.     $avp(message_body) = $rb;
  989.     avp_db_query("select contact,attr from location where username='$rU' AND domain='$rd'","$avp(i_contact);$avp(i_attr)");
  991.     xlog("$rm $fU $tU db query result $avp(i_contact) $avp(i_attr) \n");
  994.     if (!is_avp_set("$avp(i_contact)")) {
  995.             route(r_save_msg_to_db, "404");
  996.             xlog("$cfg_line $rm $fu $tu: status of lookup is $avp(sql_re) \n");
  997.             t_reply("404", "Not Found");
  998.             exit;
  999.     }
  1001.     t_on_reply("r_save_msg_record");
  1003.     $ru=$avp(i_contact);
  1004.     $du=$avp(i_attr);
  1006.     if (!t_relay()) {
  1007.             send_reply("500","Internal Error");
  1008.     }
  1010.     exit;
  1011. }
  1013. onreply_route[r_save_msg_record]{
  1014.         route(r_save_msg_to_db, $rs);
  1015. }
  1017. route[r_save_msg_to_db]{
  1018.         $var(sip_callid) = $(ci{s.escape.common});
  1019.         $var(fs_callid) = $(hdr(fs_callid){s.escape.common});
  1020.         $var(fu) = $(fU{s.escape.common}) + "@" + $(fd{s.escape.common});
  1021.         $var(tu) = $(tU{s.escape.common}) + "@" + $(td{s.escape.common});
  1022.         $var(msg) = $(avp(message_body){s.escape.common});
  1024.         xlog("$var(sip_callid), $var(fs_callid), $var(fu), $var(tu), $var(msg)");
  1025.         avp_db_query("insert into message_record(sip_callid,fs_callid,time,fu,tu,status,msg) values('$var(sip_callid)','$var(fs_callid)',now(),'$var(fu)','$var(tu)','$param(1)','$var(msg)')");
  1026.         xlog("message insert db message_record result: $rc");
  1027. }

1.is_from_local()判断是否来自domain表
2.t_check_trans()判断事务
3.t_on_relay和sl_send_reply,send_reply