在Hyperledher Fabric V1.0的本地开发环境中使用fabric客户端java sdk（因为没有Rest API支持）时出现问题

我已经完成了以下建议，我从上一篇文章中获得了与java应用程序本地运行Hyperledger Fabric V1.0网络进行通信的建议。 但我得到了下面给出的例外情况，无法解释为什么会发生这种情况。

public class Test { final HFClient client = HFClient.createNewInstance(); Channel channel; TransactionProposalRequest proposalRequest; void setupCryptoMaterialsForClient() throws CryptoException, InvalidArgumentException{ // Set default crypto suite for HF client client.setCryptoSuite(CryptoSuite.Factory.getCryptoSuite()); client.setUserContext(new User() { public String getName() { return "PeerAdmin"; } public Set getRoles() { return null; } public String getAccount() { return null; } public String getAffiliation() { return null; } public Enrollment getEnrollment() { return new Enrollment() { public PrivateKey getKey() { PrivateKey privateKey = null; try { File privateKeyFile = findFileSk("C:/Users/Public/HyperledgerFabricV1/fabric-samples/first-network/crypto-config/peerOrganizations/org1.example.com/users/[e-mail]/msp/keystore"); privateKey = getPrivateKeyFromBytes(IOUtils.toByteArray(new FileInputStream(privateKeyFile))); } catch (InvalidKeySpecException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (NoSuchProviderException e) { e.printStackTrace(); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } return privateKey; } public String getCert() { String certificate = null; try { File certificateFile = new File("C:/Users/Public/HyperledgerFabricV1/fabric-samples/first-network/crypto-config/peerOrganizations/org1.example.com/users/[e-mail]/msp/signcerts/[e-mail]"); certificate = new String(IOUtils.toByteArray(new FileInputStream(certificateFile)), "UTF-8"); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return certificate; } }; } public String getMspId() { return "Org1MSP"; } }); } static File findFileSk(String directorys) { File directory = new File(directorys); File[] matches = directory.listFiles((dir, name) -> name.endsWith("_sk")); if (null == matches) { throw new RuntimeException(format("Matches returned null does %s directory exist?", directory.getAbsoluteFile().getName())); } if (matches.length != 1) { throw new RuntimeException(format("Expected in %s only 1 sk file but found %d", directory.getAbsoluteFile().getName(), matches.length)); } return matches[0]; } static PrivateKey getPrivateKeyFromBytes(byte[] data) throws IOException, NoSuchProviderException, NoSuchAlgorithmException, InvalidKeySpecException { final Reader pemReader = new StringReader(new String(data)); final PrivateKeyInfo pemPair; try (PEMParser pemParser = new PEMParser(pemReader)) { pemPair = (PrivateKeyInfo) pemParser.readObject(); } PrivateKey privateKey = new JcaPEMKeyConverter().setProvider(BouncyCastleProvider.PROVIDER_NAME).getPrivateKey(pemPair); return privateKey; } void createChannel() throws InvalidArgumentException, TransactionException{ channel = client.newChannel("mychannel"); Properties ordererProperties = new Properties(); ordererProperties.setProperty("pemFile", "C:/Users/Public/HyperledgerFabricV1/fabric-samples/first-network/crypto-config/ordererOrganizations/example.com/orderers/orderer.example.com/tls/server.crt"); ordererProperties.setProperty("trustServerCertificate", "true"); //testing environment only NOT FOR PRODUCTION! ordererProperties.setProperty("hostnameOverride", "orderer.example.com"); ordererProperties.setProperty("sslProvider", "openSSL"); ordererProperties.setProperty("negotiationType", "TLS"); ordererProperties.put("grpc.NettyChannelBuilderOption.keepAliveTime", new Object[] {5L, TimeUnit.MINUTES}); ordererProperties.put("grpc.NettyChannelBuilderOption.keepAliveTimeout", new Object[] {8L, TimeUnit.SECONDS}); channel.addOrderer(client.newOrderer("orderer.example.com", "grpc://192.168.99.100:7050",ordererProperties)); Properties peerProperties = new Properties(); peerProperties.setProperty("pemFile", "C:/Users/Public/HyperledgerFabricV1/fabric-samples/first-network/crypto-config/peerOrganizations/org1.example.com/peers/peer0.org1.example.com/tls/server.crt"); peerProperties.setProperty("trustServerCertificate", "true"); //testing environment only NOT FOR PRODUCTION! peerProperties.setProperty("hostnameOverride", "peer0.org1.example.com"); peerProperties.setProperty("sslProvider", "openSSL"); peerProperties.setProperty("negotiationType", "TLS"); peerProperties.put("grpc.NettyChannelBuilderOption.maxInboundMessageSize", 9000000); channel.addPeer(client.newPeer("peer0.org1.example.com", "grpc://192.168.99.100:7051",peerProperties)); channel.initialize(); } void creteTransactionalProposal(){ proposalRequest = client.newTransactionProposalRequest(); final ChaincodeID chaincodeID = ChaincodeID.newBuilder() .setName("asset") .setVersion("1.0") .setPath("github.com/mygitId/myFabricRepo/assetChainCode") .build(); proposalRequest.setChaincodeID(chaincodeID); proposalRequest.setFcn("createAsset"); //proposalRequest.setFcn("init"); proposalRequest.setProposalWaitTime(TimeUnit.SECONDS.toMillis(10)); proposalRequest.setArgs(new String[]{"ORG1", "{\"assetKey\":\"a1\",\"assetName\":\"aname1\",\"assetType\":\"atype1\",\"slNo\":\"slno1\",\"orderDate\":\"19-05-2017\"}"}); } void sendProposal() throws ProposalException, InvalidArgumentException, InterruptedException, ExecutionException{ final Collection responses = channel.sendTransactionProposal(proposalRequest); CompletableFuture txFuture = channel.sendTransaction(responses, client.getUserContext()); BlockEvent.TransactionEvent event = txFuture.get(); System.out.println(event.toString()); } public static void main(String args[]) throws Exception { Test t = new Test(); t.setupCryptoMaterialsForClient(); t.createChannel(); t.creteTransactionalProposal(); t.sendProposal(); } } 

这是我的docker ps

并通过在eclipse java项目中运行代码获得以下exception。

 Exception in thread "main" org.hyperledger.fabric.sdk.exception.TransactionException: INTERNAL at org.hyperledger.fabric.sdk.OrdererClient.sendDeliver(OrdererClient.java:286) at org.hyperledger.fabric.sdk.Orderer.sendDeliver(Orderer.java:165) at org.hyperledger.fabric.sdk.Channel.getLatestBlock(Channel.java:1074) at org.hyperledger.fabric.sdk.Channel.getConfigurationBlock(Channel.java:898) at org.hyperledger.fabric.sdk.Channel.parseConfigBlock(Channel.java:826) at org.hyperledger.fabric.sdk.Channel.initialize(Channel.java:526) at com.ibs.blockchain.client.test.Test.createChannel(Test.java:151) at com.ibs.blockchain.client.test.Test.main(Test.java:179) Caused by: io.grpc.StatusRuntimeException: INTERNAL at io.grpc.Status.asRuntimeException(Status.java:540) at io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:392) 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) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: io.netty.handler.codec.http2.Http2Exception: First received frame was not SETTINGS. Hex dump for first 5 bytes: 1503010002 at io.netty.handler.codec.http2.Http2Exception.connectionError(Http2Exception.java:85) at io.netty.handler.codec.http2.Http2ConnectionHandler$PrefaceDecoder.verifyFirstFrameIsSettings(Http2ConnectionHandler.java:309) at io.netty.handler.codec.http2.Http2ConnectionHandler$PrefaceDecoder.decode(Http2ConnectionHandler.java:217) at io.netty.handler.codec.http2.Http2ConnectionHandler.decode(Http2ConnectionHandler.java:401) at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:411) at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:341) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) 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) ... 1 more 

有人请查看代码，帮助我找到我做错的地方。

给出的ip 192.168.99.100是虚拟机ip

注意：我正在使用Windows 7和Docker Toolbox ，遵循构建您的第一个网络和通过eclipse运行我的Java应用程序的步骤。

更新：
通过引用fabric-sdk-java源，根据@Gari Singh的回答添加TLS，更新了函数createChannel 。 但现在也是同样的错误。 更新：
运行java客户端后，这个docker快速启动终端控制台似乎没有日志到来

Answer 1

你是怎么创造加密材料的？！ 我不是在询问您使用的工具，我的问题与您为证书定义的公用名更相关。 证书的CN必须与您要连接的主机相同。

如果我是你，我会用加密工具创建加密材料。 然后，我将更改呼叫的URL。 我知道你在本地主机，所以你可以尝试拨打orderer.example.com而不是192.168.99.100。

另一方面，我认为您不必执行createchannel ，因为您之前已创建它。

Answer 2

如果您使用了第一个网络示例，则它已启用TLS，并且在上面的代码中您未使用TLS。 所以我最好的猜测是错误是由于你的客户端没有使用TLS引起的。