调用Lua脚本的语法：

$ redis-cli --eval path/to/redis.lua numberkeys KEYS[1] KEYS[2] , ARGV[1] ARGV[2] ...



--eval，告诉redis-cli读取并运行后面的lua脚本

path/to/redis.lua，是lua脚本的位置，也可以直接为脚本字符串。是一个Lua 5.1 script。

numberkeys ，指定后续参数有几个key。

KEYS[1] KEYS[2]，是要操作的键，可以指定多个，在lua脚本中通过KEYS[1], KEYS[2]获取

ARGV[1] ARGV[2]，参数，在lua脚本中通过ARGV[1], ARGV[2]获取。

/**

     * @summary 竞拍列表

     * @description 1.type 【1】检测用户是否已报名 【2】用户报名的拍卖列表

     * @router GET /api/v1/user/auction/auction/list

     * @request query string page 第几页

     * @request query string limit 每页几个

     * @request query string type 类型

     * @request query string status 状态

     * @apikey Authorization

     * @response 200 ACRES

     */

    async index() {

        const {

            ctx,

            ctx:{

                uid,

                query:{

                    page=1,

                    limit=12,

                    type,

                    status

                }

            }

        }= this;

        const RDS = await ctx.app.redis.get('auctionRoom')

        try {

            //  查询符合条件的hash key

            const [[],LIST] = await RDS.sscan(`ar:u:${uid}`,(page-1)*limit,'count',limit);



            // 注册脚本 

            // 1 声明输出的类型 rst {} {}对应key 为数组的下标记

            // 2 格式化输入的参数KEYS 对应lua的numberkeys  为1 

            // 3 lua中切换db 也可以做多个参数 如KEYS2 这里我是固定的 所以只传一个 KEYS

            // 4,5,6 执行redis的hget脚本 .. v 为lua中的链接符号

            // 7 返回值

            await RDS.defineCommand("hmgetall", {

                lua: `local rst={};

                      local id=cjson.decode(KEYS[1]);

                      redis.call('select',13);

                      for i,v in pairs(id)

                        do rst[i]=redis.call('hget', 'ar:' .. v,'meta_info')

                      end;

                      return rst;`,

            })

            // 使用脚本并格式化 输出

            ctx.body = (await RDS.hmgetall(1,JSON.stringify(LIST.map(e=>`${e}`)))).reduce((a,b)=>{

                a['list'].push(JSON.parse(b));

                return a

            },{list:,page:{limit,page}})

        } catch (err) {

            console.log(err)

            return ctx.body = {

                code: 211,

                message: ctx.app.config.env === 'local' ? `${(err.message)}`:'服务器忙，请稍后重试！',

                data: err.errors

            }

        }

    }[/i]

netstat -tpln | grep [port]

kill [port]

netstat -ano |findstr [port]

taskkill /f /t /im "进程id或者进程名称"

firewall-cmd --zone=public --add-port=5672/tcp --permanent

firewall-cmd --zone=public --remove-port=5672/tcp --permanent 

firewall-cmd --reload

firewall-cmd --zone=public --list-ports

systemctl stop firewalld.service

 firewall-cmd --state

netstat -lnpt

netstat -lnpt |grep 5672

• Producer：消息生产者，即投递消息的程序
• Broker：消息队列服务器实体。

1. Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。
2. Binding：绑定，它的作用就是把 Exchange 和 Queue 按照路由规则绑定起来。
3. Queue：消息队列载体，每个消息都会被投入到一个或多个队列。

• Consumer：消息消费者，即接受消息的程序。

yum install -y http://rpms.famillecollet.com/ ... 7.rpm

yum --enablerepo=remi install redis

systemctl enable redis.service

vim /etc/redis.conf

# 设置可外网访问 DEV 模式用 上线慎用

bind 0.0.0.0 

# 设置访问密码

requirepass ***********

:wq



/bin/systemctl restart redis.service

记住默认只有16个 chanceDb

const MAX_WSE = 4;  //启动几个浏览器 

let WSE_LIST = ; //存储browserWSEndpoint列表

init();

app.get('/', function (req, res) {

    let tmp = Math.floor(Math.random()* MAX_WSE);

    (async () => {

        let browserWSEndpoint = WSE_LIST[tmp];

        const browser = await puppeteer.connect({browserWSEndpoint});

        const page = await browser.newPage();

        await page.goto('file://code/screen/index.html');

        await page.setViewport({

            width: 600,

            height: 400

        });     

        await page.screenshot({path: 'example.png'});

        await page.close();

        res.send('Hello World!');

    })();

});



function init(){

    (async () => {

        for(var i=0;i<MAX_WSE;i++){

            const browser = await puppeteer.launch({headless:true,

                args: [

                '--disable-gpu',

                '--disable-dev-shm-usage',

                '--disable-setuid-sandbox',

                '--no-first-run',

                '--no-sandbox',

                '--no-zygote',

                '--single-process'

            ]});

            browserWSEndpoint = await browser.wsEndpoint();

            WSE_LIST[i] = browserWSEndpoint;

        }

        console.log(WSE_LIST);

    })();   

}[/i]

:filename:file 

:wq

本文章建议有一定Nodejs开发经验和熟悉ES6/7的开发人员查看，文中若有错误望指出！

$ npm i egg-init -g

$ egg-init egg-crm --type=simple

$ cd egg-crm

$ npm i

npm run dev

[mongodb-org-4.0]

name=MongoDB Repository

baseurl=https://repo.mongodb.org/yum/redhat/$releasever/mongodb-org/4.0/x86_64/

gpgcheck=1

enabled=1

gpgkey=https://www.mongodb.org/static/pgp/server-4.0.asc

sudo yum install -y mongodb-org-4.0.6 mongodb-org-server-4.0.6 mongodb-org-shell-4.0.6 mongodb-org-mongos-4.0.6 mongodb-org-tools-4.0.6

service mongod start

  "devDependencies": {

    "autod": "^3.0.1",

    "autod-egg": "^1.1.0",

    "baidu-aip-sdk": "^2.3.9",

    "bce-sdk-js": "^0.2.9",

    "decimal": "^0.0.2",

    "egg-bin": "^4.11.0",

    "egg-ci": "^1.11.0",

    "egg-cors": "^2.1.2",

    "egg-jwt": "^3.1.6",

    "egg-mock": "^3.21.0",

    "egg-mongoose": "^3.1.1",

    "egg-validate": "^2.0.2",

    "eslint": "^5.13.0",

    "eslint-config-egg": "^7.1.0",

    "lodash": "^4.17.11",

    "stream-to-array": "^2.3.0",

    "webstorm-disable-index": "^1.2.0",

    "xml2js": "^0.4.19"

  },

'use strict';



module.exports = appInfo => {

    const config = exports = {};



    // use for cookie sign key, should change to your own and keep security

    config.keys = appInfo.name + '_1539582326426_4353';



    // csrf配置

    config.security = {

        csrf: {

            enable: false,

            ignoreJSON: true

        },

        domainWhiteList: ['http://localhost:7001', 'http://192.168.0.123', 'http://localhost]

    };

    // 

    config.cors = {

        allowMethods: 'GET,HEAD,PUT,POST,DELETE,PATCH,OPTIONS',

        credentials: true

    };

    // // add your config here

    // config.middleware = ;

    config.middleware = ['errorHandler', 'responseFormatter', 'jwtErrorHandler'];

    config.middleware.errorHandler = {

        match: '/api',

    };

    config.middleware.responseFormatter = {

        match: '/api',

    };

    //短信配置

    config.sms = {

        svip: {

            uri: ‘',

            name: '',

            password: '',

        },

    };

    // 邮箱配置

    config.email = {

            service: 'QQex',

            port: 465,

            secureConnection: true,

            auth: {

                user: '',

                pass: '',

            }

        }

        // mongodb配置

    config.mongoose = {

        url: 'mongodb://127.0.0.1/geecrm',

        options: {},

    };

    // bos云存储

    /*****************begin********************/

    config.baiduBos = {

        endpoint: 'http://bj.bcebos.com',

        credentials: {

            ak: '',

            sk: ''

        }

    };

    config.baiduBosBucket = '';

    /*****************end***********************/

    // baidu AIP

    config.baiduAIP = {

        APP_ID: '',

        API_KEY: '',

        SECRET_KEY: ''

    };

    // baidu VOD

    config.baiduVod = {

        endpoint: 'http://vod.bj.baidubce.com',

        credentials: {

            ak: '',

            sk: ''

        }

    };

    // 企业微信配置

    config.weWork = {

        'corpid': '',

        'corpsecret': '',

        'agentId': ''

    };

    // 微信配置

    config.wechatApi = {

        appId: '',

        appSecret: '',

    };

    // 默认json 设置

    config.JSONS = {

        'code': 200,

        'message': 'success',

        'uri': 'https://api.lanjing.xyz',

    };

    config.alipay = {

        appId: "",

        rsaPrivate: "",

        notifyUrl: "", //异步回调

        signType: "RSA2",

        rsaPublic: "",

        sandbox: false //沙箱环境

    }



    config.wechatPay = {

            partnerKey: "",

            appId: "",

            mchId: "",

            notifyUrl: "http://www.langjing.xyz/wechat/notify", //异步回调，到微信平台设置下

            pfx: ""

        }

        // 

    return config;

};

'use strict';

exports.validate = {

    enable: true,

    package: 'egg-validate',

};

exports.mongoose = {

    enable: true,

    package: 'egg-mongoose',

};

exports.jwt = {

    enable: true,

    package: "egg-jwt"

};

exports.cors = {

    enable: true,

    package: "egg-cors"

};