超时消息处理 C语言

前段时间有个需求是向S端发送消息，如果在20S之内没有收到S端的回执，就要对发送的消息进行超时处理。在一个线程中去处理超时消息，创建一个单链表，在发送消息的同时，将该消息体加到链表中，在线程中一直对这个链表进行遍历，查看时间是否大于等于20，如果大于等于20，就告诉用户消息超时，接着从链表中删除该消息，或者这个数据的标志位为1，也从链表中删除该消息。如果过了20S收到消息回执，则将该消息的的标志位置为1。

  pthread_attr_t timeOutAttr;
  pthread_t timeOut_mythread;

初始化链表，并开启线程

// 初始化链表
    linklistInit(&head);

// 开启超时定时器 超时提醒用户重传
    pthread_attr_init(&timeOutAttr);
    pthread_attr_setdetachstate(&timeOutAttr, PTHREAD_CREATE_DETACHED);
    if ((pthread_create(&timeOut_mythread, &timeOutAttr, thread_timeOut_function(), NULL)) < 0) {
        printf("create thread_timeOut error \n");
    }

超时处理

void *thread_timeOut_function() {
    while (1) {
        //遍历链表，查看时间是否大于等于20
        LinkNode *currentNode = head;
        int time = 0;
        while (currentNode != NULL) {
            linkData linkMessageData;
            memset(&linkMessageData, 0, sizeof(linkData));

            time = currentNode->linkMessageData.time;
            if (time >= 20) {
                // 返回给用户，数据超时，需要用户重新去发送数据
                // 从链表中删除该数据
                linklistErase(&head, currentNode)；

            } else if (currentNode->linkMessageData.flag == 1) {
                // 从链表中删除该数据
                linklistErase(&head, currentNode);
            } else {
                sleep(1);
                currentNode->linkMessageData.time = time + 1;
            }

            currentNode = currentNode->next;

        }

    }
}

回执消息处理

 //判断是否是超时的消息
    LinkNode *currentNode = head;
    while (currentNode != NULL) {
        if (strcmp(currentNode->linkMessageData.messageMid, receiveMessageRsp->mid) == 0) {
            // 修改标志位为1，表示这条消息已经收到回执
            changeLinklist_flag(&head, currentNode, 1);
            break;
        }

        currentNode = currentNode->next;
    }

链表处理 linklist.h

 typedef struct linkData {
    BYTE *messageMid;
    int time;
    int flag;
}linkData;

typedef struct LinkNode {
    linkData linkMessageData;   // 数据域
    struct LinkNode *next;       // 指针域
}LinkNode;

// 初始化
void linklistInit(LinkNode **head);

// 节点销毁
void DestroyNode(LinkNode *node);

// 打印链表
void linklistPrint(LinkNode *head);

// 逆序打印链表
void linklistReversePrint(LinkNode *head);

// 在链表末尾插入
LinkNode *linklistPushBack(LinkNode **head, linkData linkMessageData);

// 在链表末尾删除
void linklistPopBack(LinkNode **head);

// 在链表头部插入
void linklistPushFront(LinkNode **head, linkData linkMessageData);

// 在链表头部删除
void linklistPopFront(LinkNode **head);

// 修改链表中的指定元素值
void changeLinklist_flag(LinkNode **head, LinkNode *pos, int flag);

// 删除指定元素(遍历)
void linklistErase(LinkNode **head, LinkNode *pos);

// 删除指定元素(不遍历)
void linklistErase2(LinkNode **head, LinkNode *pos);

// 判断链表是否为空,空则返回0否则返回1
int linklistEmpty(LinkNode *head);

// 链表元素的个数
size_t linklistSize(LinkNode *head);

链表处理 linklist.c

// 初始化函数
void linklistInit(LinkNode **head) {
    *head = NULL;
}

// 创建新节点函数
LinkNode *CreateNode(linkData linkMessageData) {
    // 为新节点申请空间
    LinkNode *new_node = (LinkNode *)malloc(sizeof(LinkNode));

    // 给新节点赋值
    new_node->linkMessageData = linkMessageData;

    // 将新节点的next指向null
    new_node->next = NULL;

    return new_node;
}

// 销毁一个节点
void DestroyNode(LinkNode *node) {
    free(node->linkMessageData.messageMid);
    free(node);
}

// 顺序打印链表
void linklistPrint(LinkNode *head) {
    if (head == NULL) {
        // 空链表无需打印
        return;
    }
    LinkNode *currentNode = head;
    while (currentNode != NULL) {
        printf("%d | %p\n",currentNode->linkMessageData.time,currentNode);
        // 让currentNode等于currentNode->next
        currentNode = currentNode->next;
    }
}

// 逆序打印链表
void linklistReversePrint(LinkNode *head) {
    if (head == NULL) {
        return;
    }
    linklistReversePrint(head->next);
    printf("%s | %p\n",head->linkMessageData.messageMid,head);
}

// 尾插函数
LinkNode *linklistPushBack(LinkNode **head, linkData linkMessageData) {
    // 非法输入
    if (head == NULL) {
        return NULL;
    }
    // 空链表
    if (*head == NULL) {
        *head = CreateNode(linkMessageData);
        return NULL;
    } else {
        LinkNode *currentNode = *head;
        // 遍历元素，让currentNode指向最后一个元素
        while (currentNode->next != NULL) {
            currentNode = currentNode->next;
        }

        LinkNode *new_code = CreateNode(linkMessageData);
        currentNode->next = new_code;
        return new_code;
    }

}

// 尾删函数
void linklistPopBack(LinkNode **head) {
    // 非法输入
    if (head == NULL) {
        return;
    }

    // 空链表没有可删除的元素
    if (*head == NULL) {
        return;
    }

    // 只有一个元素
    if ((*head)->next == NULL) {
        DestroyNode(*head);
        // 将头结点置空
        *head = NULL;
        return;
    } else {
        LinkNode *currentNode = *head;
        // 遍历链表，使currentNode指向倒数第二个元素
        while (currentNode->next->next != NULL) {
            currentNode = currentNode->next;
        }

        // 创建指针指向最后一个元素，也就是需要删除的元素
        LinkNode *to_delete_node = currentNode->next;
        DestroyNode(to_delete_node);
        // 将倒数第二个元素的next指向空
        currentNode->next = NULL;
    }
    return;
}

// 头插函数
void linklistPushFront(LinkNode **head, linkData linkMessageData) {
    // 非法输入
    if (head == NULL) {
        return;
    }

    // 空链表
    if (*head == NULL) {
        *head = CreateNode(linkMessageData);
        return;
    } else {
        // 创建一个新的指针指向头结点
        LinkNode *new_node = *head;
        // 创建一个新的头结点
        *head = CreateNode(linkMessageData);
        // 将新的头结点的next指向旧的头结点
        (*head)->next = new_node;
    }
    return;
}

// 头删函数
void linklistPopFront(LinkNode **head) {
    // 非法输入
    if (head == NULL) {
        return;
    }

    // 空链表
    if (*head == NULL) {
        return;
    } else {
        // 创建一个新的指针指向头结点
        LinkNode *new_node = (*head)->next;
        // 将头结点的next指向NULL
        (*head)->next = NULL;
        // 删除该头结点
        DestroyNode(*head);
        // 将第二个元素设置为新的头结点
        *head = new_node;
    }
    return;
}

// 修改链表中的指定元素值
void changeLinklist_flag(LinkNode **head, LinkNode *pos, int flag) {
    // 非法输入
    if (head == NULL) {
        return;
    }

    // 空链表
    if (*head == NULL) {
        return;
    }

    // 如果pos位置为空
    if (pos == NULL) {
        return;
    }

    LinkNode *currentNode = *head;
    if (pos != *head) {
        while (currentNode->next != pos) {
            currentNode = currentNode->next;
        }
    }

    pos->linkMessageData.flag = flag;
//    free(currentNode);

}

// 删除指定元素(遍历)
void linklistErase(LinkNode **head, LinkNode *pos) {
    // 非法输入
    if (head == NULL) {
        return;
    }

    // 空链表
    if (*head == NULL) {
        return;
    }

    // 如果pos位置为空
    if (pos == NULL) {
        return;
    }

    // 如果pos为头结点的位置
    if (pos == *head) {
        linklistPopFront(head);
        return;
    } else {
        // 创建新的指针指向头结点
        LinkNode *currentNode = *head;
        while (currentNode->next != pos) {
            currentNode = currentNode->next;
        }

        currentNode->next = pos->next;
        DestroyNode(pos);
    }
}

// 删除指定元素(不遍历)
void linklistErase2(LinkNode **head, LinkNode *pos) {
    if (head == NULL) {
        return;
    }

    // 空链表
    if (*head == NULL) {
        return;
    }

    // 如果pos位置为空
    if (pos == NULL) {
        return;
    }

    // 如果pos为头结点的位置
    if (pos == *head) {
        linklistPopFront(head);
        return;
    } else {
        LinkNode *to_delete_Node = pos->next;
        pos->linkMessageData = to_delete_Node->linkMessageData;
        pos->next = to_delete_Node->next;
        DestroyNode(to_delete_Node);

    }
}

// 判断链表是否为空链表
int linklistEmpty(LinkNode *head) {
    return head == NULL ? 0 : 1;
}

// 链表元素的个数，返回元素个数
size_t linklistSize(LinkNode *head) {
    // 空链表返回0
    if (head == NULL) {
        return 0;
    }

    size_t count = 0;
    LinkNode *currentNode = head;

    // 遍历链表
    for (;currentNode != NULL;currentNode = currentNode->next) {
        count++;
    }
    return count;
}

最后编辑于：2019.07.09 19:51:04

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 213,014评论 6赞 492
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 90,796评论 3赞 386
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 158,484评论 0赞 348
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 56,830评论 1赞 285
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 65,946评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,114评论 1赞 292
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,182评论 3赞 412
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 37,927评论 0赞 268
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,369评论 1赞 303
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,678评论 2赞 327
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 38,832评论 1赞 341
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,533评论 4赞 335
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,166评论 3赞 317
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 30,885评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,128评论 1赞 267
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 46,659评论 2赞 362
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 43,738评论 2赞 351

超时消息处理 C语言

推荐阅读更多精彩内容