简单使用 Hyperledger-Fabric-Java-SDK

介绍如何用 Fabric Java SDK 进行简单的数据块插入和查询

环境

  • Hyperledger Fabric 2.0
  • Fabric Java SDK 2.0.0

示例

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
public class LocalUser implements User {
private String name;
private String mspId;
private Enrollment enrollment;

LocalUser(String name, String mspId, String keyFile, String certFile) throws Exception {
this.name = name;
this.mspId = mspId;
this.enrollment = loadFromPemFile(keyFile, certFile);
}

private Enrollment loadFromPemFile(String keyFile, String certFile) throws Exception {
byte[] keyPem = Files.readAllBytes(Paths.get(keyFile));
byte[] certPem = Files.readAllBytes(Paths.get(certFile));
CryptoPrimitives suite = new CryptoPrimitives();
PrivateKey privateKey = suite.bytesToPrivateKey(keyPem);
return new X509Enrollment(privateKey, new String(certPem));
}

@Override
public String getName() {
return name;
}

public Set<String> getRoles() {
return null;
}

public String getMspId() {
return mspId;
}

@Override
public Enrollment getEnrollment() {
return enrollment;
}

@Override
public String getAccount() {
return null;
}

@Override
public String getAffiliation() {
return null;
}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
public class FabricTest {

private static final String BASE_PATH = "./fabric";
private static final String CHANNEL_NAME = "CHANNEL_NAME";
private static final String CHAINCODE_ID = "CHAINCODE_ID";
private static final Map<String, String> ORDERER_MAP = new HashMap<>();
private static final Map<String, String> PEER_MAP = new HashMap<>();
private static final boolean TLS = true;

static
String protocol = "grpc";
if(TLS) {
protocol += "s";
}
ORDERER_MAP.put("test.com", protocol + "://127.0.0.1:7050");
PEER_MAP.put("peer.test.com", protocol + "://127.0.0.1:7051");
}

public static void main(String[] args) throws Exception {
String keyFile = BASE_PATH + "***/user-key.pem";
String certFile = BASE_PATH + "***/user-cert.pem";
LocalUser user = new LocalUser("username", "mspId", keyFile, certFile);

HFClient client = HFClient.createNewInstance();
client.setCryptoSuite(CryptoSuite.Factory.getCryptoSuite());
client.setUserContext(user);

Channel channel = client.newChannel(CHANNEL_NAME);
for (Map.Entry<String, String> entry : ORDERER_MAP.entrySet()) {
Properties properties = new Properties();
if(TLS) {
properties.setProperty("clientCertFile", "对应配置目录下users/***/tls/client.crt文件");
properties.setProperty("clientKeyFile", "对应配置目录下users/***/tls/client.key文件");
properties.setProperty("pemFile", "对应配置目录下/tls/server.crt文件");
properties.setProperty("hostnameOverride", entry.getKey());
properties.setProperty("sslProvider", "openSSL");
properties.setProperty("negotiationType", "TLS");
}
channel.addOrderer(client.newOrderer(entry.getKey(), entry.getValue(), properties));
}
for (Map.Entry<String, String> entry : PEER_MAP.entrySet()) {
Properties properties = new Properties();
if(TLS) {
properties.setProperty("clientCertFile", "对应配置目录下users/***/tls/client.crt文件");
properties.setProperty("clientKeyFile", "对应配置目录下users/***/tls/client.key文件");
properties.setProperty("pemFile", "对应配置目录下/tls/server.crt文件");
properties.setProperty("hostnameOverride", entry.getKey());
properties.setProperty("sslProvider", "openSSL");
properties.setProperty("negotiationType", "TLS");
}
channel.addPeer(client.newPeer(entry.getKey(), entry.getValue(), properties));
}
channel.initialize();

System.out.format("Valid: %s\n", invokeRequest(client, channel, "insert", "ID1","VALUE222"));
System.out.format("Message: %s\n", queryRequest(client, channel, "query", "ID1"));
}

private static String queryRequest(HFClient client, Channel channel, String function, String... args) throws Exception {
QueryByChaincodeRequest request = client.newQueryProposalRequest();
request.setChaincodeName(CHAINCODE_ID);
request.setFcn(function);
request.setArgs(args);
ProposalResponse[] responses = channel.queryByChaincode(request).toArray(new ProposalResponse[0]);
return responses[0].getProposalResponse().getResponse().getPayload().toStringUtf8();
}

private static boolean invokeRequest(HFClient client, Channel channel, String function, String... args) throws Exception {
TransactionProposalRequest request = client.newTransactionProposalRequest();
request.setChaincodeName(CHAINCODE_ID);
request.setFcn(function);
request.setArgs(args);
Collection<ProposalResponse> responses = channel.sendTransactionProposal(request);
BlockEvent.TransactionEvent event = channel.sendTransaction(responses).get();
return event.isValid();
}
}
 欢迎关注我的博客公众号
如果觉得我的文章对你有用,请随意赞赏
0%