Skip to content

home

Jump to bottom
DarkIdiot edited this page Jun 29, 2017 · 5 revisions

Redis Cache

Tips：

 required: JDK1.5+

Overview

RedisCache是基于Jedis的SDK。

  • ①强大的泛型支持，实现了任意java对象简单存\取
  • ②增强缓存接口：支持防穿透设计，以及本地缓存同步更新
  • ③提供多种分布式锁，分布式队列支持
  • ④个性化的redis源配置支持

Usage:

RedisCache

Normal Style

    IRedisMap<Integer, User> cache = Redis.use("redisSourceName");
    User user = new User();
    cache.put(1001,user);
    User redisUser = cache.get(1001);

Fluent Style

    IRedisMap<Integer, User> cache = Redis.create().setServiceName("redisSourceName").build();
    User user = new User();
    cache.put(1001,user);
    User redisUser = cache.get(1001);

RedisLock

Normal Style

    Lock lock = RedisLock.useSimpleRedisLock("simpleLock", "redisSourceName");
    try {
        lock.lock();
        lock.isLocking();
    } finally {
        lock.unlock();
    }

Fluent Style

    Lock lock = RedisLock.create().setService("redisSourceName").setLockName("simpleLock").useSimpleRedisLock();
    try {
        lock.lock();
        lock.isLocking();
    } finally {
        lock.unlock();
    }

RedisQueue

Normal Style

    Queue<Task> queue = RedisQueue.useSimpleFifoQueue("simpleQueue","redisSourceName");
    queue.enqueue(task1,task2,task3);
    Task task = queue.dequeue();

Fluent Style

    Queue<Task> queue = RedisQueue.create().setService("redisSourceName").setQueueName("simpleQueue").useSimpleFifoQueue();
    queue.enqueue(task1,task2,task3);
    Task task = queue.dequeue();

Clone this wiki locally