node.js - nodejs怎么接合async写出连接池(获取-操作-回收)的操作?
迷茫
迷茫 2017-04-17 11:46:34
[Node.js讨论组]

接触nodejs没多久,见笑。

需要一个类似java中AOP的写法,比如现在有一个Redis连接池,获取-操作-回收的写法是这样的:

javapublic class JedisInterceptor implements MethodInterceptor{

    @Inject private Session<Jedis> session;

    @Override
    public Object invoke(MethodInvocation invocation) throws Throwable {
        if(!session.isClosed()) return invocation.proceed();
        try {
            //获取连接
            session.start();
            return invocation.proceed();
        } catch (Throwable e) {
            throw e;
        } finally {
            if(!session.isClosed()) {
                //不管是否出错,始终回收连接
                session.close();
            }
        }
    }

}
}

现在需要同样的nodejs写法,看了看async,似乎可以写出来,但真心不知道怎么写。。。求高手指点,目前nodejs代码已经是这个样子:

javascriptvar pool = require('generic-pool');

var redis = require("redis");

//async包
var async = require('async');

//Redis连接池
var redisPool = pool.Pool({
    name: 'redis',
    create: function(callback) {
        var connection = redis.createClient(6379, '127.0.0.1', {});
        callback(null, connection);
    },
    destroy: function(connection) {
        connection.quit();
    },
    max: 5,
    min: 2,
    idleTimeoutMillis: 30000,
    log: false
});

module.exports = {
    redis: function(fn) {
        //这里怎么通过async实现上面java的罗辑?
    }
}
迷茫
迷茫

业精于勤,荒于嬉;行成于思,毁于随。

全部回复(0)
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新 English
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号