在鼠兔和扭曲连接的情况下,连接为无

问题描述

我想将我的 2.7 python 项目中的 pika0.9.14 更新为 1.1.0。所以,现在我尝试连接 TCP,使用 pika 1.1.0twisted 11.0.0。像这样:

import pika


from pika.adapters import twisted_connection
from twisted.internet import defer,reactor,protocol,task

. . .

credentials = pika.credentials.PlainCredentials(
            username=self.system_config.username,password=self.system_config.password)

    parameters = pika.ConnectionParameters(
        host=self.system_config.host,credentials=credentials,port=self.system_config.port)

client_creator = protocol.ClientCreator(
            reactor,twisted_connection.TwistedProtocolConnection,parameters)

self._connection = client_creator.connectTCP(
            host=self.system_config.host,port=self.system_config.port,timeout=5)

在这种情况下,self._connection 对象是 None。如果我尝试使用 pika 版本 0.9.14 执行此操作,则此对象中将是这样的对象 <pika.adapters.twisted_connection.TwistedProtocolConnection object at 0x7f90bbbf51d0>

我做错了什么?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)