首页 \ 问答 \ 带有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

相关问答

更多

相关文章

更多

最新问答

更多
  • 如何在Laravel 5.2中使用paginate与关系?(How to use paginate with relationships in Laravel 5.2?)
  • linux的常用命令干什么用的
  • 由于有四个新控制器,Auth刀片是否有任何变化?(Are there any changes in Auth blades due to four new controllers?)
  • 如何交换返回集中的行?(How to swap rows in a return set?)
  • 在ios 7中的UITableView部分周围绘制边界线(draw borderline around UITableView section in ios 7)
  • 使用Boost.Spirit Qi和Lex时的空白队长(Whitespace skipper when using Boost.Spirit Qi and Lex)
  • Java中的不可变类(Immutable class in Java)
  • WordPress发布查询(WordPress post query)
  • 如何在关系数据库中存储与IPv6兼容的地址(How to store IPv6-compatible address in a relational database)
  • 是否可以检查对象值的条件并返回密钥?(Is it possible to check the condition of a value of an object and JUST return the key?)
  • GEP分段错误LLVM C ++ API(GEP segmentation fault LLVM C++ API)
  • 绑定属性设置器未被调用(Bound Property Setter not getting Called)
  • linux ubuntu14.04版没有那个文件或目录
  • 如何使用JSF EL表达式在param中迭代变量(How to iterate over variable in param using JSF EL expression)
  • 是否有可能在WPF中的一个单独的进程中隔离一些控件?(Is it possible to isolate some controls in a separate process in WPF?)
  • 使用Python 2.7的MSI安装的默认安装目录是什么?(What is the default installation directory with an MSI install of Python 2.7?)
  • 寻求多次出现的表达式(Seeking for more than one occurrence of an expression)
  • ckeditor config.protectedSource不适用于editor.insertHtml上的html元素属性(ckeditor config.protectedSource dont work for html element attributes on editor.insertHtml)
  • linux只知道文件名,不知道在哪个目录,怎么找到文件所在目录
  • Actionscript:检查字符串是否包含域或子域(Actionscript: check if string contains domain or subdomain)
  • 将CouchDB与AJAX一起使用是否安全?(Is it safe to use CouchDB with AJAX?)
  • 懒惰地初始化AutoMapper(Lazily initializing AutoMapper)
  • 使用hasclass为多个div与一个按钮问题(using hasclass for multiple divs with one button Problems)
  • Windows Phone 7:检查资源是否存在(Windows Phone 7: Check If Resource Exists)
  • 无法在新线程中从FREContext调用getActivity()?(Can't call getActivity() from FREContext in a new thread?)
  • 在Alpine上升级到postgres96(/ usr / bin / pg_dump:没有这样的文件或目录)(Upgrade to postgres96 on Alpine (/usr/bin/pg_dump: No such file or directory))
  • 如何按部门显示报告(How to display a report by Department wise)
  • Facebook墙贴在需要访问令牌密钥后无法正常工作(Facebook wall post not working after access token key required)
  • Javascript - 如何在不擦除输入的情况下更改标签的innerText(Javascript - how to change innerText of label while not wiping out the input)
  • WooCommerce / WordPress - 不显示具有特定标题的产品(WooCommerce/WordPress - Products with specific titles are not displayed)