干货，直接上代码：

项目结构：

2.创建此缓存接口，将缓存封装到一个对象中：dataCfg。

3.上图中缓存对象dataCfg = await getDataBaseCfg()是将这个方法封装到了工具类中，如下图：

4.在app.js中应用，启动的时候会将此对象加载到内存中。

到此，从数据库中加载配置到node缓存已经做完了，需要注意你的数据库引入时机和去获取数据的时机，最后附上读取配置字段封装的方法。后台是通过两张表，字典表和字典字段表：

'use strict';

const _ = require('underscore');
const connection = require('../config/pool.js');
const logger = require('../lib/logger');
const config = require('../config/mysql_banche');
const db = require('./db'); 
  
const dataBaseCfg = require('../config/dataBaseCfg.js');
const util = require('./util.js');



/**
 * 获取缓存配置中的字典值
 * 
 * @param dictTypeId 字典类型字段
 * @param dictKey 字典Key值
 * @return 字典描述值
 */
exports.getDictDesc = async function(dictTypeId,dictKey) {
	let dictDest = "";
	try{
		let cacheCfg = await dataBaseCfg;
		if(!cacheCfg){ //无缓存数据
			dataBaseCfg = await util.getDataBaseCfg();
			cacheCfg = await dataBaseCfg;
		}
		let dicts =await cacheCfg[dictTypeId]; //数组
		
		if(dicts && dicts.length > 0){
			for(let i=0;i<dicts.length;i++){
				if(dicts[i].dictKey == dictKey){
					dictDest = dicts[i].dictdesc;
				}
			}
		}
    }catch(err){
    	logger.info("获取缓存字典值报错:%s",err);
    }
    return dictDest;
};
/**
 * 获取缓存配置中的字典对象
 * 
 * @param dictTypeId 字典类型字段
 * @param dictKey 字典Key值
 * @return 字典描述值
 */
exports.getDict = async function(dictTypeId,dictKey) {
	let dictDest = {};
	try{
		let cacheCfg = await dataBaseCfg;
		if(!cacheCfg){ //无缓存数据
			dataBaseCfg = await util.getDataBaseCfg();
			cacheCfg = await dataBaseCfg;
		}
		let dicts =await cacheCfg[dictTypeId]; //数组
		
		if(dicts && dicts.length > 0){
			for(let i=0;i<dicts.length;i++){
				if(dicts[i].dictKey == dictKey){
					dictDest = dicts[i];
				}
			}
		}
    }catch(err){
    	logger.info("获取缓存字典值报错:%s",err);
    }
    return dictDest;
};

扫描二维码关注公众号，回复： 5048120 查看本文章