| | |
| | |
|
| | | import redis.clients.jedis.Jedis;
|
| | | import redis.clients.jedis.JedisPool;
|
| | | import redis.clients.jedis.params.SetParams;
|
| | |
|
| | | @Component
|
| | | public class AtomMethodCallManager {
|
| | |
| | | String redisKey = "atom-" + StringUtil.Md5(key);
|
| | | Jedis jedis = jedisPool.getResource();
|
| | | try {
|
| | | if (jedis.setnx(redisKey, "1") <= 0) {
|
| | | if (StringUtil.isNullOrEmpty(jedis.set(redisKey, "1", new SetParams().nx().ex(60)))) {
|
| | | System.out.println("请稍后再试");
|
| | | return;
|
| | | }
|
| | | jedis.expire(redisKey, 60);
|
| | | call.excute();
|
| | | } finally {
|
| | | jedis.del(redisKey);
|
| | | jedisPool.returnResource(jedis);
|
| | | jedis.close();
|
| | | }
|
| | | }
|
| | |
|