如何在Omnet++中实现节点每5秒广播控制消息并回复源节点

1. 定义MyControlMessage消息类型 #

创建MyControlMessage.msg文件，定义消息结构，包含源节点标识、待修改字段等核心信息：

cplusplus {{
#include <omnetpp.h>
}}

message MyControlMessage extends cMessage {
    int sourceNodeId;  // 源节点ID，用于回复定位
    int updateField;   // 接收节点需要修改的字段
}

右键该文件选择Compile，自动生成对应的C++头文件与源文件。

2. 自定义应用模块 #

创建MyControlApp.ned，定义负责消息收发逻辑的简单模块：

simple MyControlApp {
    gates:
        input in;
        output out;
}

3. 编写C++逻辑实现 #

头文件（MyControlApp.h） #

#ifndef MYCONTROLAPP_H_
#define MYCONTROLAPP_H_

#include <omnetpp.h>
#include "MyControlMessage_m.h"

using namespace omnetpp;

class MyControlApp : public cSimpleModule {
  protected:
    virtual void initialize() override;
    virtual void handleMessage(cMessage *msg) override;
    cMessage *sendTimer;  // 周期性发送定时器
};

#endif /* MYCONTROLAPP_H_ */

源文件（MyControlApp.cc） #

#include "MyControlApp.h"

Define_Module(MyControlApp);

void MyControlApp::initialize() {
    // 初始化定时器，首次发送延迟5秒
    sendTimer = new cMessage("sendControlMsgTimer");
    scheduleAt(simTime() + 5.0, sendTimer);
}

void MyControlApp::handleMessage(cMessage *msg) {
    if (msg == sendTimer) {
        // 创建控制消息并设置初始字段
        MyControlMessage *controlMsg = new MyControlMessage("MyControlMsg");
        controlMsg->setSourceNodeId(getParentModule()->getId());
        controlMsg->setUpdateField(0);

        // 发送消息到下层协议栈实现广播
        send(controlMsg, "out");

        // 调度下一次发送，保持5秒间隔
        scheduleAt(simTime() + 5.0, sendTimer);
    } else {
        // 处理收到的控制消息
        MyControlMessage *receivedMsg = check_and_cast<MyControlMessage*>(msg);

        // 修改指定字段（示例：字段值加1）
        receivedMsg->setUpdateField(receivedMsg->getUpdateField() + 1);

        // 获取源节点并发送回复
        int destNodeId = receivedMsg->getSourceNodeId();
        cModule *destModule = getSimulation()->getModule(destNodeId);

        if (destModule) {
            // 通过协议栈转发回复到源节点
            send(receivedMsg, "out");
        } else {
            EV_WARN << "目标节点不存在，丢弃消息\n";
            delete receivedMsg;
        }
    }
}

4. 修改网络NED文件 #

定义包含自定义应用的主机模块，替换原有AdhocHost：

// 自定义主机模块，集成控制应用
module MyAdhocHost extends AdhocHost {
    submodules:
        controlApp: MyControlApp {
            parameters:
                @display("p=100,100");
        }
    connections allowunconnected:
        controlApp.out --> udpApp.out;  // 连接UDP模块实现广播
        udpApp.in --> controlApp.in;    // 接收UDP消息
}

network NetworkRM
{
    parameters:
        @display("bgb=900,400");
    submodules:
        visualizer: IntegratedMultiVisualizer {
            parameters:
                @display("p=64.256,62.247997");
        }
        configurator: Ipv4NetworkConfigurator {
            parameters:
                @display("p=64.256,180.72");
        }
        radioMedium: Ieee80211DimensionalRadioMedium {
            parameters:
                @display("p=62.247997,287.14398");
        }
        source: MyAdhocHost {
            parameters:
                @display("p=277,45");
        }
        destination: MyAdhocHost {
            parameters:
                @display("p=522,45");
        }
        source2: MyAdhocHost {
            parameters:
                @display("p=277,315");
        }
        destination2: MyAdhocHost {
            parameters:
                @display("p=522,315");
        }
}

关键注意事项 #

• 广播实现：无线自组网中，可通过UDP发送到广播地址255.255.255.255，需确保UDP模块配置正确。
• 消息回复：实际场景中可通过消息携带的源IP地址路由，上述代码简化了模块查找逻辑，可根据需求调整。
• 定时器调度：通过循环调用scheduleAt确保节点持续周期性发送消息。

内容的提问来源于stack exchange，提问作者Maryam