首先来确定一下数据交换层需要对上层协议提供的基本功能，上图是IPFS的交换层接口设计，他要求具体的交换层实现者需要提供查找数据和交换数据的功能，这些都是交换层需要满足的最小功能集合。
接下来我们逐个接口讲解器实现逻辑，首先我们讲解获取指定一组key对应的数据接口:GetBlocks
上图是GetBlocks()接口的第一步，就是将获取一组key对应的data这个请求发送到数据交换层的不同组件中去，通知各个模块，新的任务到来。
第一步，首先将所有的key交给PubSub模块，将所有的key加入到一个叫做notification Queue的订阅队列中，这个订阅队列是一个管道组，管道组的长度依据key的个数来决定。管理这个管道队列是一个循环协程。每当有订阅的key对应的数据block到来，那么就生成一个从want list删除的请求，将已经获得的数据对应的key从want list删除，如图中的步骤4表示的数据方向。
第二步，将本组key打包成一个请求数据项加入到Incoming Queue中，这是一个请求缓存，大小固定为10，专门用来存储获取数据的请求和取消数据请求的请求。这个队列的使用在接下来的小节中还会继续讲到。他的作用是起到一个缓存关于数据的请求的作用。
第三步，将这一组key的第0个元素作为findkeys Queue的元素插入，该队列的长度为32固定大小。该队列的详细使用方式接下来会进行详细的解释。
第五步，从Incoming Queue中将各项操作取出，判断一下操作类型，根据数据的ID，我们有key-value的map，map中的每一项都是一个消息队列，如果操作类型是增加，则将操作类型中携带的key加入到队列，如果是删除，怎根据key将数据从消息队列中删除。这里需要指出的是，本步骤中使用的run loop会对两类want list进行操作，一个是普通的want list，一个广播式的want list。广播式的want list存储的是没有制定查询节点的待查key数据，普通的want list是由发起者指定查询节点对象，来查找固定的key数组。
对于普通的want list列表，有一个协程定时从列表中随机选择一个key加入到Findkeys Queue中，对于Findkeys Queue，有一个协程专门管理这个队列，它将其中一个元素取出之后，访问数据交换协议的网络接口，询问网络，有哪些节点能够提供关于该元素（该元素中存有数据对应的key值）的数据，这个网络接口会调用底层的路由层来查找对应的节点。
网络接口返回关于某一key的数据提供者列表，这些列表存储的元素是Peer Info，这些信息是用于网络层(网络层是最底层，之后是路由层，然后才是本节讲的数据交换层，不熟悉的同学可以查看之前的章节)建立数据连接的基本信息。数据交换层有一个host对象，该对象用于管理与数据交换层与网络层之间的网络链接信息。通过该对象，数据交换层与返回的所有网络层节点直接建立链接。
总结，本节主要站在一个接受GetBlocks()接口命令的节点来分析其处理流程，重点描述了当接收到这样的指令之后，节点通知各个队列来缓存这个指令并进行全网数据查询，并与相关的节点建立直接网络层链接，下一节我们将站在数据提供者或者数据中转者的角度来分析整个获取数据的过程如何实现的。
网友评论