二十分钟教你如何将区块链应用与函数计算相结合

本文涉及的产品
函数计算FC,每月15万CU 3个月
Serverless 应用引擎免费试用套餐包,4320000 CU,有效期3个月
简介: 前言 本篇文章适合对区块链应用感兴趣或是想要通过函数计算服务进一步开发区块链应用的新人。本文将结合阿里云区块链服务、阿里云函数计算服务、阿里云日志服务 以及社区应用 Marbles,手把手教大家如何将阿里云区块链服务与阿里云函数计算服务相结合,并进一步提供业务上的结合场景,供大家开拓思路。

前言

本篇文章适合对区块链应用感兴趣或是想要通过函数计算服务进一步开发区块链应用的新人。本文将结合阿里云区块链服务、阿里云函数计算服务、阿里云日志服务 以及社区应用 Marbles,手把手教大家如何将阿里云区块链服务与阿里云函数计算服务相结合,并进一步提供业务上的结合场景,供大家开拓思路。

本文分为以下几部分:

  • 函数计算与区块链
  • Marbles 区块链应用介绍
  • Marbles 区块链应用结合函数计算进行扩展示例
  • 区块链应用与函数计算在业务上结合的场景与价值探讨

函数计算与区块链

函数计算

函数计算是事件驱动的全托管计算服务。使用函数计算,无需采购与管理服务器等基础设施,只需编写并上传代码。函数计算为用户准备好计算资源,弹性地可靠地运行任务,并提供日志查询、性能监控和报警等功能。借助函数计算,可以快速构建任何类型的应用和服务,并且只需为任务实际消耗的资源付费。

下图为函数计算工作流程:

1543305945131_84730dd2_0b63_4e0d_bfe6_1a0c6917be54

区块链

区块链可以理解为去中心的分布式记账系统,其是一种 分布式、去中心化的计算与存储架构 。区块链通过某种方式来记录数据,使用户可以信任区块链系统记录的数据。区块链中的记账节点会按照一致性协议记账。记账节点愿意按照一致性协议记账,是因为在一致性协议的设计中,诚实的记账节点会得到相应的奖赏,且诚实的记录比恶意篡改记录的收益更大。

依托于区块链网络的可信度,衍生出了智能合约的概念。什么是智能合约呢?现实生活中,买家与卖家要进行一笔交易,为了保证交易的顺利进行,双方会签订一份合约,合约中会声明双方各自的身份、权利以及义务。当交易出现纠纷时,买家与卖家根据当时签订的合约通过法律的手段解决纠纷。这种方式的不足之处在于解决纠纷的过程需要第三方权威来仲裁以及需要大量时间。那么,假使我们现在有一位可信公正的交易代理人。卖家将商品交给代理人,买家与代理人双方之间一手交钱一手交货。若买家拒绝购买,代理人会将商品归还给买家。买家也不会付了钱拿不到商品。智能合约就可以充当这样的代理人,其为区块链上一个包含合约代码和存储空间的虚拟账户,合约的代码控制智能合约的行为,合约的账户存储合约的状态。

由于有了智能合约,DApp (Decentralized Application 即去中心化应用)也应运而生。DApp 是运行在区块链网络上的应用软件,其上运行的代码我们称之为智能合约。

Marbles 区块链应用介绍

Marbles 区块链应用是一个 资产转移 应用演示。在 Marbles 区块链应用中多个用户可以创建并相互转移弹珠。 ( 即弹珠就是资产转移中的资产 )

marbles

上图中:

  • Amy、Alice、Ava 所在的小长方形是她们每个人的账户
  • 小长方形中的圆形弹珠是每个人账户中的资产,弹珠的颜色和大小是资产的属性
  • 点击小长方形中的加号是为某个账户创建弹珠(资产)
  • 将某个小长方形中的弹珠拖拽到右上方的垃圾桶中,是为某个账户删除弹珠(资产)
  • 将某个弹珠从一个小长方形拖拽到到另一个小长方形,是弹珠(资产)的转移
  • 每一步的操作会在下方的 BLOCKS 创建一个新的小正方形,这个小正方形就代表包含交易内容的区块

Marbles 区块链应用代码分成三部分:

  1. 链码 - 区块链网络中,对等节点所运行的代码。链码在此次介绍的 Marbles 应用中的主要作用是处理创建以及转移弹珠的逻辑。
  2. 客户端 - 浏览器中运行的代码,负责 Marbles 应用页面的渲染与交互。
  3. 服务端 - 服务器中运行的代码,充当 Marbles 应用与区块链网络之间的桥梁,其与客户端以及区块链网络中运行着链码的节点进行通信。

在 Marbles 应用中,当客户端发送消息给服务端,服务端与区块链网络通信的时序图大体上如下图所示:( 读者对详细过程感兴趣,可以阅读 Github IBM-Blockchain/marbles )
其中,Peer 节点(对等节点) 存在于区块链网络中,拥有账本并且可安装链码。Orderer 节点负责接收包含签名的交易,对未打包的交易进行排序生成区块,广播给 Peer 节点。

marbles_process
上图中:Client 以及 Server 是上文中所说的客户端以及服务端。

  1. 当用户创建或转移弹珠时,Client 客户端触发相应事件,并向 Server 服务端发起请求。
  2. Server 接收到事件信息后,首先会构建提案(也就是交易),提案是将事件信息进行封装,比如:此次交易的两方以及交易内容是什么。
  3. Server 将构建好的提案发送给区块链网络中的一个 Peer 节点,由 Peer 节点来对提案进行模拟,校验其合法性。为什么要这么做呢?因为链码的作用就是处理交易逻辑,而链码安装在 Peer 节点上,并没有安装在 Server 上。
  4. 如果 Peer 节点模拟提案成功,认为其合法,则会对提案进行背书,并向 Server 返回背书后的提案。背书可以理解为,当我们去购买东西并忘记带现金,付给对方一张 别人 给的支票。对方怀疑支票不可兑现的时候,我们在支票上签字并表明若这张 他人 给的支票不能兑换,则可以来找我们要现金。这个签字的动作就是背书,声明对事物或被认可人的支持。
  5. Server 将背书后的提案发送给 Orderer 节点。
  6. Orderer 节点对提案进行排序并打包进区块,将区块广播给区块链网络中的所有 Peer 节点。

Marbles 区块链应用结合函数计算进行扩展示例

假设说,现在有这么一个业务场景,需要在每次 Marbles 应用有事件发生时,要对事件进行相应处理,且这部分的处理代码会 经常迭代 。那么,在区块链应用更新需要较多时间的情况下,通过函数计算来处理是较为方便的。( 具体缘由在下一节将会继续探讨 )

接下来,笔者将带着大家模拟这个业务场景,扩展 Marbles Server 端代码。在每次事件发生时,将事件信息打包并通过函数计算的 HTTP 触发器,由函数计算来对事件信息做相应处理。

demo_process

1. 准备工作

开通阿里云日志服务、函数计算服务、区块链服务

2. 在阿里云区块链服务中创建组织、创建联盟

3. 在阿里云区块链服务中创建通道

  • 点击相应组织
  • 点击通道
  • 点击添加通道,填写名称与组织,并创建
  • 点击新创建的通道右侧的待审批链接,同意审批

4. 部署 Marbles 应用以及链码

参考 阿里云区块链服务开发指南
注意事项:nodejs 版本为 v8

5. 下载并配置阿里云函数计算开发工具 fun

  • fun 是一个 Node.js 编写的命令行工具,通过 npm 进行安装:$ npm install @alicloud/fun -g
  • 通过在命令行输入 fun config,根据提示依次配置 Account IDAccess Key IdAccess Key Secret 以及 Default Region Name。可参考:服务地址创建 AccessKey
  • 配置 template.yml

在项目根目录下创建一个 template.yml 文件:

ROSTemplateFormatVersion: '2015-09-01'
Transform: 'Aliyun::Serverless-2018-04-03'
Resources:
  marblesFC: # 服务名称
    Type: 'Aliyun::Serverless::Service'
    Properties:
      Description: 'fc test'
      LogConfig:  # 日志配置
        Project: test-log-project  # 日志 Project
        Logstore: test-log-store   # 日志 LogStore
    processEvent: # 函数名
      Type: 'Aliyun::Serverless::Function'
      Properties:
        Handler: httpTrigger.handler # 文件名.方法名
        Runtime: nodejs8
        CodeUri: './'
        Timeout: 60
      Events:
        http-test: # 触发器名
          Type: HTTP # 触发器类型
          Properties:
              AuthType: ANONYMOUS
              Methods: ['GET', 'POST', 'PUT']
  test-log-project:  #  LogProject 名称
    Type: 'Aliyun::Serverless::Log'
    Properties:
      Description: 'just for test'
    test-log-store:    # LogStore 名称
      Type: 'Aliyun::Serverless::Log::Logstore'
      Properties:
        TTL: 10
        ShardCount: 1

上述文件做了如下事项:

  1. 在函数计算中创建了 marblesFC 服务
  2. marblesFC 服务配置了 test-log-project 日志 Project 以及 test-log-store 日志 LogStore
  3. marblesFC 服务中创建了 processEvent 函数,并为其设置入口函数为 httpTrigger.js 文件中的 handler 方法
  4. processEvent 函数配置了 HTTP 触发器,触发器名为 http-test
  5. 创建了 test-log-project 日志 Project 以及 test-log-store 日志 LogStore
  • 在项目根目录下创建 httpTrigger.js 文件

code

var getRawBody = require('raw-body')
module.exports.handler = function (request, response, context) {
  // get request info
  getRawBody(request, function (err, data) {
    var params = {
      path: request.path,
      queries: request.queries,
      headers: request.headers,
      method: request.method,
      body: data,
      url: request.url,
      clientIP: request.clientIP,
    }
    // you can deal with your own logic here
    console.log(JSON.stringify(params.queries))
    // set response
    var respBody = new Buffer.from(JSON.stringify(params));
    // var respBody = new Buffer( )
    response.setStatusCode(200)
    response.setHeader('content-type', 'application/json')
    response.send(respBody)
  })
};
  • 在项目根目录下执行 fun deploy 进行部署
  • 在阿里云函数计算控制台中,进入到 marblesFC 服务下的 processEvent 函数,在代码执行页面记录下调用 HTTP 触发器的地址

httptrigger

6. 修改 Marbles Server 端代码

  1. 打开 Marbles 源代码根目录文件夹下的 app.js 文件
  2. 添加 var https = require('https'); https模块
  3. 修改 setupWebSocket 函数

marbles_code

  function setupWebSocket() {
    console.log('------------------------------------------ Websocket Up ------------------------------------------');
    wss = new ws.Server({ server: server }); // start the websocket now
    wss.on('connection', function connection(ws) {

      // -- Process all websocket messages -- //
      ws.on('message', function incoming(message) {
        console.log(' ');
        console.log('-------------------------------- Incoming WS Msg --------------------------------');
        logger.debug('[ws] received ws msg:', message);
        var data = null;
        try {
          data = JSON.parse(message); // it better be json
        } catch (e) {
          logger.debug('[ws] message error', message, e.stack);
        }

        // --- [5] Process the ws message  --- //
        if (data && data.type == 'setup') { // its a setup request, enter the setup code
          logger.debug('[ws] setup message', data);
          startup_lib.setup_ws_steps(data); // <-- open startup_lib.js to view the rest of the start up code

        } else if (data) { // its a normal marble request, pass it to the lib for processing
          https.get("此处填写触发 HTTP 触发器的 URL 地址?type="+data.type, function(res){
            console.log('test http trigger');
          });
          ws_server.process_msg(ws, data); // <-- the interesting "blockchainy" code is this way (websocket_server_side.js)
        }
      });

      // log web socket errors
      ws.on('error', function (e) { logger.debug('[ws] error', e); });

      // log web socket connection disconnects (typically client closed browser)
      ws.on('close', function () { logger.debug('[ws] closed'); });

      // whenever someone connects, tell them our app's state
      ws.send(JSON.stringify(ws_server.build_state_msg())); // tell client our app state
    });

    // --- Send a message to all connected clients --- //
    wss.broadcast = function broadcast(data) {
      var i = 0;
      wss.clients.forEach(function each(client) { // iter on each connection
        try {
          logger.debug('[ws] broadcasting to clients. ', (++i), data.msg);
          client.send(JSON.stringify(data)); // BAM, send the data
        } catch (e) {
          logger.debug('[ws] error broadcast ws', e);
        }
      });
    };

    ws_server.setup(wss, null);
  }

7. 启动 Marbles

在控制台中进入 Marbles 项目,通过 gulp marbles_baas 启动 Marbles 应用

8. 创建弹珠或转移弹珠

试着在浏览器中创建弹珠或者用鼠标拖拽转移弹珠

9. 查看日志

对 Marbles 应用做了相应操作后,进入阿里云日志服务 test-log-project Project 下的 test-log-store LogStore,查看日志

log

我们看到当 Marbles Server 接收到事件后,会触发 HTTP 触发器,由函数计算 FC 来对事件做相应处理。( 简单起见,demo 的处理目前仅仅是记录日志,读者们可以自行扩展 )

区块链应用与函数计算在业务上结合的场景与价值探讨

通过制作上面的 demo,相信大家现在对于如何将区块链应用与函数计算相结合有了一定的认识。接下来,就让我们一起探讨下,区块链应用与函数计算在业务上有哪些结合的场景与价值。

下图是最原始的 Fabric SDK 时序图

fabric

为了让读者方便理解,我们仍旧使用 Marbles 应用的时序图,读者可以将 Marbles 应用中的 Server 理解为 Fabric SDK 时序图中的 Application,

marbles_process

在笔者看来,函数计算可以与区块链应用相结合的场景主要有以下三点:

1. 处理事件

处理事件的场景刚刚在 demo 中各位读者想必已经体验过了。那么,为什么笔者倡导用函数计算来处理事件呢?

通过函数计算可以将每一次的事件进行相应的处理,处理完成后发送给日志服务。同时,还可以在函数计算中设定定时触发器,在指定时间内,再次统计事件的信息,由此对区块链状态进行一个数据分析。

而关于这种方式的统计逻辑,很有可能是需要经常迭代的。因此,不适合将其逻辑放入区块链应用中,而是更适合放在小巧易迭代的函数计算场景中。

2. 附加业务

考虑一个这样的场景:现在 X 公司推出了一款新的支付 App,为了鼓励用户使用该公司的 App,该公司对外宣传当用户用该公司的 App 成功完成交易后,该公司会送大量优惠券以及积分。若该 App 是一款区块链应用,那么把优惠活动的业务逻辑放在哪里最合适呢?

笔者目前觉得是放在 Orderer 将交易打包成区块并广播的时候最合适,因为优惠活动的业务逻辑是经常会变化的,这类业务逻辑可以统称为附加业务,将附加业务抽象为一个个函数并放在函数计算中,容易更新迭代。

3. 验证交易

Peer 节点在模拟提案时,若是有复杂多变的逻辑,可以放入函数计算中,由 Peer 节点来负责调用。

以上三点就是笔者对于如何将区块链服务与函数计算相结合的思考,有不准确的地方,欢迎大家指出。

相关实践学习
【文生图】一键部署Stable Diffusion基于函数计算
本实验教你如何在函数计算FC上从零开始部署Stable Diffusion来进行AI绘画创作,开启AIGC盲盒。函数计算提供一定的免费额度供用户使用。本实验答疑钉钉群:29290019867
建立 Serverless 思维
本课程包括: Serverless 应用引擎的概念, 为开发者带来的实际价值, 以及让您了解常见的 Serverless 架构模式
目录
相关文章
|
11天前
|
存储 安全 分布式数据库
探索区块链技术在数据安全中的应用
【10月更文挑战第21天】 本文深入探讨了区块链技术在增强数据安全性方面的应用。通过对区块链基本原理的解释,结合其在数据存储、传输和访问控制中的具体实现方式,本文揭示了区块链技术如何有效防止数据篡改和未授权访问。此外,文章还讨论了区块链技术面临的挑战及其未来发展趋势,为读者提供了一个全面了解区块链技术在数据安全领域应用的视角。
35 4
|
1天前
|
供应链 分布式数据库 区块链
深度探索:区块链技术在供应链管理中的应用与优化####
【10月更文挑战第29天】 本文深入剖析了区块链技术如何革新供应链管理,通过构建去中心化的信任机制,显著提升透明度、效率及安全性。我们将探讨区块链在追踪产品来源、简化交易流程、增强数据安全等方面的具体应用实例,并分析其面临的挑战与未来发展趋势,为相关领域提供有价值的参考与启示。 ####
19 2
|
3天前
|
供应链 安全 物联网
深入浅出:区块链技术及其应用
【10月更文挑战第29天】 本文旨在为读者提供一个关于区块链技术的全面介绍,包括其基本原理、发展历程以及在多个领域的实际应用。通过本文,您将能够理解区块链不仅仅是一种技术,更是一种可能改变未来社会运作方式的理念。我们将探讨区块链如何从加密货币的基础扩展到供应链管理、智能合约、身份验证等众多领域,并分析它面临的挑战与机遇。
14 2
|
2天前
|
存储 供应链 安全
深入探讨区块链技术在数据安全中的应用
本文旨在探讨区块链技术在数据安全领域的应用,分析其如何通过去中心化的特性增强数据的安全性和透明度。文章首先介绍区块链的基本原理,然后详细阐述其在防止数据篡改、提高交易安全性以及实现数据共享方面的优势。最后,文章讨论了当前区块链技术面临的挑战和未来的发展趋势。
|
5天前
|
供应链 区块链
探索区块链技术在供应链管理中的应用
【10月更文挑战第28天】 本文深入探讨了区块链技术如何革新传统的供应链管理系统,通过提供一个去中心化、透明且不可篡改的数据记录平台,来增强整个供应链的透明度和效率。文章首先介绍了区块链技术的基本原理及其核心特性,随后分析了当前供应链管理面临的主要挑战,并详细讨论了区块链技术在解决这些问题中的潜在作用。通过具体案例分析,本文展示了区块链技术在实际供应链管理中的应用效果,包括提高数据透明度、降低运营成本、增强供应链各环节之间的信任等方面。最后,文章还探讨了实施区块链解决方案时可能遇到的技术与非技术障碍,并对未来区块链技术在供应链领域的发展趋势进行了展望。
28 2
|
10天前
|
人工智能 供应链 安全
探索区块链技术的奥秘与应用
在数字化浪潮中,区块链技术以其独特的去中心化、不可篡改和透明性特点,正逐渐改变着我们的世界。本文旨在深入浅出地解析区块链技术的基本原理,探讨其在金融、供应链管理、版权保护等领域的创新应用,并展望未来发展趋势,为读者揭开这一神秘面纱背后的真实面貌。
|
7天前
|
运维 Serverless 数据处理
Serverless架构通过提供更快的研发交付速度、降低成本、简化运维、优化资源利用、提供自动扩展能力、支持实时数据处理和快速原型开发等优势,为图像处理等计算密集型应用提供了一个高效、灵活且成本效益高的解决方案。
Serverless架构通过提供更快的研发交付速度、降低成本、简化运维、优化资源利用、提供自动扩展能力、支持实时数据处理和快速原型开发等优势,为图像处理等计算密集型应用提供了一个高效、灵活且成本效益高的解决方案。
31 1
|
13天前
|
安全 物联网 区块链
探索未来:区块链技术在物联网和虚拟现实中的融合应用
【10月更文挑战第21天】本文深入探讨了区块链、物联网(IoT)和虚拟现实(VR)这三项前沿技术的发展趋势,并分析了它们如何相互作用以推动创新。我们将通过具体案例来揭示这些技术如何改变我们的工作和生活方式,同时提供对未来发展的一些预测。
|
10天前
|
运维 监控 Serverless
Serverless架构在图像处理等计算密集型应用中展现了显著的优势
Serverless架构在图像处理等计算密集型应用中展现了显著的优势
23 1
|
15天前
|
存储 供应链 监控
如何在供应链行业中应用区块链
【10月更文挑战第26天】区块链在供应链行业的应用包括提高透明度、优化流程、增强安全性和改善金融服务。具体表现为全流程信息记录与追溯、智能合约自动化执行、数据安全与隐私保护、应收账款融资及信用评估等,促进供应链的高效协同与信任建设。

热门文章

最新文章

相关产品

  • 函数计算