Я пытался вызывать и запрашивать транзакции из Java SDK для сети BYFN в Hyperledger Fabri c v1.4.4. До сих пор я запустил сеть (в которой есть два участника в двух организациях, заказчик). и код цепи мой cc установлен). Сеть запускается успешно, и сценарии и тесты завершаются.
Это мой Java код SDK для управления сетью с Java, выполнения запросов и вызова
Основной класс:
public class sdksample {
// Main program to simply call the client, Am i making some mistake here ?? persistency ?
public static void main(String[] args) throws Exception {
// create fabric-ca client
BlockChainHFClient.getInstance().setupCryptoMaterialsForClient();
BlockChainHFClient.getInstance().initChannel();
// get HFC client instance
BlockChainHFClient client = BlockChainHFClient.getInstance();
System.out.println(client);
}
}
BlockchainClient Class:
public class BlockChainHFClient {
private static BlockChainHFClient instance;
/**
* Client instance constructor
*/
private BlockChainHFClient() {
}
/**
* Returns an instance of the Fabric client
*
* @return instance
*/
public static synchronized BlockChainHFClient getInstance() {
if (instance == null) {
instance = new BlockChainHFClient();
}
return instance;
}
/**
* Fabric client object
*/
final HFClient hfClient = HFClient.createNewInstance();
/**
* Crypto config folder location . keep crypto-config folder in user/home
*/
final String CRYPTO_CONFIG_HOME_DIR = System.getProperty("user.home");
/**
* Grpcs URL
*/
final String GRPCS = "grpcs://";
/**
* Dot for utility
*/
final String DOT = ".";
/**
* MSP ID Root
*/
final String ROOT_MSP_ID = "Org1MSP";
/**
* Admin user
*/
final String PEER_ADMIN = "PeerAdmin";
/**
* Channel object
*/
Channel channel;
/**
* Channel initialize timeout values
*/
final Long ChannelBuilderOptionkeepAliveMinutes = 15L;
final Long ChannelBuilderOptionkeepAliveSeconds = 15L;
/**
* Get channel instance
*
* @return channel
*/
public Channel getChannel() {
return channel;
}
/**
* Get HF client
*
* @return HF client
*/
public HFClient getClient() {
return hfClient;
}
/**
* Set up User contexts by using Crypto materials - Private key and cert files
*
* @throws CryptoException
* @throws InvalidArgumentException
* @throws IllegalAccessException
* @throws InstantiationException
* @throws ClassNotFoundException
* @throws NoSuchMethodException
* @throws InvocationTargetException
*/
public void setupCryptoMaterialsForClient()
throws CryptoException, InvalidArgumentException, IllegalAccessException, InstantiationException,
ClassNotFoundException, NoSuchMethodException, InvocationTargetException {
hfClient.setCryptoSuite(CryptoSuite.Factory.getCryptoSuite());
hfClient.setUserContext(new User() {
public String getName() {
return PEER_ADMIN;
}
public Set<String> 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;
File privateKeyFile = findFileSk(
"D:\\Hyperledger Fabric_Research_Blockchain\\Fabric1.4.4\\fabric-samples\\first-network\\crypto-config\\peerOrganizations\\org1.example.com\\users\\Admin@org1.example.com\\msp\\keystore");
try {
privateKey = getPrivateKeyFromBytes(
IOUtils.toByteArray(new FileInputStream(privateKeyFile)));
} catch (IOException e) {
e.printStackTrace();
} catch (NoSuchProviderException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (NoSuchAlgorithmException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvalidKeySpecException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return privateKey;
}
public String getCert() {
String certificate = null;
try {
File certificateFile = new File(
"D:\\Hyperledger Fabric_Research_Blockchain\\Fabric1.4.4\\fabric-samples\\first-network\\crypto-config\\peerOrganizations\\org1.example.com\\users\\Admin@org1.example.com\\msp\\signcerts\\Admin@org1.example.com-cert.pem");
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 ROOT_MSP_ID;
}
});
}
public void initChannel() throws Exception {
Properties peerProperties = new Properties();
peerProperties.setProperty("pemFile",
"D:\\Hyperledger Fabric_Research_Blockchain\\Fabric1.4.4\\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);
Peer peer = hfClient.newPeer("peer0.org1.example.com", "grpcs://localhost:7051");
Properties ordererProperties = new Properties();
ordererProperties.setProperty("pemFile",
"D:\\Hyperledger Fabric_Research_Blockchain\\Fabric1.4.4\\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 });
Orderer orderer = hfClient.newOrderer("orderer.example.com", "grpcs://localhost:7050");
Channel channel = hfClient.newChannel("mychannel");
channel.addPeer(peer);
channel.addOrderer(orderer);
channel.initialize();
moveUnits(hfClient);
queryBlockChain(hfClient);
}
private String printableString(String string) {
int maxLogStringLength = 10000;
if (string == null || string.length() == 0) {
return string;
}
String ret = string.replaceAll("[^\\p{Print}]", "\n");
ret = ret.substring(0, Math.min(ret.length(), maxLogStringLength))
+ (ret.length() > maxLogStringLength ? "..." : "");
return ret;
}
void queryBlockChain(HFClient client) throws ProposalException, InvalidArgumentException {
// get channel instance from client
Channel channel = client.getChannel("mychannel");
// create chaincode request
QueryByChaincodeRequest qpr = client.newQueryProposalRequest();
// build cc id providing the chaincode name. Version is omitted here.
ChaincodeID cid = ChaincodeID.newBuilder().setName("mycc").build();
qpr.setChaincodeID(cid);
// CC function to be called
qpr.setFcn("query");
qpr.setArgs(new String[] { "a" });
Collection<ProposalResponse> res = channel.queryByChaincode(qpr);
// display response
for (ProposalResponse pres : res) {
String stringResponse = new String(pres.getChaincodeActionResponsePayload());
System.out.println(stringResponse);
}
}
void moveUnits(HFClient client)
throws Exception {
Channel channel = client.getChannel("mychannel");
TransactionProposalRequest req = client.newTransactionProposalRequest();
ChaincodeID cid = ChaincodeID.newBuilder().setName("mycc").setVersion("1.0").build();
req.setChaincodeID(cid);
req.setFcn("invoke");
req.setArgs(new String[] {"a","b","50"});
Collection<ProposalResponse> resps = channel.sendTransactionProposal(req);
channel.sendTransaction(resps);
}
/**
* Utility method to get private key from bytes using Bouncy Castle Security
* Provider
*
* @param data
* @return privateKey
* @throws IOException
* @throws NoSuchProviderException
* @throws NoSuchAlgorithmException
* @throws InvalidKeySpecException
*/
private PrivateKey getPrivateKeyFromBytes(byte[] data)
throws IOException, NoSuchProviderException, NoSuchAlgorithmException, InvalidKeySpecException {
final Reader pemReader = new StringReader(new String(data));
Security.addProvider(new org.bouncycastle.jce.provider.BouncyCastleProvider());
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;
}
/**
* Find files ending with _sk
*
* @param directorys
* @return file
*/
private 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];
}
}
Настройка части криптографических материалов и части инициализации канала работает нормально (добавление узла и порядка в канал и его инициализация)
I получить ошибки во время QueryProposal или TransactionProposal, то есть, если я хочу что-либо сделать после инициализации канала с требуемым криптографическим материалом
Это трассировка ошибок:
Ошибка обработки запроса сообщения ; вложенное исключение: org.hyperledger.fabri c .sdk.exception.ProposalException: org.hyperledger.fabri c .sdk.exception.ProposalException: канал mychannel не выполнил предложение на одноранговом peer0.org1.example.com org.hyperledger. fabri c .sdk.exception.TransactionException: org.hyperledger.fabri c .sdk.exception.ProposalException: getConfigBlock для канала mychannel завершился неудачно с равноправным peer0.org1.example.com. Статус СБОЙ, подробности: Канал Канал {id: 1, имя: mychannel} Отправка предложения с транзакцией: 3323e96e7e9147ccee2491b310e6dacfc2db93d50578f08a43a5c997a211135a для Peer {id: 7, имя: peer0.org1.example.com, myhostchan // канал: localhost, //Name локальный_канал // канал: имя_сайла: канал: имя_компонента_сайла: канал: имя_хоста // имя_сайла_сайла: канал: имя_хоста, // имя_компонента_сайла: канал: имя_хоста, канал: имя_компонента_группы: имя_хоста, канал: имя_компонента_группы: имя_хоста, канал: имя_компонента_группы: имя_хоста, канал: имя_компонента_группы: имя_хоста, канал: имя_компонента_группы: имя_хоста, канал: имя_компонента_группы: имя_сайта: myhostnel, канал: // : 7051} не удалось из-за: сбоя gRPC = Статус {code = UNAVAILABLE, описание = исключение io, причина = io.netty.channel.AbstractChannel $ AnnotatedConnectException: соединение отклонено: нет дополнительной информации: localhost / 0: 0: 0: 0: 0: 0: 0: 1: 7051
Я пытался изменить docker изображения, не сработало, та же ошибка, у меня такое ощущение, что эта ошибка связана с отказом подключения grpcs с пира на порт? Есть ли что-то, что я пропустил или что-то, что может помешать доступу к пиру. Где-то порт уже используется, или, возможно, брандмауэр? Потому что это работало в другой системе с теми же шагами. Не совсем уверен в этом. Предложения помогут!
Спасибо