OMNeT++中节点带宽约束下链路数据率动态修改方法咨询

以下是针对你的需求的分步实现方案，直接基于OMNeT++的cDatarateChannel扩展和模块逻辑来完成：

1. 搭建基础4节点网络拓扑 #

首先在NED文件中定义节点、自定义通道和网络结构：

// 自定义节点模块
simple Node {
    parameters:
        double incomingBandwidth @unit(bps); // 节点入带宽上限
        double outgoingBandwidth @unit(bps); // 节点出带宽上限
        @class("Node");
    gates:
        input in[];
        output out[];
}

// 扩展cDatarateChannel，支持动态速率调整和节点关联
channel CustomDatarateChannel extends cDatarateChannel {
    parameters:
        @class("CustomDatarateChannel");
        string sourceNode; // 记录源节点名称
        string destNode;   // 记录目的节点名称
}

// 4节点网络
network FourNodeNetwork {
    submodules:
        node1: Node {
            parameters:
                incomingBandwidth = "50Mbps";
                outgoingBandwidth = "50Mbps";
        }
        node2: Node {
            parameters:
                incomingBandwidth = "50Mbps";
                outgoingBandwidth = "50Mbps";
        }
        node3: Node {
            parameters:
                incomingBandwidth = "50Mbps";
                outgoingBandwidth = "50Mbps";
        }
        node4: Node {
            parameters:
                incomingBandwidth = "50Mbps";
                outgoingBandwidth = "50Mbps";
        }
        controller: Controller; // 用于触发动态速率修改
    connections:
        node1.out++ <--> CustomDatarateChannel { datarate = "10Mbps"; delay = "1ms"; sourceNode = "node1"; destNode = "node2"; } <--> node2.in++;
        node2.out++ <--> CustomDatarateChannel { datarate = "10Mbps"; delay = "1ms"; sourceNode = "node2"; destNode = "node3"; } <--> node3.in++;
        node3.out++ <--> CustomDatarateChannel { datarate = "10Mbps"; delay = "1ms"; sourceNode = "node3"; destNode = "node4"; } <--> node4.in++;
        node1.out++ <--> CustomDatarateChannel { datarate = "10Mbps"; delay = "1ms"; sourceNode = "node1"; destNode = "node4"; } <--> node4.in++;
}

2. 实现自定义通道模块 #

继承cDatarateChannel，暴露速率修改接口并处理参数变更：

CustomDatarateChannel.h #

#ifndef CUSTOMDATARATECHANNEL_H_
#define CUSTOMDATARATECHANNEL_H_

#include <omnetpp.h>

using namespace omnetpp;

class CustomDatarateChannel : public cDatarateChannel
{
  protected:
    virtual void handleParameterChange(const char* parname) override;

  public:
    void setLinkDatarate(double newRate);
    std::string getSourceNode() const { return par("sourceNode").stringValue(); }
    std::string getDestNode() const { return par("destNode").stringValue(); }
};

#endif /* CUSTOMDATARATECHANNEL_H_ */

CustomDatarateChannel.cc #

#include "CustomDatarateChannel.h"

void CustomDatarateChannel::handleParameterChange(const char* parname)
{
    cDatarateChannel::handleParameterChange(parname);
    // 速率变更时打印日志（可选）
    if (!strcmp(parname, "datarate")) {
        EV_INFO << "Link datarate updated to " << datarate << " bps\n";
    }
}

void CustomDatarateChannel::setLinkDatarate(double newRate)
{
    setDatarate(newRate);
    // 触发参数变更处理，确保通道内部状态同步
    handleParameterChange("datarate");
}

3. 实现节点带宽约束逻辑 #

节点模块需要统计出入链路总速率，修改前检查是否符合约束：

Node.h #

#ifndef NODE_H_
#define NODE_H_

#include <omnetpp.h>
#include <map>

using namespace omnetpp;

class Node : public cSimpleModule
{
  private:
    double incomingBandwidth;
    double outgoingBandwidth;
    std::map<cChannel*, double> outgoingLinkRates; // 出链路当前速率映射
    std::map<cChannel*, double> incomingLinkRates; // 入链路当前速率映射

    // 检查出链路总速率是否超出上限
    bool checkOutgoingBandwidth(double newRate, cChannel* link);
    // 检查入链路总速率是否超出上限
    bool checkIncomingBandwidth(double newRate, cChannel* link);

  protected:
    virtual void initialize() override;
    virtual void handleMessage(cMessage* msg) override;

  public:
    // 对外暴露的链路速率修改接口
    void updateLinkRate(cChannel* link, double newRate);
};

#endif /* NODE_H_ */

Node.cc #

#include "Node.h"
#include "CustomDatarateChannel.h"

void Node::initialize()
{
    incomingBandwidth = par("incomingBandwidth").doubleValue();
    outgoingBandwidth = par("outgoingBandwidth").doubleValue();

    // 初始化时记录所有链路的初始速率
    for (int i = 0; i < outGateSize(); i++) {
        cChannel* channel = gate("out", i)->getTransmissionChannel();
        auto customChan = dynamic_cast<CustomDatarateChannel*>(channel);
        if (customChan) outgoingLinkRates[channel] = customChan->getDatarate();
    }

    for (int i = 0; i < inGateSize(); i++) {
        cChannel* channel = gate("in", i)->getTransmissionChannel();
        auto customChan = dynamic_cast<CustomDatarateChannel*>(channel);
        if (customChan) incomingLinkRates[channel] = customChan->getDatarate();
    }
}

bool Node::checkOutgoingBandwidth(double newRate, cChannel* link)
{
    double total = 0;
    for (auto& pair : outgoingLinkRates) {
        total += (pair.first == link) ? newRate : pair.second;
    }
    return total <= outgoingBandwidth;
}

bool Node::checkIncomingBandwidth(double newRate, cChannel* link)
{
    double total = 0;
    for (auto& pair : incomingLinkRates) {
        total += (pair.first == link) ? newRate : pair.second;
    }
    return total <= incomingBandwidth;
}

void Node::updateLinkRate(cChannel* link, double newRate)
{
    auto customChan = dynamic_cast<CustomDatarateChannel*>(link);
    if (!customChan) {
        EV_ERROR << getName() << ": Target channel is not a CustomDatarateChannel\n";
        return;
    }

    // 判断链路类型（出/入）
    bool isOutgoing = false;
    for (int i = 0; i < outGateSize(); i++) {
        if (gate("out", i)->getTransmissionChannel() == link) {
            isOutgoing = true;
            break;
        }
    }

    bool allowed = isOutgoing ? checkOutgoingBandwidth(newRate, link) : checkIncomingBandwidth(newRate, link);
    if (allowed) {
        customChan->setLinkDatarate(newRate);
        // 更新本地速率记录
        if (isOutgoing) outgoingLinkRates[link] = newRate;
        else incomingLinkRates[link] = newRate;
        EV_INFO << getName() << ": Link rate updated to " << newRate << " bps (constraint satisfied)\n";
    } else {
        EV_WARN << getName() << ": Link rate update rejected - exceeds node bandwidth limit\n";
    }
}

void Node::handleMessage(cMessage* msg)
{
    // 这里实现节点的业务逻辑（比如数据包转发）
    delete msg;
}

4. 实现动态速率触发控制器 #

创建控制器模块，定时或按需触发链路速率修改：

Controller.h #

#ifndef CONTROLLER_H_
#define CONTROLLER_H_

#include <omnetpp.h>

using namespace omnetpp;

class Controller : public cSimpleModule
{
  protected:
    virtual void initialize() override;
    virtual void handleMessage(cMessage* msg) override;
};

#endif /* CONTROLLER_H_ */

Controller.cc #

#include "Controller.h"
#include "Node.h"

void Controller::initialize()
{
    // 仿真启动1秒后第一次触发速率修改
    cMessage* updateMsg = new cMessage("triggerLinkUpdate");
    scheduleAt(simTime() + 1.0, updateMsg);
}

void Controller::handleMessage(cMessage* msg)
{
    // 获取目标节点和链路（示例：修改node1到node2的链路）
    Node* node1 = dynamic_cast<Node*>(getModuleByPath("FourNodeNetwork.node1"));
    if (!node1) {
        EV_ERROR << "Failed to locate node1\n";
        delete msg;
        return;
    }

    cChannel* targetLink = node1->gate("out", 0)->getTransmissionChannel();
    // 尝试修改为15Mbps（注意单位是bps，15Mbps=15*1e6）
    node1->updateLinkRate(targetLink, 15 * 1e6);

    // 2秒后再次触发修改（循环触发示例）
    scheduleAt(simTime() + 2.0, msg);
}

关键注意事项 #

• 单位统一：所有速率参数需使用bps为单位，比如10Mbps要转换为10*1e6。
• 双向链路处理：OMNeT++的<-->会创建两条单向通道，修改时需针对对应节点的出/入链路分别操作。
• 模块路径：控制器中getModuleByPath的路径需与网络NED中的模块层次完全匹配。

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