基于OMNeT++/Veins/SUMO的IOV项目：代码修改、示例解析与通信日志

一、借助DemoMessageApp修改MyVeinsApp的步骤 #

1. 梳理DemoMessageApp核心逻辑

   • 重点分析它的消息收发流程：handleSelfMsg（定时器触发消息发送）、handleLowerMsg（处理下层传来的消息）、sendDown（封装消息到MAC层）
   • 熟悉自定义消息结构DemoMessage_m（在DemoMessage.msg中定义，包含发送方地址、消息内容等字段）

2. 代码迁移与适配

   • 在MyVeinsApp.h中导入消息定义：#include "DemoMessage_m.h"
   • 重写核心方法：
     • 在initialize()中初始化定时发送事件（如每隔1秒发送消息）
     • 在handleSelfMsg()中创建DemoMessage_m实例，填充字段后调用sendDown()发送
     • 在handleLowerMsg()中解析收到的DemoMessage_m消息，根据业务需求处理（如更新车辆状态、触发RSU指令）
   • 调整消息字段：将Demo中的示例内容替换为IOV项目所需的业务数据（如车辆速度、位置、RSU的路况通知）

3. 配置文件验证

   • 在omnetpp.ini中确保MyVeinsApp的模块路径正确，消息类型映射无误（如**.applType = "MyVeinsApp"）

二、Veins示例代码理解与通信日志实现 #

1. Veins示例代码快速理解方法 #

• 从Veins自带的veins/examples/veins工程入手，核心模块为TraCIDemo11p，拆解其生命周期：
  • initialize()：初始化MAC层参数、应用层定时器，注册消息类型
  • handleMessage()：区分自消息（定时触发）和下层消息（来自802.11p协议栈）
  • populateWSM()：填充Wave Short Message的通用字段（如发送方地址、消息ID）
• 关键代码片段（发送 beacon 消息）：

void TraCIDemo11p::handleSelfMsg(cMessage* msg) {
    if (msg == sendBeaconEvt) {
        DemoSafetyMessage* bsm = new DemoSafetyMessage();
        populateWSM(bsm); // 填充通用消息字段
        bsm->setSenderPos(curPosition); // 自定义业务字段
        sendDown(bsm); // 发送到下层协议栈
        scheduleAt(simTime() + beaconInterval, sendBeaconEvt); // 重置定时器
    }
    BaseWaveApplLayer::handleSelfMsg(msg);
}

2. 通信日志实现方案 #

方案1：用OMNeT++内置EV宏输出调试日志

适合开发阶段快速查看，日志会输出到OMNeT++仿真控制台：

void MyVeinsApp::handleLowerMsg(cMessage* msg) {
    DemoMessage_m* receivedMsg = check_and_cast<DemoMessage_m*>(msg);
    // 记录接收日志
    EV << "[SIM_TIME: " << simTime() << "] "
       << "RECEIVER: " << getParentModule()->getIndex() << " "
       << "SENDER: " << receivedMsg->getSenderAddress() << " "
       << "CONTENT: " << receivedMsg->getMessageContent() << endl;
    
    // 记录发送日志（在sendDown前添加）
    EV << "[SIM_TIME: " << simTime() << "] "
       << "SENDER: " << getParentModule()->getIndex() << " "
       << "MSG_TYPE: " << receivedMsg->getMsgType() << endl;
}

方案2：自定义日志文件记录（适合批量数据分析）

将日志写入本地文件，支持后续离线分析：

#include <fstream>
std::ofstream commLog;

void MyVeinsApp::initialize(int stage) {
    BaseWaveApplLayer::initialize(stage);
    if (stage == 0) {
        // 打开日志文件，追加模式
        commLog.open("iov_communication_logs.txt", std::ios::app);
        // 写入表头
        commLog << "TIMESTAMP\tNODE_ID\tACTION\tSENDER_ID\tMSG_TYPE\tCONTENT" << endl;
    }
}

void MyVeinsApp::sendDown(cMessage* msg) {
    DemoMessage_m* sentMsg = check_and_cast<DemoMessage_m*>(msg);
    // 记录发送动作
    commLog << simTime() << "\t"
            << getParentModule()->getIndex() << "\t"
            << "SEND\t"
            << sentMsg->getSenderAddress() << "\t"
            << sentMsg->getMsgType() << "\t"
            << sentMsg->getMessageContent() << endl;
    BaseWaveApplLayer::sendDown(msg);
}

void MyVeinsApp::handleLowerMsg(cMessage* msg) {
    DemoMessage_m* receivedMsg = check_and_cast<DemoMessage_m*>(msg);
    // 记录接收动作
    commLog << simTime() << "\t"
            << getParentModule()->getIndex() << "\t"
            << "RECEIVE\t"
            << receivedMsg->getSenderAddress() << "\t"
            << receivedMsg->getMsgType() << "\t"
            << receivedMsg->getMessageContent() << endl;
    // 后续业务处理逻辑
    delete msg;
}

void MyVeinsApp::finish() {
    // 关闭日志文件
    if (commLog.is_open()) {
        commLog.close();
    }
    BaseWaveApplLayer::finish();
}

日志扩展建议 #

• 可添加RSSI、消息接收强度等字段（通过receivedMsg->getRssi()获取）
• 区分车辆、RSU节点：通过getParentModule()->getNedTypeName()判断节点类型，在日志中标记

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