pyAMF.django的处理机制

androider

既然跟django结合，就应该有一套处理request，response的机制。
pyamf里对应的就是 pyamf.remoting.gateway.django模块。打开能看到有一个类class DjangoGateway(gateway.BaseGateway)，它就是整个处理流程的主干。仅仅需要在views.py中建立一个DjangoGateway实例，这个实例是urlmap对应的处理函数，它把从django底层传递过来的request（其实是AMF编码过的）解码，并映射相应的python对象，然后执行注册的RPC方法（就是flex调用amf过程中看到的方法调用）返回一个response，最后用AMF机制编码这个response，返回给 django。这样django再通过层层处理返回这个AMF信息给flex。如此便是一个完整的amf PRC调用过程。很多的server基本上都是基于类似的机制，通过中间件层层过滤request和response，达到隔离底层处理的目的。最后我们能看到，django内部处理amf的调用是如此之简单。

DjangoGateway有两个方法很重要，一个是__call__（python的特殊名字方法，自己定义的方法不能用这些名字哦，__call__使得对象能像方法那样用，比如有对象a，执行a()相当于执行a.__call__()。也许可以猜到了，没错，在django里urlmap需要有一个对应的处理函数，__call__就是起这个处理函数的作用）。还有一个就是getResponse方法。它的作用是处理解码后的request，这是一些很普通的方法调用，因为request已经AMF解码了，它会寻找合适的PRC方法（选择的依据就是 AMF指定的方法名，也就是flex调用amf url时的方法名）来处理request。
    def getResponse(self, http_request, request):        """        Processes the AMF request, returning an AMF response.         @param http_request: The underlying HTTP Request.        @type http_request: C{HTTPRequest}        @param request: The AMF Request.        @type request: L{Envelope}        @rtype: L{Envelope}        @return: The AMF Response.        """        response = remoting.Envelope(request.amfVersion, request.clientType)         for name, message in request:            processor = self.getProcessor(message)            response[name] = processor(message, http_request=http_request)         return response     def __call__(self, http_request):        """        Processes and dispatches the request. 解码request，并处理         @param http_request: The C{HTTPRequest} object. 来自django底层的httprequest对象，body还是被AMF编码的        @type http_request: C{HTTPRequest}        @return: The response to the request. 返回一个AMF编码过的response对象        @rtype: C{HTTPResponse}        """        if http_request.method != 'POST':            return http.HttpResponseNotAllowed(['POST'])         context = pyamf.get_context(pyamf.AMF0)        stream = None        http_response = http.HttpResponse()         # Decode the request 解码request对象        try:            request = remoting.decode(http_request.raw_post_data, context)        except pyamf.DecodeError:            self.logger.exception(gateway.format_exception())            http_response.status_code = 400             return http_response         self.logger.debug("AMF Request: %r" % request)         # Process the request 处理request，这里它调用了getResponse，就会按照指定的方法名来正式处理request        try:            response = self.getResponse(http_request, request)        except (KeyboardInterrupt, SystemExit):            raise        except:            self.logger.exception(gateway.format_exception())             return http.HttpResponseServerError()         self.logger.debug("AMF Response: %r" % response)         # Encode the response 编码response，在返回之前要用AMF编码好        try:            stream = remoting.encode(response, context)        except pyamf.EncodeError:            self.logger.exception(gateway.format_exception())             return http.HttpResponseServerError('Unable to encode the response')         buf = stream.getvalue()        http_response['Content-Type'] = remoting.CONTENT_TYPE        http_response['Content-Length'] = str(len(buf))        http_response['Server'] = gateway.SERVER_NAME        http_response.write(buf)         return http_response