0

httpサーバーとhttpクライアントの簡単なコードを書きました。クライアントからxmlの形式でサーバーにメッセージを正常に送信できます。これが私のコードです。

client.py

from StringIO import StringIO
from twisted.internet import reactor
from twisted.web.client import Agent
from twisted.web.http_headers import Headers

from twisted.web.client import FileBodyProducer
from xml_dict import bm_xml

xml_str = bm_xml()
agent = Agent(reactor)
body = FileBodyProducer(StringIO(xml_str))

d = agent.request(
   'GET',
   'http://localhost:8080/',
    Headers({'User-Agent': ['Replication'],
            'Content-Type': ['text/x-greeting']}),
    body)

def cbResponse(response):
    print response.version
d.addCallback(cbResponse)

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

reactor.run()

サーバー.py

from twisted.web import server, resource
from twisted.internet import reactor

def parse_xml(xml_str):
  print xml_str
  response = "xml_to_client"
  return response



class Simple(resource.Resource):
     isLeaf = True
     def render_GET(self, request):
        xml_request_str = request.content.read()
        response = parse_xml(xml_request_str)
        print response

 site = server.Site(Simple())
 reactor.listenTCP(8080, site) 
 reactor.run()

私がここでやろうとしているのは、クライアントから xml 文字列をサーバーに送信することです。xml は別のファイルである bm_xml モジュールから生成されます。この xml はサーバーに正常に読み込まれます。サーバーが xml を受信したら、この xml を解析して別の xml 文字列を返す必要があります。クライアントがサーバーからこのxmlを受信できるように、xmlを解析して別のxmlを構築するコードがありますが、サーバーからクライアントにメッセージを送信する方法がわかりません。サーバーまたはクライアントで、すべての変更が必要な場所はどこですか? クライアントで変更を行う必要があるのは 1 つであると想定しcbresponseていますが、サーバー側で変更を行う必要がある場所がわかりません。サーバーresponse変数には、クライアントに送信する必要がある変数があります。

4

2 に答える 2

2

あなたのコードは、あなたが求めていることをすでに行っているようです。 Simple.render_GET戻りますresponse。 responseクライアントに送信されるものです。おそらく、クライアントに送信された後に応答を取得する方法がわからないことがありますか? もしそうなら、答えはreadBody ( more docs ) かもしれません。

于 2013-06-06T10:32:08.093 に答える
0

私が欲しかったものを見つけました：これは client.py の私の更新されたコードです

 from StringIO import StringIO

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

 from twisted.web.client import FileBodyProducer
 from xml_dict import bm_xml

 xml_str = bm_xml()
 agent = Agent(reactor)
 body = FileBodyProducer(StringIO(xml_str))

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

     def dataReceived(self, bytes):
        if self.remaining:
            reply = bytes[:self.remaining]
            print reply

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


  d = agent.request(
   'POST',
   'http://localhost:8080/',
    Headers({'User-Agent': ['Replication'],
            'Content-Type': ['text/x-greeting']}),
    body)

  def cbRequest(response):
      finished = Deferred()
      response.deliverBody(BeginningPrinter(finished))
      return finished

  d.addCallback(cbRequest)

  def cbShutdown(ignored):
  reactor.stop()

  d.addBoth(cbShutdown)
  reactor.run()

これは私のserver.pyです

  from twisted.web import server, resource
  from twisted.internet import reactor
  from xml_parser import parser
  from twisted.web.resource import Resource

  def parse_xml(xml_str):
       print xml_str
       xml_response = parser(xml_str)
       return xml_response

 class re_simple(Resource):
       isLeaf = True
       def render_POST(self, request):
            xml_request_str = request.content.read()
            xml_response = parse_xml(xml_request_str)
            return xml_response

 site = server.Site(re_simple())
 reactor.listenTCP(8080, site)
 print "server started"
 reactor.run()

今度は Request:<some Xml>をサーバーに送信し、サーバーから応答を取得します<some response>。

これが私が欲しかったものです。

于 2013-06-06T17:05:43.350 に答える