胡荣良

胡荣良

工程架构 | 算法

© 2019

项目实践:公益项目接入区块链

项目背景

某大型公益组织打算建设一个公益平台,为了增加平台的公信力,打算引入区块链技术,将用户的捐赠行为存入区块链网络。

技术选型

有两个方案可供选择,一是部署私有的同盟链,好处是可以减少外部依赖,缺点是开发和维护成本较高,同时私有联盟链的公信力不如开放链。二是使用市场上成熟的区块链服务,有点是开发维护成本低,缺点是需要持续付费。

国内的区块链服务其实都不是真正去中心化的,比如蚂蚁区块链,是有20个节点(后续可能会扩展)充电授信网络节点。在这些节点内是去中心化的,但是这20个节点仍然受人为控制(比如将他们关掉)。

因为项目不缺钱,需要尽快发布。于是决定使用目前较为成熟的蚂蚁金服开放联盟链,我们对其进行了调研,结合项目本身,得出以下结论:

  • 蚂蚁金服最近才发布开放联盟链,项目处于初期阶段,缺少社区支持,影响接入效率。
  • 产品功能和配套工具处于迭代中,接入方后续可能需要跟进调整。
  • 不在区块链中存储状态数据,不适用合约服务,只用存证服务。
  • 服务调用需要消耗燃料,因此进入区块链的存证数据应该尽量的少。

之所以选择蚂蚁金服开放联盟链,一是没有更好的选择,二是有蚂蚁金服的信用和技术背书。但在实际接入过程中还是存在一些问题。

接入指南

官方提供可接入文档,地址:https://tech.antfin.com/docs/2/143566

这里给出重点步骤。

一、开通开放联盟链。需要用到支付宝账号,建议使用项目专用账号。地址:https://openchain.cloud.alipay.com/

二、购买燃料,调用区块链服务时需要消耗燃料。地址:https://openchain.cloud.alipay.com/balance

三、创建链账户,建议选择秘钥托管,可以减少后续SDK接入的配置,不过我们项目使用的秘钥非托管。地址:https://openchain.cloud.alipay.com/account/lists

四、给链账户分配燃料,通常每次存证服务需要消耗3w燃料,根据自身业务量来分配,本项目测试阶段分配了500W的燃料。地址:https://openchain.cloud.alipay.com/balance

五、SDK接入

因为本项目服务端使用springboot架构,因此需要用到他们提供的Java SDK。官方接入文档地址:https://tech.antfin.com/docs/2/146924

这里遇到的第一个坑是官方依赖没有发布到maven仓库中心,因此需要将sdk作为本地jar包引入项目。pom.xml配置参考

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    ...

    <dependencies>

        ...

        <!-- blockchain -->
        <dependency>
            <groupId>org.springframework.retry</groupId>
            <artifactId>spring-retry</artifactId>
            <version>1.2.4.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>com.antfinancial.baas</groupId>
            <artifactId>mychain-rest-lib</artifactId>
            <version>0.10.2.11</version>
            <scope>system</scope>
            <systemPath>${project.basedir}/lib/rest-client-2.11-2020.03.12-async-SNAPSHOT-with-dependencies.jar
            </systemPath>
        </dependency>
    </dependencies>

    <build>
        <resources>
            <resource>
                <directory>${project.basedir}/lib</directory>
                <targetPath>BOOT-INF/lib/</targetPath>
                <includes>
                    <include>*.jar</include>
                </includes>
            </resource>
            <resource>
                <directory>src/main/resources</directory>
                <targetPath>BOOT-INF/classes/</targetPath>
            </resource>
        </resources>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <includeSystemScope>true</includeSystemScope>
                </configuration>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-surefire-plugin</artifactId>
                <version>2.5</version>
                <configuration>
                    <skipTests>true</skipTests>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

第二个坑,官方的SDK是个胖SDK,将SDK依赖也一并打包进去了,里面包含spring boot 1.5.9.RELEASE版本,而我们的项目使用springboot 2.1.9,类冲突导致项目无法启动。

这里有几种解决思路:

    1. 将区块链服务使用springboot 1.5.9 单独部署,但是我们项目使用了spring cloud集群,出了要接入springboot还要接入eureka,不适合本项目。
    1. 使用HTTP方式接入,需要很多额外的操作,增加了开发成本,违背快速上线的项目目标,不适合本项目。
    1. 修改jar包,移除springboot相关依赖,重新打包。经过测试,sdk能正常运行,本项目采用的这个方法。

    六、调用存证服务将数据上链

参照官方教程调用SDK即可。地址:https://tech.antfin.com/docs/2/146924#h4-u5B58u8BC1

这里给出本项目使用的Client封装类

package com.zhiyu.guangda.support.business;

import com.alibaba.fastjson.JSON;
import com.antfinancial.mychain.baas.tool.restclient.RestClient;
import com.antfinancial.mychain.baas.tool.restclient.RestClientProperties;
import com.antfinancial.mychain.baas.tool.restclient.model.ClientParam;
import com.antfinancial.mychain.baas.tool.restclient.model.Method;
import com.antfinancial.mychain.baas.tool.restclient.response.BaseResp;
import com.zhiyu.guangda.base.exception.RetryException;
import com.zhiyu.guangda.support.bo.BTQueryTransactionResponseData;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.bouncycastle.util.encoders.Base64;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class BlockchainClient {

    @Autowired
    private RestClient restClient;

    @Autowired
    private RestClientProperties restClientProperties;

    /**
     * 存证上链
     *
     * @param data 存证内容
     * @return
     * @throws Exception
     */
    public String deposit(String data) throws Exception {
        ClientParam clientParam = restClient.createDepositTransaction(restClientProperties.getDefaultAccount(), data, 50000L);
        BaseResp resp = restClient.chainCall(clientParam.getHash(), clientParam.getSignData(), Method.DEPOSIT);
        checkResp(resp);
        log.info("存证上链成功,内容 = {}, hash = {}", data, clientParam.getHash());
        return clientParam.getHash();
    }

    /**
     * 查询存证结果
     *
     * @param hash
     * @return
     */
    public String queryTransaction(String hash) {
        BTQueryTransactionResponseData data = queryTransactionOrigin(hash);
        String transactionData = new String(Base64.decode(data.getTransactionDO().getData()));
        log.info("存证内容 {}", transactionData);
        return transactionData;
    }

    /**
     * 查询存证原始结果
     *
     * @param hash
     * @return
     */
    @Retryable(value = RetryException.class, maxAttempts = 2, backoff = @Backoff(delay = 30000, multiplier = 1))
    public BTQueryTransactionResponseData queryTransactionOrigin(String hash) {
        BaseResp resp;
        try {
            resp = restClient.chainCall(hash, null, Method.QUERYTRANSACTION);
        } catch (Exception e) {
            throw RetryException.create(e.getMessage(), e);
        }
        if (!resp.isSuccess() || !StringUtils.equals(resp.getCode(), "200")) {
            throw new RetryException(JSON.toJSONString(resp));
        }

        log.info("查询到存证结果, resp = {}, hash = {}", JSON.toJSONString(resp), hash);
        return JSON.parseObject(resp.getData(), BTQueryTransactionResponseData.class);
    }


    private void checkResp(BaseResp resp) throws Exception {
        if (!resp.isSuccess() || !StringUtils.equals(resp.getCode(), "200")) {
            throw new Exception(JSON.toJSONString(resp));
        }
    }
}

工程源码

参见:https://github.com/hurongliang/fundation-use-alipay-openchain

小结

通过该项目,我们学到了区块链技术在实际应用中如何产生价值。

早期市场培育存在过度神秘化现象,导致业界对其价值落地产生怀疑,而区块链的理念本身是有价值的,相信随着炒作热情消退,市场趋于理性,我们会找到更多区块链技术与现实需求相结合的落地场景。

在技术演进和更大规模落地的进程中如何能否保持其去权威、公开、平等的技术理念依然存在较大不确定性。