OMNET++中单节点如何向多节点广播消息及跨子网同时发信

你当前的代码存在两个核心限制：节点仅支持单入单出链路、消息转发逻辑仅支持单端口发送，按如下步骤修改即可满足需求： #

1. NED文件修改 #

将Node的门定义修改为向量形式，支持同时连接多个节点，同时补全广播节点到5个目标节点、双子网的连接配置，修改后代码如下：

package simulationnetwork;

network my_network
{
    @display("bgb=757,458,#80FF00;bgi=background/terrain,s");
    types:
        simple Node
        {
            gates:
                input in[]; // 输入门向量，支持多链路接入
                output out[]; // 输出门向量，支持多链路发送
        }

    submodules:
        broadcastNode: Node { // 负责广播的核心节点
            @display("p=155,377");
        }
        // 子网1节点（4个节点组成环形）
        node1: Node {
            @display("p=30,58");
        }
        node2: Node {
            @display("p=249,58");
        }
        node3: Node {
            @display("p=330,165");
        }
        node4: Node {
            @display("p=182,193");
        }
        // 子网2节点（3个节点组成环形）
        node5: Node {
            @display("p=275,291");
        }
        node6: Node {
            @display("p=451,311");
        }
    connections:
        // 广播节点到5个目标节点的直连链路，用于广播
        broadcastNode.out++ --> node1.in++;
        broadcastNode.out++ --> node2.in++;
        broadcastNode.out++ --> node3.in++;
        broadcastNode.out++ --> node5.in++;
        broadcastNode.out++ --> node6.in++;
        // 子网1内部连接
        node1.out++ --> node2.in++;
        node2.out++ --> node3.in++;
        node3.out++ --> node4.in++;
        node4.out++ --> node1.in++;
        // 子网2内部连接
        node5.out++ --> node6.in++;
        node6.out++ --> broadcastNode.in++;
        broadcastNode.out++ --> node5.in++;
}

2. C++逻辑修改 #

调整消息发送逻辑，支持广播时遍历所有输出门发送消息副本，同时支持指定端口向不同子网并行发送，修改后代码如下：

#include <omnetpp.h>
#include <string>

using namespace omnetpp;

class Node: public cSimpleModule
{
protected:
    void initialize() override;
    void handleMessage(cMessage *msg) override;
    void broadcastMessage(cMessage *baseMsg); // 广播方法
    void sendToSubnet(cMessage *msg, int subnetIndex); // 向指定子网发送
};

Define_Module(Node);

void Node::initialize()
{
    if(strcmp("broadcastNode", getName()) == 0)
    {
        // 测试广播：向所有连接的节点发送广播消息
        cMessage *broadcastMsg = new cMessage("nodetable:location");
        broadcastMessage(broadcastMsg);
        
        // 测试双子网并行发送：分别向子网1（端口0）和子网2（端口5）发消息
        cMessage *sub1Msg = new cMessage("subnet1_data");
        sendToSubnet(sub1Msg, 0);
        cMessage *sub2Msg = new cMessage("subnet2_data");
        sendToSubnet(sub2Msg, 5);
    }
}

void Node::handleMessage(cMessage *msg)
{
    // 普通节点收到消息后转发到所有其他输出端口（可根据业务需求调整）
    for(int i=0; i<gateSize("out"); i++)
    {
        // 跳过消息进来的端口，避免回环
        if(gate("in", 0)->getPreviousGate() == gate("out", i)) continue;
        send(msg->dup(), "out", i);
    }
    delete msg; // 原始消息用完释放，避免内存泄漏
}

void Node::broadcastMessage(cMessage *baseMsg)
{
    int outGateCount = gateSize("out");
    for(int i=0; i<outGateCount; i++)
    {
        cMessage *copyMsg = baseMsg->dup();
        send(copyMsg, "out", i);
    }
    delete baseMsg;
}

void Node::sendToSubnet(cMessage *msg, int subnetIndex)
{
    if(subnetIndex < gateSize("out"))
    {
        send(msg, "out", subnetIndex);
    }
    else
    {
        delete msg;
        EV << "子网端口索引不存在" << endl;
    }
}

关键优化点 #

• 门向量支持动态扩展端口数量，无需硬编码端口定义，适配广播和多子网连接需求
• 广播时使用dup()方法复制消息实例，避免同一消息指针被多次释放导致的内存错误
• 新增子网定向发送方法，可通过端口索引灵活控制消息发送到指定子网，实现并行传输

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