Java RBucket类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.redisson.api.RBucket类的典型用法代码示例。如果您正苦于以下问题：Java RBucket类的具体用法？Java RBucket怎么用？Java RBucket使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

RBucket类属于org.redisson.api包，在下文中一共展示了RBucket类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: findList

import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public List<T> findList(String key, boolean unlock) throws LockingException {
  if (!containerIsLockedByCurrentThread()) {
    lockContainer();
  }
  RKeys keys = redissonClient.getKeys();
  Iterable<String> matches = keys.getKeysByPattern(createAllInstancesKey(key));
  List<T> allContents = new ArrayList<>();
  for (String match : matches) {
    RBucket<List<T>> bucket = redissonClient.getBucket(match);
    if (bucket != null) {
      List<T> bucketContents = bucket.get();
      if (bucketContents != null) {
        allContents.addAll(bucketContents);
      }
    }
  }
  if (unlock) {
    unlockContainer();
  }
  return allContents;
}

开发者ID:ONSdigital，项目名称:rm-common-service，代码行数:23，代码来源:DistributedListManagerRedissonImpl.java

示例2: doWrite

import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
protected boolean doWrite(CaValue<K, V> val) {
    RBucket<V> bucket = redisson.getBucket(val.key().toString());
    V v = val.value();
    if (v == null) {
        bucket.delete();
    } else {
        long ttl = val.ttl();
        if (ttl > 0) {
            bucket.set(v, ttl, TimeUnit.MILLISECONDS);
        } else {
            bucket.set(v);
        }
    }
    return true;
}

开发者ID:dzh，项目名称:coca，代码行数:17，代码来源:CaRedis.java

示例3: testBucket

import org.redisson.api.RBucket; //导入依赖的package包/类
@Test
public void testBucket() throws Exception {
    RBucket<String> bucket = redis.getBucket("str", new StringCodec("utf-8"));
    bucket.set("x", 6, TimeUnit.SECONDS);
    LOG.info("get {}", bucket.get());
    Thread.sleep(4000);
    LOG.info("get {} after {}s", bucket.get(), 4);
    Thread.sleep(2000);
    LOG.info("get {} after {}s", bucket.get(), 6);
    bucket.delete();

    RBucket<TestClazz> bucket1 = redis.getBucket("clazz");
    bucket1.set(new TestClazz("c", 3));
    LOG.info("get {}", bucket1.get());
    bucket1.delete();
}

开发者ID:dzh，项目名称:coca，代码行数:17，代码来源:TestRedisson.java

示例4: main

import org.redisson.api.RBucket; //导入依赖的package包/类
public static void main(String[] args) {
    RedissonClient redisson = Redisson.create();
    
    RBucket<String> bucket = redisson.getBucket("test");
    bucket.set("123");
    boolean isUpdated = bucket.compareAndSet("123", "4934");
    String prevObject = bucket.getAndSet("321");
    boolean isSet = bucket.trySet("901");
    long objectSize = bucket.size();
    
    // set with expiration
    bucket.set("value", 10, TimeUnit.SECONDS);
    boolean isNewSet = bucket.trySet("nextValue", 10, TimeUnit.SECONDS);
    
    redisson.shutdown();
}

开发者ID:redisson，项目名称:redisson-examples，代码行数:17，代码来源:BucketExamples.java

示例5: main

import org.redisson.api.RBucket; //导入依赖的package包/类
public static void main(String[] args) {
    // connects to 127.0.0.1:6379 by default
    RedissonClient redisson = Redisson.create();
    
    RBucket<String> bucket = redisson.getBucket("test");
    bucket.set("123");
    boolean isUpdated = bucket.compareAndSet("123", "4934");
    String prevObject = bucket.getAndSet("321");
    boolean isSet = bucket.trySet("901");
    long objectSize = bucket.size();
    
    // set with expiration
    bucket.set("value", 10, TimeUnit.SECONDS);
    boolean isNewSet = bucket.trySet("nextValue", 10, TimeUnit.SECONDS);
    
    redisson.shutdown();
}

开发者ID:redisson，项目名称:redisson-examples，代码行数:18，代码来源:BucketExamples.java

示例6: getAll

import org.redisson.api.RBucket; //导入依赖的package包/类
public Set<Object> getAll(String pattern, Integer expire) {
    Set<Object> set = InstanceUtil.newHashSet();
    Iterable<String> keys = redissonClient.getKeys().getKeysByPattern(pattern);
    for (Iterator<String> iterator = keys.iterator(); iterator.hasNext();) {
        String key = iterator.next();
        RBucket<Object> bucket = getRedisBucket(key);
        expire(bucket, expire);
        set.add(bucket.get());
    }
    return set;
}

开发者ID:iBase4J，项目名称:iBase4J-Common，代码行数:12，代码来源:RedissonHelper.java

示例7: home

import org.redisson.api.RBucket; //导入依赖的package包/类
/**
 * Home string.
 *
 * @param model the model
 * @return the string
 */
@RequestMapping("/sitemap.xml")
@ResponseBody
public String home(final Model model) {
    final RBucket<String> bucket = redissonClient.getBucket("SiteMapCache");

    if (bucket.get() == null || bucket.get().isEmpty()) {
        bucket.set(sitemapGenerator.generate());
    }

    return bucket.get();
}

开发者ID:mhaddon，项目名称:Sound.je，代码行数:18，代码来源:SitemapController.java

示例8: main

import org.redisson.api.RBucket; //导入依赖的package包/类
public static void main(String[] args) throws InterruptedException {
    Bench<RedissonClient> bench = new RedissonBench() {
        @Override
        public void executeOperation(String data, RedissonClient benchInstance, int threadNumber, int iteration,
                MetricRegistry metrics) {
            RBucket<String> bucket = benchInstance.getBucket("bucket_" + threadNumber + "_" + iteration);
            Timer.Context time = metrics.timer("bucket").time();
            bucket.set(data);
            time.stop();
        }
    };
    
    Benchmark benchmark = new Benchmark(bench);
    benchmark.run(args);
}

开发者ID:redisson，项目名称:redisson-benchmark，代码行数:16，代码来源:BucketSetBenchmark.java

示例9: main

import org.redisson.api.RBucket; //导入依赖的package包/类
public static void main(String[] args) throws InterruptedException {
    Bench<RedissonClient> bench = new RedissonBench() {
        @Override
        public void executeOperation(String data, RedissonClient benchInstance, int threadNumber, int iteration,
                MetricRegistry metrics) {
            RBucket<Object> bucket = benchInstance.getBucket("bucket_" + threadNumber + "_" + iteration);
            Timer.Context time = metrics.timer("bucket").time();
            bucket.set(value);
            time.stop();
        }
    };
    
    Benchmark benchmark = new Benchmark(bench);
    benchmark.run(args);
}

开发者ID:redisson，项目名称:redisson-benchmark，代码行数:16，代码来源:BinaryBenchmark.java

示例10: saveList

import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public void saveList(String key, List<T> list, boolean unlock) throws LockingException {
  if (!containerIsLockedByCurrentThread()) {
    String msg = String.format("DistributedList lock must be held by current thread before saving");
    throw new LockingException(msg);
  }
  RBucket<List<T>> bucket = redissonClient.getBucket(createKey(key));
  bucket.set(list, timeToLive, TimeUnit.SECONDS);
  if (unlock) {
    unlockContainer();
  }
}

开发者ID:ONSdigital，项目名称:rm-common-service，代码行数:13，代码来源:DistributedListManagerRedissonImpl.java

示例11: deleteList

import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public void deleteList(String key, boolean unlock) throws LockingException {
  if (!containerIsLockedByCurrentThread()) {
    lockContainer();
  }
  RBucket<List<T>> bucket = redissonClient.getBucket(createKey(key));
  bucket.delete();
  if (unlock) {
    unlockContainer();
  }
}

开发者ID:ONSdigital，项目名称:rm-common-service，代码行数:12，代码来源:DistributedListManagerRedissonImpl.java

示例12: test1k

import org.redisson.api.RBucket; //导入依赖的package包/类
@Test
public void test1k() {
    long s0 = System.currentTimeMillis();
    for (int i = 0; i < 10000000; i++) {
        RBucket<String> bucket = redis.getBucket("test1k" + i, new StringCodec("utf-8"));
        bucket.set(String.valueOf(System.nanoTime()), 1, TimeUnit.HOURS);
    }
    long s1 = System.currentTimeMillis();
    LOG.info("cost {}ms", s1 - s0);
}

开发者ID:dzh，项目名称:coca，代码行数:11，代码来源:TestRedisson.java

示例13: getRedisBucket

import org.redisson.api.RBucket; //导入依赖的package包/类
private RBucket<Object> getRedisBucket(String key) {
    return redissonClient.getBucket(key);
}

开发者ID:iBase4J，项目名称:iBase4J-Common，代码行数:4，代码来源:RedissonHelper.java