Redis特殊类型数据结构Bitmap、HyperLogLog、GEO的使用及场景分析

> setbit sign 5 1
0
> setbit sign 3 1
0
> getbit sign 0
0
> getbit sign 3
1
> bitcount sign 0 5
2
> bitpos sign 1 0 5
3
> getbit sign 3
1
> setbit sign1 3 1
0
> setbit sign1 4 1
0
> bitop and sign2 sign sign1
1
> getbit sign2 3
1
> getbit sign2 4
0
> getbit sign2 5
0
> bitop or sign3 sign sign1
1
> getbit sign3 4
1

> pfadd chars a b c d e
1
> pfadd chars f g
1
> pfcount chars
7
> pfadd nums 1 2 3
1
> pfcount chars nums
10
> pfmerge destination chars nums
ok
> pfcount destination
10

> geoadd location 116.33 39.89 user1 116.34 39.90 user2 116.35 39.88 user3 119.35 41.22 user4
3
> geopos location user1
116.3299986720085144
39.89000061669732844
> geodist location user1 user2 km
1.4018
> geodist location user1 user4 km
294.9606
> georadius location 116.33 39.87 3 km
user3
user1
> georadius location 116.33 39.87 5 km
user3
user1
user2
> georadiusbymember location user1 3 km
user3
user1
user2
> georadiusbymember location user1 2 km
user1
user2

package com.eckey.lab.service.util;
import com.alibaba.fastjson.json;
import org.slf4j.logger;
import org.slf4j.loggerfactory;
import org.springframework.data.redis.connection.redisconnection;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.data.redis.core.zsetoperations;
import org.springframework.data.redis.core.types.redisclientinfo;
import org.springframework.stereotype.component;
import javax.annotation.resource;
import java.nio.charset.standardcharsets;
import java.security.messagedigest;
import java.security.nosuchalgorithmexception;
import java.util.*;
import java.util.concurrent.concurrenthashmap;
import java.util.concurrent.timeunit;
@component
public class redisutil {
    private static final logger log = loggerfactory.getlogger(redisutil.class);
    @resource
    private redistemplate<string, object> redistemplate;
    @resource(name = "strredistemplate")
    private redistemplate<string, string> stringredistemplate;
	 /**
	     * 创建布隆过滤器
	     *
	     * @param size          位数组大小
	     * @param hashfunctions 哈希函数数量
	     * @param value         元素值
	     */
    private list<long> gethashpositions(string value, int hashfunctions, int size) {
        list<long> positions = new arraylist<>(hashfunctions);
        try {
            messagedigest md = messagedigest.getinstance("md5");
            byte[] bytes = md.digest(value.getbytes(standardcharsets.utf_8));
            // 使用同一个md5值生成多个哈希位置
            for (int i = 0; i < hashfunctions; i++) {
                long hashvalue = 0;
                for (int j = i * 4; j < i * 4 + 4; j++) {
                    hashvalue <<= 8;
                    int index = j % bytes.length;
                    hashvalue |= (bytes[index] & 0xff);
                }
                positions.add(math.abs(hashvalue % size));
            }
        } catch (nosuchalgorithmexception e) {
            throw new runtimeexception("md5 algorithm not found", e);
        }
        return positions;
    }
    public void bloomfilteradd(string key, string value, int hashfunctions, int size) {
        for (long position : gethashpositions(value, hashfunctions, size)) {
            stringredistemplate.opsforvalue().setbit(key, position, true);
        }
    }
    public boolean bloomfiltercontains(string key, string value, int hashfunctions, int size) {
        for (long position : gethashpositions(value, hashfunctions, size)) {
            if (boolean.false.equals(stringredistemplate.opsforvalue().getbit(key, position))) {
                return false;
            }
        }
        return true;
    }
    public void hyperadd(string key, string value) {
        stringredistemplate.opsforhyperloglog().add(key, value);
    }
    public void hyperadd(string key, string... values) {
        stringredistemplate.opsforhyperloglog().add(key, values);
    }
    public long hypersize(string key) {
        return stringredistemplate.opsforhyperloglog().size(key);
    }
    public void hyperdel(string key) {
        stringredistemplate.opsforhyperloglog().delete(key);
    }
    public long hyperunion(string destkey, string srckey1, string srckey2) {
        return stringredistemplate.opsforhyperloglog().union(destkey, srckey1, srckey2);
    }
    public long hyperunion(string destkey, string... srckeys) {
        return stringredistemplate.opsforhyperloglog().union(destkey, srckeys);
    }
  public long geoadd(string key, double lat, double lon, string member) {
        return stringredistemplate.opsforgeo().add(key, new point(lat, lon), member);
    }
    public list<point> geoget(string key, string member) {
        return stringredistemplate.opsforgeo().position(key, member);
    }
    public distance geodistance(string key, string member1, string member2, metric metric) {
        return stringredistemplate.opsforgeo().distance(key, member1, member2, metric);
    }
    public georesults<redisgeocommands.geolocation<string>> georadius(string key, double longitude, double latitude, double radius, redisgeocommands.distanceunit unit) {
        point point = new point(longitude, latitude);
        circle circle = new circle(point, new distance(radius, unit));
        redisgeocommands.georadiuscommandargs args = redisgeocommands.georadiuscommandargs.newgeoradiusargs().includedistance().includecoordinates().sortascending();
        return stringredistemplate.opsforgeo().radius(key, circle, args);
    }
    public georesults<redisgeocommands.geolocation<string>> geonearbymember(string key, string member, double radius, redisgeocommands.distanceunit unit) {
        redisgeocommands.georadiuscommandargs args = redisgeocommands.georadiuscommandargs.newgeoradiusargs().includedistance().includecoordinates().sortascending();
        return stringredistemplate.opsforgeo().radius(key, member, new distance(radius, unit), args);
    }
}