6

我知道使用“transport.write()”我可以传输字符串对象，但我想知道这是否可以传输其他类型的数据，比如 python 类对象？如果有可能我该怎么做？

4

3 回答 3

3

您可以设计一些任意的自定义协议，但使用为此目的已经存在的框架可能会更有效率，例如 google 的协议缓冲区，它允许您轻松定义有效的消息传递结构，并且已经支持 python。

JSON 是一个简单的替代方案，很多人只是使用压缩的 json 对象，因为它很容易并且默认内置在 python 中，但是结果很慢，具有不可预测的大小工件（对于许多小消息，压缩通常大于未压缩的输出） ，并且是传输二进制数据的不良解决方案。

编辑：哦，是的，不要使用泡菜。

于 2014-01-05T11:03:52.850 回答
2

您可以使用json序列化对象。几乎所有 Python 对象都是 json 可序列化的，如果不是，那么您可以编写自己的编码器-解码器来处理它们。但是不要使用eval来解码输入。

于 2014-01-04T12:44:25.837 回答
-2

传输层的作用是将数据写入物理连接。它处于低抽象级别，python 类对象到字节的映射在协议栈的上层处理得更好。

因此，处理此问题的一种方法是编写一个接受 python 对象的自定义协议，将其转换为字节表示形式，然后将其推送到传输中，因为我写这个 Ashwini 的答案刚刚弹出建议泡菜，所以我们'将使用它来定义我们的自定义协议

import pickle 
from twisted.internet.protocol import Protocol, ClientFactory
from twisted.internet import reactor
from twisted.internet.endpoints import TCP4ClientEndpoint


class ClassSender(Protocol):

    def dataReceived(self, data):
        print pickle.loads(data)

    def writeObject(self, _object):
        pickle.dump(_object,self.transport)


class ClassSenderFactory(ClientFactory):
    def buildProtocol(self, addr):
        return ClassSender()

class MyClass(object):
   def __init__(self,data):
       self.data = data

def SendObject(protocol):
    print "Sending"
    protocol.writeObject(MyClass('some sample data'))


point = TCP4ClientEndpoint(reactor, "localhost", 8000)
d = point.connect(ClassSenderFactory())
d.addCallback(SendObject)

reactor.run()

此示例代码尝试连接到 TCP 上的端口 8000 (localhost)。建立连接后，我们获取一个样本对象，将其腌制并将其推送到传输器上。

相反，当接收到数据时，我们会尝试将其解压并将其打印到控制台。

要查看实际情况，请运行回显服务器（http://twistedmatrix.com/documents/current/core/examples/echoserv.py）并运行，然后运行示例代码以查看示例对象从回显服务器反弹。

这样做的问题是需要考虑很多极端情况。如果数据被分成两个块，我们不能在一次调用中解压它怎么办？幸运的是，twisted 提供了一个现成的类来处理这个所谓的透视代理。如果您可以控制电线的两端，这可以为您解决很多这些问题。看看：https ://twistedmatrix.com/documents/12.2.0/core/howto/pb-intro.html

于 2014-01-04T13:26:29.287 回答