Errno 111 连接被拒绝 - Python Mininet API 主机客户端/服务器没有连接？

问题描述

我是 Mininet 的新手，我正在尝试找到一种方法，在 Python 中使用脚本来使用 Mininet 执行一些测试。更准确地说，我想构建拓扑并将一些 xmlrpc 请求从一台主机发送到另一台主机。我最近发现了如何使用 mininet API。问题是我无法从客户端连接到服务器 o 获得响应，我已经使用来自客户端主机的 telnet 10.0.0.x 12345 命令进行了测试并得到了 connection denial。代码如下：

topology_test.py

import subprocess
from time import time,sleep
from signal import SIGINT
from xmlrpc.server import SimpleXMLRPCServer
import xmlrpc.client as cl
from mininet.util import pmonitor
from mininet.topo import Topo
from mininet.net import Mininet
from mininet.util import dumpNodeConnections
from mininet.log import setLogLevel,info
from mininet.cli import CLI


# mininet topology
class MyTopology(Topo):
    def build(self,n=2):
        switch = self.addSwitch("s1")
        embedder = self.addHost("embedder")
        self.addLink(embedder,switch)
        # Python's range(N) generates 0..N-1
        for h in range(n):
            host = self.addHost("server%s" % (h + 1))
            self.addLink(host,switch)


def simpleTest():
    "Create and test a simple network"
    output = subprocess.run(["sudo","mn","-c"])
    print(output)
    seconds = 10
    topo = MyTopology(n=4)
    net = Mininet(topo)
    net.start()
    print("Dumping host connections")
    dumpNodeConnections(net.hosts)
    print("Testing network connectivity")
    net.pingAll()

    h1 = net.get("server1")
    p1 = h1.popen("python3 myServer.py -i %s &" % h1.IP())

    h2 = net.get("embedder")
    h2.cmdPrint("telnet 10.0.0.2 12345")

    # CLI(net)
    p1.terminate()
    net.stop()


if __name__ == "__main__":
    # Tell mininet to print useful information
    setLogLevel("info")
    simpleTest()

server.py

from xmlrpc.server import SimpleXMLRPCServer
import socket
import string
import socketserver
import os
import sys
from subprocess import Popen,PIPE

x = int(sys.argv[1])
tries = 0


class SimpleThreadedXMLRPCServer(socketserver.ThreadingMixIn,SimpleXMLRPCServer):
    allow_reuse_address = True


class Functions:
    # var_str = "yyyaaa"

    def guess_number(self,n):
        global tries
        tries = tries + 1
        if n > x:
            msg = "Number is too high"
        if n < x:
            msg = "Number is too low"
        if n == x:
            msg = "You found the number in " + str(tries) + "tries. Congratulations!"
            tries = 0
        return msg

    # def str_get():
    #     return var_str


if __name__ == "__main__":
    port = 8100
    server = SimpleThreadedXMLRPCServer(("",port))
    server.register_instance(Functions())
    print("Serever listening...")
    server.serve_forever()

客户端.py

import xmlrpc.client as cl



addr = "10.0.0.2"
port = 8100
# rhost = xmlrpclib.Server("http://" + addr + ":" + str(port))
rhost = cl.Server("http://" + addr + ":" + str(port))
# msg = rhost.str_get()
# print(msg)
# inp = ""
print("Guess a number between 1 and 100")
print()
while 1:
    # msg = rhost.str_get()
    # print(msg)

    inp = input(">")
    msg = rhost.guess_number(int(inp))

    print(msg)

if "found" in msg:
    sys.exit(0)

向主机执行服务器/客户端脚本

host1.sendCmd("python3 server.py")
host2.cmdPrint("python3 client.py")

如果我使用不同的 mininet CLI 窗口运行 xterm 中的所有内容，但运行正常，但使用 mininet API 时没有任何工作正常，我还尝试了一些不同的客户端/服务器脚本，有时它正在工作。实际上，它仅在第一次运行时起作用。所以我在想，也许有一种方法可以使用 subprocess 打开 xterm 窗口，然后在 xterm 中使用一些 pipe subprocess 运行命令。我希望一切都通过 python 脚本运行，而不是手动运行。任何人都可以给我任何帮助吗？

解决方法

为什么不使用mininet的python接口来实现呢？从您的问题来看，您似乎想获取 sudo mn 默认创建的节点的名称。

在这种情况下，为什么不将以下内容添加到您的 Python 中：

from mininet.topo import SingleSwitchTopo
from mininet.net import Mininet
from mininet.node import CPULimitedHost
from mininet.link import TCLink

if __name__ == '__main__':
    topo = SingleSwitchTopo()
    net = Mininet(topo=topo,host=CPULimitedHost,link=TCLink)

    net.start()

    nodes = net.items()
    node_names,_ = zip(*nodes)

    print(node_names)
    net.stop()

SingleSwitchTopo 是 mn 默认使用的（两台主机连接到一个交换机）。 net.items() 为您提供节点名称和 ID 的元组，请参见 here。也许我误解了您的问题，但似乎在有 API 时尝试通过子进程访问它会使原本简单的任务变得过于复杂。

,

最后，我找到了客户端尝试连接到服务器时出现 [Errno 111] : connection refused 的原因。这是一种“疯狂”的好方法；)

我刚刚意识到当客户端发出请求时服务器没有准备好并正在运行，仅仅是因为两个执行命令同时启动。因此，我在调用/执行 cmd 行之间添加了一个延迟，如下所示：

host1.sendCmd("python3 server.py")
sleep(5)
host2.cmdPrint("python3 client.py")

额外评论：

重要的是，当 sendCmd() 运行时，assertion await 会给出 net.stop() 错误。文档说在 host1.monitor() 之后和 sendCmd() 之前使用 net.stop() 但它没有用。因此，我用 sendCmd() 替换了 popen()，然后使用了 terminate()，现在一切正常！