阐明:本篇所波及的DAPP众筹需要及合约实现来自登链社区
在后面的众筹案例中,创作者没有方法查看到所有参与者,有两个方法能够实现查案所有参与者:
- 退出一个状态变量:address[] joinAccounts,这是一个数组,用来记录所有参与者的地址,每当有新的参与者进来时,往数组中退出参与者地址。
- 通过触发事件把参与者地址记录到日志中,而后启动一个服务程序监听事件,当事件触发时,把参与者地址记录到数据库中,并提供一个后端服务,把数据库中的参与者列表返回给前端。
两种办法各有优缺点:办法1的gas耗费会远高于办法2,长处是不须要额定引入服务器;办法2则相同,应用事件的办法2其实还有一个益处,就是能够实时监听到事件的变动(通常对应着链上状态的变动),这在一些场合十分有用。
上面次要介绍办法2,通过后盾服务,监听事件变动。咱们应用Node.js及Express框架作为后盾服务。
装置服务端环境
进入crowdfunding工程目录,创立server目录作为后端工程目录,并装置环境:
mkdir servercd servernpm initnpm install express --save
新建一个文件index.js,编写服务端程序:
const express = require('express')const app = express()app.get('/', (req, res) => res.send('Hello World'))app.listen(3000, () => console.log('Start Server, listening on port 3000!'))
下面代码,引入了express模块,它在后盾常驻运行,并监听3000端口,当客户端发动申请后,响应“Hello World”字符串。
启动后端服务:
node index.js
启动后,在浏览器拜访http://localhost:3000,就能够看到Hello World!
常驻服务监听合约事件
先批改Crowdfunding合约,退出一个事件。而后在receive函数中触发该事件:
contract Crowdfunding { ... // address[] joinAccouts; event Join(address indexed user, uint price); ... // 用户向合约转账时,触发的回调函数 receive() external payable { ... emit Join(msg.sender, msg.value); // 48820 gas } ... }
批改完合约后,应用truffle migrate --reset从新编译部署。
回到后端,在server目录下装置web3:
npm install web3 --save
而后批改index.js,退出监听Join事件的代码:
// express 启动代码...// 引入web库var Web3 = require('web3');// 应用WebSocket协定 连贯节点let web3 = new Web3(new Web3.providers.WebsocketProvider('ws://localhost:7545'));// 获取合约实例var Crowdfunding = require('../build/contracts/Crowdfunding.json');const crowdFund = new web3.eth.Contract( Crowdfunding.abi, Crowdfunding.networks[5777].address);// 监听Join事件crowdFund.events.Join(function(error, event) { if (error) { console.log(error); } // 打印出交易hash 及区块号 console.log("交易hash:" + event.transactionHash); console.log("区块高度:" + event.blockNumber); // 取得监听到的数据: console.log("参加地址:" + event.returnValues.user); console.log("参加金额:" + event.returnValues.price);});
在初始化web3时,应用了WebsocketProvider,通过WebSocket通信协议与节点通信,如果是应用Geth节点,须要应用--ws开启服务,开发应用的Ganache默认开启了WebSocket服务。
重新启动后盾服务:
node index.js
启动前端服务:
npm run serve
在浏览器里拜访http://localhost:8080,进入前端页面,点击“参加众筹”(如果以后账户参加过,就切换不同账号参加众筹),切换到后端的命令行控制台窗口,能够看到打印出日志:
交易hash:0xe45848494c6990469db6de4485708ffb72d2d27bbc64cde92ff67d11394176ad区块高度:6参加地址:0xa75a4da940a2dDcE9db7e4FbCC62e236558DbEaA参加金额:20000000000000000
为了方便管理,咱们能够把这部分业务数据写入到中心化的数据库里。
MySql数据库环境筹备
装置Mysql数据库,并创立以下数据库和表来存储众筹数据:
CREATE DATABASE crowdfund;use crowdfund;CREATE TABLE joins( id INT UNIQUE AUTO_INCREMENT, address VARCHAR(42) UNIQUE, price FLOAT NOT NULL, tx VARCHAR(66) NOT NULL, block_no INT NOT NULL, created_at datetime, PRIMARY KEY (id));
监听数据入库
给后盾装置node-mysql驱动:
cd servernpm install mysql --save
批改index.js,引入mysql,并退出一个插入数据库函数:
var mysql = require('mysql');function getConn() { return mysql.createConnection({ host : 'localhost', user : 'root', password : '123456', port : '3306', database : 'crowdfund' });}function insertJoins(address, price, tx, blockNo) { // 连贯数据库 var connection = getConn(); connection.connect(); // 构建插入语句 const query = `INSERT into joins ( address, price, tx, block_no, created_at ) Values (?,?,?,?,NOW())`; const params = [address, price, tx, blockNo]; // 执行插入操作 connection.query(query, params, function (error, results) { if (error) throw error; // console.log('results=> ' + results); }); connection.end();}
并在监听打印日志的前面调用insertJoins()函数:
// 监听Join事件crowdFund.events.Join(function(error, event) { ... insertJoins(event.returnValues.user, // 把以wei为单位的价格转为ether单位 web3.utils.fromWei(event.returnValues.price), event.transactionHash, event.blockNumber)});
重启后盾服务:
node index.js
在DAPP前端页面单击“参加众筹”后(如果以后账户参加过,就切换不同账号参加众筹),如果一切正常,就能够在数据库查问到相应的众筹记录:
为前端提供众筹记录显示
通过读取数据库的数据,并在Express退出一个路由,承受前端申请后返回读取到的数据,在index.js先退出一个getJoins()函数来读取数据库数据:
// 通过一个回调函数把后果返回进来function getJoins(callback) { // 获取数据库链接 var connection = getConn(); connection.connect(); // 查问 SQL const query = `SELECT address, price from joins`; const params = []; // 查询数据库 connection.query(query, params, (err, rows)=>{ if(err){ return callback(err); } console.log(`result=>`, rows); callback(rows); }); connection.end();}
退出一个新路由/joins:
app.get('/joins', (req, res) => { getJoins( rows=> { // 设置容许跨域拜访 res.set({'Access-Control-Allow-Origin': '*'}) .send(rows) });})
重启后端服务,浏览器拜访http://localhost:3000/joins,能够看到返回参加众筹的JSON数据:
后端筹备好了后,接下来咱们让前端通过Ajax申请拜访http://localhost:3000/joins接口获取众筹数据列表。
在前端我的项目根目录下,装置axios:
npm install axios
批改CrowdFund.vue,退出获取众筹列表的getJoins()函数:
...import axios from 'axios';export default { name: 'CrowdFund', data() { return { ... joinList: [], }; }, // 以后Vue组件被创立时回调的hook 函数 async created() { ... this.getJoins() }, methods: { ... // 获取众筹列表 getJoins() { axios.get('http://localhost:3000/joins') .then(response => { this.joinList = response.data }) .catch(function (error) { // Ajax申请失败解决 console.log(error); }); }, }}
最初还须要在HTML模板中退出joinList的渲染:
<!-- 如果是创作者,显示 --><div class="box" v-if="isAuthor"> <div > <p v-bind:key="item" v-for="item in joinList" > <label> 地址:{{ item.address.substring(0, 30) + "..." }}</label> 金额:<b> {{ item.price }} </b> </p> </div> <button :disabled="closed" @click="withdrawFund"> 提取资金</button></div>
启动前端利用:
npm run serve
浏览器拜访http://localhost:8000,在MetaMask中切换到创作者账号,刷新浏览器后能够看到输入的众筹列表:
在众筹DAPP案例中,咱们通过Vue.js开发利用前端,应用Node.js后端监控合约事件,并将一些外围业务数据用中心化数据库进行了存储。这就囊括了所有在DAPP开发中波及的内容了。