服务器分布式锁
2015-08-18 20:55
169 查看
多进程处理数据的时候难免会出现数据不一致问题,例如有一个进程正在处理数据,还没有来得及写入,另一个进程已经在读,导致拿到的数据不是最新的。应该要保证第一个进程更新完后再读取才不会出错,要解决这个问题就要进行类似一个原子操作了,给执行的代码加一个分布式锁。
下面用ssdb实现一把分布式锁:
bool SsdbLock(const string& key, uint32_t last)
{
Client* client = GetSsdbClientByKey(key);
if ( !client)
{
return false;
}
string lastTime = util::toString(last);
int count = 5;
while (true && count > 0)
{
int64_t retVal = 0;
if ( client->incr(key, 1, &retVal) && 1 == retVal )
{
const std::vector<std::string> *resp = client->request("expire", key.c_str(), lastTime.c_str());
Status status(resp);
if ( status.ok() )
{
return true;
}
}
usleep( 300000 * (6 - count) );
--count;
}
return count > 0;
}
void SsdbUnLock(const string& key)
{
Client* client = GetSsdbClientByKey(key);
if ( !client )
{
return;
}
Status status = client->del(key);
int count = 3;
while ( !status.ok() && count > 0)
{
status = client->del(key);
usleep(300000 * (4 - count) );
--count;
}
}
上面用incr自增来实现锁,也可以通过setnx命令来实现,但c++客户端API现在还不支持该命令的执行。
用expire命令设置一个有生存周期的key值,保证超时后其它进程可以获得锁。
除了可以用ssdb实现分布式锁,也可以通过redis和MySql实现
redis的实现方式和上面的ssdb的方式一样
MySql可以用update语句来实现(设置一个时间字段,每次更新都写入当前的时间,确保超时控制),具体实现方式留给读者思考了。
下面用ssdb实现一把分布式锁:
bool SsdbLock(const string& key, uint32_t last)
{
Client* client = GetSsdbClientByKey(key);
if ( !client)
{
return false;
}
string lastTime = util::toString(last);
int count = 5;
while (true && count > 0)
{
int64_t retVal = 0;
if ( client->incr(key, 1, &retVal) && 1 == retVal )
{
const std::vector<std::string> *resp = client->request("expire", key.c_str(), lastTime.c_str());
Status status(resp);
if ( status.ok() )
{
return true;
}
}
usleep( 300000 * (6 - count) );
--count;
}
return count > 0;
}
void SsdbUnLock(const string& key)
{
Client* client = GetSsdbClientByKey(key);
if ( !client )
{
return;
}
Status status = client->del(key);
int count = 3;
while ( !status.ok() && count > 0)
{
status = client->del(key);
usleep(300000 * (4 - count) );
--count;
}
}
上面用incr自增来实现锁,也可以通过setnx命令来实现,但c++客户端API现在还不支持该命令的执行。
用expire命令设置一个有生存周期的key值,保证超时后其它进程可以获得锁。
除了可以用ssdb实现分布式锁,也可以通过redis和MySql实现
redis的实现方式和上面的ssdb的方式一样
MySql可以用update语句来实现(设置一个时间字段,每次更新都写入当前的时间,确保超时控制),具体实现方式留给读者思考了。
相关文章推荐
- 用vbscript实现启用 Caps Lock (大写)键
- C#中lock死锁实例教程
- Node.js中child_process实现多进程
- 解析使用C# lock同时访问共享数据
- [Oracle] 浅谈Lock与Latch
- mysql下普通用户备份数据库时无lock tables权限的解决方法
- Linux BASH多进程并行处理的方法实现
- c语言多进程tcp服务器示例
- C#中的lock、Monitor、Mutex学习笔记
- PHP的pcntl多进程用法实例
- 以实例全面讲解PHP中多进程编程的相关函数的使用
- 深入探究PHP的多进程编程方法
- C#中lock用法详解
- Python多线程同步Lock、RLock、Semaphore、Event实例
- 深入解析PHP中的(伪)多线程与多进程
- Java多线程编程之Lock用法实例
- Python多线程编程(四):使用Lock互斥锁
- 用map函数来完成Python并行任务的简单示例
- python 多进程通信模块的简单实现
- python多进程操作实例