nodejs之实现一个随项目启动将数据库配置加载到内存中

小咪咪 2022-04-18 04:59 293阅读 0赞

干货，直接上代码：

--------------------

项目结构：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpX2RhYmlu_size_16_color_FFFFFF_t_70][]

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

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpX2RhYmlu_size_16_color_FFFFFF_t_70 1][]

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

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpX2RhYmlu_size_16_color_FFFFFF_t_70 2][]

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

![20181108183652107.png][]

到此，从数据库中加载配置到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;
    };

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpX2RhYmlu_size_16_color_FFFFFF_t_70]: /images/20220418/47c287d9b48e40ac94d13cc3b0eccefb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpX2RhYmlu_size_16_color_FFFFFF_t_70 1]: /images/20220418/6e97432cc0be4d068f315abf14b2d697.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FpX2RhYmlu_size_16_color_FFFFFF_t_70 2]: /images/20220418/d8cd9b71c2ca478eb94476fddccded91.png
[20181108183652107.png]: /images/20220418/32d5ecf3ce3c4ad089e4af21f960d0ce.png