Redis —— SpringBoot工程下的GeoHash工具类

一、依赖引入

        <!--lombok--><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><!--redis连接依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>

二、工具类代码

@Component
@Slf4j
public class RedisUtil {@Value("${spring.redis.geo.key}")private String GEO_REDIS_KEY;@Resourceprivate RedisTemplate<String, Object> redisTemplate;/*** 指定缓存失效时间*/public boolean expire(String key, long time) {try {if (time > 0) {redisTemplate.expire(key, time, TimeUnit.SECONDS);}return true;} catch (Exception e) {log.error("set expire time error.key:{}.", key, e);return false;}}/*** 根据key 获取过期时间*/public long getExpire(String key) {return redisTemplate.getExpire(key, TimeUnit.SECONDS);}/*** 判断key是否存在*/public boolean hasKey(String key) {try {return redisTemplate.hasKey(key);} catch (Exception e) {log.error("redis hasKey method error.key:{}.", key, e);return false;}}/*** 删除缓存*/public void del(String... key) {if (key != null && key.length > 0) {if (key.length == 1) {redisTemplate.delete(key[0]);} else {redisTemplate.delete(Arrays.asList(key));}}}//------------------------------------GEO----------------------------------------/*** 增加用户位置*/public Long addGeoLocation(String username, double x, double y) {try {RedisGeoCommands.GeoLocation geoLocation = new RedisGeoCommands.GeoLocation(username, new Point(x, y));return redisTemplate.opsForGeo().add(GEO_REDIS_KEY, geoLocation);} catch (Exception exception) {throw new RuntimeException("addGeoLocation error.", exception);}}/*** 删除用户位置,GEO实际上放在ZSET结构的数据,因此可用ZREM删除*/public Long deleteGeoLocation(String username) {try {return redisTemplate.opsForZSet().remove(GEO_REDIS_KEY, username);} catch (Exception exception) {throw new RuntimeException("deleteGeoLocation error.", exception);}}/*** 获取用户位置*/public List<Point> getGeoLocation(String username) {try {return redisTemplate.opsForGeo().position(GEO_REDIS_KEY, username);} catch (Exception e) {throw new RuntimeException("getGetLocation error.", e);}}/*** 计算用户相隔距离*/public Distance getDistance(String usernameOne, String usernameTwo, RedisGeoCommands.DistanceUnit unit) {try {return redisTemplate.opsForGeo().distance(GEO_REDIS_KEY, usernameOne, usernameTwo,unit);} catch (Exception e) {throw new RuntimeException("getDistance error.", e);}}/*** 获取某个用户 附近 n个距离单位m 内的附近z个用户*/public GeoResults<RedisGeoCommands.GeoLocation<Object>> getRadius(String username, int radius, RedisGeoCommands.DistanceUnit unit, int limit) {try {Distance distance = new Distance(radius, unit);RedisGeoCommands.GeoRadiusCommandArgs args =RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs().includeDistance().includeCoordinates().sortAscending().limit(limit);return redisTemplate.opsForGeo().radius(GEO_REDIS_KEY, username, distance, args);} catch (Exception e) {throw new RuntimeException("getDistance error.", e);}}
}

三、使用样例

添加Redis相关yml配置。

# redis配置，以下有默认配置的也可以使用默认配置
spring:redis:host: 127.0.0.1port: 6379password: 123456    # 如果无密码，直接注释掉即可timeout: 1000pool:minIdle: 5maxIdle: 10maxWait: -1maxActive: 20geo:key: spring_homeworkapplication:name: position-provider

工具类相关Bean。

// ----------------------UserPosition------------------------------
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;import java.io.Serializable;@Data
@NoArgsConstructor
@AllArgsConstructor
public class UserPosition implements Serializable {private String username;    // 用户名private double longitude;   // 经度private double latitude;    // 纬度
}// -----------------------UserNearby-----------------------------
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.geo.Distance;import java.io.Serializable;@Data
@AllArgsConstructor
@NoArgsConstructor
public class UserNearby implements Serializable {private Distance distance;private UserPosition position;
}

Service层使用RedisUtil。

@Slf4j
public class PositionServiceImpl implements PositionService {@Autowiredprivate RedisUtil redisUtil;@Overridepublic List<UserPosition> getGeoLocation(String username) {log.info("username:{} delete geoLocation.",username);List<Point> points = redisUtil.getGeoLocation(username);List<UserPosition> positions = new ArrayList<>();for (Point point : points) {if (Objects.nonNull(point)) {positions.add(new UserPosition(username,point.getX(),point.getY()));}}return positions;}@Overridepublic Long addGeoLocation(String username, double x, double y) {return redisUtil.addGeoLocation(username, x, y);}@Overridepublic Long deleteGeoLocation(String username) {log.info("username:{} delete geoLocation.",username);return redisUtil.deleteGeoLocation(username);}@Overridepublic Distance getDistance(String usernameOne, String usernameTwo, RedisGeoCommands.DistanceUnit unit) {return redisUtil.getDistance(usernameOne, usernameTwo, unit);}@Overridepublic List<UserNearby> getRadius(String username, int radius, RedisGeoCommands.DistanceUnit unit, int limit) {GeoResults<RedisGeoCommands.GeoLocation<Object>> result = redisUtil.getRadius(username, radius, unit, limit);List<UserNearby> userNearbyList = new ArrayList<>();result.getContent().forEach((one) -> {userNearbyList.add(new UserNearby(one.getDistance(), new UserPosition((String) one.getContent().getName(),one.getContent().getPoint().getX(),one.getContent().getPoint().getY())));});return userNearbyList;}
}

Redis —— SpringBoot工程下的GeoHash工具类相关推荐

Springboot工程下使用mybatis反向工程
Springboot工程下使用mybatis逆向工程 1.引言 mybatis是目前很流行的持久层框架,其逆向工程更是大大缩减了我们的开发时间.所谓mybatis逆向工程,就是mybatis会根据我们 ...
Apache下的ArrayUtils工具类总结
Apache下的ArrayUtils工具类总结 ArrayUtils中的方法: 1.add():将给定的数据添加到指定的数组中,返回一个新的数组. 2.addAll():合并两个数组. 3.conta ...
多线程十 JUC包下的常用工具类
JUC包下的常用工具类 1. CountDownLatch-闭锁 2. CyclicBarrier-循环栅栏 3. Semaphore-信号量 4. Exchanger-线程数据交换器这篇文章主要是 ...
SpringBoot实战：整合Redis、mybatis，封装RedisUtils工具类等（附源码）
创建SpringBoot项目在线创建方式网址:https://start.spring.io/ 然后创建Controller.Mapper.Service包 SpringBoot整合Redis 引 ...
SpringBoot实战：整合Redis、mybatis，封装RedisUtils工具类等
创建SpringBoot项目在线创建方式网址:https://start.spring.io/ 然后创建Controller.Mapper.Service包 SpringBoot整合Redis 引 ...
Spring Boot实战：整合Redis、MyBatis，封装RedisUtils工具类
创建 Spring Boot 项目在线创建方式网址:https://start.spring.io/ 然后创建Controller.Mapper.Service包 SpringBoot整合Redi ...
这些SpringBoot天生自带Buff工具类你都用过哪些？
欢迎关注方志朋的博客,回复"666"获面试宝典来源:https://juejin.cn/post/7043403364020781064 断言断言是一个逻辑判断,用于检查不应该 ...
Springboot+axios+vue使用VerifyCodeUtils工具类实现验证码图片功能
一.环境准备 idea java 1.8 maven 3.6.3 操作系统:window10 vue.min.js axios.min.js 二.VerifyCodeUtils工具类 import j ...
【redis系列】redisTemplate缓存常用工具类
背景日常开发过程中,大家使用redis缓存基本上是家常便饭,但是代码中使用redisTemplate组件会略显得麻烦,使用时需要开发人员查阅官网文档,具体场景使用哪些方法,会花费相对的时间,故小编为 ...

Redis —— SpringBoot工程下的GeoHash工具类

一、依赖引入

二、工具类代码

三、使用样例

Redis —— SpringBoot工程下的GeoHash工具类相关推荐

最新文章

热门文章