在我的并发项目中,我需要在redis中获取一个值,然后更新它并在redis中设置。像下面的代码,我期望的结果应该是3000,但是我无法得到正确的结果。顺序可能不对,可能是GET GET SET SET 或GET SET SET GET 等。如何才能得到正确的顺序和正确的结果?我应该使用一些锁吗?
import * as redis from 'redis';
let config: redis.ClientOpts = {
host: '127.0.0.1',
port: 6379
};
let redisClient: redis.RedisClient = new redis.RedisClient(config);
redisClient.set('num', '0');
(async () => {
for (let i = 0; i < 1000; i++) {
await add ();
}
})();
(async () => {
for (let i = 0; i < 1000; i++) {
await add ();
}
})();
(async () => {
for (let i = 0; i < 1000; i++) {
await add ();
}
})();
// I know incr command, this is just an example.
async function add () {
let numStr: string = await get('num');
let num: number = Number(numStr);
num++;
await set('num', String(num));
console.log(num);
}
async function get (key: string): Promise<string> {
return new Promise<string>((resovle, reject) => {
redisClient.get(key, (err: Error, reply: string) => {
if (err) {
console.error(err);
reject(err);
}
resovle(reply);
})
});
}
async function set (key: string, value: string): Promise<string> {
return new Promise<string>((resovle, reject) => {
redisClient.set(key, value, (err: Error, reply: string) => {
if (err) {
console.error(err);
reject(err);
}
resovle(reply);
})
});
}
最佳答案
Redis 提供了一种更灵活的方式来使用 MULTI-EXEC 方法“原子地”执行事务。
假设您正在处理一个银行系统,一位客户请求进行货币转账。您需要先从客户账户中打折,然后再存入另一个账户。在这些操作之间,其中一个可能会失败。所以,我们使用交易。
事务是原子的,这意味着所有操作要么全部发生,要么全部不发生。数据库具有锁定和并发管理实现,可确保发生这种情况,同时不会显着影响系统性能。
例子:
var redis = require("redis"),
client = redis.createClient(), multi;
async function add () {
multi = client.multi();
let numStr: string = await multi.get('num');
let num: number = Number(numStr);
num++;
await multi.set('num', String(num));
multi.exec(function (err, replies) {
console.log(replies);});
}
}
关于node.js - nodejs并发下如何正确使用redis的GET SET命令?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50628429/