This is a simple distributed tools based on Redis.
Visit this website for more information.
- Fixed #9.
- Optimization RedisCluster.
- Upgrade distributed lock API.
- Support connection pool.
- Improve distributed lock performance β‘.
- Upgrade API.
- Add Anation.
- Improve performance β‘ .
Mail: crossoverJie@gmail.com
- High performance.
- No deadlock.
- Support Redis cluster, single.
- Non-blocking lock.
- blocking lock.
- Support connection pool.
- Suppport Spring4.x+.
maven dependency:
<dependency> <groupId>top.crossoverjie.opensource</groupId> <artifactId>distributed-redis-tool</artifactId> <version>1.0.4</version> </dependency>Set bean:
@Configuration public class RedisLockConfig { private Logger logger = LoggerFactory.getLogger(RedisLockConfig.class); @Autowired private JedisConnectionFactory jedisConnectionFactory; @Bean public RedisLock build() { RedisLock redisLock = new RedisLock.Builder(jedisConnectionFactory,RedisToolsConstant.SINGLE) .lockPrefix("lock_") .sleepTime(100) .build(); return redisLock; } } @Autowired private RedisLock redisLock ; public void use() { String key = "key"; String request = UUID.randomUUID().toString(); try { boolean locktest = redisLock.tryLock(key, request); if (!locktest) { System.out.println("locked error"); return; } //do something } finally { redisLock.unlock(key,request) ; } }redisLock.lock(String key, String request);redisLock.lock(String key, String request,int blockTime);- High performance.
- native API.
- Annation API.
- Support Redis cluster, single.
- Suppport Spring4.x+
maven dependency:
<dependency> <groupId>top.crossoverjie.opensource</groupId> <artifactId>distributed-redis-tool</artifactId> <version>1.0.4</version> </dependency>- Set bean:
@Configuration public class RedisLimitConfig { private Logger logger = LoggerFactory.getLogger(RedisLimitConfig.class); @Value("${redis.limit}") private int limit; @Autowired private JedisConnectionFactory jedisConnectionFactory; @Bean public RedisLimit build() { RedisLimit redisLimit = new RedisLimit.Builder(jedisConnectionFactory, RedisToolsConstant.SINGLE) .limit(limit) .build(); return redisLimit; } }- Scan packages.
@ComponentScan(value = "com.crossoverjie.distributed.intercept") # RedisLimitConfig's package @ComponentScan(value = "xx.xxx.config") boolean limit = redisLimit.limit(); if (!limit){ res.setCode(StatusEnum.REQUEST_LIMIT.getCode()); res.setMessage(StatusEnum.REQUEST_LIMIT.getMessage()); return res ; }Other apis:
@CommonLimit @RequestMapping("/xx") public void anyMethod(){}If you are using native Spring:
@SpringControllerLimit(errorCode = 200,errorMsg = "request has limited") @RequestMapping("/createOptimisticLimitOrderByRedis/{sid}") @ResponseBody public String createOptimisticLimitOrderByRedis(@PathVariable int sid) { logger.info("sid=[{}]", sid); int id = 0; try { id = orderService.createOptimisticOrderUseRedis(sid); } catch (Exception e) { logger.error("Exception",e); } return String.valueOf(id); }Spring xml:
<mvc:interceptors> <mvc:interceptor> <mvc:mapping path="/**"/> <bean class="com.crossoverjie.distributed.intercept.SpringMVCIntercept"/> </mvc:interceptor> </mvc:interceptors>It can be used for any methods.