【分布式】Redis分布式之Set
使用package com.demo.redis.set;import org.redisson.api.RSet;import org.redisson.api.RedissonClient;import org.redisson.client.codec.StringCodec;import org.springframework.stereotype.Component;import org
·
说明
配置文件参考:https://blog.csdn.net/qq_38428623/article/details/123217001?utm_source=app&app_version=5.1.1&code=app_1562916241&uLinkId=usr1mkqgl919blen
使用
package com.demo.redis.set;
import org.redisson.api.RSet;
import org.redisson.api.RedissonClient;
import org.redisson.client.codec.StringCodec;
import org.springframework.stereotype.Component;
import org.springframework.util.Assert;
import javax.annotation.Resource;
import java.util.List;
import java.util.Set;
/**
* RedisSet
*
* @author 王思勤
*/
@Component
public class RedisSet {
@Resource
private RedissonClient redissonClient;
/**
* 获取 字符串 的 RSet
*
* @param name 名称
* @return 返回 值
*/
public RSet<String> getSet(String name) {
RSet<String> rSet = redissonClient.getSet(name, StringCodec.INSTANCE);
Assert.notNull(rSet, "rSet is null");
return rSet;
}
/**
* 新增 set 数据
*
* @param name 名称
* @param value 值
* @return 返回 是否新增成功
*/
public boolean set(String name, String value) {
return this.getSet(name).add(value);
}
/**
* 新增 set 数据
*
* @param name 名称
* @param values 值
* @return 返回 是否新增成功
*/
public boolean set(String name, List<String> values) {
return this.getSet(name).addAll(values);
}
/**
* 读取 set 的数据
*
* @param name 名称
* @return 返回 是否新增成功
*/
public Set<String> readAll(String name) {
return this.getSet(name).readAll();
}
/**
* 验证 是否包含
*
* @param name 名称
* @param value 值
* @return 返回 是否 包含
*/
public boolean contains(String name, String value) {
return this.getSet(name).contains(value);
}
/**
* 验证 是否包含
*
* @param name 名称
* @param values 值
* @return 返回 是否 包含
*/
public boolean containsAll(String name, List<String> values) {
return this.getSet(name).containsAll(values);
}
}
更多推荐
所有评论(0)