2

Python twisted ライブラリを使用して開発された次のコードがあります。

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

    def dataReceived(self, data):
        request = json.loads(data)
        self.factory.handle[request['command']](**request)
        self.transport.write(data)

class CacheFactory(protocol.Factory):
    def buildProtocol(self, addr):
        return Cache(self)
    def handle_get(self, **kwargs):
        print 'get\n', kwargs
    def handle_set(self, **kwargs):
        print 'set\n', kwargs
    def handle_delete(self, **kwargs):
        print 'delete\n', kwargs
    handle = {
        'get': handle_get,
        'set': handle_set,
        'delete': handle_delete,
    }

reactor.listenTCP(int(sys.argv[1]), CacheFactory())
reactor.run()

telnet を使用してクライアント接続を実行します。

Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
{"command": "set", "value": 1234567890}
Connection closed by foreign host.

例外がスローされます:

Traceback (most recent call last):
  File "/usr/lib/python2.7/dist-packages/twisted/python/log.py", line 84, in callWithLogger
    return callWithContext({"system": lp}, func, *args, **kw)
  File "/usr/lib/python2.7/dist-packages/twisted/python/log.py", line 69, in callWithContext
    return context.call({ILogContext: newCtx}, func, *args, **kw)
  File "/usr/lib/python2.7/dist-packages/twisted/python/context.py", line 118, in callWithContext
    return self.currentContext().callWithContext(ctx, func, *args, **kw)
  File "/usr/lib/python2.7/dist-packages/twisted/python/context.py", line 81, in callWithContext
    return func(*args,**kw)
--- <exception caught here> ---
  File "/usr/lib/python2.7/dist-packages/twisted/internet/selectreactor.py", line 146, in _doReadOrWrite
    why = getattr(selectable, method)()
  File "/usr/lib/python2.7/dist-packages/twisted/internet/tcp.py", line 460, in doRead
    rval = self.protocol.dataReceived(data)
  File "./server.py", line 18, in dataReceived
    self.factory.handle[request['command']](**request)
exceptions.TypeError: handle_set() takes exactly 1 argument (0 given)

わかりません。line に何か問題がある可能性がありますself.factory.handle[request['command']](**request)が、私の意見では正しいです-selfパラメーターを暗黙的に渡し（結局メソッドです）、リクエストパラメーターを明示的にアンパックします。例外メッセージは、関数が1つの引数を取ることを示しています.2つのパラメータを取るため、それは嘘です:) self, **kwargs。また、引数を 2 つ渡すので、引数を 0 つ渡すというのは正しくありません。

誰かが問題を見つけるのを手伝ってくれますか?

それが役立つ場合、json リクエストは次のようにデコードされます。

{u'command': u'set', u'value': 1234567890}
4

1 に答える 1

4

現在のように、handle_*メソッドはインスタンス メソッドですが、 dict はバインドhandleされていないメソッドを指しています。つまり、暗黙的に渡されていません。代わりにこれを試してください：self

class CacheFactory(protocol.Factory):
    def buildProtocol(self, addr):
        return Cache(self)
    def handle_get(self, **kwargs):
        print 'get\n', kwargs
    def handle_set(self, **kwargs):
        print 'set\n', kwargs
    def handle_delete(self, **kwargs):
        print 'delete\n', kwargs
    def __init__(self, *args, **kwargs):
        protocol.Factory.__init__(self, *args, **kwargs)
        self.handle = {
            'get': self.handle_get,
            'set': self.handle_set,
            'delete': self.handle_delete,
        }

handleまたは、同じままにしてこれを行うこともできます。

    def dataReceived(self, data):
        request = json.loads(data)
        self.factory.handle[request['command']](self.factory, **request)
        self.transport.write(data)

または、このアプローチを取ることができ、handleどちらの方法でも口述は必要ありません。

    def dataReceived(self, data):
        request = json.loads(data)
        getattr(self.factory, "handle_%s" % (request['command'],))(**request)
        self.transport.write(data)

dataReceivedまた、パケットが任意に分割される可能性があるため、現時点では安全ではないことに注意してください。つまり、jsonメッセージ全体を一度に受信できない可能性があります。

于 2013-10-17T19:09:48.353 に答える