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

以前咱们制定了一个很是easy的RPC消息 的格式，但是还遗留了两个问题，上一篇解决掉了一个。还留下一个

• 咱们并无实现对应的encode和decode方法，没有基于可以跨设备的字符串传输，而是直接的内存变量传递。
• 现在的RPC request不支持带參数的请求命令。

  如add(a, b), 怎样在RPC消息中描写叙述參数a,b 。

如下咱们处理掉这个编解码问题。

实际的RPC应用基本都是跨机器链接。因此没法直接传递内存变量，也就是说还需要将消息编码成 诸如字符串一类的可以跨设备传输的内容。

详细的RPC消息的封装协议很是多。常见的是基于xml，json封装的。但假设抽象一下，实际也就是一个编解码，管你编码成什么内容呢。就是不编码也可以。管他黑猫白猫。仅仅要能传过去，就是好猫。

这里我仍是简单原则，重点在于晓义嘛。

利用python里的两个运算。

str 和eval。

若是 一个字典msg =  { 'a' : 1, 'b' : 2}.  那么str(msg) =   " { 'a' : 1, 'b' : 2}", 注意变成字符串喽。

        而后eval（" { 'a' : 1, 'b' : 2}"）-->msg， 作一个eval运算，又从字符串变成 字典变量了。

 

       因而编码时。先将RPC消息转换成dict，而后调用str编码成字符串。

         解码时。先调用eval 获得dict对象，而后再转换为详细的RPC消息对象

设计已定，剩下的就仅仅是code filling。

先改动一下原来Request的str方法。返回一个dict的字符串表示。对Response也作相似处理

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

而后引入encode方法

    @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')

相同的，引入decode方法，略微复杂一些。基本的麻烦在于怎样区分解码出来的是Response仍是Request

个人办法是比較投机的，直接依据字典的内容去推断。有command字段的确定是request，有result字段的确定是response

@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')

另外，client和server的代码也要稍做调整，那个很是easy，调用一下上面的 方法就可以了。这里不贴了。

over，RPC消息 这一块，咱们完全玩完了。

总结：

• Request和Resonse的定义可以一直不变。
• encode 和decode方法，如孙大圣。是可以变幻无穷的。假设採用xml或者json或者其它的描写叙述，仅仅要本身定义encode和decode方法就能够
• 从更高的层次看，RPC消息，事实上就是对函数调用的一个描写叙述，因此充其量就是view。既然是view。实际自由度是很是大的。