在 Twisted 客户端中生成标头

Question

我正在使用 Twisted Web“HTTPClient”协议与 http 服务器对话（使用 Twisted 应用程序作为客户端），问题是我的大多数请求不接受我的标头。是否有某种方法（也许使用某些库）来生成标头？ 我将发布一些代码，以便您可以查看

class Local(HTTPClient):
def generateHeaders(self, type=None):
    self.sendHeader('User-Agent', 'Twisted Web Client')
    if type:
        self.sendHeader('Content-Type', 'x-www-form-urlencoded')
    self.sendHeader('Accept', '*/*')
    self.sendHeader('Host', 'localhost')
    self.endHeaders()

def connectionMade(self):
    ## GENERATE ID
    self.userid= self.generateID()
    self.sendCommand('POST', '/chat/action=join&user=pirosb3')
    self.generateHeaders(type=True)

def dataReceived(self, data):
    print data

如您所见，我创建了一个为我生成标头的方法，但我必须说效率不是很高，我总是收到错误响应。

有人知道解决办法吗？

谢谢

Answer 1

我绝对推荐您使用 Twisted 的 Agent 类以及 twisted.web.http_headers 模块中的 Header 类。

此处提供了一个很好的指南。

如果您需要一个现实生活中的 Twisted HTTP 客户端示例，该客户端向请求添加一些标头并可以读取答案的标头，这里是：

from pprint import pformat

from twisted.internet import reactor
from twisted.internet.defer import Deferred
from twisted.internet.protocol import Protocol
from twisted.web.client import Agent
from twisted.web.http_headers import Headers

class BeginningPrinter(Protocol):
    def __init__(self, finished):
        self.finished = finished
        self.remaining = 1024 * 10

    def dataReceived(self, bytes):
        if self.remaining:
            display = bytes[:self.remaining]
            print 'Some data received:'
            print display
            self.remaining -= len(display)

    def connectionLost(self, reason):
        print 'Finished receiving body:', reason.getErrorMessage()
        self.finished.callback(None)

agent = Agent(reactor)
d = agent.request(
    'GET',
    'http://example.com/',
    Headers({'User-Agent': ['Twisted Web Client Example']}),
    None)

def cbRequest(response):
    print 'Response version:', response.version
    print 'Response code:', response.code
    print 'Response phrase:', response.phrase
    print 'Response headers:'
    print pformat(list(response.headers.getAllRawHeaders()))
    finished = Deferred()
    response.deliverBody(BeginningPrinter(finished))
    return finished
d.addCallback(cbRequest)

def cbShutdown(ignored):
    reactor.stop()
d.addBoth(cbShutdown)

reactor.run()