Python 扭曲：函数未正确调用？

Question

我在设置连接到“分发者”服务器以发送某些数据的客户端时遇到问题。 服务器的目的是从客户端获取数据，然后将该数据发送给所有连接的客户端。服务器工作没有任何问题。 主要客户端也应该作为 IRC 机器人工作。 下面是一个说明其工作方式的文本示例：

(IRC) John：你好！

1. IRC客户端收到消息，我们现在需要将其发送给分发者。

2.经销商应该收到“约翰：你好！”字符串并将其发送回所有连接的客户端。

3.如果其他客户端向分发器发送数据，分发器会将数据广播给所有客户端，IRC 客户端应将收到的数据输出到指定通道

以下代码是 IRC bot 客户端（ircbot.py）：

import sys
import socket
import time
import traceback
from twisted.words.protocols import irc
from twisted.internet import reactor
from twisted.internet import protocol

VERBOSE = True
f = None

class IRCBot(irc.IRCClient):
    def _get_nickname(self):
        return self.factory.nickname
    nickname = property(_get_nickname)

    def signedOn(self):
        self.msg("NickServ", "id <password_removed>") # Identify the bot
        time.sleep(0.1) # Wait a little...
        self.join(self.factory.channel) # Join channel #chantest
        print "Signed on as %s." % (self.nickname,)

    def joined(self, channel):
        print "Joined %s." % (channel,)

    def privmsg(self, user, channel, msg):
        name = user.split('!', 1)[0]
        prefix = "%s: %s" % (name, msg)
        print prefix
        if not user:
            return
        if self.nickname in msg:
            msg = re.compile(self.nickname + "[:,]* ?", re.I).sub('', msg)
            print msg
        else:
            prefix = ''
        if msg.startswith("!"):
            if name.lower() == "longdouble":
                self.msg(channel, "Owner command") # etc just testing stuff
            else:
                self.msg(channel, "Command")
        if channel == "#testchan" and name != "BotName":
            EchoClient().sendData('IRC:'+' '.join(map(str, [name, msg])))
            # This should make the bot send chat data to the distributor server (NOT IRC server)

    def irc_NICK(self, prefix, params):
        """Called when an IRC user changes their nickname."""
        old_nick = prefix.split('!')[0]
        new_nick = params[0]
        self.msg(, "%s is now known as %s" % (old_nick, new_nick))

    def alterCollidedNick(self, nickname):
        return nickname + '1'

class BotFactory(protocol.ClientFactory):
    protocol = IRCBot    
    def __init__(self, channel, nickname='BotName'):
        self.channel = channel
        self.nickname = nickname

    def clientConnectionLost(self, connector, reason):
        print "Lost connection (%s), reconnecting." % (reason,)
        connector.connect()

    def clientConnectionFailed(self, connector, reason):
        print "Could not connect: %s" % (reason,)


class EchoClient(protocol.Protocol):
    def connectionMade(self):
        pass

    def sendData(self, data):
            self.transport.write(data)

    def dataReceived(self, data):
        if VERBOSE:
            print "RECV:", data
        IRC.msg("#chantest", data)
        #This one should send the received data from the distributor to the IRC channel

        def connectionLost(self, reason):
            print "Connection was lost."

class EchoFactory(protocol.ClientFactory):
    def startedConnecting(self, connector):
        print 'Started to connect.'

    def buildProtocol(self, addr):
        print 'Connected to the Distributor'
        return EchoClient()
    def clientConnectionFailed(self, connector, reason):
        print "Cannot connect to distributor! Check all settings!"
        reactor.stop()

    def clientConnectionLost(self, connector, reason):
        print "Distributor Lost connection!!"
        reactor.stop()


if __name__ == "__main__":
    IRC = BotFactory('#chantest')
    reactor.connectTCP('irc.rizon.net', 6667, IRC) # Our IRC connection
    f = EchoFactory()
    reactor.connectTCP("localhost", 8000, f) # Connection to the Distributor server
    reactor.run()

下面的代码是分发服务器（distributor.py）：（

这个工作正常，但也许对进一步参考很有用）

from twisted.internet.protocol import Protocol, Factory
from twisted.internet import reactor


class MultiEcho(Protocol):
    def __init__(self, factory):
        self.factory = factory

    def connectionMade(self):
        print "Client connected:",self
        self.factory.echoers.append(self)
        self.factory.clients = self.factory.clients+1
        #self.transport.write("Welcome to the server! There are currently "+`self.factory.clients`+" clients connected.")

    def dataReceived(self, data):
        print "RECV:",data
        for echoer in self.factory.echoers:
            echoer.transport.write(data)

    def connectionLost(self, reason):
        print "Client disconnected:",self
        self.factory.echoers.remove(self)
        self.factory.clients = self.factory.clients-1

class MultiEchoFactory(Factory):
    def __init__(self):
        self.clients = 0
        self.names = []
        self.echoers = []

    def buildProtocol(self, addr):
        return MultiEcho(self)

if __name__ == '__main__':
    print "Running..."
    reactor.listenTCP(8000, MultiEchoFactory())
    reactor.run()

我希望客户端将所有传入的聊天数据从 IRC 服务器输出到“分发服务器”，并且还输出来自的传入数据“经销商”。 但是，我收到这样的错误：

对于 ircbot.py 中的以下行，

EchoClient().sendData('IRC'+' '.join(map(str, [name, msg])))

我收到以下错误：

Joined #chantest.
Longdouble: test
Traceback (most recent call last):
  File "C:\Python\lib\site-packages\twisted\internet\tcp.py", line 460, in doRea
d
    return self.protocol.dataReceived(data)
  File "C:\Python\lib\site-packages\twisted\words\protocols\irc.py", line 2277,
in dataReceived
    basic.LineReceiver.dataReceived(self, data.replace('\r', ''))
  File "C:\Python\lib\site-packages\twisted\protocols\basic.py", line 564, in da
taReceived
    why = self.lineReceived(line)
  File "C:\Python\lib\site-packages\twisted\words\protocols\irc.py", line 2285,
in lineReceived
    self.handleCommand(command, prefix, params)
--- <exception caught here> ---
  File "C:\Python\lib\site-packages\twisted\words\protocols\irc.py", line 2329,
in handleCommand
    method(prefix, params)
  File "C:\Python\lib\site-packages\twisted\words\protocols\irc.py", line 1813,
in irc_PRIVMSG
    self.privmsg(user, channel, message)
  File "C:\Python\Traance\kwlbot\ircbot.py", line 51, in privmsg
    EchoClient().sendData('IRC'+' '.join(map(str, [name, msg])))
  File "C:\Python\Traance\kwlbot\ircbot.py", line 90, in sendData
    self.transport.write(data)
exceptions.AttributeError: 'NoneType' object has no attribute 'write'

同样转到同一 ircbot.py 中的这一行

IRC.msg("#chantest", data)

->

RECV: Hello from Distributor Server
Traceback (most recent call last):
  File "C:\Python\Traance\kwlbot\ircbot.py", line 96, in dataReceived
    IRC.msg("#chantest", data)
AttributeError: BotFactory instance has no attribute 'msg'

我做错了什么？如何从IRCbot类中调用正确的函数，使其将数据发送到分发服务器，并将从分发服务器接收到的数据通过IRC输出到指定通道？

欢迎任何建议和可能的解决方案。

如果我遗漏了任何其他细节，请告诉我。

谢谢您的宝贵时间！

Answer 1

您应该避免编写这样的阻塞代码：

def signedOn(self):
    self.msg("NickServ", "id <password_removed>") # Identify the bot
    time.sleep(0.1) # Wait a little...
    self.join(self.factory.channel) # Join channel #chantest
    print "Signed on as %s." % (self.nickname,)

有关详细信息，请参阅 tail -f 登录服务器，处理数据，然后通过twisted服务给客户端。

除此之外，这里的主要问题是您尝试在没有连接的情况下发送数据。当您编写如下内容时：

EchoClient().sendData('IRC'+' '.join(map(str, [name, msg])))

您正在创建一个负责处理连接的协议实例，然后尝试使用它，但您没有创建一个连接。发送数据的尝试失败，因为协议尚未附加到任何传输。

您的代码片段已经演示了创建连接的正确方法，实际上是两次：

IRC = BotFactory('#chantest')
reactor.connectTCP('irc.rizon.net', 6667, IRC) # Our IRC connection
f = EchoFactory()
reactor.connectTCP("localhost", 8000, f) # Connection to the Distributor server

错误是创建一个新的 EchoClient 实例，该实例没有连接。 reactor.connectTCP 调用创建一个新连接和一个新的 EchoClient 实例，并将它们相互关联。

您希望使用工厂创建的 EchoClient 实例，而不是 EchoClient().sendData(...)：

def buildProtocol(self, addr):
    print 'Connected to the Distributor'
    return EchoClient()

您的 buildProtocol 实现创建实例，所缺少的只是保存实例，以便您的 IRC 机器人可以使用它。

考虑这样的事情：

def buildProtocol(self, addr):
    print 'Connected to the Distributor'
    self.connection = EchoClient()
    return self.connection

然后，您的 IRC 客户端可以使用保存的 EchoClient 实例：

    if channel == "#testchan" and name != "BotName":
        f.connection.sendData('IRC:'+' '.join(map(str, [name, msg])))
        # This should make the bot send chat data to the distributor server (NOT IRC server)

请注意，我在这里给出的具体代码是一种非常粗略的方法。它使用全局变量f来查找EchoFactory实例。与大多数全局变量的使用一样，这使得代码有点难以理解。此外，我没有添加任何代码来处理 connectionLost 事件以清除 connection 属性。这意味着当连接已经丢失时，您可能会认为正在向分布式服务器发送数据。同样，无法保证在 IRC 客户端首次尝试使用它时已创建与分布式服务器的连接，因此当它尝试使用 时，您可能会遇到 AttributeError f.connection.sendData。

然而，解决这些问题并不需要太大的飞跃。像修复任何其他变量一样修复全局变量的使用 - 通过将参数传递给函数、将对象保存为其他对象的引用等。通过处理可能的 AttributeError 来修复它，或者直到不创建 IRC 连接为止创建分布式连接后等。并通过将属性值重置为 None 或其他哨兵来处理丢失的连接，并在尝试使用之前注意 IRC 代码中的这种情况分布式客户端连接发送任何数据。

Answer 2

TFM 从未在您的代码中定义，所以我不知道其中的含义。

另一个错误是您正在实例化客户端，但从未将其连接到任何东西，就像使用 Reactor.connectTCP(...) 或 endpoint.connect(...) 一样代码>. transport 属性将是 None，直到它被某些东西设置。

（对您来说，提出此代码的更简单版本会很有帮助，该版本是完整的，并且不包含不必要的详细信息，例如所有打印的日志消息。这使得更难看出真正的问题是什么。）