OMNeT++ scheduleAt 自消息介绍与应用

admin管理员组

文章数量:1130349

什么是自消息？

在OMNeT++中，自消息是指一个模块向自身发送的消息。这种消息通常用于实现模块内部的事件调度和处理。通过发送自消息，模块可以在未来的某个时间点触发特定的操作或事件。在OMNeT++中，模块可以使用scheduleAt()函数来安排未来的自消息，并且可以使用cancelEvent()函数取消已安排的自消息。这种机制使得模块能够更灵活地管理自身的行为和事件处理。

int cSimpleModule::scheduleAt(simtime_t t, cMessage * msg);
cMessage* cSimpleModule::cancelEvent(cMessage * msg);

详细描述可自行参考👉官方文档。

如何实现自消息？

举个例子，在车联网仿真中，路侧单元（Roadside Unit, RSU）可能需要定期广播消息给附近的车辆，我们可以使用自消息来实现这一功能。我们在Veins给定的Demo中进行修改实现，如下：

首先我们需要在TraCIDemoRSU11p.h中定义相关参数

// TraCIDemoRSU11p.h
private:
    double selfMsgInterval; // 定义RSU发送检测消息时间间隔
    TraCIDemo11pMessage* selfMsg; // 用于发送自消息
    TraCIDemo11pMessage* newWSM;    // 用于发送R2V消息

然后在TraCIDemoRSU11p中RSU模块初始化的时候安排一个自消息，当RSU收到这个自消息时重新重复自消息，最后在仿真结束后取消自消息。具体实现如下：

void TraCIDemoRSU11p::initialize(int stage)
{
    DemoBaseApplLayer::initialize(stage);

    if (stage == 1) {
        selfMsgInterval = 1;  // 设定轮询间隔为1秒

        selfMsg = new TraCIDemo11pMessage();
        populateWSM(selfMsg);
        scheduleAt(simTime() + selfMsgInterval + uniform(0.01, 0.1), selfMsg);  // 首次调度
    }
}

void TraCIDemoRSU11p::handleSelfMsg(cMessage* msg)
{
    if (msg == selfMsg) {
        // 重新调度 selfMsg，保持每秒发送一次
        scheduleAt(simTime() + selfMsg + uniform(0.01, 0.1), selfMsg);

        // 向车辆发送R2V消息
        newWSM = new TraCIDemo11pMessage();
        populateWSM(newWSM);
        newWSM->setMsgType("R2V");
        sendDown(newWSM->dup(), uniform(0.01, 0.1));
        delete newWSM;
        newWSM = nullptr;
    }
}

void TraCIDemoRSU11p::finish()
{
    DemoBaseApplLayer::finish();
    cancelEvent(selfMsg); // 取消自消息
    delete selfMsg;
    selfMsg = nullptr;
}

参考资料

• https://doc.omnetpp/omnetpp4/api/classcSimpleModule.html
• https://github/sommer/veins
• chatGPT

Veins平台教程推荐

根据之前学习的内容，在GitHub整理了一个简易教程供大家参考。【Veins_SUMO_OMNeTpp】

什么是自消息？

在OMNeT++中，自消息是指一个模块向自身发送的消息。这种消息通常用于实现模块内部的事件调度和处理。通过发送自消息，模块可以在未来的某个时间点触发特定的操作或事件。在OMNeT++中，模块可以使用scheduleAt()函数来安排未来的自消息，并且可以使用cancelEvent()函数取消已安排的自消息。这种机制使得模块能够更灵活地管理自身的行为和事件处理。

int cSimpleModule::scheduleAt(simtime_t t, cMessage * msg);
cMessage* cSimpleModule::cancelEvent(cMessage * msg);

详细描述可自行参考👉官方文档。

如何实现自消息？

举个例子，在车联网仿真中，路侧单元（Roadside Unit, RSU）可能需要定期广播消息给附近的车辆，我们可以使用自消息来实现这一功能。我们在Veins给定的Demo中进行修改实现，如下：

首先我们需要在TraCIDemoRSU11p.h中定义相关参数

// TraCIDemoRSU11p.h
private:
    double selfMsgInterval; // 定义RSU发送检测消息时间间隔
    TraCIDemo11pMessage* selfMsg; // 用于发送自消息
    TraCIDemo11pMessage* newWSM;    // 用于发送R2V消息

然后在TraCIDemoRSU11p中RSU模块初始化的时候安排一个自消息，当RSU收到这个自消息时重新重复自消息，最后在仿真结束后取消自消息。具体实现如下：

void TraCIDemoRSU11p::initialize(int stage)
{
    DemoBaseApplLayer::initialize(stage);

    if (stage == 1) {
        selfMsgInterval = 1;  // 设定轮询间隔为1秒

        selfMsg = new TraCIDemo11pMessage();
        populateWSM(selfMsg);
        scheduleAt(simTime() + selfMsgInterval + uniform(0.01, 0.1), selfMsg);  // 首次调度
    }
}

void TraCIDemoRSU11p::handleSelfMsg(cMessage* msg)
{
    if (msg == selfMsg) {
        // 重新调度 selfMsg，保持每秒发送一次
        scheduleAt(simTime() + selfMsg + uniform(0.01, 0.1), selfMsg);

        // 向车辆发送R2V消息
        newWSM = new TraCIDemo11pMessage();
        populateWSM(newWSM);
        newWSM->setMsgType("R2V");
        sendDown(newWSM->dup(), uniform(0.01, 0.1));
        delete newWSM;
        newWSM = nullptr;
    }
}

void TraCIDemoRSU11p::finish()
{
    DemoBaseApplLayer::finish();
    cancelEvent(selfMsg); // 取消自消息
    delete selfMsg;
    selfMsg = nullptr;
}

参考资料

• https://doc.omnetpp/omnetpp4/api/classcSimpleModule.html
• https://github/sommer/veins
• chatGPT

Veins平台教程推荐

根据之前学习的内容，在GitHub整理了一个简易教程供大家参考。【Veins_SUMO_OMNeTpp】

本文标签： 消息OMNeTscheduleAt