Python3网络服务器为IRC机器人程序在线程之间进行通信

Question

我读了很多关于线程、队列、池等的文档，但仍然不知道如何解决我的问题。情况如下：我构建了一个由cherrypy提供服务的python3Django应用程序。该应用程序基本上是另一个IRC客户端。当我第一次使用GUI运行代码时，IRC机器人程序会通过deamon线程启动并侦听事件。我的问题是：我如何向那个线程（和我的机器人）发送数据，例如告诉他加入第二个通道？当我第二次运行代码时，很明显，我的机器人程序的一个新实例和一个新的服务器连接都被创建了。我需要一种通过GUI交互与我的机器人进行通信的方式。现在，我唯一能让我的机器人对特定的事情做出反应的方法就是读取数据库。其他一些GUI操作将更改该数据库。这是一个糟糕的系统。

这是启动我的机器人的相关代码。

def DCC_deamonthread(c, server, nickname, upload):
    try:
        c.connect(server, 6667, nickname)
        c.start()
    except irc.client.ServerConnectionError as x:
        log("error" + str(x)).write()
        upload.status, upload.active = "Error during connection", False
        upload.save()
def upload_file(filename, rec_nick, pw):
    global upload
    Upload_Ongoing.objects.all().delete()
    upload = Upload_Ongoing(filename=filename,status="Connecting to server...", active=True)
    upload.save()
    irc.client.ServerConnection.buffer_class.encoding = 'latin-1'
    c = DCCSend(filename, rec_nick, pw)
    server = "irc.rizon.net"
    nickname = ''.join(random.choice(string.ascii_lowercase) for i in range(10))
    t = threading.Thread(target=DCC_deamonthread, args=(c, server, nickname, upload))
    t.daemon=True
    t.start()

Answer 1

问题是，正如您所注意到的，每次上传时都会生成一个新的线程/bot。一个可能的解决方案是重写你的代码来做这样的事情：

event_queue = multiprocessing.Queue() # Events that will be sent to the IRC bot thread
def irc_bot_thread():
    bot = connect_to_irc()
    for event in event_queue:
        bot.handle_event(event)
threading.Thread(target=irc_bot_thread).start()
def upload_file(filename, rec_nick, pw):
    # Django stuff
    event_queue.push(<necessary data for use by the bot>)