首页 \ 问答 \ 带有EX和NX的Ruby REDIS(Ruby REDIS with EX AND NX)

带有EX和NX的Ruby REDIS(Ruby REDIS with EX AND NX)

我试图在我们的rails应用程序服务器中实现锁定。

如果我想永远获得一个锁,REDIS.setnx工作正常。 但我希望获得有效期限的锁定,基本上我希望锁定在一定时间后过期,以便锁定可以再次获得。

从REDIS的设置文档中,我发现它是可能的。 https://redis.io/commands/set “命令SET resource-name anystring NX EX max-lock-time是一种使用Redis实现锁定系统的简单方法。”

如何在ruby中实现这一点。 命令:

REDIS = Redis.new(host: ENV['REDIS_HOST'], port: ENV['REDIS_PORT'])
REDIS.set "key", "value", "nx", "ex", 3600

抛出错误:

ArgumentError: wrong number of arguments (given 5, expected 2..3)

还有另一种方法,但需要两次REDIS调用。

if(REDIS.setnx "key", "value")
    REDIS.setex "key", 3600, "value"
end

该方法不是优选的。 我正在寻找一种方法来获得REDIS锁定与红宝石单一REDIS调用。 基本上“SET资源名称anystring NX EX max-lock-time”等效于ruby。

谢谢,

Anshul


I am trying to implement a locking in our rails application server.

REDIS.setnx works fine if I want to acquire a lock forever. But I want to acquire lock with expiry, basically I want the lock to expire after certain duration so that lock will be free to be acquired again.

From REDIS's set documentation, I see it is possible. https://redis.io/commands/set "The command SET resource-name anystring NX EX max-lock-time is a simple way to implement a locking system with Redis."

How to implement this in ruby. Command :

REDIS = Redis.new(host: ENV['REDIS_HOST'], port: ENV['REDIS_PORT'])
REDIS.set "key", "value", "nx", "ex", 3600

throws error:

ArgumentError: wrong number of arguments (given 5, expected 2..3)

There is another way to do that, but it requires two REDIS calls.

if(REDIS.setnx "key", "value")
    REDIS.setex "key", 3600, "value"
end

This method is not preferred. I am looking to a way to acquire REDIS lock with single REDIS call in ruby. Basically "SET resource-name anystring NX EX max-lock-time" equivalent in ruby.

Thanks,

Anshul


原文:https://stackoverflow.com/questions/48318207
更新时间:2023-08-17 21:08

最满意答案

你可以使用这样的东西:

@Service
public class MyPropertiesServ implements InitializingBean {

@Autowired
protected ApplicationContext context;
private Properties properties;

private static MyPropertiesServ singleInst;

protected MyPropertiesServ () {
    properties = new Properties();
    singleInst= this;
}

@Override
public void afterPropertiesSet() throws Exception {
    properties.load(context.getResource("classpath:file.properties").getInputStream());
}

public static String getStringProperty(String key) {
    return singleInst.properties.getProperty(key);
}

}

另一个例子: http//forum.spring.io/forum/spring-projects/container/35703-initialising-static-property-of-class-through-injection-on-startup


You could use something like this:

@Service
public class MyPropertiesServ implements InitializingBean {

@Autowired
protected ApplicationContext context;
private Properties properties;

private static MyPropertiesServ singleInst;

protected MyPropertiesServ () {
    properties = new Properties();
    singleInst= this;
}

@Override
public void afterPropertiesSet() throws Exception {
    properties.load(context.getResource("classpath:file.properties").getInputStream());
}

public static String getStringProperty(String key) {
    return singleInst.properties.getProperty(key);
}

}

Another example: http://forum.spring.io/forum/spring-projects/container/35703-initialising-static-property-of-class-through-injection-on-startup

相关问答

更多

相关文章

更多

最新问答

更多
  • python的访问器方法有哪些
  • 使用Zend Framework 2中的JOIN sql检索数据(Retrieve data using JOIN sql in Zend Framework 2)
  • 透明度错误IE11(Transparency bug IE11)
  • linux的基本操作命令。。。
  • 响应navi重叠h1和nav上的h1链接不起作用(Responsive navi overlaps h1 and navi links on h1 isn't working)
  • 在C中读取文件:“r”和“a +”标志的不同行为(Reading a File in C: different behavior for “r” and “a+” flags)
  • NFC提供什么样的带宽?(What Kind of Bandwidth does NFC Provide?)
  • 元素上的盒子阴影行为(box-shadow behaviour on elements)
  • Laravel检查是否存在记录(Laravel Checking If a Record Exists)
  • 设置base64图像的大小javascript - angularjs(set size of a base64 image javascript - angularjs)
  • 想学Linux 运维 深圳有哪个培训机构好一点
  • 为什么有时不需要在lambda中捕获一个常量变量?(Why is a const variable sometimes not required to be captured in a lambda?)
  • 在Framework 3.5中使用服务器标签<%=%>设置Visible属性(Set Visible property with server tag <%= %> in Framework 3.5)
  • AdoNetAppender中的log4net连接类型无效(log4net connection type invalid in AdoNetAppender)
  • 错误:发送后无法设置标题。(Error: Can't set headers after they are sent. authentication system)
  • 等待EC2实例重启(Wait for an EC2 instance to reboot)
  • 如何在红宝石中使用正则表达式?(How to do this in regex in ruby?)
  • 使用鼠标在OpenGL GLUT中绘制多边形(Draw a polygon in OpenGL GLUT with mouse)
  • 江民杀毒软件的KSysnon.sys模块是什么东西?
  • 处理器在传递到add_xpath()或add_value()时调用了什么顺序?(What order are processors called when passed into add_xpath() or add_value()?)
  • sp_updatestats是否导致SQL Server 2005中无法访问表?(Does sp_updatestats cause tables to be inaccessible in SQL Server 2005?)
  • 如何创建一个可以与持续运行的服务交互的CLI,类似于MySQL的shell?(How to create a CLI that can interact with a continuously running service, similar to MySQL's shell?)
  • AESGCM解密失败的MAC(AESGCM decryption failing with MAC)
  • SQL查询,其中字段不包含$ x(SQL Query Where Field DOES NOT Contain $x)
  • PerSession与PerCall(PerSession vs. PerCall)
  • C#:有两个构造函数的对象:如何限制哪些属性设置在一起?(C#: Object having two constructors: how to limit which properties are set together?)
  • 平衡一个精灵(Balancing a sprite)
  • n2cms Asp.net在“文件”菜单上给出错误(文件管理器)(n2cms Asp.net give error on Files menu (File Manager))
  • Zurb Foundation 4 - 嵌套网格对齐问题(Zurb Foundation 4 - Nested grid alignment issues)
  • 湖北京山哪里有修平板计算机的