hwelltech block chain cpp sdk
Dependencies: EthernetInterface SDFileSystem mbed-rtos mbed uniqueCPUID
Fork of bcsdk by
bcsdk 是 block chain sdk 的简写。它是由江苏恒为信息科技有限公司开发的 BlockChain 的 基于 mbed os 的 C++ 版本SDK,它能帮助开发者快速的在支持 mbed os 的芯片上开发 BlockChain 的应用。 bcsdk 的demo文件中包含了BlockChain中的 Key、Account、Asset、Transaction等方面的示例。其中: (1) Key 加密私钥是区块链上的主要授权机制。他们控制资产单位的发行和转让。 资产或帐户将定义发行或转移所需的单个密钥。 在 Key_test.cpp 中,我们实现了: 创建HSM密钥 键入密钥别名的名称(例如'gold','silver','bronze'),密钥别名是用于区分密钥的标签。
(2) Asset 资产是一种可以在区块链上发布的值类型。资产的所有单位均可互换,可以在各方之间直接交易,无需发行人参与。 在 Asset_test.cpp 中,我们实现了: 创建资产 键入资产别名的名称(例如'gold','silver','bronze'),资产别名是用于区分资产的标签。 选择“Key”键以使用现有的HSM密键,此密钥将用于此帐户中资产单位的发放和转移。
(3) Account 加帐户是恒为区块链核心平台中的一个对象,通过创建和跟踪控制程序来跟踪区块链上的资产的所有权。创建帐户时,您提供一个或多个“root”密钥和仲裁。 在 Account_test.cpp 中,我们实现了: 创建帐户 1 输入帐户别名的名称(例如'alice','bob'),帐户别名是用于区分帐户的标签。 2 键入名称以生成新的HSM密钥(例如'alice key','bob key'),此密钥将用于此帐户中资产单位的发放和转移。
(4) Transaction 交易包含一个或多个输入,以及一个或多个输出。恒为区块链核心平台的API允许您使用操作(包括发出,支出和返还)构建交易。 在 Transaction_test.cpp 中,我们实现了: 资产的交易 1 添加“账户支出”操作 2 为资产别名选择“Asset” 3 输入“100”作为金额 4 添加“使用帐户控制”操作 5 为帐户别名选择“Account” 6 为资产别名选择“Asset” 7 输入“100”作为金额 8 “提交”
Diff: main.cpp
- Revision:
- 8:f2a567ee3a46
- Parent:
- 7:04744a9ce2b9
- Child:
- 9:d7468574ef8f
diff -r 04744a9ce2b9 -r f2a567ee3a46 main.cpp --- a/main.cpp Sun Apr 12 03:04:28 2015 +0000 +++ b/main.cpp Thu Sep 21 02:09:04 2017 +0000 @@ -2,7 +2,15 @@ #include "EthernetInterface.h" #include "SDFileSystem.h" #include <stdio.h> -#include <string.h> +//#include <string.h> + +#include <iostream> +#include <string> +#include "UnitTest.h" +//#include "BlockChain.h" +#include "MockHsm.h" + +using namespace std; #define HTTPD_SERVER_PORT 80 #define HTTPD_MAX_REQ_LENGTH 1023 @@ -10,6 +18,9 @@ #define HTTPD_MAX_FNAME_LENGTH 127 #define HTTPD_MAX_DNAME_LENGTH 127 +const char* ECHO_SERVER_ADDRESS = "192.168.31.185"; +const int ECHO_SERVER_PORT = 10003; + Serial uart(USBTX, USBRX); //SDFileSystem sd(p5, p6, p7, p8, "sd"); // LPC1768 MBD2PMD @@ -19,6 +30,7 @@ EthernetInterface eth; TCPSocketServer server; TCPSocketConnection client; +TCPSocketConnection my_client; char buffer[HTTPD_MAX_REQ_LENGTH+1]; char httpHeader[HTTPD_MAX_HDR_LENGTH+1]; @@ -31,6 +43,82 @@ FILE *fp; int rdCnt; +// function declation +int test_socket_client(void); +int socket_init(); +int socket_fini(); + +int test_MockHsm() +{ + MockHsm mh; + mh.setAlias("cpp_key"); + //cout<<mh.getAlias()<<endl; + //cout<<mh.createKey()<<endl; + cout<< mh.listKeys() <<endl; + return 0; +} + +int main(void) +{ + printf("main start\n"); + + socket_init(); + + test_MockHsm(); + + test_socket_client(); + + socket_fini(); + + printf("main end\n"); + return 0; +} + +int socket_init() +{ + int ret = 0; + // EthernetInterface eth; + printf("Initializing Ethernet\n"); + ret = eth.init(); //Use DHCP + //eth.init("192.168.31.186", "255.255.255.0", "192.168.31.1"); //Use static ip + printf("Connecting\n"); + ret = eth.connect(); + printf("IP Address is %s\n", eth.getIPAddress()); + + return ret; +} + +int socket_fini() +{ + return eth.disconnect(); +} + +int test_socket_client(void) +{ + TCPSocketConnection socket; + while (socket.connect(ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT) < 0) { + printf("Unable to connect to (%s) on port (%d)\n", ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT); + wait(1); + } + printf("Connected to Server at %s\n",ECHO_SERVER_ADDRESS); + + // Send message to server + char hello[] = "Hello World"; + printf("Sending message to Server : '%s' \n",hello); + socket.send_all(hello, sizeof(hello) - 1); + + // Receive message from server + char buf[256]; + int n = socket.receive(buf, 256); + buf[n] = '\0'; + printf("Received message from server: '%s'\n", buf); + + // Clean up + socket.close(); + + return 0; +} + void get_file(char* uri) { uart.printf("get_file %s\n", uri); @@ -86,7 +174,7 @@ } } -int main (void) +int main_1 (void) { // Serial Interface eth; uart.baud(115200); @@ -103,10 +191,37 @@ // EthernetInterface eth; uart.printf("Initializing Ethernet\n"); - eth.init(); //Use DHCP + //eth.init(); //Use DHCP + eth.init("192.168.31.186", "255.255.255.0", "192.168.31.1"); //Use uart.printf("Connecting\n"); eth.connect(); uart.printf("IP Address is %s\n", eth.getIPAddress()); + + //test socket client + //my_client.connect("192.168.31.185",10003); + //my_client.send_all("hello world",11); + + TCPSocketConnection socket; + while (socket.connect(ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT) < 0) { + uart.printf("Unable to connect to (%s) on port (%d)\n", ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT); + wait(1); + } + uart.printf("Connected to Server at %s\n",ECHO_SERVER_ADDRESS); + + // Send message to server + char hello[] = "Hello World"; + uart.printf("Sending message to Server : '%s' \n",hello); + socket.send_all(hello, sizeof(hello) - 1); + + // Receive message from server + char buf[256]; + int n = socket.receive(buf, 256); + buf[n] = '\0'; + uart.printf("Received message from server: '%s'\n", buf); + + // Clean up + socket.close(); + //////////////////////////////////////////////////////////////////////////// // TCPSocketServer server; server.bind(HTTPD_SERVER_PORT); @@ -117,6 +232,8 @@ uart.printf("\nWait for new connection...\r\n"); server.accept(client); client.set_blocking(false, 1500); // Timeout after (1.5)s + + my_client.send_all("hello world",11); uart.printf("Connection from: %s\r\n", client.get_address()); while (true) { @@ -148,3 +265,40 @@ client.close(); } } + + +int main_2() { + // Serial Interface eth; + uart.baud(115200); + uart.printf("Initializing\n"); + + EthernetInterface eth; + eth.init(); //Use DHCP + eth.connect(); + printf("\nClient IP Address is %s\n", eth.getIPAddress()); + + // Connect to Server + TCPSocketConnection socket; + while (socket.connect(ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT) < 0) { + printf("Unable to connect to (%s) on port (%d)\n", ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT); + wait(1); + } + printf("Connected to Server at %s\n",ECHO_SERVER_ADDRESS); + + // Send message to server + char hello[] = "Hello World"; + printf("Sending message to Server : '%s' \n",hello); + socket.send_all(hello, sizeof(hello) - 1); + + // Receive message from server + char buf[256]; + int n = socket.receive(buf, 256); + buf[n] = '\0'; + printf("Received message from server: '%s'\n", buf); + + // Clean up + socket.close(); + eth.disconnect(); + + while(true) {} +} \ No newline at end of file