Facebook最新Libra币开发指南---接口服务器开发2

2019年06月24日 16:23:16 最老程序员闫涛 阅读数 1145

在上一篇博文中，我们已经使用Rust语言开发了一款简单的Web服务器，虽然以单线程方式工作，但是可以正确解析Libra Core的常见命令，完成了程序的基本框架，在这一篇文件中，我们将带领大家逐个实现这些命令，最后形成一个基本完整的程序，最后集成Libra Core的client工具中。这样我们就有一个Libra Core的Web接口，大家就可以将自己的应用系统第一时间移植到Libra Core，相信应该在绝对是Libra Core上的第一批应用，为明年Facebook推出的主网商用服务抢占有利的位置。

集成到命令行工具

我们首先需要将我们开发的Web服务器，集成到Libra Core Client中。首先打开libra/client/src/main.rs文件，将上一篇博文中的代码，除main函数外，全部拷贝到libra/client/src/main.rs文件中。
拷贝完成之后，我们首先编译运行一下Libra Core Client，以保证我们的程序没有编译错误，在libra目录下运行如下命令：

./scripts/cli/start_cli_testnet.sh

• 1

在编译过程中会有一些警告信息，提示我们定义了一些函数而没有使用这些函数，因为我们定义的命令处理函数，确实没有调用过，所以我们可以暂时忽略这些警告信息。
接着我们在原来loop循环开始时调用启动我们服务器的方法，启动服务器，如下所示：

......let config = Config::builder().history_ignore_space(true).completion_type(CompletionType::List).auto_add_history(true).build();let mut rl = Editor::<()>::with_config(config);start_server(&mut client_proxy);/*loop {let readline = rl.readline("libra% ");match readline {Ok(line) => {......
*/

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14

在上面的代码中，我们将client_proxy作为参数传入，实际上所有调用Libra Core功能的操作，均由此对象来实现。
重新编译运行客户端。我们应该可以看到Web服务器已经正常启动，在浏览器上输入http://127.0.0.1:7878/ls?cmd=query_balance&account_id=88 ，会显示如下所示的结果：

如果可以显示上述结果，就证明我们的Web服务器已经正常启动，并且可以正常接受和处理Libra Core的命令了。下面我们将在接收到客户端发送过来的命令之后，调用Libra Core相应接口，执行相应的逻辑，最后将调用结果返回给客户端。

改造启动方法和处理连接方法

由于我们要在Libra Core Client的模式下运行，我们的启动方法需要做出如下改动：

fn start_server(client_proxy: &mut ClientProxy) {println!("Libra Server v0.0.3 Starting up ...");let listener = TcpListener::bind("127.0.0.1:7878").unwrap();for stream in listener.incoming() {let stream = stream.unwrap();handle_connection(stream, client_proxy);}
}

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8

我们的连接处理方法需要做出如下改动：

fn handle_connection(mut stream: TcpStream, client_proxy: &mut ClientProxy) {let mut contents: String = String::from("Hello World!");let mut buffer = [0; 1024];// 获取请求信息stream.read(&mut buffer).unwrap();println!("Request: {}", String::from_utf8_lossy(&buffer[..]));let request = String::from_utf8_lossy(&buffer[..]);// 不处理请求网站图标请求if request.find("GET /favicon.ico HTTP/1.1") >= Some(0) {return ;}// 请出请求中的query stringlet query_string = &get_query_string(&request);println!("query_string:{}", query_string);let cmd = get_cmd_param(query_string.to_string());println!("接收到命令：cmd={}!", cmd);let params: Vec<_> = query_string.split("&").collect();if cmd.find("account_create")>=Some(0) {contents = handle_account_create(params, client_proxy);} else if cmd.find("account_list")>=Some(0) {contents = handle_account_list(params, client_proxy);} else if cmd.find("account_mint")>=Some(0) {contents = handle_account_mint(params, client_proxy);} else if cmd.find("query_balance")>=Some(0) {contents = handle_query_balance(params, client_proxy);} else if cmd.find("query_sequence")>=Some(0) {contents = handle_query_sequence(params, client_proxy);} else if cmd.find("transfer")>=Some(0) {contents = handle_transfer(params, client_proxy);} else if cmd.find("query_txn_acc_seq")>=Some(0) {contents = handle_query_txn_acc_seq(params, client_proxy);}let response = format!("HTTP/1.1 200 OK\r\n\r\n{}", contents);stream.write(response.as_bytes()).unwrap();stream.flush().unwrap();
}/**
* 获取请求中的Query String，规定参数以?cmd=开头
* @version v0.0.1 闫涛 2019.06.23
*/
fn get_query_string(request: &str) -> String {let pos = request.find("?cmd=");if pos <= Some(0) {return "Has no parameters in request".to_string();}let end_pos = request.find(" HTTP/1.1");return (&request[(pos.unwrap()+1)..end_pos.unwrap()]).to_string();
}/**
* 获取请求cmd参数值
* @version v0.0.1 闫涛 2019.06.23
*/
fn get_cmd_param(query_string: String) -> String {let params: Vec<_> = query_string.split("&").collect();for param in params.iter() {println!("item: {}!", param);if param.find("cmd=") >= Some(0) {let cmd = &param[4..];return cmd.to_string();}}return "".to_string();
}

• 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

与前一篇文章中的程序不同点在于，调用每个命令处理函数时，需将client_proxy作为参数传入。有了这些公共方法之后，我们就可以开始实现各个命令处理函数了。

账户生成

在命令行模式下，我们通过account create来创建账户，在我们的web服务器中我们通过http://127.0.0.1:7878/ls?cmd=account_create来创建账户，命令处理代码如下所示：

/**
* 生成账户命令处理函数
* @version v0.0.1 闫涛 2019.06.23
*/
fn handle_account_create(_params: Vec<&str>, client_proxy: &mut ClientProxy) -> String {println!("生成新账户！");let mut rst: String;match client_proxy.create_next_account() {Ok(account_data) => {rst = format!("{{\"account_id\": \"{}\", \"wallet_address\": \"{}\"}}", account_data.index, hex::encode(account_data.address));},Err(e) => rst = format!("Error creating account:{}", e),}return rst;
}

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16

在这个例子中使用了Rust的一种比较特别的语法，我们用match修饰调用client_proxy.create_next_account方法，该方法会返回Ok或Err两种情况，我们需要分别进行处理，大家可以将match 理解为其他语言中的switch语句。

查询所有账户列表

我们通过http://127.0.0.1:7878/ls?cmd=account_list请求来获取所有账户列表，命令处理函数如下所示：

/**
* 列出当前系统的所有账户
* @version v0.0.1 闫涛 2019.06.23
*/
fn handle_account_list(params: Vec<&str>, client_proxy: &ClientProxy) -> String {return client_proxy.get_all_accounts();
}

• 1
• 2
• 3
• 4
• 5
• 6
• 7

我们在client/src/client_proxy.rs中添加一个新的函数，如下所示：

    /// Print index and address of all accounts.pub fn get_all_accounts(&self) -> String {let mut rst: String = String::new();rst.push_str("[");if !self.accounts.is_empty() {for (ref index, ref account) in self.accounts.iter().enumerate() {let mut item: String = String::new();item.push_str(&format!("{{\"account_id\":{}, \"wallet_address\":\"{}\", \"account_seq\":{}, \"account_status\":\"{:?}\"}},", index, hex::encode(&account.address), account.sequence_number, account.status));rst.push_str(&item);}}if let Some(faucet_account) = &self.faucet_account {println!("Faucet account address: {}, sequence_number: {}, status: {:?}",hex::encode(&faucet_account.address),faucet_account.sequence_number,faucet_account.status,);}rst.push_str("]");return rst;}

• 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

本来在官方程序中，有一个print_all_accounts方法，但是该方法只是将信息打印到屏幕上，这显然不是我们所需要的，所以我们重写了这个函数，将其返回值定义为Json字符串。

挖矿和发币

我们通过http://127.0.0.1:7878/ls?cmd=account_mint&account_id=1&num_coins=100来进行挖矿和发币，表明向编号为1的钱包发送100个Libra币，命令处理函数如下所示：

/**
* 挖指定数量的币发送给指定的账户
* @version v0.0.1 闫涛 2019.06.23
*/
fn handle_account_mint(params: Vec<&str>, client_proxy: &mut ClientProxy) -> String {let mut account_id: String = String::new();let mut num_coins: String = String::new();for param in params.iter() {if param.find("account_id=") >= Some(0) {account_id.push_str(&param[11..]);} else if param.find("num_coins=") >= Some(0) {num_coins.push_str(&param[10..]);}}println!("挖矿发币：account_id={}; num_coins={}!", account_id, num_coins);let cmd = format!("mint {} {}", account_id, num_coins);let params = ["mint", account_id.as_str(), num_coins.as_str()];match client_proxy.account_mint_coins(&params, false) {Ok(msg) => return msg,Err(_) => "{{\"status\": \"Error\"}}".to_string()}
}

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22

查询账户余额

我们通过http://127.0.0.1:7878/ls?cmd=query_balance&account_id=1来查询账户编号为1的账户的余额，命令处理函数如下所示：

/**
* 查询账户余额
* @version v0.0.1 闫涛 2019.06.23
*/
fn handle_query_balance(params: Vec<&str>, client_proxy: &mut ClientProxy) -> String {let mut account_id: String = String::new();for param in params.iter() {if param.find("account_id=") >= Some(0) {account_id.push_str(&param[11..]);} }println!("查询余额：account_id={};!", account_id);let params = ["balance", account_id.as_str()];match client_proxy.get_balance(&params) {Ok(num) => {let resp = format!("{{\"status\": \"Ok\", \"balance\": {} }}", num);return resp;},Err(_) => "{{\"status\": \"Error\"}}".to_string()}
}

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21

查询账户最新交易编号

我们通过http://127.0.0.1:7878/ls?cmd=query_sequence&account_id=1查询账户编号为1的账户的交易编号，注意这里只有资金转出时才产生交易，命令处理方法如下所示：

/**
* 查询指定账户的交易编号，即已经发生的交易数（指转出的笔数）
* @version v0.0.1 闫涛 2019.06.23
*/
fn handle_query_sequence(params: Vec<&str>, client_proxy: &mut ClientProxy) -> String {let mut account_id: String = String::new();for param in params.iter() {if param.find("account_id=") >= Some(0) {account_id.push_str(&param[11..]);}}println!("查询交易编号：account_id={};!", account_id);let params = ["sequence", account_id.as_str()];match client_proxy.get_sequence_number(&params) {Ok(seq) => {let resp = format!("{{\"status\": \"Ok\", \"sequence\": {} }}", seq);return resp;},Err(_) => "{{\"status\": \"Error\"}}".to_string()}
}

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21

转账

我们通过http://127.0.0.1:7878/ls?cmd=transfer&src_account_id=1&dest_account_id=2&amount=20来实现从账户1转20个Libra币给账户2,命令处理函数如下所示：

/**
* 账户之间转账
* @version v0.0.1 闫涛 2019.06.23
*/
fn handle_transfer(params: Vec<&str>, client_proxy: &mut ClientProxy) -> String {let mut src_account_id: String = String::new();let mut dest_account_id: String = String::new();let mut amount: String = String::new();for param in params.iter() {if param.find("src_account_id=") >= Some(0) {src_account_id.push_str(&param[15..]);} else if param.find("dest_account_id=") >= Some(0) {dest_account_id.push_str(&param[16..]);} else if param.find("amount=") >= Some(0) {amount.push_str(&param[7..]);}}println!("账户间转账交易：src_account_id={}; dest_account_id={}; amount={}!", src_account_id, dest_account_id, amount);let params = ["transfer", src_account_id.as_str(),dest_account_id.as_str(),amount.as_str()];match client_proxy.transfer_coins(&params, false) {Ok(ias) => {let resp = format!("{{\"status\": \"Ok\", \"account_index\": {}, \"account_number\": {} }}", ias.account_index, ias.sequence_number);return resp;},Err(_) => "{{\"status\": \"Error\"}}".to_string()}
}

• 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

查询交易详细信息

我们通过http://127.0.0.1:7878/ls?cmd=query_txn_acc_seq&account_id=1&seq=1用来查询账户1的编号为1的交易的详情，命令处理函数如下所示：

/**
* 查询交易详情
* @version v0.0.1 闫涛 2019.06.23
*/
fn handle_query_txn_acc_seq(params: Vec<&str>, client_proxy: &mut ClientProxy) -> String {let mut account_id: String = String::new();let mut seq: String = String::new();for param in params.iter() {if param.find("account_id=") >= Some(0) {account_id.push_str(&param[11..]);} else if param.find("seq=") >= Some(0) {seq.push_str(&param[4..]);}}println!("查询交易详情：account_id={}; seq={}!", account_id, seq);let params = ["txn_acc_seq", account_id.as_str(), seq.as_str(), "false"];match client_proxy.get_committed_txn_by_acc_seq(&params) {Ok(rst) => {let mut resp = String::new(); //format!("{{\"status\": \"Ok\" }}");if let Some(obj) = rst {let trans = obj.0;resp.push_str(&trans.format_for_client(name_cb));}return resp;},Err(_) => "{{\"status\": \"Error\"}}".to_string()}
}

• 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

这样，我们就拥有了一个与官方命令功能相等的Web API，虽然十分简陋，但是作为应用系统测试后台已经足够了，我们可以现在就开始构建基于Libra的应用系统，祝大家能抓住Libra的商机。

Facebook最新Libra币开发指南---接口服务器开发2相关推荐

1. Facebook最新Libra币开发指南---接口服务器开发

   在Libra Core中,官方提供了一个命令行工具,可以实现创建账户.挖矿和转账等基本操作,但是没有提供Restful接口,使我们想要开发的应用系统,将区块链逻辑移植到Libra Testnet上去. ...

2. DigWS 短消息和WapPush 快速开发指南-接口介绍

   DigWS 短消息和WapPush 快速开发指南-接口介绍 SendSms:发送短消息 Parameter<?xml:namespace prefix = o /> Description ...

3. MeeGo 开发指南 1.0 开发教程

   MeeGo 开发指南 1.0 开发教程 转自: MeeGo中文 介绍 如果想获取MeeGo平台的开发概览,最好地方的是MeeGo developers.这里讨论的是一些更细节化的问题,比如MeeGo ...

4. 理解各种设计模式原则及区别丨浅谈Nginx中核心设计模式-责任链模式丨C++后端开发丨Linux服务器开发丨web服务器

   理解各种设计模式原则及区别丨浅谈Nginx中核心设计模式-责任链模式 1. 开闭.单一职责.里氏替换.接口隔离等设计原则 2. 随处可见的模板方法 3. nginx中核心设计模式 责任链模式 4. 责 ...

5. redis，memcached到nginx，底层网络io中剥离精髓丨C/C++Linux丨C++后端开发丨Linux服务器开发丨底层原理

   redis,memcached到nginx,底层网络io中剥离精髓 1. redis单线程网络的优缺点 2. memcached多线程网络的并发优势 3. nginx多进程网络的优势 视频讲解如下,点 ...

6. 从100场腾讯面试中，抽出来经典面试题，腾讯技术职业等级丨C++后端开发丨Linux服务器开发丨面试经验丨面试总结

   从100场腾讯面试中,抽出来经典面试题,腾讯技术职业等级 视频讲解如下,点击观看: 从100场腾讯面试中,抽出来经典面试题,腾讯技术职业等级丨C++后端开发丨Linux服务器开发丨面试经验丨面试总结丨 ...

7. 解析Linux内核源码中数据同步问题丨C++后端开发丨Linux服务器开发丨Linux内核开发丨驱动开发丨嵌入式开发丨内核操作系统

   剖析Linux内核源码数据同步 1.pdflush机制原理 2.超级块同步/inode同步 3.拥塞及强制回写技术 视频讲解如下,点击观看: 解析Linux内核源码中数据同步问题丨C++后端开发丨Li ...

8. Nginx源码从模块开发入手，3个项目弄透nginx模块开发丨Linux服务器开发丨C++后端开发丨中间件开发丨分布式丨web服务器

   Nginx源码从模块开发入手,3个项目弄透nginx模块开发 1. Nginx http请求的11个处理流程 2. Upstream, Filter,Handler模块分析 3. nginx如何拒绝无 ...

9. AutoCAD 开发文档，AutoLISP 教程，.Net AutoCAD开发教程，VB AutoCAD开发教程，ObjectARX 开发指南,VBA AutoCAD开发教程，ActiveX 开发指南

   AutoCAD 开发文档, CAD开发者社区 - AutoCAD二次开发文档,CAD二次开发,CAD插件开发,中文CAD文档 - 中文CAD开发文档,CAD二次开发问题交流,优秀插件分享 AutoLI ...

最新文章

1. 谈谈机器学习模型的部署
2. ERROR MESSAGE: Invalid command line: Malformed walker argument: Could not find walker with name
3. [九省联考2018]IIIDX
4. 打开指定摄像头_我在无人区深处，遇到了一个高清摄像头
5. JSsearch实现在购物网站输入后推荐联想的效果
6. python基础----python的使用(四)
7. MMM结合Semisync机制实现Mysql Master-Master高可用
8. javaScript第一天（1）
9. matlab 如何hidden,Matlab基本函数-hidden函数
10. 第8章 硬盘和显卡的访问与控制
11. 大数据平台数据挖掘的作用是什么
12. 977计算机考研,中国海洋大学 977计算机技术与软件工程专业课经验分享
13. js 实现60秒倒计时
14. 数据库——怎样实现数据完整性
15. Android Studio首次连接不上网易mumu模拟器解决办法
16. python中如何判断大小写_用python如何判断字符的大小写
17. KFC宅急送点餐系统开发 MFC动态树形控件使用
18. PTA(每日一题)7-66 分解素因子
19. C++ 位域(Bit Fields)
20. sharding-jdbc 分库分表的 4种分片策略，还蛮简单的

热门文章

1. java字节的输入输出流,java 字节输入输出流
2. php下字符与二进制互转函数,PHP 字符串与二进制互转
3. 基于keras 的神经网络股价预测模型
4. 数学知识笔记：拉格朗日乘子
5. tkinter笔记：画布canvas
6. Tableau可视化分析实战系列Tableau基础概念全解析 （一）-数据结构及字段
7. MCMC采样和M-H采样
8. Java项目导出为可执行jar包，并在windows/linux下运行
9. 大数据之“用户行为分析”
10. pandas包 问题汇总