我希望能够在我的Go程序中使用Go-IPFS,但它完全没有文档记录 . 这是我的研究带领我的地方:
package main
import (
"context"
"fmt"
"io/ioutil"
"log"
"os"
"path/filepath"
"gx/ipfs/QmSP88ryZkHSRn1fnngAaV2Vcn63WUJzAavnRM9CVdU1Ky/go-ipfs-cmdkit/files"
"github.com/ipfs/go-ipfs/core"
"github.com/ipfs/go-ipfs/core/coreunix"
)
func main() {
ctx := context.Background()
node, err := core.NewNode(ctx, &core.BuildCfg{})
if err != nil {
log.Fatalf("Failed to start IPFS node: %v", err)
}
reader, err := coreunix.Cat(ctx, node, "QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB")
if err != nil {
log.Fatalf("Failed to look up IPFS welcome page: %v", err)
}
blob, err := ioutil.ReadAll(reader)
if err != nil {
log.Fatalf("Failed to retrieve IPFS welcome page: %v", err)
}
fmt.Println(string(blob))
}
但是我不确定它的区别
context.Background()
相似 context.TODO()
相 context.WithCancel(context.Background())
.
最重要的是,如何选择IPFS将IPFS回购放在哪里,并确保它也初始化它?
如何启用和使用Pubsub及其命令 subscribe
和 publish
?
如何添加文件并将其固定到IPFS,还可以为大文件输入流?
coreunix.Cat
是否适合用流读取文件?
如何从CLI运行ipfs守护程序并让所有端口(如webui,swarm等)运行时,如何保持节点“监听”?
怎么样添加文件?这是使用流还是将整个文件读入内存?如何改进?
func addFile(ctx *context.Context, node *core.IpfsNode, path *string) error {
file, err := os.Open(*path)
if err != nil {
return err
}
adder, err := coreunix.NewAdder(*ctx, node.Pinning, node.Blockstore, node.DAG)
if err != nil {
return err
}
filename := filepath.Base(*path)
fileReader := files.NewReaderFile(filename, filename, file, nil)
adder.AddFile(fileReader)
adder.PinRoot()
return nil
}
1 回答
你可能想把你的问题分解成更小的部分,我一直在玩go-ipfs的源代码一段时间,这里是我可以给你的一般指令:
大多数数据结构,如context,DAG,IPFSNode等都是以go结构的形式定义的,你应该能够在gx / ... / ...目录中找到它们,你也应该能够查看有关所使用的每个变量的详细信息(通过该目录进行简单的字符串搜索可以获得所需的源文件)
所有方法都在文件夹github.com/../ ..目录中定义
清除指针的概念,因为它们大多数时候都使用指针将参数传递给函数