node-lock

Node.js进程互斥锁:

Linux下默认读写/dev/shm.

Notice: 这一分支下开发互斥锁版本. 如无需锁支持, 可以使用master分支HEAD的高性能版本.

$3

+ Parser性能测试
+ 压力测试

原理: 由于Node的单进程单线程模型, 同一时间只允许一个阻塞任务执行,
利用这一机制在Linux内存映射文件系统/dev/shm上使用Node原生的阻塞读写函数, 可以实现多进程对同一块内存区域访问的读写互斥作用.

如果需要进一步控制资源访问, 需要用.lock/.unlock. 它会根据LockFile判断是否允许申请资源锁,
用lock(key)对一个资源的事务过程加锁, 锁在超时(默认5s)后会自动释放掉, 申请失败时会在next Tick里重试.

Notice: 由于资源访问的互斥性, 带来不可避免的同步原语, 因此任何异步执行是无意义的, 最终仍需要等待锁的释放, 所以服务端采用同步模型.
但C/S的结构允许客户端的异步请求, 这样就做到了异步互斥.

Usage

``coffee


master process

lock server

LockProxy = require 'node-lock/proxy'

LockServer [options]

@options:

+ namespace: 命名空间(默认为"default")

+ dir: 共享内存位置, linux下默认为/dev/shm, osx需要手动指定一块已经创建区域

m = LockProxy namespace: 'ddd', dir: '/Volume/shm'

m = LockProxy namespace: 'ddd', dir: '/Volume/shm'

启动服务端

LockProxy().startStandAlone()
`

`coffee


other process

LockClient = require 'node-lock'
client = new LockClient '/tmp/-tmp-default'

连接服务端socket

client.connect()
.then (resource) ->
resource
.lock 'key::1'
.once 'lock', ->
resource.create 'key::1', 'value'
.once 'create', ->
resource.retrieve 'key::1'
.once 'retrieve', (ret) ->
console.log ret
resource.unlock 'key::1'
.catch (err) ->
console.error err
``