Python bsonrpc源码是什么

发布时间:2021-03-15 10:46:10 作者:TREX
来源:亿速云 阅读:235

这篇文章主要介绍“Python bsonrpc源码是什么”,在日常操作中,相信很多人在Python bsonrpc源码是什么问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Python bsonrpc源码是什么”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

bsonrpc 是python中⼀个基于json或bson的远程过程调⽤的库,提供了服务端与客户端实现,其底层采⽤的是基于TCP连接的通信。

程序结构

Python bsonrpc源码是什么

bsonrpc主要包括以下⽂件:

  1. concurrent.py:针对两种并发⽅式(threading线程对象、gevent协程对象)涉及的相应组件(Queue,Event,Lock等)提供统⼀的对外的⽣成接⼝:spawn(),new_promise(),new_queue(), new_lock()等;

  2. definitions.py:定义rpc的消息结构和错误编码;

  3. dispatcher.py:rpc的处理调度,路由处理(消息对应的处理函数);

  4. exceptions.py:异常定义;

  5. framing.py:定义不同类实现JSON RPC 2.0标准中的不同消息结构;

  6. interfaces.py:定义提供服务的装饰器;

  7. misc.py:该⽂件中定义了⼀个id⽣成器,从1开始累加。

  8. options.py:定义配置选项。

  9. rpc.py:主要为BSONRpc和JSONRpc类的实现;

  10. socket_queue.py:主要为消息的拆包组包部分;

  11. util.py:系统⼯具。

本⽂主要描述库包中对于不同协议的分包组包的处理,涉及到socket_queue.py和framing.py⽂件,主要采⽤的是对象组合的技术。

解读

socket_queue.py中的SocketQueue类是⽤来处理从socket接收数据,主要的⽅法为_receiver()和put()⽅法,分别对应分包和组包,分包的主要内容如下:

def _receiver(self):
  bbuffer = b''
  while True:
    try:
      chunk = self.socket.recv(self.BUFSIZE) # 从socket上接收数据
      bbuffer = self._to_queue(bbuffer + chunk) # 数据分包
    except DecodingError as e:
      self._queue.put(e)
    # 后⾯省略...
def _to_queue(self, bbuffer):
  b_msg, bbuffer = self.codec.extract_message(bbuffer) # 解码器提取完整的信息
  while b_msg is not None:
    self._queue.put(self.codec.loads(b_msg)) # 解码后的消息放⼊消息队列中等待处理
    b_msg, bbuffer = self.codec.extract_message(bbuffer)
  return bbuffer

组包的主要内容如下:

def put(self, item):
  if self._closed:
    raise BsonRpcError('Attempt to put items to closed queue.')
  msg_bytes = self.codec.into_frame(self.codec.dumps(item)) # 组包
  with self._lock:
    self.socket.sendall(msg_bytes)

Python bsonrpc源码是什么

如上图所示,程序采⽤的是对象组合的⽅式实现消息分包处理的。对象组合是继承之外的另⼀种选择,对象组合要求被组合的对象具有良好定义的接⼝,通过接⼝的⽅式调⽤其他对象的功能,这个也被“⿊箱复⽤”,因为对象的内部细节是不可⻅的。SocketQueue中依赖Codec的extract_message()接⼝⽅法,不⽤关⼼其具体的实现⽅法。具体实现由JSONCodec和BSONCode进⾏实现。JSONCodec中依赖JSONFrame中的extract_message()接⼝⽅法,该接⼝⽅法的实现由JSONFramingNone、JSONFramingNetstring、JSONFramingRFC7464进⾏实现。SocketQueue消息组包过程依赖于into_frame()⽅法,也是通过对象组合实现的。

注:图中的接⼝为了⼤家容易理解才加上了,源码⾥⾯并没有。

到此,关于“Python bsonrpc源码是什么”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!

推荐阅读:
  1. python程序文件扩展名知识点详解
  2. python中turtle是什么

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

python bsonrpc 源码

上一篇:php7 curl怎么开启

下一篇:c# 如何实现发送邮件到指定邮箱

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》