关于serverless:人人都是-Serverless-架构师-弹幕应用开发实战

简介：如何应用 Serverless 架构实现全双工通信的利用，Serverless 架构中数据库是如何应用的，本篇文章将为您揭开答

作者 | 寒斜（阿里云云原生中间件前端负责人）

Serverless 的理念是即时弹性，用完即走。服务并非长时间运行，这也就意味着像 websocket 这种长链接的申请模式看起来并不适宜 Serverless。

是否有其它的方法即能够满足长连贯模式申请，又可能利用 Serverless 自身个性呢？

答案是必定的，上一篇文章咱们谈及了网关的关键作用，所以这次也是通过网关来解决全双工通信的问题。本次将以弹幕场景为例，为大家开展咱们是怎么应用 Serverless 架构来实现这个场景的。

利用成果预览

弹幕利用的实用场景比拟多，比方经营推广，年会流动等。然而通常实现一套带管控的流程，且部署公布的话，个别会破费比拟长的工夫。本篇实战则能够让你在 2 分钟之内就部署好本人的弹幕利用。同时做到反对炫彩和弹幕内容管控，你能够用它来丰盛公司年会的模式。文末也会贴上源码，能够供大家参考和二次定制。

架构一览

整体架构仍然采纳 dns 解析 -> 网关 -> oss | fc。不一样的是分了 3 个动态资源的工程，函数局部则采纳事件驱动和 http 相结合，并且 api 局部采纳 tablestore 进行数据的长久化。

流程阐明

弹幕利用总工由大屏幕，个人用户，管理员三个客户端，以及一个注册设施的服务 & api 服务组成。客户端跟服务端的长链接由网关来承载，每次客户端连贯到网关的时候，网关都会存储设备编号，并且触发一次注册函数，设施编号存储到 tablestore。

当用户发动弹幕的时候经网关到 api 服务，api 服务会做一次查问先判断弹幕是否被管制，如果无管制则间接查找以后的大屏幕设施 id，并且进行网关的上行调用，网关在发到前端页面，显示数据。如果被管制，则查问在线的管理员设施，将弹幕上行告诉到网关，网关发送给管理员前端页面。

equipment（设施）

barrage（弹幕）

interceptor (过滤器)

同前篇《人人都是 Serverless 架构师 | 现代化 Web 利用开发实战》文章一样须要提前准备好域名，并装置好 Serverless Devs 开发者工具, 以及上面的产品：

云解析 DNS
API 网关
函数计算
对象存储 OSS
Tablestore

这次咱们引入了 tablestore 的数据库忘性数据的长久化性能，同样须要创立好数据库实例备用。

为了更好的展现成果，本次演示应用 ServerlessDesktop 来给大家演示一下如何 2 分钟部署一个简单的弹幕利用。你能够依据本身须要抉择 Serverless Devs Cli 或者 Serverless Desktop 对弹幕利用进行初始化和部署构建。

1）秘钥配置

可参考密钥获取文档：

http://www.serverless-devs.co…

2）初始化

本次初始化除了须要将利用模板下载到本地之外，还会帮忙初始化 tablestore 的表和数据，因而须要预配置几个参数：

秘钥别名 – 对应你的阿里云账号
域名 – 自定义域名
bucketName – oss 的 bucket 名称
endpoint – 对应 tablestore 实例的公网拜访地址
instance – 对应 tablestore 的实例名

预配置参数写好后点击“确定”, 接下来的工作就叫给 Serverless Devs，它会帮咱们初始化弹幕利用的表。

3）构建部署

初始化之后，咱们从新进入配置页面，对我的项目进行部署。配置信息 -> 全量操作 -> deploy 点击后其余的就交给 Serverless Devs 了，它会帮忙咱们实现:

大屏幕，治理后盾和玩家的前端部署;
注册函数以及 api 函数的部署
以及网关的路由设置和网关的域名绑定

4) 部署成果查看

网关

函数计算

Oss

DNS

此时拜访 barragego.serverless-developer.com 发现拜访不同，查看发现起因是 apigateway 的域名和 oss 域名都未绑定胜利，咱们手动解决一下:

接下来再拜访 barragego.serverless-developer.com 即可看到成果：

数据库方面想拿出来说一下，次要本次用的数据库的确比拟新，也就是 tablestore。

1）数据库配置传递

能够看到，咱们在初始化利用的时候是填写了数据库的公网拜访地址和实例名称信息的，初始化的时候会把用户的输出配置写入到 s.yaml 中，这里如果是比拟敏感的信息倡议从 s.yaml 提取进去放到 .env 环境中，并且 ignore 掉这个文件，缩小数据库信息被泄露到代码仓库的危险。

最终 Devs 会把这两个根本信息放到函数计算的环境变量中而后各运行时能够通过环境变量取到这些值，比方这里是 nodejs 的运行环境，则通过 process.env.instance 获取。

除了实例名称和公网拜访地址外数据库的初始化还须要用户的秘钥信息。鉴于秘钥信息的敏感性比拟高，不倡议间接把秘钥信息配置到 s.yaml 里，而是通过给函数服务受权 tablestore 角色权限，让函数内置长期秘钥信息。

函数服务受权配置如下：

函数内获取秘钥信息如下：

2）数据库初始化

为了缩小数据库初始化次数，咱们能够在函数的 initializer 办法中初始化，当函数未被开释的时候能够间接应用数据库的实例而不用从新连贯。这样能够升高申请响应工夫。单实例多并发的状况下比拟实用。

exports.initializer = (context, callback) => {

  try {

    const ak = context.credentials.accessKeyId;

    const sk = context.credentials.accessKeySecret;

    const stsToken = context.credentials.securityToken;

    SAT.init(endpoint, instance, ak, sk, stsToken);

    internal = {tableClient: SAT, TableStore};

    callback();} catch (err) {callback(err.message);

  }

}

数据库实例初始化之后，咱们通过赋值给全局变量来从其余的办法中获得实例，进行后续的操作。

3）CRUD

tablestore 原生的 api 去做 CRUD 操作用户体验不够敌对，tablestore 社区提供了一个很好的封装 SAT。咱们用它来做根底的增删改查会十分的不便，代码看起来也十分整洁。

// 单主键查问

const getInterceptor = async (ctx) => {const { tableClient} = ctx.req.requestContext.internal;

  const res = await tableClient.table('interceptor').get(1, cols = []);

  return res;

}



// 查问全副

const getAllEquipment = async (tableClient,TableStore) => {const res = await tableClient.table('equipment').getRange(TableStore.INF_MIN, TableStore.INF_MAX, cols = [])

  return Object.keys(res).map((key)=> res[key]);

}

// 双主键（一个分区键，一个自增键）的插入

const addBarrage = async (ctx) => {const { tableClient, TableStore} = ctx.req.requestContext.internal;

  const {fromId, fromName, color, fontSize = '28px', checkStatus = 0, message} = ctx.request.body;

  const currentTime = Date.now().toString();

  const newData = Object.assign({}, { fromId, fromName, color, fontSize, checkStatus: parseInt(checkStatus), message }, {sendTime: currentTime, checkTime: currentTime});

  const res = await tableClient.table('barrage', ['gid', 'id']).put([1, TableStore.PK_AUTO_INCR], newData, c = 'I');

  return res;

}

// 更新

const updateBarrage = async (ctx) => {const { tableClient} = ctx.req.requestContext.internal;

  const {checkStatus} = ctx.request.body;

  const {id} = ctx.request.params;

  const currentTime = Date.now().toString();

  const res = await tableClient.table('barrage', ['gid', 'id']).update([1, parseInt(id)], {checkStatus: parseInt(checkStatus), checkTime: currentTime }, c = 'I')

  return res;

}

// 条件查问

const getBarrageByCondition = async (ctx) => {const { tableClient, TableStore} = ctx.req.requestContext.internal;

  const res = await tableClient.table('barrage').search('index', ['checkStatus', 0])

  return res;

}

当然如果你想做更高级的查问，就须要本人去查阅官网文档了。

这个我的项目自身是对 Serverless 如何应用 websocket 的一个展现示例。你能够把它变成任意相近状态的利用，比方聊天室，多人合作平台等。

利用自身也还有很多改良空间，比方减少点赞成果，管控局部能够加上管理员的登录注册等。总之你能够依据本身需要定制更高级的性能，相干的源码曾经提供进去供大家参考。下个篇章我会持续跟大家聊一聊 Serverless 和低代码的场景，并分享一个咱们最近做的实际。

原文链接
本文为阿里云原创内容，未经容许不得转载。

关于serverless:人人都是-Serverless-架构师-弹幕应用开发实战

数据表设计

1、筹备工作

2、操作步骤

2、数据库明细

总结