nodejs 异步变同步实战代码

桃扇骨 2022-03-11 03:08 263阅读 0赞

在定时短信提醒项目中，使用nodejs开发，

设计为每10秒轮询一次数据库，获取普通短信提醒。

1、定时器代码：

//定时更新会话，10秒刷新一次
    app.use('/___updatesession___', (req, res, next)=>{
       
        //对于普通短信提醒的触发    
        getNormal();
    
        var resData = {
            errno: 0,
            data: 'success'
        };
        res.send(resData);
    });

2、同步开发的普通短信提醒：

var getNormal = co.wrap(function *(){
        var ret = yield pify.promisify(db.get_normal);
        var res = ret[0];
        var data = ret[1];    
    
        if ((res == false) || (data == 0))
        {
            return;
        }
    
        for (var i = 0; i < data.length; i++)
        {   
            var content = data[i]["content"];
            var submailprj = data[i]["submailprj"];
            var custom = data[i]["custom"]; 
            var checkstatus = data[i]["checkstatus"];
            var templateid = data[i]["templateid"];
            var mobiles = data[i]["mobiles"];
            var smscnt = data[i]["smscnt"];
            var id = data[i]["id"];
            var userid = data[i]["createuserid"];
    
            console.log("content:", content);
    
            if (mobiles == "")
            {
                continue;
            }
            
            //手机号
            var arrMobile = dealMobile(mobiles);
            if (arrMobile.length == 0)
            {
                continue;
            }
    
            //短信数
            smscnt = dealSmscnt(arrMobile, smscnt);
    
            console.log("arrMobile:", arrMobile.join(","), "custom:", custom, "checkstatus:", checkstatus, "id:", id);
            
            //发送短信
            if (custom == "1")  //定制类
            {
                if (checkstatus == "2") //审核通过的
                {
                    console.log("SendFixedSmsWithPrj: ", arrMobile.join(","), templateid);
                }
                else if (checkstatus == "3")
                {
                    //更新为已触发
                    yield pify.promisify(id, db.upd_result);
                    continue;
                }
                else
                {
                    continue;
                }
            }
            else    //非定制
            {
                if ((submailprj == "") || (submailprj == undefined))
                {
                    console.log("Send normal:"+ arrMobile.join(","));
                }
                else
                {
                    console.log("SendWithPrj: "+ arrMobile.join(",") + content + submailprj);
                }
            }
    
            var upd = "2";
            var openid = "";
            var weid = "";
    
            //获取openid
            var oRet = yield pify.promisify(userid, db.get_weidopenid);
            var oRes = oRet[0];
            var oData = oRet[1];
            if ((oRes == false) || (oData == 0))
            {
                continue;
            }
    
            openid = oData.openid;
            weid = oData.id;
            if ((openid == undefined) || (openid == ""))
            {
                continue;
            }
    
            var reqData = {
                weid: weid,
                openid: openid,
                upd : upd,
                smscnt: smscnt,
                originalid: id
            };
    
            //计费
            yield pify.promisify(reqData, db.consume_smscnt);   
    
            //更新为已触发
            yield pify.promisify(id, db.upd_result);
        }
    })

如上，这里核心代码为：

var getNormal = co.wrap(function *(){
        var ret = yield pify.promisify(db.get_normal);
        var oRet = yield pify.promisify(userid, db.get_weidopenid);
        yield pify.promisify(reqData, db.consume_smscnt);
        yield pify.promisify(id, db.upd_result);
    }
    
    app.use('/___updatesession___', (req, res, next)=>{
        getNormal();    
    }

即需要用到同步时，用var fn = co.wrap(function \*()\{ \});

调用时，直接调用fn();即可。

**  注： 在nodejs中开发最关键的就是这一块，这一块搞明白了，相当于nodejs就完全掌握了，可以开发各种应用了！**

发表评论取消回复

表情：

评论列表（有 0 条评论，263人围观）

还没有评论，来说两句吧...

相关阅读

相关同步异步

[https://blog.csdn.net/ideality\_hunter/article/details/53453285][https_blog.csdn.net_i

蔚落/ 2023年10月17日 23:35/ 0 赞/ 136 阅读

相关同步异步

阻塞非阻塞同步异步进程运行的三个状态:运行, 就绪,阻塞两个角度分析执行和提交任务执行角度阻塞 : 程序运行时遇到 IO,程序挂起,CPU 被切

港控/mmm°/ 2023年08月17日 15:25/ 0 赞/ 122 阅读

相关同步异步实现代码小结

客户端同步服务端异步。 Future<Result> future = request(server);//server立刻返回future synchron

- 日理万妓/ 2022年09月23日 08:18/ 0 赞/ 163 阅读

相关 nodejs异步流程控制

场景： > 1、图片上传服务器 > > 2、图片写入磁盘 > > 3、图片写入数据库 > > 在nodejs里面这三种方式都是异步操作，不想java其他语言同步进行，这

朱雀/ 2022年09月09日 09:14/ 0 赞/ 207 阅读

相关同步异步

在做高校的时候（当时还没有学到ajax呢），用到了ajax代码，其中最看不懂的就是async，在网上一查，原来这个属性表示的是同步、异步。Async默认是true（异步

灰太狼/ 2022年08月07日 01:55/ 0 赞/ 210 阅读

相关 NodeJS -- 异步I/O

为什么要异步I/O Node是面向网络而设计的，因此，异步IO格外重要。下面，我们从两个方面来说。原因1：用户体验异步的概念之所以首先在Web中火起来，是因为

桃扇骨/ 2022年06月13日 06:58/ 0 赞/ 205 阅读

相关 nodejs入门02__异步与同步

Node.js 最大的特点就是异步式 I/O（或者非阻塞 I/O）与事件紧密结合的编程模式，通过事件和回调函数将一个逻辑拆成若干个单元。 Node.js异步读取文件：

桃扇骨/ 2022年06月02日 10:36/ 0 赞/ 211 阅读

相关 nodejs 异步变同步实战代码

在定时短信提醒项目中，使用nodejs开发，设计为每10秒轮询一次数据库，获取普通短信提醒。 1、定时器代码： //定时更新会话，10秒刷新一次 app

桃扇骨/ 2022年03月11日 03:08/ 0 赞/ 264 阅读

相关异步变同步

1. promise.all let behind = (time) => { return new Promise((resolve, reje

约定不等于承诺〃/ 2021年08月30日 15:14/ 0 赞/ 384 阅读

相关 Javascript 中通过 yield 和 promise 使异步变同步

背景由于最近一段时间一直在用`react-native`进行APP的开发，所以接触了不少 `javascript`。在我们第一次使用`react-native +

朱雀/ 2021年06月26日 16:06/ 0 赞/ 511 阅读