LOCK:IPFS技术系列 | 揭秘IPFS数据交换模块Bitswap

导?读

本文为IPFS系列文第4篇,详解IPFS的核心模块——Bitswap。

星际文件系统是一个旨在创建持久且分布式存储和共享文件的网络传输协议。

与传统的文件系统不同,它是一种基于内容寻址的点对点超媒体分发协议。

IPFS网络中的节点构成一个分布式文件系统网络,其中Bitswap是IPFS的核心模块,负责与网络中其他节点之间请求和发送数据块。

图1

IPFS将文件分解为称为block的数据块,这些块由内容标识符标识。?

IPFS文件内容存储在不同的节点上,每个节点存储rootblock,少量节点存储完整文件数据,大部分节点存储部分文件block。因为block分散存储在不同节点,Bitswap协议解决了从多个节点高效获取全部数据块的问题。

金色算力云副总裁:IPFS有变革的能力,Fileocin存在短期价格泡沫:金色财经报道,在7月28日举办的《家里有矿 | Filecoin:革命or泡沫?》的直播节目中,金色算力云副总裁Maggie表示,从二级市场的角度,我主要从三个方面,来讨论Filecoin价格火热的原因。

1.基于供需关系角度,70%的币都是通过挖矿获得,早期投资人可抛售Filecoin量少。

2.基于经济模型的角度,主网上线后,矿工需要自行购买Filecoin来进行质押,才能参与挖矿,已经开通Filecoin的交易所也需要购买去给到用户交割。

3.挖矿角度,因为主网上线后,需要从0开始往里填充有效算力,才能挖矿,也就是前期能够挖出来的fileocin量也比较少。这三方面导致用户在二级市场一片看多,挖矿的头矿红利也就尤为明显。综合来说,我认为IPFS有变革的能力,Fileocin也存在短期价格泡沫,这将持续到主网上线后的一段时间,但是吹掉泡沫后,也是真实存在底层应用价值去支撑前行的。我们看到有很多的开发者都致力于其中的发展,未来还是很有想象空间的。[2020/7/28]

图2?多节点文件存储示意图

总体架构

本文基于Bitswapv0.3.3版本进行分析。

IPFS向Bitswap获取block,Bitswap是IPFSexchange接口的具体实现,负责完成IPFS网络数据交换功能。

人人矿场IPFS技术背景展露,同步发布两大研究成果:7月18日,人人矿场作为冰河分布式存储实验室成员,联合戴尔中国、上海储迅、启赋资本等机构举行实验室发布会。宣布两大研究成果:雅典娜矿池和星矢矿机同步亮相。雅典娜矿池具有高性能、高并发、高扩展、高可靠、高安全的“五高”特点;单个星矢矿机测试网每日有效封存量达到了2TB。

人人矿场以星矢矿机为IPFS算力产品矿机原型,接入雅典娜矿池的测试网矿工号:t0118768(标签RRM),目前有效存力排名位于全球前4,爆块率保持前三。[2020/7/18]

图3?Bitswap组件架构图

Bitswap协议内容比较繁琐,为了降低实现复杂度协议划分为block请求模块、block发送模块、会话管理模块、block提供者发现模块、网络模块等。

Bitswap模块负责接收新的消息并且提供对外数据交换接口。

session管理模块用来管理多个session,每个session管理一组文件的下载,来提高下载效率。

block发送模块负责管理向其它节点发送数据块。block请求模块负责管理数据块的请求。block提供者发现模块负责通过DHT网络发现网络中的数据块,通常session找不到已拥有所需block的节点时会调用此模块进行数据块发现。

协议概述

为了完成节点间block交换,Bitswap定义了通信消息及通信协议。

币赢即将于今日14时开启第三轮IPFS抢购活动:据官方消息,第三轮“IPFS打折抢购”活动,可享受8折抢购优惠,所有完成CoinW实名认证的用户提前购买USDT,即可参与本次抢购活动。首轮抢购时间为今天下午14:00开启,共90分钟抢购时间,详见原文链接。[2020/7/3]

图4

Bitswap消息处理流程:

1、IPFS请求文件区块,Bitswap发送want-have消息携带CID1信息到连接的所有节点。节点根据自己是否有CID1文件块返回have或dont-have消息。

2、client向拥有CID1的节点发送want-block消息,节点返回相应的block消息。

3、当没有节点有请求的block,Bitswap广播want-have到所有的连接节点,或者通过DHT查找拥有文件区块的节点。

模块详解

▲?Bitswap模块

Bitswap模块负责接收新消息并且实现对外的数据交换接口。

当接收到新消息后,Bitswap处理流程:

币赢即将开展第11期Fansup“IPFS打折抢购”活动:据官方消息,币赢即将开展第11期Fansup“IPFS打折抢购”活动,可享受3折超低抢购优惠,所有完成CoinW实名认证的用户提前购买USDT,即可参与本次抢购活动。首轮抢购时间为今天下午14:00开启,共90分钟抢购时间,详情见原文链接 。[2020/7/1]

1、记录有关消息的一些统计信息

2、通知发送模块wants消息,这样数据发送模块可以根据实际情况向需求节点发送响应消息。

3、通知发送模块任何收到的blocks,发送模块根据节点的需求列表可以将接收到的块发送给任何需要它们的节点

4、向SessionManager通知接收到的blocks,HAVEs和DONT_HAVEs消息,这样SessionManager可以通知消息相关的session。

Bitswap通过FacadePattern提高了模块使用的便利性,使得Bitswap子系统的用法变得简单,避免了IPFS和Bitswap的高度耦合。

▲?Session管理模块

session管理模块用来管理多个数据块下载session,每个session管理一组文件的下载。

当SessionManager收到新消息时,它将

1、通知BlockPresenceManager组件跟踪每个block。

嘉楠耘智辟谣:目前还没有相关布局IPFS的计划:5月14日中午,嘉楠耘智官方公众号发布辟谣声明称,近日,有行业自媒体在未经查证的情况下,公开发布了关于嘉楠耘智联系某头部IPFS/Filecoin企业合作,以及布局IPFS挖矿等虚假谣言。嘉楠区块链从2016年成立以来,就积极关注所有POW相关区块链技术,IPFS分布式存储技术兴起后,在研究IPFS技术的同时,与IPFS领域内的专业机构保持深度技术交流,但这与嘉楠耘智布局IPFS并无关系。目前,嘉楠耘智还没有相关布局IPFS的计划。[2020/5/14]

2、通知对接收到的block感兴趣并想要的Sessions。

3、通知PeerManager组件收到的block,PeerManager检查是否有任何wants被发送到节点以接收已经收到的块。?如果是这样,它将向那些节点发送“CANCEL”消息,防止其它节点重复发送消息。

Session管理模块通过协调多个session的数据需求来提高数据交互的效率,避免数据块的重复请求、发送。

▲?Session模块

Session管理一组文件的下载,用来提高一组文件块,比如单个文件下载效率。当IPFS调用Bitswap时,Bitswap会创建一个新的Session并调用Session的相应方法,比如GetBlocks()获取blocks。Session会管理一个节点列表,数据获取过程只会向session中的节点获取数据,而不是所有的连接节点。当Session中的节点都没有某个block时,Bitswap才会通过DHT获取具有block的节点并加入session。

由于session刚开始没有任何节点,处于“discovery”模式。当IPFS最初从session请求block时,该session处理流程如下:

1、通知SessionInterestManager组件它感兴趣的block。

2、通知sessionWantManager组件需要的block。

3、通知PeerManager组件向连接节点发送“want-have”消息,以发现哪些节点有需要的block。

4、查询ProviderQueryManager组件以发现哪些节点具有该block。

当session收到带有“HAVE”或“block”的消息时,它将通知SessionPeerManager组件。

当session收到带有“block”的消息时,它将通知SessionInterestManager组件。

一旦session具有节点,就不再处于“discovery”模式。当IPFS请求后续block时,session将通知sessionWantSender组件。sessionWantSender组件通知PeerManager组件向会话中的节点发送“want-have”和“want-block”消息。

对于session所需的每个block,sessionWantSender组件通过与BlockPresenceManager组件核对哪些节点已为该block发送了“HAVE”,来确定哪个节点最有可能拥有该block。如果多个节点发送过“HAVE”,则会根据先前请求回复速度来选择节点。

由于DHT内容发现速度慢并且网络带宽消耗大,session通过向一组含有目标数据块可能性大的节点获取数据,从而大大提高了数据块获取的效率。

▲?Block发送模块

block发送模块负责管理向其它节点发送数据块,包含节点需求管理组件和消息发送任务队列。

Engine是block发送模块的处理类,当Engine被告知有新的wants时

1、将want添加到Ledger,Ledger会存储每个节点的需求列表。

2、检查blockstore中的相应block,并将任务添加到PeerTaskQueue组件。如果block库没有想要的block,则添加“DONT_HAVE”任务;如果blockstore有block,对于“want-have”添加了“HAVE”任务,对于“want-block”添加了“block”任务。

3、当Engine收到新block的消息时,它会检查Ledger以查看是否有节点需要此block。对于发送“want-have”的每个节点向PeerTaskQueue组件添加一个?“HAVE”任务,对于为发送了“want-block”的每个节点,向PeerTaskQueue组件添加一个“block”任务。

4、Engine会定期从PeerTaskQueue组件中取出任务,并创建带有“blocks”,“HAVEs”和“DONT_HAVEs”的消息。

PeerTaskQueue组件通过对任务进行优先级排序,发送队列中数据量最少的节点方具有最高优先级,通过这种流控措施,提高数据块发送处理效率。

▲?数据块请求模块

Block请求模块负责管理数据块的请求。PeerManager组件为连接到Bitswap的每个节点创建一个MessageQueue组件,记录了“want-have”?、“want-block”已发送到哪个节点,并将任何新的wants定向到正确的节点。并且MessageQueue组件通过合并多个want为一条消息,然后将该消息发送给节点,从而提高了消息发送效率。

▲?内容发现模块

当Bitswap找不到已拥有所需block的节点时,它会使用DHT进行内容发现。Bitswap通过ProviderQueryManager组件管理这些请求,ProviderQueryManager组件对请求进行速率限制,并对进行中的请求进行重复删除处理。

总结

Bitswap作为IPFS网络数据交换接口的具体实现,设计并实现了一套高效的节点间交换数据的协议。

协议主要关注点是如何快速、高效获取需要的block,其中包括节点选择策略,如何最大化利用每个节点的能力。

Bitswap通过FacadePattern提高了模块使用的便利性,在具体实现上解耦复杂依赖到各功能模块,从而降低系统实现的复杂度。

作者简介

马耀耀来自数据网格实验室BitXMesh团队研究方向:P2P网络、数据安全传输

参考资料

https://github.com/ipfs/go-bitswap/blob/master/docs/how-bitswap-works.md

https://github.com/ipfs/specs/blob/master/BITSWAP.md

郑重声明: 本文版权归原作者所有, 转载文章仅为传播更多信息之目的, 如作者信息标记有误, 请第一时间联系我们修改或删除, 多谢。

金星链

[0:15ms0-0:961ms