当前位置: 首页 > 工具软件 > koa-redis > 使用案例 >

Koa学习笔记 --redis

宋鸿德
2023-12-01

相对于MySQL和MongoDB,Koa操作Redis稍微顺利了点,没有遇到太多的问题。

看一段简单的demo:

const redis = require('redis')
const client = redis.createClient(6379, '127.0.0.1')

client.on('error',(err)=>{
  console.log(err);
})

client.set('name', 'asen', redis.print)
client.get('name', (err, value)=>{
  if (err) throw err
  console.log(value);
})

为了方便同样是使用本机的docker的redis客户端,操作也相对加拿大,port和host输入即可。

on方法同时通过client对象对error事件进行监听,可以实时捕捉error。

至于各种语法方法,同redis本身的操作大同小异,不再赘述。

前文说过,Session 也被称为“会话控制”,顾名思义,它是用于控制网络会话的,如用户的登录信息、购物车中的商品,或者用户的一些浏览喜好都可以存储在Session中,是保存状态的一种实现形式 

关于session要在redis中持久化存储的好处,书中讲到:

 Session 中的数据一般都是短时间内高频访问的,需要保证性能,所以比 较好的方式是内存配合 Redis 做一个持久化。这是因为内存访问的性能虽然是最好的,但是 容易丢失数据,如遇到重启服务器等情况。 因此, 可以在 Redis 中做一个备份,当内存中的 数据丢失时,就可以从 Redis 中恢复数据

除在服务器端保存完整的Session数据外,还需要在客户端(浏览器等)通过Cookie来保存Session的一个唯一标识,我们可以通过koa-session这个中间件来实现。

下面是用koa-session这个中间件实现的一种记录session的实例,但是当我们可能因为各种因素重启服务器的时候,session是会丢失的,这就需要我们使用redis对之做好记录。

const koa = require('koa')
const app = new koa()
const session = require('koa-session')

app.keys = ['dtubjhfgjj'];
const CONGIF = {
  key: 'myAppSessKey',
  maxAge: 86400000,
  overwrite: true,
  httpOnly: true,
  signed: true
}
app.use(session(CONGIF, app))
app.use(ctx=>{
  if (ctx.path === '/favicon.ico') return;
  let n = ctx.session.views || 0
  ctx.session.views=++n
  ctx.body = `${n} views`
});

app.listen(3000)

下面是使用redis做了优化之后的代码:

const koa = require('koa')
const app = new koa()
const session = require('koa-session')
const redis = require('redis')
const client = redis.createClient(6379, '127.0.0.1')
const {promisify} = require('util')

const hgetallAsync = promisify(client.hgetall).bind(client)

app.keys = ['dtubjhfgjj'];
const store = {
  get: async (key, maxAge)=>{
    return await hgetallAsync(key)
  },
  set: (key, sess, maxAge)=>{
    client.hmset(key, sess)
  },
  destroy: (key)=>{
    client.hdel(key)
  }
}

const CONGIF = {
  key: 'koa:sess',
  maxAge: 86400000,
  overwrite: true,
  httpOnly: true,
  signed: true,
  store
}
app.use(session(CONGIF, app))
app.use(ctx=>{
  if (ctx.path === '/favicon.ico') return;
  let n = ctx.session.views || 0
  ctx.session.views=++n
  ctx.body = `${n} views`
});

app.listen(3000)

这时重启服务器,我们可以看到浏览器中views的计数不会重新开始。

 类似资料: