10.fabric

可莉
• 阅读 309 
[2017-11-25 15:23:22] [grpc-default-worker-ELG-2-3] [ERROR] [io.netty.handler.codec.http2.DefaultHttp2Connection:181] Caught Throwable from listener onStreamActive.
java.lang.IllegalArgumentException: delay: -846693464887 (expected: >= 0)
    at io.netty.util.concurrent.AbstractScheduledEventExecutor.schedule(AbstractScheduledEventExecutor.java:138)
    at io.netty.util.concurrent.AbstractScheduledEventExecutor.schedule(AbstractScheduledEventExecutor.java:29)
    at io.grpc.internal.KeepAliveManager.onTransportActive(KeepAliveManager.java:202)
    at io.grpc.netty.NettyClientHandler$1.onStreamActive(NettyClientHandler.java:211)
    at io.netty.handler.codec.http2.DefaultHttp2Connection$ActiveStreams.addToActiveStreams(DefaultHttp2Connection.java:1212)
    at io.netty.handler.codec.http2.DefaultHttp2Connection$ActiveStreams.activate(DefaultHttp2Connection.java:1159)
    at io.netty.handler.codec.http2.DefaultHttp2Connection$DefaultStream.activate(DefaultHttp2Connection.java:538)
    at io.netty.handler.codec.http2.DefaultHttp2Connection$DefaultEndpoint.createStream(DefaultHttp2Connection.java:961)
    at io.netty.handler.codec.http2.DefaultHttp2Connection$DefaultEndpoint.createStream(DefaultHttp2Connection.java:868)
    at io.netty.handler.codec.http2.DefaultHttp2ConnectionEncoder.writeHeaders(DefaultHttp2ConnectionEncoder.java:158)
    at io.netty.handler.codec.http2.DecoratingHttp2FrameWriter.writeHeaders(DecoratingHttp2FrameWriter.java:52)
    at io.netty.handler.codec.http2.StreamBufferingEncoder.writeHeaders(StreamBufferingEncoder.java:157)
    at io.netty.handler.codec.http2.StreamBufferingEncoder.writeHeaders(StreamBufferingEncoder.java:141)
    at io.grpc.netty.NettyClientHandler.createStream(NettyClientHandler.java:426)
    at io.grpc.netty.NettyClientHandler.write(NettyClientHandler.java:240)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:739)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:731)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:817)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:724)
    at io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1022)
    at io.netty.channel.AbstractChannel.write(AbstractChannel.java:291)
    at io.grpc.netty.WriteQueue.flush(WriteQueue.java:127)
    at io.grpc.netty.WriteQueue.access$000(WriteQueue.java:47)
    at io.grpc.netty.WriteQueue$1.run(WriteQueue.java:59)
    at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:403)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:445)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
    at java.lang.Thread.run(Thread.java:748)
[2017-11-25 15:23:22] [DubboServerHandler-192.170.0.18:20888-thread-179] [ERROR] [org.hyperledger.fabric.sdk.Channel:2241] Sending proposal to peer0.ebaoquan.org failed because of: gRPC failure=Status{code=UNAVAILABLE, description=null, cause=java.io.IOException: 远程主机强迫关闭了一个现有的连接。
    at sun.nio.ch.SocketDispatcher.read0(Native Method)
    at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43)
    at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
    at sun.nio.ch.IOUtil.read(IOUtil.java:192)
    at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
    at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288)
    at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1100)
    at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:367)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:118)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:642)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:565)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:479)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:441)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
    at java.lang.Thread.run(Thread.java:748)
}
java.lang.Exception: io.grpc.StatusRuntimeException: UNAVAILABLE
    at org.hyperledger.fabric.sdk.Channel.sendProposalToPeers(Channel.java:2241)
    at org.hyperledger.fabric.sdk.Channel.sendProposal(Channel.java:2155)
    at org.hyperledger.fabric.sdk.Channel.queryBlockByNumber(Channel.java:1680)
    at org.mapu.fabric.api.service.client.BcClientService.getBlockInfo(BcClientService.java:132)
    at org.mapu.fabric.api.BlockChainApiImpl.getBlockInfo(BlockChainApiImpl.java:117)
    at com.alibaba.dubbo.common.bytecode.Wrapper1.invokeMethod(Wrapper1.java)
    at com.alibaba.dubbo.rpc.proxy.javassist.JavassistProxyFactory$1.doInvoke(JavassistProxyFactory.java:46)
    at com.alibaba.dubbo.rpc.proxy.AbstractProxyInvoker.invoke(AbstractProxyInvoker.java:72)
    at com.alibaba.dubbo.rpc.protocol.InvokerWrapper.invoke(InvokerWrapper.java:53)
    at com.alibaba.dubbo.validation.filter.ValidationFilter.invoke(ValidationFilter.java:57)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.rpc.filter.ExceptionFilter.invoke(ExceptionFilter.java:64)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.monitor.support.MonitorFilter.invoke(MonitorFilter.java:65)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.rpc.filter.TimeoutFilter.invoke(TimeoutFilter.java:42)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.rpc.protocol.dubbo.filter.TraceFilter.invoke(TraceFilter.java:78)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.rpc.filter.ContextFilter.invoke(ContextFilter.java:61)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.rpc.filter.GenericFilter.invoke(GenericFilter.java:132)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.rpc.filter.ClassLoaderFilter.invoke(ClassLoaderFilter.java:38)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.rpc.filter.EchoFilter.invoke(EchoFilter.java:38)
    at com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper$1.invoke(ProtocolFilterWrapper.java:69)
    at com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol$1.reply(DubboProtocol.java:102)
    at com.alibaba.dubbo.remoting.exchange.support.header.HeaderExchangeHandler.handleRequest(HeaderExchangeHandler.java:98)
    at com.alibaba.dubbo.remoting.exchange.support.header.HeaderExchangeHandler.received(HeaderExchangeHandler.java:170)
    at com.alibaba.dubbo.remoting.transport.DecodeHandler.received(DecodeHandler.java:52)
    at com.alibaba.dubbo.remoting.transport.dispatcher.ChannelEventRunnable.run(ChannelEventRunnable.java:81)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
Caused by: io.grpc.StatusRuntimeException: UNAVAILABLE
    at io.grpc.Status.asRuntimeException(Status.java:540)
    at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:439)
    at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:426)
    at io.grpc.internal.ClientCallImpl.access$100(ClientCallImpl.java:76)
    at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.close(ClientCallImpl.java:512)
    at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.access$700(ClientCallImpl.java:429)
    at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:544)
    at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:52)
    at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:117)
    ... 3 common frames omitted

然后先研究了下grpc的调用，发现问题出在：

class org.hyperledger.fabric.sdk.EndorserClient
###以下为这个类的要改动的地方，只用看我写的注释的那一部份,huhu
    /**
     * Construct client for accessing Peer server using the existing channel.
     *
     * @param channelBuilder The ChannelBuilder to build the endorser client
     */
    EndorserClient(ManagedChannelBuilder<?> channelBuilder) {
        managedChannel = channelBuilder.build();
        //blockingStub = EndorserGrpc.newBlockingStub(managedChannel);//这个没有注释,源码上
        //futureStub = EndorserGrpc.newFutureStub(managedChannel);//这个没有注释,源码上
    }


    public ListenableFuture<FabricProposalResponse.ProposalResponse> sendProposalAsync(FabricProposal.SignedProposal proposal) throws PeerException {
        if (shutdown) {
            throw new PeerException("Shutdown");
        }
        futureStub = EndorserGrpc.newFutureStub(managedChannel);//这个为新加
        return futureStub.processProposal(proposal);
    }

    public FabricProposalResponse.ProposalResponse sendProposal(FabricProposal.SignedProposal proposal) throws PeerException {

        if (shutdown) {
            throw new PeerException("Shutdown");
        }

        try {
            blockingStub=EndorserGrpc.newBlockingStub(managedChannel);//这个为新加
            return blockingStub.processProposal(proposal);
        } catch (StatusRuntimeException e) {
            logger.warn(String.format("RPC failed: %s", e.getStatus()));
            throw new PeerException("Sending transaction to peer failed", e);
        }
    }

这个类上。

改动这个类并mvn package后，重新使用。

使用后发现hfclient长时间不用后，还是会抛出：

java.lang.IllegalArgumentException: delay: -846693464887 (expected: >= 0)

的异常，但已不影响正常使用了。现有代码是出这个异常会重新获取。有时也会报错，重试下也会成功。

用common-pool2线程池管理，idle超过一定时间的就移出，也就不会出问题了

前端
点赞
收藏
评论区
推荐文章
秃头王路飞 秃头王路飞
•
6个月前
webpack5手撸vue2脚手架
webpack5手撸vue相信工作个12年的小伙伴们在面试的时候多多少少怕被问到关于webpack方面的知识，本菜鸟最近闲来无事，就尝试了手撸了下vue2的脚手架，第一次发帖实在是没有经验，望海涵。languageJavaScript"name":"vuecliversion2","version":"1.0.0","desc
2912
0
0
光头强的博客 光头强的博客
•
6个月前
Java面向对象试题
1、请创建一个Animal动物类，要求有方法eat（）方法，方法输出一条语句“吃东西”。创建一个接口A，接口里有一个抽象方法fly（）。创建一个Bird类继承Animal类并实现接口A里的方法输出一条有语句“鸟儿飞翔”，重写eat（）方法输出一条语句“鸟儿吃虫”。在Test类中向上转型创建b对象，调用eat方法。然后向下转型调用eat（）方
2228
0
0
刚刚好 刚刚好
•
6个月前
css问题
1、在IOS中图片不显示（给图片加了圆角或者img没有父级）<div<imgsrc""/</divdiv{width:20px;height:20px;borderradius:20px;overflow:h
1267
0
0
小森森 小森森
•
3天前
租房类微信小程序-基于微信云开发-小程序端集成了管理员后台-一键部署，快速发布
温馨提醒本项目使用MITLicense协议，仅适用于学习交流，并且不提供无偿的、不提供无偿的、不提供无偿的维护修改服务（但可提issue）。若直接将本项目用于商用，因本项目带来的所有后果由使用者自行承担。如需商用升级版，请联系我微信，微信二维码在本博客页面右上角在此奉劝某些人，请尊重作者的劳动成果，做人积点德吧！最近发现有人拿我的源码进行二次分
983
0
0
小森森 小森森
•
3天前
计划助手V1.0-微信小程序(QQ小程序)-源代码分享
疫情期间在家感觉好无聊啊，于是利用空闲时间做了一个用来记录和管理小目标时间的小程序，命名为《小沙漏》。QQ版本小程序同步上线，QQ小程序叫《时间小沙漏》，欢迎大家前来体验，后期也会添加其他的新功能哦【区别】：微信小程序的代码与QQ小程序的源码是不一样的。微信小程序的源码基于微信小程序云开发，需要在有网络的情况下使用，具有同步功能，所有记录在删除小
976
0
0
小森森 小森森
•
6个月前
校园表白墙微信小程序V1.0 SayLove -基于微信云开发-一键快速搭建,开箱即用
后续会继续更新，敬请期待2.0全新版本欢迎添加左边的微信一起探讨！项目地址：(https://www.aliyun.com/activity/daily/bestoffer?userCodesskuuw5n)\2.Bug修复更新日历2.情侣脸功能大家不要使用了，现在阿里云的接口已经要收费了(土豪请随意)，\\和注意
1312
0
0
晴空闲云 晴空闲云
•
6个月前
css中box-sizing解放盒子实际宽高计算
我们知道传统的盒子模型，如果增加内边距padding和边框border，那么会撑大整个盒子，造成盒子的宽度不好计算，在实务中特别不方便。boxsizing可以设置盒模型的方式，可以很好的设置固定宽高的盒模型。盒子宽高计算假如我们设置如下盒子：宽度和高度均为200px，那么这会这个盒子实际的宽高就都是200px。但是当我们设置这个盒子的边框和内间距的时候，那
1201
0
0
艾木酱 艾木酱
•
5个月前
快速入门｜使用MemFire Cloud构建React Native应用程序
MemFireCloud是一款提供云数据库，用户可以创建云数据库，并对数据库进行管理，还可以对数据库进行备份操作。它还提供后端即服务，用户可以在1分钟内新建一个应用，使用自动生成的API和SDK，访问云数据库、对象存储、用户认证与授权等功能，可专
320
0
0
天翼云开发者社区 天翼云开发者社区
•
2个月前
密钥管理系统-为你的天翼云资产上把“锁
本文关键词：数据安全，密码机，密钥管理一、你的云上资产真的安全么？1.2021年1月，巴西的一个数据库30TB数据被破坏，泄露的数据包含有1.04亿辆汽车和约4000万家公司的详细信息，受影响的人员数量可能有2.2亿；2.2021年2月，广受欢迎的音频聊天室应用Clubhouse的用户数据被恶意黑客或间谍窃取。据悉，一位身份不明的用户能够将Clubho
114
0
0
天翼云开发者社区 天翼云开发者社区
•
2个月前
NVIDIA安培架构下MIG技术分析
关键词：NVIDIA、MIG、安培一什么是MIG2020年5月，NVIDIA发布了最新的GPU架构:安培，以及基于安培架构的最新的GPU:A100。安培提供了许多新的特性，MIG是其中一项非常重要的新特性。MIG的全名是MultiInstanceGPU。NVIDIA安培架构中的MIG模式可以在A100GPU上并行运行七个作业。多实
98
0
0
helloworld_28799839 helloworld_28799839
•
6个月前
常用知识整理
Javascript判断对象是否为空jsObject.keys(myObject).length0经常使用的三元运算我们经常遇到处理表格列状态字段如status的时候可以用到vue
356
0
0
可莉
可莉
Lv1
暂时还承受不起任何人的爱意。
543
文章
1
粉丝
1
获赞
热门文章
带你入门前端工程：微前端
了解Vuex状态管理模式
Vue 包大小优化
11款插件让你的Chrome成为全世界最好用的浏览器｜Chrome插件推荐
2020年webstorm最新激活码（同步更新）