主页 / 问题 / 589410
Accepted
SLoN
Asked:2020-11-10 19:59:19 +0000 UTC2020-11-10 19:59:19 +0000 UTC

Kannel 短信网关。节流错误

  • 772

问候！收到节流错误后需要 Kannel 特定行为：

  1. 停止发送任何消息 60 秒。

此功能是通过编辑源文件 smsc_smpp.c 实现的：
#define SMPP_THROTTLING_SLEEP_TIME 60

  1. 超时后，不发送队列中的下一条消息，而是发送收到错误的消息。

也就是说，如果您发送消息“1”、“2”、“3”、“4”、“5”，并在消息“3”上收到节流错误，那么 Kannel 将在超时后发送消息“4”，然后是“5”，然后才是“3”。

收到节流错误后，Kannel 必须发送“3”，然后是“4”，然后是“5”。这样消息“3”在队列的开头出现，而不是在结尾。

谷歌搜索发现了很多类似的问题，但没有有效的解决方案。例如：

sms

2 个回答

  1. 该问题已通过以下方式解决：

    I did the following patch to smsc/smsc_smpp.c in "case submit_sm_resp:"
section from line 1609:
change
***
if (pdu->u.submit_sm_resp.command_status == SMPP_ESME_RTHROTTLED)
    time(&(smpp->throttling_err_time));
else
    smpp->throttling_err_time = 0;

bb_smscconn_send_failed(smpp->conn, msg, reason, octstr_format("0x%08lx/%s",
pdu->u.submit_sm_resp.command_status,

 smpp_error_to_string(pdu->u.submit_sm_resp.command_status)));
***
to
***
if (pdu->u.submit_sm_resp.command_status == SMPP_ESME_RTHROTTLED) {
    time(&(smpp->throttling_err_time));
    /* Put the message back into the SMPP queue */
    gw_prioqueue_produce(smpp->msgs_to_send, msg);
} else {
    smpp->throttling_err_time = 0;
    bb_smscconn_send_failed(smpp->conn, msg, reason,
octstr_format("0x%08lx/%s", pdu->u.submit_sm_resp.command_status,
        smpp_error_to_string(pdu->u.submit_sm_resp.command_status)));
}
***

and in sms.c I have changed the function sms_priority_compare() to reverse
time sorting order (for some reason it was LIFO):
if (msg1->sms.time > msg2->sms.time)
    ret = -1;
else if (msg1->sms.time < msg2->sms.time)
    ret = 1;
-------------- next part --------------

    SMPP 节流错误处理

    但是，此更改不会影响多部分消息的各个部分的发送顺序。要解决此问题，您需要通过sms.c添加sms_priority_compare比较sms.id。将消息分成几部分时，sms_split此 ID 使用uuid_generate(part->sms.id). 最终函数sms_priority_compare如下所示：

    int sms_priority_compare(const void *a, const void *b)
{
    int ret;
    Msg *msg1 = (Msg*)a, *msg2 = (Msg*)b;
    gw_assert(msg_type(msg1) == sms);
    gw_assert(msg_type(msg2) == sms);

    if (msg1->sms.priority > msg2->sms.priority)
        ret = 1;
    else if (msg1->sms.priority < msg2->sms.priority)
        ret = -1;
    else {
        if (msg1->sms.time > msg2->sms.time)
            ret = -1;
        else if (msg1->sms.time < msg2->sms.time)
            ret = 1;
        else {
            if (msg1->sms.id > msg2->sms.id)
                ret = -1;
            else if (msg1->sms.id < msg2->sms.id)
                ret = 1;
            else
                ret = 0;           
        }
    }

    return ret;
}
    • 2
  2. Best Answer

    我在 2016 年 11 月 11 日的回答中的解决方案一直有效，直到出现 Message Queue Full 错误消息。根据 SMS 中心的请求，当收到 MQF 错误时应发送以下消息。

    总要求：

    • 节流错误 - 超时 60 秒，重新发送错误消息
    • 消息队列已满 - 没有超时，重新发送队列中的下一条消息。错误消息放在队列的末尾

    解决方案：

    1. SMPP_THROTTLING_SLEEP_TIME正如我在问题中所写，超时持续时间是使用smsc_smpp.c

    2. sms.c在函数的文件中，sms_priority_compare我们按时间更改顺序。我们还为复合消息添加按 id 排序：

      if (msg1->sms.time > msg2->sms.time)
        ret = 1;
else if (msg1->sms.time < msg2->sms.time)
        ret = -1;

      改成

      if (msg1->sms.time > msg2->sms.time)
    ret = -1;
else if (msg1->sms.time < msg2->sms.time)
    ret = 1;
else {
    if (msg1->sms.id > msg2->sms.id)
        ret = -1;
    else if (msg1->sms.id < msg2->sms.id)
        ret = 1;
    else
        ret = 0;           
}

    3. 默认情况下，Kannel 在出现任何错误时将消息放在队列的末尾。smsc/smsc_smpp.c为了单独跟踪 TE，我们更改文件中的函数smpp_status_to_smscconn_failure_reason：

      static long smpp_status_to_smscconn_failure_reason(long status)
{
    switch(status) {
        case SMPP_ESME_RMSGQFUL:
        case SMPP_ESME_RTHROTTLED:
        case SMPP_ESME_RX_T_APPN:
        case SMPP_ESME_RSYSERR:
            return SMSCCONN_FAILED_TEMPORARILY;
            break;

        default:
            return SMSCCONN_FAILED_REJECTED;
    }
}

      在

      static long smpp_status_to_smscconn_failure_reason(long status)
{
    switch(status) {
        case SMPP_ESME_RMSGQFUL:
        case SMPP_ESME_RX_T_APPN:
        case SMPP_ESME_RSYSERR:
            return SMSCCONN_FAILED_TEMPORARILY;
            break;

        case SMPP_ESME_RTHROTTLED:
            return SMPP_ESME_RTHROTTLED;
            break;

        default:
            return SMSCCONN_FAILED_REJECTED;
    }
}

    4. 收到 MQF 后，我们更改消息时间。否则，当 TE 收到已收到 MQF 并移动到队列末尾的消息时，它们将被移动到队列的前面。在块smsc/smsc_smpp.c中函数的文件中，我们更改：handle_pducase submit_sm_resp:

      if (pdu->u.submit_sm_resp.command_status == SMPP_ESME_RTHROTTLED)
        time(&(smpp->throttling_err_time));
else
        smpp->throttling_err_time = 0;    

bb_smscconn_send_failed(smpp->conn, msg, reason, octstr_format("0x%08lx/%s", pdu->u.submit_sm_resp.command_status,
                                    smpp_error_to_string(pdu->u.submit_sm_resp.command_status)));

      在

      if (pdu->u.submit_sm_resp.command_status == SMPP_ESME_RTHROTTLED)
        time(&(smpp->throttling_err_time));
else
        smpp->throttling_err_time = 0;    

if (pdu->u.submit_sm_resp.command_status == SMPP_ESME_RMSGQFUL)
        time(&(msg->sms.time));    

bb_smscconn_send_failed(smpp->conn, msg, reason, octstr_format("0x%08lx/%s", pdu->u.submit_sm_resp.command_status,
                                    smpp_error_to_string(pdu->u.submit_sm_resp.command_status)));

    5. 当我们收到 TE 错误时，我们将消息放在队列的头部。为此，在我们更改bb_smscconn.c函数的文件中：bb_smscconn_send_failed

      case SMSCCONN_FAILED_TEMPORARILY:     
       ...
       gwlist_produce(outgoing_sms, sms);
       break;

case SMSCCONN_FAILED_SHUTDOWN:
       gwlist_produce(outgoing_sms, sms);
       break;

      在

      case SMSCCONN_FAILED_TEMPORARILY:     
       ...
       gwlist_produce(outgoing_sms, sms);
       break;

case SMPP_ESME_RTHROTTLED:   
       gwlist_insert(outgoing_sms, 0, sms);
       break;

case SMSCCONN_FAILED_SHUTDOWN:
       gwlist_produce(outgoing_sms, sms);
       break;

    6. 同样，您需要更改功能handle_split：

      case SMSCCONN_FAILED_TEMPORARILY:     
       ...
       gwlist_produce(outgoing_sms, msg);
       break;

case SMSCCONN_FAILED_DISCARDED:

      在

      case SMSCCONN_FAILED_TEMPORARILY:     
       ...
       gwlist_produce(outgoing_sms, msg);
       break;

case SMPP_ESME_RTHROTTLED:   
       gwlist_insert(outgoing_sms, 0, msg);
       break;

case SMSCCONN_FAILED_DISCARDED:
    • 1

相关问题