node使用redis

国际惯例，先简单介绍下redis。

redis是什么

REmote DIctionary Server(Redis) 是一个由Salvatore Sanfilippo写的key-value存储系统。

Redis是一个开源的使用ANSI C语言编写、遵守BSD协议、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的API。

它通常被称为数据结构服务器，因为值（value）可以是 字符串(String), 哈希(Hash), 列表(list), 集合(sets) 和 有序集合(sorted sets)等类型。

相关git

koakoa-routerkoa-bodynode_redisAnotherRedisDesktopManager

安装redis

安装redis，网上教程很多，这里就不多说，自行搜索一下哈。(本文介绍的是在Windows环境下)
安装完redis后，运行redis-server.exe，搭配使用redis可视化管理工具 → AnotherRedisDesktopManager

node下安装redis

支持所有redis的命令，redis文档

1. npm install redis

官方使用示例

1. var redis = require("redis"),
2. client = redis.createClient();
4. //如果要切换数据库，可以使用下面命令
5. // client.select(3, function() { /* ... */ });
7. client.on("error", function (err) {
8. console.log("Error " + err);
9. });
11. client.set("string key", "string val", redis.print);
12. client.hset("hash key", "hashtest 1", "some value", redis.print);
13. client.hset(["hash key", "hashtest 2", "some other value"], redis.print);
14. client.hkeys("hash key", function (err, replies) {
15. console.log(replies.length + " replies:");
16. replies.forEach(function (reply, i) {
17. console.log(" " + i + ": " + reply);
18. });
19. client.quit();
20. });

如果node版本是V8或更高的，还可以使用同步

1. const {promisify} = require('util');
2. const getAsync = promisify(client.get).bind(client);
4. return getAsync('foo').then(function(res) {
5. console.log(res); // => 'bar'
6. });
8. //或者使用async await
9. async myFunc() {
10. const res = await getAsync('foo');
11. console.log(res);
12. }

实际使用

koa + redis 进行增删改查，使用redis中的DB 3

增：添加一个IP ，默认值为0

请求地址	http://localhost:3001/gateway
请求方式	POST
请求参数	{ “ip”: “192.168.2.1” }

删：删除IP

请求地址	http://localhost:3001/gateway?ip=192.168.2.1
请求方式	DELETE
请求参数	{ “ip”: “192.168.2.1” }

改：修改IP 的value

请求地址	http://localhost:3001/gateway
请求方式	PUT
请求参数	{ “ip”: “192.168.2.1”, “value”:”222″ }

查：查询IP的value

请求地址	http://localhost:3001/gateway?ip=192.168.2.1
请求方式	GET
请求参数	{ “ip”: “192.168.2.1” }

核心代码

1. //app.js
3. const Koa = require('koa')
4. const router = require('./routes/index')
6. const app = new Koa()
7. app.use(router.routes()).use(router.allowedMethods());
9. app.listen(3001)
10. console.log("服务启动成功，端口号:3001 ")

1. //路由 routes/index.js
2. const Router = require('koa-router');
3. const koaBody = require('koa-body');
5. const testController = require('../controllers/test')
7. const router = new Router()
9. //test
10. router.get('/gateway',testController.assignServer)//分配
11. router.post('/gateway',koaBody(),testController.registerServer)//注册
12. router.put('/gateway',koaBody(),testController.updateServer)//更新
13. router.delete('/gateway',testController.deleteServer)//注销
16. module.exports = router

1. //封装redis util/redis.js
2. const redis = require("redis");
3. const { promisify } = require('util');
4. //Redis 命令参考 http://doc.redisfans.com/index.html
6. /**
7. *
8. * @param {*} db 需要切换的DB，不传则默认DB 0
9. */
10. function Client(num){
11. let db = num || 0
12. let client = redis.createClient({db});
14. //需要使用同步函数，按照如下定义即可
15. this.exists = promisify(client.exists).bind(client);
16. this.keys = promisify(client.keys).bind(client);
18. this.set = promisify(client.set).bind(client);
19. this.get = promisify(client.get).bind(client);
20. this.del = promisify(client.del).bind(client);
21. this.incr = promisify(client.incr).bind(client);
22. this.decr = promisify(client.decr).bind(client);
24. this.lpush = promisify(client.lpush).bind(client);
26. this.hexists = promisify(client.hexists).bind(client);
27. this.hgetall = promisify(client.hgetall).bind(client);
28. this.hset = promisify(client.hset).bind(client);
29. this.hmset = promisify(client.hmset).bind(client);
30. this.hget = promisify(client.hget).bind(client);
31. this.hincrby = promisify(client.hincrby).bind(client);
32. this.hdel = promisify(client.hdel).bind(client);
33. this.hvals = promisify(client.hvals).bind(client);
34. this.hscan = promisify(client.hscan).bind(client);
36. this.sadd = promisify(client.sadd).bind(client);
37. this.smembers = promisify(client.smembers).bind(client);
38. this.scard = promisify(client.scard).bind(client);
39. this.srem = promisify(client.srem).bind(client);
40. return this;
41. }
43. module.exports = Client

业务处理代码

1. //controllers/test.js
2. const Client = require('../util/redis')
4. class TestController {
6. /* 查询
7. */
8. static async get(ctx) {
9. let ip = ctx.request.query.ip;
10. const client = new Client(3);
11. try {
12. let res = await client.get(ip);
13. ctx.body = {
14. data:res
15. }
16. } catch (err) {
17. ctx.body = {
18. message:err
19. }
20. }
21. }
23. /* 增
24. */
25. static async add(ctx) {
26. let ip = ctx.request.body.ip;
27. const client = new Client(3);
28. try {
29. let old = await client.exists(ip);
30. if (old) {
31. ctx.error(false, "添加失败, ip已存在")
32. } else {
33. await client.set(ip, 0);
34. ctx.body = {
35. message:"添加成功"
36. }
37. }
39. } catch (err) {
40. ctx.body = {
41. message:err
42. }
43. }
44. }
46. /* 改
47. */
48. static async update(ctx) {
49. let ip = ctx.request.body.ip,
50. value = ctx.request.body.value;
51. let isDecr;
53. let client = new Client(3); //gateway在REDIS中的默认DB 为0
54. try {
55. let old = await client.exists(ip);//先查询
56. if (old) {//存在
57. await client.set(ip, value);
58. ctx.body = {
59. message:"修改成功"
60. }
61. } else {
62. ctx.body = {
63. message:"修改失败，IP不存在"
64. }
65. }
66. } catch (err) {
67. ctx.body = {
68. message:err
69. }
70. }
71. }
75. /**
76. * 删
77. */
78. static async delete(ctx) {
79. let ip = ctx.request.query.ip;
80. const client = new Client(3);
82. try {
83. let old = await client.exists(ip);//先查询
84. if (old) {//存在
85. await client.del(ip);
86. ctx.body = {
87. message:"删除成功"
88. }
89. } else {
90. ctx.body = {
91. message:"删除失败，IP不存在"
92. }
93. }
94. } catch (err) {
95. ctx.body = {
96. message:err
97. }
98. }
99. }
103. }
105. module.exports = TestController

完整代码

完整代码
代码下载到本地后，进入文件夹根目录，输入命令

1. npm i

安装完node包后再运行

1. node app.js