从控制器 1 向控制器 2 发送消息

Question

我在 mininet 中有一个拓扑，它由 2 个泛光灯控制器（c1 和 c2）、一个连接到 c1 的交换机（s1）和连接到这个交换机的 2 个主机（h1 和 h2）组成。我正在编写一个程序，当 c1 收到来自 s1 的 ICMP 数据包时，它会向 c2 发送一个 Hello 消息。

我为此目的使用本教程，其中说：

可以使用发送功能将消息从一个控制器发送到另一个控制器，并且消息必须用“m”“m”标记。您将此消息发送到特定控制器，因此 TO 地址由 IP:port 两部分组成。IP是另一个控制器的机器IP地址（HAServer正在监听所有的ip），端口是那台机器上HAServer对应的监听端口。

默认情况下，控制器 1 上的 HAServer 正在侦听 4242、控制器 2 上的 4243、控制器 3 上的 4244……等等。

recv() 函数类似于 send 函数，您将提供 FROM 地址以从特定控制器收听。发件人地址也由两部分组成，IP:port。IP是另一个控制器的机器IP地址（HAServer正在监听所有的ip），端口是那台机器上HAServer对应的监听端口。

理想情况下，该函数在调用相应的 send() 函数后调用，否则可能还没有建立连接，只会返回错误。

有什么问题？recv() 函数似乎有问题。这是内置的 send() 和接收函数的代码。

Answer 1

此代码的问题在于，当交换机向控制器发送新数据包时，会调用 receive() 方法或（假设）处于活动状态。这里当第一个控制器收到 ICMP 数据包时，它通过这段代码向第二个控制器发送一个 hello 消息： hacontroller.send("127.0.0.1:4243", "mHelloWorld");但是由于第二个控制器没有收到来自交换机的任何消息，它目前没有实现这段代码（receive()），也没有看到：hacontroller.recv("127.0.0.1:4242");据我所知，这就是为什么clientSock从未初始化的原因，所以我收到了这个错误。

Answer 2

NetworkNode.recv() 方法存在多个问题：您应该在取消引用对象之前检查 null。您不应在 String 对象上调用 toString。这是多余的。在捕获和忽略异常时应该小心。在这种情况下，您不需要捕获异常，因为 NioClient.recv() 不会抛出任何异常。该方法应该抑制异常的地方是另一个问题。避免使用成员变量而不是局部变量。需要在每个方法中声明局部变量。这是代码中许多地方的常见问题。接收方法可以改写如下：NioClient receivingSock = socketDict.get(receivingPort);if (receivingSock == null) {    logger.debug("[NetworkNode] No receivingSock on receivingport: " + receivingPort);    return "";}else {    response = receivingSock.recv();    if (response != null) {        response.trim();    }    return response;}

Answer 3

从您发布的日志和您提供的 Github 存储库来看，似乎clientSock是null. 第NullPointerException529 行抛出第一个：response = clientSock.recv();和被抓住。但是在 catch 块中，clientSockis still null，所以当你这样做时：if (clientSock.getSocketChannel() != null) {一秒钟NullPointerException被抛出（我们在日志中看到的那个）隐藏了之前抛出的那个。你能调试你的代码来验证是否socketDict包含receivingPort吗？如果没有，请务必正确初始化。此外，捕捉通常不是一个好主意，Exception因为它太大了。如果可以，我建议您捕获更精确的异常（或异常）。如果你这样做了，你会更容易看到这个错误的来源。