封装布隆过滤器
<T> RBloomFilter<T> createBloomFilter(String filterName, Long expectedInsertions, Double falsePositiveRate);
@Override
public <T> RBloomFilter<T> createBloomFilter(String filterName, Long expectedInsertions, Double falsePositiveRate) {
RBloomFilter<T> bloomFilter = redissonClient.getBloomFilter(filterName);
bloomFilter.tryInit(expectedInsertions, falsePositiveRate);
return bloomFilter;
}
使用示例
@Resource
private RedissonService redissonService;
public void someMethod() {
RBloomFilter<String> bloomFilter = redissonService.create("myBloomFilter", 10000, 0.03);
bloomFilter.add("test");
boolean result = bloomFilter.contains("test");
System.out.println("Does 'test' exist? " + result);
}