Frontend Learning Book

brew install redis

redis-server

brew services start redis
brew services list
brew services stop redis # stop

redis-cli ping
redis-cli -h 127.0.0.1 # 默认 port 6379
CONFIG SET requirepass "xxxxxx" # 同local.js
AUTH "xxxxxx"
select 4 # db
flushdb # clear database
KEYS * # get all keys
get sapToken # get certain key
ttl sapToken # get expire time
PSETEX sapToken 1500000 "xxx" # set
del sapToken # delete
shutdown # shutdown

wget https://download.redis.io/releases/redis-6.2.6.tar.gz # 下载
tar xzf redis-6.2.6.tar.gz # 解压
mv redis-6.2.6 /usr/local/redis # 移动
cd /usr/local/redis # 进入安装目录
yum -y install gcc automake autoconf libtool make # 安装gcc
make MALLOC=libc # 编译（指定分配器为libc）
make install PREFIX=/usr/local/redis # 安装

./bin/redis-server redis.conf # 启动
ps -ef | grep redis # 查看进程
netstat -pan | grep 6379 # 查看端口

./bin/redis-cli
set test hello
get test

export REDIS_HOME=/usr/local/redis
PATH=$PATH:$HOME/bin:$REDIS_HOME/bin

# bind 127.0.0.1 -::1 # 127.0.0.1只允许本机访问，加上#会变成0.0.0.0
protected-mode no  # yes 以守护进程方式启动 -> no 以配置文件方式启动

docker run --restart=always -p 6379:6379 --name myredis -d redis:7.0.12

docker run \
-p 6379:6379 \
--name vredis \
-v /var/docker/redis/redis.conf:/etc/redis/redis.conf \
-v /var/docker/redis/data:/data \
--restart=always \
-d redis:7.0.12 redis-server /etc/redis/redis.conf # -d 后台运行

docker exec -it <CONTAINER_ID> bash # 以交互方式进入容器
redis-cli
ctrl+c # 退出 redis
exit # 退出 docker

const redis = require('redis');
const { promisify } = require('util');

const redisClient = redis.createClient({
  db: sails.config.session.db,
  password: sails.config.session.pass,
  port: sails.config.session.port,
  host: sails.config.session.host,
});
const getRedisAsync = promisify(redisClient.get).bind(redisClient);

redisClient.psetex(sapTokenKey, 25 * 60 * 1000, val);

extoken = await getRedisAsync(sapTokenKey);

CONFIG SET notify-keyspace-events Ex

// client 1
redis-cli -h xxx-dev-rep-group-1-001.ugvuyh.0001.use1.cache.amazonaws.com
setex name 10 yoga

// client 2
redis-cli -h xxx-dev-rep-group-1-001.ugvuyh.0001.use1.cache.amazonaws.com --csv psubscribe '*'
// Reading messages... (press Ctrl-C to quit)
// "psubscribe","*",1
// "pmessage","*","__keyevent@0__:expired","name"

const SubscribeExpired = () => {
  const sub = redis.createClient({
    db: sails.config.session.db,
    password: sails.config.session.pass,
    port: sails.config.session.port,
    host: sails.config.session.host,
  });
  const expiredSubKey = `__keyevent@${sails.config.session.db}__:expired`;
  sub.psubscribe(expiredSubKey, () => {
    sub.on('pmessage', async (pattern, channel, message) => {
      ...
    });
  });
};
// 只在instance1上注册事件
if (process.env.NODE_APP_INSTANCE === '0' || !process.env.NODE_APP_INSTANCE) {
  redisClient.send_command('config', ['set', 'notify-keyspace-events', 'Ex'], SubscribeExpired);
}

// local.js
session: {
  adapter: '@sailshq/connect-redis',
  pass: 'XXXXXXXXXXXXX',
  db: 5,
},

async function flushCacheWithDomain(domain) {
  if (!domain) {
    throw new Error('need domain.')
  }
  function innerScan(cursor) {
    return new Promise((resolve, reject) => {
      redisClient.scan(cursor, 'MATCH', `*${domain}*`, 'COUNT', '100', (err, res) => {
        if (err) {
          reject(err)
        }
        const [newCursor, keys] = res
        Promise.all(keys.map((key) => redisClient.del(key)))
          .then(() => {
            sails.log.info(`del ${keys.length} keys.`)
            if (newCursor === '0' || newCursor === 0) {
              resolve(1)
            } else {
              resolve(innerScan(newCursor))
            }
          })
          .catch(reject)
      })
    })
  }

  await innerScan('0')
}

export default express().use(middlewareCollection())

export function middlewareCollection() {
  const middlewarePromise = (async () => {
    const { environment, sessionSecret, oauth } = await getConfig();
    const store = await getSessionStore(environment);

    const sessionMiddleware = session({
      resave: true,
      saveUninitialized: true,
      store,
      secret: sessionSecret,
      cookie: {
        maxAge: 1000 * 60 * 15, // 15分钟未操作清除缓存，用户登出
        secure: true,
      },
      proxy: true,
    });

    return express
      .Router()
      .use(sessionMiddleware)
      .use(passport.initialize())
      .use(passport.session());
  })();

import session from "express-session";
import RedisStore from "connect-redis"; // 内存中的键值存储，高性能和可扩展性
import sessionFileStore from "session-file-store"; // 设置较为简单，只需要文件系统访问权限, 在需求较低的环境中使用

export const getSessionStore = async (
  environment: Environments
): Promise<StoreWithAll> => {
  if (environment === Environments.LOCAL) {
    const FileStore = sessionFileStore(session);
    return new FileStore({
      path: "../../localsession",
      retries: 0,
    }) as StoreWithAll;
  } else {
    const redisClient = await Cache.getClientWithConfig();
    return new RedisStore({
      client: redisClient,
      prefix: "user-session:",
    });
  }
};