架設在redis基礎上的java駐內存 數(shù)據(jù)網(wǎng)格(In-Memory Data Grid),基于NIO的Netty框架上,利用了redis鍵值數(shù)據(jù)庫

<dependency>
      <groupId>org.redisson</groupId>
      <artifactId>redisson</artifactId>
      <version>2.9.0</version>
    </dependency>
  <dependency>
      <groupId>com.fasterxml.jackson.dataformat</groupId>
      <artifactId>jackson-dataformat-avro</artifactId>
      <version>2.9.0</version>
    </dependency>

import com.mmall.util.PropertiesUtil;
import lombok.extern.slf4j.Slf4j;
import org.redisson.Redisson;
import org.redisson.config.Config;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

/**
 * Created by geely
 */
@Component
@Slf4j
public class RedissonManager {

    private Config config = new Config();

    private Redisson redisson = null;

    public Redisson getRedisson() {
        return redisson;
    }

    private static String redis1Ip = PropertiesUtil.getProperty("redis1.ip");
    private static Integer redis1Port = Integer.parseInt(PropertiesUtil.getProperty("redis1.port"));
    //不支持分片
    //private static String redis2Ip = PropertiesUtil.getProperty("redis2.ip");
    //private static Integer redis2Port = Integer.parseInt(PropertiesUtil.getProperty("redis2.port"));

    @PostConstruct
    private void init(){
        try {
            config.useSingleServer().setAddress(redis1Ip + ":" + redis1Port);

            redisson = (Redisson) Redisson.create(config);

            log.info("初始化Redisson結束");
        } catch (Exception e) {
            log.error("redisson init error",e);
        }
    }



}

使用Redison鎖的例子

    @Autowired
    private RedissonManager redissonManager;
 RLock lock = redissonManager.getRedisson().getLock(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);