本文整理汇总了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
示例14: get
import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public final Object get(final String key) {
RBucket<Object> temp = getRedisBucket(key);
return temp.get();
}
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:6,代码来源:RedissonHelper.java
示例15: getFire
import org.redisson.api.RBucket; //导入依赖的package包/类
public Object getFire(String key) {
RBucket<Object> temp = getRedisBucket(key);
expire(temp, EXPIRE);
return temp.get();
}
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:6,代码来源:RedissonHelper.java
示例16: set
import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public final void set(final String key, final Serializable value) {
RBucket<Object> temp = getRedisBucket(key);
temp.set(value);
expire(temp, EXPIRE);
}
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:7,代码来源:RedissonHelper.java
示例17: exists
import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public final Boolean exists(final String key) {
RBucket<Object> temp = getRedisBucket(key);
return temp.isExists();
}
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:6,代码来源:RedissonHelper.java
示例18: ttl
import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public final Long ttl(final String key) {
RBucket<Object> rBucket = getRedisBucket(key);
return rBucket.remainTimeToLive();
}
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:6,代码来源:RedissonHelper.java
示例19: getSet
import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public final Object getSet(final String key, final Serializable value) {
RBucket<Object> rBucket = getRedisBucket(key);
return rBucket.getAndSet(value);
}
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:6,代码来源:RedissonHelper.java
示例20: expire
import org.redisson.api.RBucket; //导入依赖的package包/类
@Override
public Boolean expire(String key, int seconds) {
RBucket<Object> bucket = getRedisBucket(key);
expire(bucket, seconds);
return true;
}
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:7,代码来源:RedissonHelper.java
注:本文中的org.redisson.api.RBucket类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论