omnet 通过双向通道进行节点位置信息的交换 代码 网路层

以下是使用双向通道进行节点位置信息交换的示例代码（仅涉及网络层）：

在 `omnetpp.ini` 中添加以下内容：

[General]
sim-time-limit = 100s

**.numNodes = 2

**.node[*].xCoor = uniform(0, 100)
**.node[*].yCoor = uniform(0, 100)

**.node[*].udpApp[0].typename = "UDPBasicApp"
**.node[*].udpApp[0].destAddresses = "node[1]"
**.node[*].udpApp[0].destPort = 5000
**.node[*].udpApp[0].messageLength = 100

**.node[*].udpApp[1].typename = "UDPBasicApp"
**.node[*].udpApp[1].localPort = 5000
**.node[*].udpApp[1].messageLength = 100

**.node[*].routing.strategy = "cbr"
**.node[*].routing.cbr.destAddr = "node[1]"

这里定义了两个节点，并为每个节点设置了 x 和 y 坐标。每个节点都有一个 `UDPBasicApp` 应用程序，一个用于发送位置信息，另一个用于接收位置信息。每个节点也都有一个 `cbr` 路由策略，用于指定目标节点地址。

在 `UDPBasicApp` 中添加以下内容：

#include "inet/applications/base/ApplicationPacket_m.h"
#include "inet/common/geometry/common/Coord.h"
#include "inet/common/packet/Packet.h"
#include "inet/networklayer/common/L3AddressResolver.h"
#include "inet/transportlayer/contract/udp/UDPControlInfo.h"

using namespace inet;

class UDPBasicApp : public cSimpleModule
{
  private:
    simtime_t startTime;
    simtime_t stopTime;
    cMessage *event;
    int localPort;
    int destPort;
    const char *destAddresses;
    int messageLength;
    UDPSocket socket;

  public:
    UDPBasicApp();
    virtual ~UDPBasicApp();

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

Define_Module(UDPBasicApp);

UDPBasicApp::UDPBasicApp()
{
    event = nullptr;
}

UDPBasicApp::~UDPBasicApp()
{
    cancelAndDelete(event);
}

void UDPBasicApp::initialize()
{
    startTime = par("startTime");
    stopTime = par("stopTime");
    localPort = par("localPort");
    destPort = par("destPort");
    destAddresses = par("destAddresses");
    messageLength = par("messageLength");

    if (strcmp(destAddresses, ""))
        socket.setOutputGate(gate("udpOut"));
    else
        socket.bind(localPort);

    event = new cMessage("event");
    scheduleAt(startTime, event);
}

void UDPBasicApp::handleMessage(cMessage *msg)
{
    if (msg == event) {
        if (strcmp(destAddresses, "")) {
            const auto& addr = L3AddressResolver().resolve(destAddresses);
            if (addr.isUnspecified()) {
                EV_ERROR << "cannot resolve destination address: " << destAddresses << endl;
                return;
            }
            socket.connect(addr, destPort);
        }
        auto packet = new Packet("data");
        auto payload = makeShared<ApplicationPacket>();
        auto coord = Coord(par("xCoor"), par("yCoor"), 0);
        payload->setCoord(coord);
        packet->insertAtBack(payload);
        socket.send(packet);
        scheduleAt(simTime() + 1, event);
    }
    else if (msg->getKind() == UDP_I_DATA) {
        auto packet = check_and_cast<Packet *>(msg);
        auto payload = packet->popAtFront<ApplicationPacket>();
        auto coord = payload->getCoord();
        EV_INFO << "Received position information from " << packet->getTag<UDPControlInfo>()->getSrcAddr() << ": (" << coord.x << ", " << coord.y << ")" << endl;

        // 将位置信息转发到其他节点
        auto destAddr = L3AddressResolver().resolve(par("destAddr"));
        if (destAddr.isUnspecified()) {
            EV_ERROR << "cannot resolve destination address: " << par("destAddr") << endl;
            return;
        }
        auto routingPacket = new Packet("routing");
        auto routingPayload = makeShared<ApplicationPacket>();
        routingPayload->setCoord(coord);
        routingPacket->insertAtBack(routingPayload);
        auto udpControlInfo = makeShared<UDPControlInfo>();
        udpControlInfo->setDestAddr(destAddr);
        udpControlInfo->setDestPort(5000);
        udpControlInfo->setSrcAddr(packet->getTag<UDPControlInfo>()->getSrcAddr());
        udpControlInfo->setSrcPort(localPort);
        routingPacket->addTagIfAbsent<UDPControlInfo>()->setChunkLength(udpControlInfo->getChunkLength());
        routingPacket->addTagIfAbsent<UDPControlInfo>()->setUdpControlInfo(Protocol::udp, udpControlInfo);
        socket.sendTo(routingPacket, destAddr, 5000);
        delete msg;
    }
    else
        throw cRuntimeError("Unknown message kind");
}

这里定义了一个名为 `UDPBasicApp` 的应用程序，它具有发送和接收位置信息的功能。在 `initialize()` 中，我们将应用程序绑定到本地端口或连接到目标地址和端口。在 `handleMessage()` 中，我们使用 `Coord` 类创建一个包含节点位置信息的 payload，并将其封装在一个 `Packet` 中发送到目标节点。当接收到包含位置信息的 `Packet` 时，我们将其提取出来，并将其打印到控制台上。然后，我们创建一个新的 `Packet`，其中包含接收到的位置信息，并将其转发到其他节点。

请注意，该代码只是一个示例，实际使用中可能需要添加更多的错误处理和其他功能。