一个简单RPC框架是如何炼成的(IV)——实现RPC消息的编解码

class Request(object):
    def __str__(self):
        return str({'id':self.id,  'command':self.command, 'parameter':self.parameter})

    @classmethod
    def encode(cls, message):
        if isinstance(message, Request):
            return str(message)
        elif isinstance(message, Response):
            return str(message)
        elif isinstance(message, Notification):
            return str(message)
        else:
            raise Exception('unknown type when encode')

@classmethod    
    def decode(cls, data):
        info = eval(data)
        if 'command' in info:
            request = Request()
            request.id = info.get('id')
            request.command = info.get('command') 
            request.parameter = info.get('parameter', {})
            return request
        elif 'result' in info:
            response = Response()
            response.id = info.get('id')
            response.result = info.get('result')
            return response
        elif 'message' in info:
            note = Notification()
            note.message = info.get('message')
            return note
        else:
            raise Exception('unknown data when decode')

• Request和Resonse的定义可以一直不变，
• encode 和decode方法，如孙大圣，是可以千变万化的。如果采用xml或者json或者其他的描述，只要自定义encode和decode方法即可
• 从更高的层次看，RPC消息，其实就是对函数调用的一个描述，所以充其量就是view。既然是view，实际自由度是很大的。

版权声明：本文为博主原创文章，未经博主允许不得转载。