redis使用场景和java测试案例 - 好文

redis数据结构和使用场景

* strings
* lists
* sets
* sort sets
* hashes
strings

* token
* session
* validateCode
* 分布锁
*
lists

* 最近联系人
*
sets

* 优惠卷
* 激活码
* 用户标签
*
sort sets

* 排行榜
*
hashes

* 购物车
*
bitmaps

* 用户签到
* 在线状态
*
hyperloglog

* ip去重复统计
*
geo

* 附近的人
* 摇一摇
* 两位距离
*
主要使用场景对应的java源码
/** * 代金卷例子. * set结构保证了value的唯一性. */ @Test public void setCoupon() { final
String COUPON_KEY = "coupon"; for (int i = 0; i < 100; i++) {
redisTemplate.opsForSet().add(COUPON_KEY, String.format("abc%s", i));
redisTemplate.opsForSet().add(COUPON_KEY, String.format("abc%s", i)); }
Assert.assertEquals(Long.valueOf(100),
redisTemplate.opsForSet().size(COUPON_KEY));
redisTemplate.opsForSet().pop(COUPON_KEY);
Assert.assertEquals(Long.valueOf(99),
redisTemplate.opsForSet().size(COUPON_KEY)); } /** * 用户消费top10. *
sortList结构做实时排名. */ @Test public void sortListTop() { final String
CONSUMPTION_KEY = "consumption";
redisTemplate.opsForZSet().add(CONSUMPTION_KEY, "person1", 1);
redisTemplate.opsForZSet().add(CONSUMPTION_KEY, "person2", 2);
redisTemplate.opsForZSet().add(CONSUMPTION_KEY, "person3", 1); for (Object o :
redisTemplate.opsForZSet().rangeByScore(CONSUMPTION_KEY, 1, 1)) {
System.out.println(o); } } @Test public void distributeLock2() { new Thread(()
-> { for (int i = 0; i < 5; i++) { queue2(); } }).start(); } /** * 地理位置测试. */
@Test public void geoTest() { BoundGeoOperations boundGeoOperations =
redisTemplate.boundGeoOps("CHINA:CITY"); Point nanjing = new Point(118.803805,
32.060168); boundGeoOperations.add(nanjing, "南京市"); Point beijing = new
Point(116.397039, 39.9077); boundGeoOperations.add(beijing, "北京市"); Point
shanghai = new Point(120.52, 30.40); boundGeoOperations.add(shanghai, "上海市");
//geodist：获取两个地理位置的距离 Distance distance = boundGeoOperations.distance("南京市",
"北京市", Metrics.KILOMETERS); System.out.println("南京市到北京市之间的距离是：" +
distance.getValue() + "km"); Distance distance2 =
boundGeoOperations.distance("南京市", "上海市", Metrics.KILOMETERS);
System.out.println("南京市到上海市之间的距离是：" + distance2.getValue() + "km");
//geohash：获取某个地理位置的geohash值 List<String> list = boundGeoOperations.hash("南京市");
System.out.println("南京市的geoHash = " + list.get(0)); //geopos：获取某个地理位置的坐标
List<Point> pointList = boundGeoOperations.position("南京市");
System.out.println("南京市的经纬度为 = " + pointList.get(0));
//georadius：根据给定地理位置坐标获取指定范围内的地理位置集合 //查询南京市1000KM范围内的城市 Circle within = new
Circle(nanjing, 1000000); //设置geo查询参数 RedisGeoCommands.GeoRadiusCommandArgs
geoRadiusArgs = RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs();
//查询返回结果包括距离和坐标 geoRadiusArgs =
geoRadiusArgs.includeCoordinates().includeDistance(); //按查询出的坐标距离中心坐标的距离进行排序
geoRadiusArgs.sortAscending(); //限制查询返回的数量 geoRadiusArgs.limit(2);
GeoResults<RedisGeoCommands.GeoLocation<String>> geoResults =
boundGeoOperations.radius(within, geoRadiusArgs);
List<GeoResult<RedisGeoCommands.GeoLocation<String>>> geoResultList =
geoResults.getContent(); for (GeoResult geoResult : geoResultList) {
System.out.println("geoRadius " + geoResult.getContent()); }
//georadiusbymember：根据给定地理位置获取指定范围内的地理位置集合 geoRadiusArgs.limit(1); geoResults =
boundGeoOperations.radius("南京市", new Distance(1000000), geoRadiusArgs);
geoResultList = geoResults.getContent(); for (GeoResult geoResult :
geoResultList) { System.out.println("geoRadiusByMember " +
geoResult.getContent()); } //删除位置信息,此命令不是geo提供的，是使用zrem命令删除的
boundGeoOperations.remove("南京市"); } /** * 查看用户在线状态情况 1在线，0离线. */ @Test public
void bitmapTest() { final String onlineKey = "online:"; for (int i = 0; i <
100; i++) { redisTemplate.opsForValue().setBit(onlineKey, i, i % 2 == 0); } for
(int i = 0; i < 10; i++) { System.out.println(i + "=" +
redisTemplate.opsForValue().getBit(onlineKey, i)); }
System.out.println("online:" + redisConfig.bitCount(onlineKey)); } /** *
统一数组里数据唯一性. * IP地址去重复. */ @Test public void hyperLogLogTest() { final String
loglogKey = "loglog:"; String[] arr = new String[100]; for (int i = 0; i < 100;
i++) { arr[i] = "A" + new Random().nextInt(10) + 1; }
redisTemplate.opsForHyperLogLog().add(loglogKey, arr);
System.out.println("loglog:" +
redisTemplate.opsForHyperLogLog().size(loglogKey)); }

热门工具换一换