ipfs私有链环境搭建与java-sdk调用

2024-05-07 06:12

本文主要是介绍ipfs私有链环境搭建与java-sdk调用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

ipfs镜像文件

docker pull ipfs/go-ipfs

私有链密钥生成工具生成密钥文件

go get github.com/Kubuxu/go-ipfs-swarm-key-gen
cd $GOPATH/src/github.com/Kubuxu/go-ipfs-swarm-key-gen
go build
$GOPATH/src/github.com/Kubuxu/go-ipfs-swarm-key-gen > ~/swarm.key

在宿主机创建ipfs 的data、export目录

mkdir -p ~/ipfs/ipfs1/data ~/ipfs/ipfs1/export ~/ipfs/ipfs2/data ~/ipfs/ipfs2/export

把第2步生成的密钥文件分别拷贝至 ipfs 对应的 data 文件夹下

cp ~/swarm.key ~/ipfs/ipfs1/data 
cp ~/swarm.key ~/ipfs/ipfs2/data 

环境配置

分别启动 ipfs 两个容器

docker run -d --name ipfs_host1 --privileged=true --entrypoint="sh" -v ~/ipfs/ipfs1/export:/export -v ~/ipfs/ipfs1/data:/data/ipfs -p 4001:4001 -p 127.0.0.1:8085:8080 -p 5001:5001 ipfs/go-ipfs:latest -c "while true; do sleep 1;done"
docker run -d --name ipfs_host2 --privileged=true --entrypoint="sh" -v ~/ipfs/ipfs2/export:/export -v ~/ipfs/ipfs2/data:/data/ipfs -p 4011:5001 -p 127.0.0.1:9085:8080 -p 5011:5001 ipfs/go-ipfs:latest -c "while true; do sleep 1;done"

注意:启动命令中的参数说明。--entrypoint="sh" 由于 ipfs 容器的 dockerfile 中注明了 entrypoint 执行的命令,当直接运行容器后,容器会根据默认配置文件启动 ipfs 服务,并连接 ipfs 公网环境。由于我们需要搭建自己的私有链环境所以需要改写entrypoint执行我们制定的命令,并在容器中修改相应的配置文件,运行私有链环境。这里我们设置 entrypoint 运行 sh命令,并执行上诉命令最后部分的参数 -c "while true; do sleep 1;done",启动一个主进程来保持 ipfs 容器运行。

修改 ipfs 服务默认配置

docker exec -it ipfs_host1 sh
初始化节点配置
ipfs init

运行初始化命令后,会在/data/ipfs目录下创建启动配置信息,并且在屏幕中出现以下初始化信息

initializing IPFS node at /data/ipfs
generating 2048-bit RSA keypair...done
peer identity: QmcLnHDuhN7bCbdv5FRbYiTNKuqNhs1WSCUezFPt7F4vHJ
to get started, enter:ipfs cat /ipfs/QmcLnHDuhN7bCbdv5FRbYiTNKuqNhs1WSCUezFPt7F4vHJ/readme

记住ipfs_host1中的peer identity: QmcLnHDuhN7bCbdv5FRbYiTNKuqNhs1WSCUezFPt7F4vHJ信息,在后面启动 ipfs_host2服务的时候需要用到

删除默认配置中的引导节点信息
ipfs bootstrap rm --all
修改接口调用地址

打开服务启动配置文件

vi config

修改配置文件中 Addresses中的 API值:

"API": "/ip4/127.0.0.1/tcp/5001" --> "API": "/ip4/0.0.0.0/tcp/5001"

注意,修改后调用 sdk 初始化 IPFS 对象的时候才能远程访问 ipfs 服务。如果没有修改则初始化 IPFS 对象的时候则会出错。

环境启动

启动 ipfs 服务

启动 ipfs_host1服务

ipfs daemon

启动 ipfs_host2服务,注意下面的命令使用到ipfs_host1初始化时生成的peer identity

ipfs bootstrap add /ip4/宿主机ip/tcp/4001/ipfs/QmcLnHDuhN7bCbdv5FRbYiTNKuqNhs1WSCUezFPt7F4vHJ
ipfs daemon

环境验证

进入 ipfs_host1容器中执行以下命令

cd ~
echo test > test.txt

上传文件

ipfs add text.txt

ipfs 上传文件后会有如下提示信息反馈

added QmeomffUNfmQy76CQGy9NdmqEnnHU9soCexBnGU3ezPHVH test.txt

其中QmeomffUNfmQy76CQGy9NdmqEnnHU9soCexBnGU3ezPHVH就是文件test.txt的hash值

ipfs 是根据文件内容进行 hash 只要文件内容不变,只修改文件名是不会影响最终的上链文件 hash 值的。

进入 ipfs_host2容器中验证上传文件
执行文件查看命令,查看文件内容

ipfs cat QmeomffUNfmQy76CQGy9NdmqEnnHU9soCexBnGU3ezPHVH

执行命令后,控制台会返回查询结果:test

至此,ipfs 私有网络搭建成功。

java-ipfs-http-client的使用

pom.xml中添加依赖,这里需要根据 github 上的版本修改$LATEST_VERSION的值

  <repositories><repository><id>jitpack.io</id><url>https://jitpack.io</url></repository></repositories><dependencies><dependency><groupId>com.github.ipfs</groupId><artifactId>java-ipfs-http-client</artifactId><version>$LATEST_VERSION</version> </dependency></dependencies>

使用ipfs上传文件以及下载文件

// 实例化ipfs对象
IPFS ipfs = new IPFS("/ip4/10.121.60.26/tcp/5001");//保存上传文件
NamedStreamable.FileWrapper savefile = new NamedStreamable.FileWrapper(new File("/Users/song/Documents/book/test1.pdf"));
MerkleNode result = ipfs.add(savefile).get(0);
System.out.println(result.toJSONString());//返回结果里面获取保存文件的唯一hash,基于文件内容的 hash//下载文件
Multihash filePointer = Multihash.fromBase58("Qmc51yHGyaxdRsUwBozP9tQuTRQuXLkZv3sPEcpSgb8BxP");//参数为文件 hash
byte[] fileContents = ipfs.cat(filePointer);//保存文件
File downloadfile = new File("/Users/song/Documents/aaa.pdf");if(!downloadfile.exists()) {downloadfile.createNewFile();
}FileOutputStream fop = new FileOutputStream(downloadfile);
fop.write(fileContents);
fop.flush();
fop.close();

ipfs命令手册 / ipfs命令行简介 - 汇智网 (hubwiz.com)
 

搭建2

environment:
操作系统: CentOS Linux release 7.5.1804 (Core)
docker: v0.4.22
go: go1.13.3 linux/amd64

  • 准备两台centos设备
    两台机器ip分别为:10.252.101.3和10.252.101.4
    两台机器分别安装一样的环境

  • docker安装

yum install docker
systemctl enable docker # 开机启动
systemctl start docker  # 启动docker
  • ipfs镜像安装

docker pull ipfs/go-ipfs
  • 创建ipfs容器

docker run -d --name ipfs_host \ -v /ipfs/export:/export \      -v /ipfs/data:/data/ipfs \      -p 4001:4001 \                  -p 5001:5001 \-p 8000:8080 \ipfs/go-ipfs:latest
  • 生成并分发一个共享key
    在10.252.101.3设备上生成key,然后放在两台机的/ipfs/data目录下。
    注意:两台设备的key要一样才能同步

go get -u github.com/Kubuxu/go-ipfs-swarm-key-gen/ipfs-swarm-key-gen$GOPATH/ipfs-swarm-key-gen > swarm.key
  • 移除默认的boostrap节点
    两台设备都执行:

docker exec ipfs_host ipfs bootstrap rm --all
  • 添加节点创建网络

    • 在10.252.101.3上查看id
    docker exec ipfs_host ipfs id
    
    • 然后在10.252.101.4上增加节点
    docker exec ipfs_host ipfs bootstrap add /ip4/10.252.101.3/tcp/4001/ipfs/QmbfswPyEdVmseUYH3g5i14m3y22Gf69BJ2uetB78cUhea
    
  • 重启服务(两台设备)

docker restart ipfs_host
  • 查看邻居

这篇关于ipfs私有链环境搭建与java-sdk调用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/966547

相关文章

Java中流式并行操作parallelStream的原理和使用方法

《Java中流式并行操作parallelStream的原理和使用方法》本文详细介绍了Java中的并行流(parallelStream)的原理、正确使用方法以及在实际业务中的应用案例,并指出在使用并行流... 目录Java中流式并行操作parallelStream0. 问题的产生1. 什么是parallelS

Java中Redisson 的原理深度解析

《Java中Redisson的原理深度解析》Redisson是一个高性能的Redis客户端,它通过将Redis数据结构映射为Java对象和分布式对象,实现了在Java应用中方便地使用Redis,本文... 目录前言一、核心设计理念二、核心架构与通信层1. 基于 Netty 的异步非阻塞通信2. 编解码器三、

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代

一篇文章彻底搞懂macOS如何决定java环境

《一篇文章彻底搞懂macOS如何决定java环境》MacOS作为一个功能强大的操作系统,为开发者提供了丰富的开发工具和框架,下面:本文主要介绍macOS如何决定java环境的相关资料,文中通过代码... 目录方法一:使用 which命令方法二:使用 Java_home工具(Apple 官方推荐)那问题来了,

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述:HashMap的宏观结构二、核心数据结构解析1. 数组(桶数组)2. 链表节点(Node

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点(如日志、事务)与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么?二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关

详解SpringBoot+Ehcache使用示例

《详解SpringBoot+Ehcache使用示例》本文介绍了SpringBoot中配置Ehcache、自定义get/set方式,并实际使用缓存的过程,文中通过示例代码介绍的非常详细,对大家的学习或者... 目录摘要概念内存与磁盘持久化存储:配置灵活性:编码示例引入依赖:配置ehcache.XML文件:配置

Java 虚拟线程的创建与使用深度解析

《Java虚拟线程的创建与使用深度解析》虚拟线程是Java19中以预览特性形式引入,Java21起正式发布的轻量级线程,本文给大家介绍Java虚拟线程的创建与使用,感兴趣的朋友一起看看吧... 目录一、虚拟线程简介1.1 什么是虚拟线程?1.2 为什么需要虚拟线程?二、虚拟线程与平台线程对比代码对比示例:三

vite搭建vue3项目的搭建步骤

《vite搭建vue3项目的搭建步骤》本文主要介绍了vite搭建vue3项目的搭建步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学... 目录1.确保Nodejs环境2.使用vite-cli工具3.进入项目安装依赖1.确保Nodejs环境

Nginx搭建前端本地预览环境的完整步骤教学

《Nginx搭建前端本地预览环境的完整步骤教学》这篇文章主要为大家详细介绍了Nginx搭建前端本地预览环境的完整步骤教学,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录项目目录结构核心配置文件:nginx.conf脚本化操作:nginx.shnpm 脚本集成总结:对前端的意义很多