整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:

Node.js 实现抢票小工具&短信

Node.js 实现抢票小工具&短信通知提醒(上)「干货」

者:西岚

转发链接:https://juejin.im/post/5dadd0236fb9a04de04d968e

只需编写简单的云函数,就可以实现自己的业务逻辑,发布后就可以生成自己的接口给客户端调用。

果创云支持对云函数进行在线接口编程,进入开放平台我的接口 - 在线接口编程,设计一个新接口,设计和配置好接口参数、接口名称、接口返回后,再把云函数源代码填上,提交审核通过并发布后即可使用。

云函数编写入口:在线接口编程。

云函数优势

云函数具有以下特点和优势:

  • 1、无需管理服务器即可运行移动后端代码
  • 2、可在线接口编程,自动生成云接口和接口文档
  • 3、代码简单,功能强大,一行代码就可以实现数据库、短信发送等功能
  • 4、可以开发自己的接口,实现自己的业务逻辑

云函数架构

云函数由开发者自己编写,发布后可生成自己的云接口,即MyAPI,而云函数底层则依赖于果创云提供的基础服务。

因此,云函数整体架构如下:

整体架构分为四层:

  • 第一层:MyAPI我的接口 提供给客户端调用的云接口。
  • 第二层:云函数。 由开发者自己编写,可在线接口编程,编写云函数,生成接口。
  • 第三层:果创云聚合服务 由果创云提供,封装了常用的服务,可进行数据库、CURL、短信等服务操作。
  • 第四层:云服务 由第三方提供的云服务,包括但不限于自建数据库、云数据库、企业邮箱、短信接口、开放平台接口和内部接口等。

云函数格式

当前只支持PHP云函数,开发者自定义的云函数,需要符合PHP语法。其云函数签名和云函数模板如下:

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');

    // TODO
    // 在这里编写你的具体业务

    return $result;
}

云函数参数

云函数参数说明:

  • $params,类型:数组,为当前客户端的接口参数,由开发者配置的接口参数和客户端动态传递的参数而定,例如:array('uuid'=> null, 'left'=> 1, 'right'=> 2)
  • $di,类型:数组,为DI容器,里面封装并提供了众多强大而实用的PHP服务,例如数据库操作等,对于后端编程有非常大的帮助,后面会详细介绍。

获取接口参数

如何获取客户端传递过来的接口参数?

在果创云开放接口参数配置,添加参数后,就可以在源代码中获取。如下:

假设,配置的接口参数名字为:abc,那么在PHP源代码中,获取接口参数的方式是从$params参数中获取,如:

$abc=$params['abc'];

参数名称和配置的接口名称一致。并且,此时获取的接口参数会根据配置的接口参数规则进行过滤、转换和检测。

温馨提示:接口会自动对客户端的参数进行校验、核对和转换,通过$params参数获取的是最终可用的参数。

云函数代码规范

开头不需要<?php标签,结束不需要?>标签。你可以在本地调试好PHP代码函数,或者通过在线工具编写和运行你的PHP代码。

特别注意以下几点:

  • 1、接口代码需要符合PHP语法,PHP语法可参考PHP 教程
  • 2、一些敏感的PHP函数和API接口会被禁用,例如读写本地文件、获取系统信息等。

如何进行本地调试? 在本地调试时,可以这样执行你的PHP代码。首先,创建一个PHP文件,例如:yesapi.php,然后在里面放置代码:

<?php
$fun=function ($params, $di) {
    // 函数内的代码复制过来
    $result=array('err_code'=> 0, 'err_msg'=> '');

    $result['sum']=$params['left'] + $params['right'];

    return $result;
};

// 模拟一些测试数据
$params=array('left'=> 1, 'right'=> 2);

// 执行函数,输出结果
var_dump($fun($params, array()));

// 输出结果 1+2=3
array(3) {
    ["err_code"]=>
    int(0)
    ["err_msg"]=>
    string(0) ""
    ["sum"]=>
    int(3)
}

即这样执行,通过CLI方式运行。

$ php ~/tmp/test.php          
array(3) {
    ["err_code"]=>
    int(0)
    ["err_msg"]=>
    string(0) ""
    ["sum"]=>
    int(3)
}

温馨提示:在本地没有$di服务,可以使用空数组来代替,或进行模拟测试。

云函数运行结果

如何返回接口结果呢?

以下是一个返回示例:

return array('err_code'=> 0, 'err_msg'=> '', 'title'=> 'Hi, 欢迎使用果创云开放接口!');

注意,应该在函数的最后一行代码通过return关键字返回结果。结果的类型是数组,且应包括:err_code、err_msg这两个基本字段,以及其他需要自定义的返回字段。其中,约定err_code为0表示成功。

云函数示例

以下是一个简单的例子,进行两个数的相加。

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['sum']=$params['left'] + $params['right'];
    return $result;
}

添加一个新接口,并进行编辑:

编写接口时,设置接口参数、接口返回、云函数代码等,如(局部截图):

保存后,你可以看到类似这样的在线接口文档(部分截图):

提交审核和发布

在完成接口设计和云函数开发后,就可以勾选“申请发布”。等审核通过后即可发布和使用。

生成云接口和接口文档

发布通过后,你就可以生成了自己的云接口,以及在线接口文档。

在线接口文档,可以提供给客户端开发人员查看和接入使用;云接口可以提供给客户端进行调用。

生成的完整在线接口文档类似:

接口文档地址:

http://api.yesapi.cn/docs.php?service=SVIP.Sdogstar_MyApi.ATest&detail=1&type=fold

客户端调用后,就可以得到云函数执行后的结果。

编写好云函数后,会自动生成云接口,和接口文档。如果需要,也可以自己手动编写接口文档。

温馨提示:如果需要手动编写API接口文档,可以进入我的在线文档编辑,保存后可发布接口文档。

文档编辑后台:

保存后,外部查看的接口文档效果:

如何支持多个客户端接入?

如果需要支持多个客户端调用API接口,可以【客户端管理】,添加客户端应用,然后分配app_key和密钥。

云函数PHP开发手册

以下通过代码示例和模板,介绍云函数如何进行开发,大家可以把代码复制过去,稍作修改。只需要简短的几行PHP代码,或者一段代码,你就实现自己的业务逻辑,无需管理服务器即可运行移动后端代码。

HIGHLIGHT 开发须知

在开始,以下是一些重要的知识点和注意事项。

  • 我的模型数据库操作请使用:$di['db']->模型英文名称_tbl,例如文章模型:$di['db']->article_tbl,后面要固定加上_tbl;
  • 直连数据库(MySQL/SQLServer等)操作请使用:$di['db_super']->数据库表完整名称,例如:$di['db_super']->article;使用前请配置接入你的数据库。

再重复说明下,直连数据库和我的模型数据库操作一样,区别在于:直连数据库在使用前需要先配置接入你的数据库,DI服务使用$di['db_super'],最后需要填写完整的表名称,不需要额外的_tbl后缀。

DI服务一览

DI服务 功能说明 备注 $di['db'] 我的模型数据库 可进行CURD数据库操作,针对单表 $di['db_super'] 直连数据库 可进行CURD数据库操作,针对单表,使用前需要进行MySQL数据库直连服务配置 $di['logger'] 日志服务 纪录各种日志 $di['email'] 邮箱服务 发送邮件,使用前需要进行邮箱服务配置 $di['pinyin'] 拼音服务 将汉字转成拼音 $di['curl'] CURL服务 请求远程接口,仅支持80端口 $di['crypt'] 安全服务 对数据进行加密和解密 $di['sms_aliyun'] 阿里云短信 通过阿里云服务发送短信,使用前需要进行阿里云服务配置

云函数代码模板

F1-1、两数相加

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['sum']=$params['left'] + $params['right'];
    return $result;
}

假设传递参数为:left=1&right=2,请求此云函数后,将会得到如下结果:

{
    "ret": 200,
    "data": {
        "err_code": 0,
        "err_msg": "",
        "sum": 3
    },
    "msg": "V2.1.1 YesApi"
}

F1-2、数据库-获取模型总数

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['count']=$di['db']->article_tbl->count('id'); // 模型名称后面须带上_tbl后缀
    return $result;
}

假设你有模型如下,有23条数据:

请求此云函数后,将会得到如下结果:

{
    "ret": 200,
    "data": {
        "err_code": 0,
        "err_msg": "",
        "count": 23
    },
    "msg": "V2.1.1 YesApi"
}

F1-3、数据库-添加模型数据

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $article=$di['db']->article_tbl;
    $article->insert($data);
    $result['id']=$article->insert_id(); // 返回新增的ID
    return $result;
}

F1-4、数据库-查询模型数据

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['article']=$di['db']->article_tbl->where('id', 1)->fetchOne(); // 取出id=1的文章数据
    return $result;
}

F1-5、数据库-更新模型数据

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $data=array('title'=> '新文章标题', 'content'=> '文章内容'); // 待更新的数据
    $result['update_row']=\$di['db']->article_tbl->where('id', 1)->update($data); // 更新id=1的文章数据,返回更新的数量
    return $result;
}

F1-6、数据库-删除模型数据

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['delete_row']=$di['db']->article_tbl->where('id', 1)->delete(); // 删除数据,返回删除的数量
    return $result;
}

F1-7、数据库-获取模型列表数据

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['list']=$di['db']->article_tbl->where('id > ?', 1)->where('id < ?', 10)->fetchAll(); // 取出id从1到10的全部数据
    return $result;
}

F1-8、数据库-获取模型列表数据(搜索+分页+排序+字段选择)

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['list']=$di['db']->article_tbl
        ->select('id, title, content')
        ->where('id', 1) // 精确区配
        ->where('name LIKE ?', '%小白%') // 模糊匹配
        ->where('id', array(1, 2, 3)) // 范围枚举
        ->where('id > ?', 1) // 范围大于
        ->where('id < ?', 10) // 范围小于
        ->where('id BETWEEN ? AND ?', array(1, 10)) // 范围介于
        ->or('status', 1) // 或逻辑条件
        ->order('add_time DESC') // 按时间降序
        ->limit(0, 100) // 分页,取出前面100条
        ->fetchAll(); // 取全部数据
    return $result;
}

温馨提示:获取列表数据时,一定要使用limit限制分页数量,否则会审核不通过。

F2-1、CURL-GET请求

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    // 第一个参数为网址,第二个参数表示超时时间(单位毫秒)
    $result['res']=$di['curl']->get('http://demo.phalapi.net/?username=YesApi', 3000);
    // 得到结果类似:{"ret":200,"data":{"title":"Hello YesApi","version":"2.13.3","time":1590764249},"msg":""}
    return $result;
}

F2-2、CURl-POST请求

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    // 第一个参数为网址,第二个参数是POST的参数,第三个参数表示超时时间(单位毫秒)
    $result['res']=$di['curl']->post('http://demo.phalapi.net/', array('username'=> 'YesApi'), 3000);
    // 得到结果类似:{"ret":200,"data":{"title":"Hello YesApi","version":"2.13.3","time":1590764249},"msg":""}
    return $result;
}

温馨提示:通过云函数以及CURL,可以对原有的API接口进行封装,形成对外开放的接口API。

F3-1、日志

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $di['logger']->record('DEBUG', '调试日志,这里可放日志内容');
    $di['logger']->record('INFO', '业务日志,这里可放日志内容');
    $di['logger']->record('INFO', array('uuid'=> 'ABC', 'tip'=> '第二个参数还可以是数组'));
    $di['logger']->record('NOTICE', '提醒日志,这里可放日志内容');
    $di['logger']->record('WARNNING', '警告日志,这里可放日志内容');
    $di['logger']->record('ERROR', '错误日志,这里可放日志内容');
    return $result;
}

温馨提示:日志纪录后,可以到开放平台查看日志。

F4-1、发送邮件

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    // 第一个参数是收件人邮箱,第二个参数是邮件标题,第三个参数是邮件正文内容(HTML格式)
    $result['is_send']=$di['email']->send('helper@yesapi.cn', '邮件标题', '邮件内容');
    return $result;
}

温馨提示:使用前请先配置邮箱服务配置。

F5-1、安全-加密解密

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['encrypt_data']=$di['crypt']->encrypt('YesApi'); // 对数据进行加密
    $result['decrypt_data']=$di['crypt']->decrypt($result['encrypt_data']); // 对数据进行解密
    return $result;
}

温馨提示:每个app_key加密的数据,只能由自己的app_key进行解密。

F6-1、拼音

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $result['pinyin_1']=$di['pinyin']->convert('小白接口'); // 将一段汉字串内容转成拼音,结果是:xiao bai jie kou
    $result['pinyin_2']=$di['pinyin']->abbr('小白接口'); // 获取拼音首字母,结果是:x b j k
    $result['pinyin_3']=$di['pinyin']->name('张三'); // 姓名转拼音,结果是:zhang san
    return $result;
}

F7-1、发送短信

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    // 参数1:手机号,参数2:短信签名,参数3:短信模板,参数3:更多数组参数(没动态参数时可传空数组)
    $di['sms_aliyun']->aliyunSendSms('13800138000', '小白接口', 'SMS_153055065', array('code'=> '123456'));
    return $result;
}

温馨提示:使用前需要进行阿里云服务配置

F9、实用函数

function ($params, $di) {
    $result=array('err_code'=> 0, 'err_msg'=> '');
    $time=time(); // 当前时间戳,例如:1590561632
    $datetime=date('Y-m-d H:i:s'); // 当前时间,例如:2020-05-20 00:00:00
    $arr=json_decode('{"name":"YesApi"}', true); // json解析成数组
    $json=json_encode($arr); // 数组转json
    $md5=md5('123456'); // md5操作
    return $result;
}

更多示例,即将到来!

说到发短信验证码接口,第一印象就是好货不便宜,速度快、送达率高的通道各大短信接口厂商收费也好贵,小微个人不舍得接入,也不符合大部分大厂的准入门槛。

想着自己几张手机卡面每月还有几千条免费短信是不是能好好利用一下,做个能发送短信的app在后台运行问题也不大,不过自己手机号还是不要乱搞的为好。

曙光

研发App过程中发现有几个大平台对App提供免费短信验证码,微博开放平台Mob,App上用完全免费,但Web Api都不免费,也许App内接入SDK可以让他们收回成本吧(真实情况是:收益远大于成本)。

虽然不直接提供免费Web Api,那我们是不是可以通过App来发验证码:手机打开App在后台运行,只有有发验证码的需求时,App自动调用SDK发送验证码。

通过研究微博和Mob的文档发现,理论上是可行的,除了符合国情的标准限制(单手机号每分钟、每天限制)外,每个应用也有速率限制。但对小微网站来讲(没啥流量的博客啥的),远远够用,一天撑死了发100条短信,一小时下来也发不了几条。

注意:流量大的不能用本文这个方法,稳定性和安全性大幅下降,都有这么大流量了,应该不差钱接稳定的短信接口吧。本文只适用于学习、小流量网站之用。

说干就干

首先要有个App,并且接入了免费短信SDK,能正常发短信(没有?写一个App,然后尝试申请一下)。有很多混合app开发平台,会js+css就能开发出来,当然原生的最好。

流程图:

流程分解

一、自研短信API网关

就是个普通REST API,提供3个接口:

  1. 单条验证码短信发送请求接口,只需提交手机号参数,然后接口把请求加入队列
  2. 发送请求队列拉取接口,用于手机App后台任务定时拉取发送队列 (改为WebSocket推送会不会快一些,复杂且没价值!)。
  3. [可选]App发送短信后的回执接口,保存发送结果信息。

二、一个手机+自研App(只要成功接入第三方就行)

当然是手机后台跑着我们的App,然后定时拉取自研短信API网关的队列数据,有发送请求数据就调用第三方SDK进行验证码发送,顺带保存回执。

三、网站使用

在需要发短信验证码的地方调用我们自己的短信API网关。

用户提交短信验证码后调用第三方接口对验证码进行校验(也许有第三方可以发自定义短信,验证码由我们自己生成,就不需要和第三方打交道了)。

注意要点

  1. 我们要保证手机App在后台长时间稳定驻留,保证网络稳定。
  2. 有备用收费短信接口,避免在我们的短信API网关无法正常发送短信时,直连收费短信接口。
  3. 提高可用性,如果用户是首次点击发送验证码按钮,这次请求发往我们的短信API网关,如果是第二次点击发送验证码按钮(没有收到验证码用户重试),发往收费短信接口,稳定性大幅提高。
  4. 此方法小流量网站可用,大流量硬要强上,也许准备个手机集群、申请N个App轮换使用,哈哈哈。

使用案例

由于我没用5分钱的短信接口,用户首次发送验证码走的是老东家App的SDK免费短信接口。比如:注册、找回密码、绑定支付宝账号使用到此接口。

我用一个老手机来运行的App,15秒播报语音播报一次错误数量(报警用),一直放在那里不动,一直报0,效果还不错。

后台App

纯javascript代码实现的,截了个图:

好了,喜欢自己动手的小伙伴可以去试一下了。