卓越飞翔博客卓越飞翔博客

卓越飞翔 - 您值得收藏的技术分享站
技术文章35527本站已运行397

是否可以在 hyperledger-chaincode 中使用 gRPC,如果可以,如何避免在测试网络上调用期间出现错误?

是否可以在 hyperledger-chaincode 中使用 grpc,如果可以,如何避免在测试网络上调用期间出现错误?

php小编西瓜在这里回答你的问题。是的,你可以在Hyperledger Chaincode中使用gRPC。gRPC是一种高性能、开源的远程过程调用(RPC)框架,它可以使您的Chaincode与其他服务进行通信。为了避免在测试网络上调用期间出现错误,您可以采取以下几个步骤。首先,确保您的测试网络已经正确配置和运行。其次,检查您的代码和配置文件以确保正确地使用gRPC。最后,进行适当的错误处理和日志记录,以便及时发现和解决任何问题。通过这些步骤,您应该能够避免在测试网络上调用期间出现错误,并顺利地使用gRPC进行通信。

问题内容

我想在fabric chaincode中使用grpc来实现跨链通信,而不是使用fabric sdk。 但是当我在fabric-sample/test-network上调用chaincode函数时,总是会出现错误。

error: endorsement failure during invoke. response: status:500 message:"error in simulation: failed to execute transaction eb5e480bd4075a767f56ae263741ca0f5f19620ef88952e26b7f1952bdbe83cd: could not launch chaincode chaincode_1.2:d3f97f15a635e73d3de230c8e5899e5fb95a68cf897c03e19f9e4eeca7ca3fd5: chaincode registration failed: container exited with 2"

谁能告诉我这个错误是什么原因造成的? 我的链代码有 bug 或者 grpc 无法在链代码函数中使用?

我关于 grpc 的链代码:

func (s *smartcontract) begin(ctx contractapi.transactioncontextinterface) error {
    server.main()
    return nil
}

func (s *smartcontract) client(ctx contractapi.transactioncontextinterface) error {
    // client.clientfunc is the client main function
    client.clientfunc(xt, r, sign, m)
}

服务器.go

func main() {
    listen, err := net.listen("tcp", ":9090")
    if err != nil {
        fmt.printf("failed to listen: %v", err)
        return
    }
    grpcserver := grpc.newserver()
    pb.registersendserviceserver(grpcserver, &server{})
    err2 := grpcserver.serve(listen)
    if err2 != nil {
        fmt.printf("failed to serve: %v", err2)
        return
    }
}

client.go

func Clientfunc(Xt *btcec.PublicKey, R *btcec.PublicKey, s *big.Int, m []byte) []byte {
    conn, err := grpc.Dial("127.0.0.1:9090", grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        log.Fatalf("did not connect: %v", err)
    }
    defer conn.Close()
    client := pb.NewSendServiceClient(conn)
    output := &pb.SignInput{
        XtX: Xt.X().Int64(),
        XtY: Xt.Y().Int64(),
        M:   m,
        RX:  R.X().Int64(),
        RY:  R.Y().Int64(),
        S:   s.Int64(),
    }
    resp, _ := client.Send(context.Background(), output)
    return resp.GetM()
}

解决方法

谁能告诉我这个错误是什么原因造成的?

详见 hyperledger fabric v2.x/ 日志控制,什么可以告诉你是什么导致了 错误 500 (内部服务器错误)是服务器日志

取决于您的运行方式:

docker logs <chaincode_container_id>
kubectl logs -n <namespace> <pod_name>
oc logs -n <namespace> <pod_name>

这可能是由于您的链代码中的问题(例如 grpc 代码中的错误),或者可能是由于链代码运行的环境所致。

从您的代码中,您可能会考虑在链代码中启动 grpc 服务器 (server.main())。 chaincode 在 hyperledger fabric 网络中运行,并不像独立应用程序那样处理网络通信。
相反,您应该使 grpc 服务器成为独立运行的单独服务,然后链代码可以根据需要与该服务进行通信。

加上client.clientfunc()函数似乎建立了grpc连接,发送请求,并等待响应。这是同步操作,如果响应需要很长时间才能到达,则可能会出现问题。最好使用异步操作(即发送请求并在回调函数中处理响应)以避免阻塞链码执行。
而且...您不应该忽略来自 client.send() 的错误;)

确保您的 grpc 服务器不需要安全连接,否则 grpc.withtransportcredentials(insecure.newcredentials()) (没有 ssl/tls 的不安全连接)将会失败。

通常,建议在 fabric 客户端应用程序中处理与外部系统(例如通过 grpc)的通信,而不是在链代码本身内。

如果我只想使用链码而不是结构应用程序,有没有办法在不同渠道的组织之间进行通信?

不同渠道上的组织之间的通信可能很复杂,因为它是 hyperledger fabric 设计的一个基本方面,渠道相互隔离,以维护数据隐私。

您可能会考虑:

  • 链码函数:一个组织可以在自己的通道上调用链码函数,该通道又调用另一个通道上的链码函数。这是可能的,因为链码可以与多个通道关联。
    请注意,此方法有一个限制,即第二个函数调用与第一个函数调用不属于同一事务,因此如果第一个事务失败,则无法回滚。

  • 双重会员:一个组织可以属于多个渠道。因此,它可以从一个通道读取数据并将数据写入另一通道。但是,这是在两个单独的事务中完成的,因此无法保证原子性。

  • 私有数据收集 (pdc):如果目标是在特定组织之间(甚至跨不同渠道)共享私有数据,pdc 可能是一种选择。 pdc 允许通道上定义的组织子集认可、提交或查询私有数据,而无需将数据分发到通道上的所有组织。

  • 互操作性解决方案:还有更多针对区块链互操作性的高级解决方案正在开发中,例如 interledger protocol (ilp),可用于在不同 fabric 网络之间(甚至在完全不同类型的区块链网络之间)移动数据或资产。
    然而,这些技术仍主要处于研发阶段,可能尚未准备好投入生产使用。

上一篇: 代理服务器上下文超时
下一篇: 返回列表
留言与评论(共有 0 条评论)
   
验证码:
隐藏边栏