redis期末作业作业作业

package com.itcast.redis; import org.junit.Test; import redis.clients.jedis.*; import redis.clients.jedis.params.GeoRadiusParam; import java.util.*; import static redis.clients.jedis.GeoUnit.*; public class TestGeospatial { //连接远程数据库，IP都使用192.168.22.100 private static Jedis jedis = new Jedis("192.168.20.107", 6379); public static void main(String[] args) { String ping = jedis.ping(); System.out.println("数据库正在连接："+ping); System.out.println("数据库正在清空："+jedis.flushDB()); } /* * 1.getadd 添加地理位置 * GEOADD key [ NX | XX] [CH] longitude latitude member [ longitude latitude member ...] * 参数 key（经度、维度、名称） **/ @Test public void geoaddTest(){ //当坐标位置超出上述指定范围时，该命令将会返回一个错误。 //Long location = jedis.geoadd("china:city", 39.90,116.40,"beijing"); Long location = jedis.geoadd("china:city", 116.40, 39.90, "beijing"); System.out.println(location); } /* * 2.getpos 获取指定的城市的经度和纬度 **/ @Test public void geoposTest(){ List<GeoCoordinate> location = jedis.geopos("china:city", "beijing"); System.out.println("北京的地理位置信息是："+location); } /* * 3.Pipeline 批量添加多个城市的地理位置信息 * 在 Jedis 中，geoadd 方法本身不提供直接的批量添加多个城市的功能。但你可以使用 Jedis 提供的 Pipeline 来执行批量操作，以提高性能。 * 使用 Pipeline 来批量执行多个 geoadd 操作，这样可以减少与 Redis 服务器的通信次数，提高效率。 * 在实际应用中，你可以根据需求动态构建城市和地理位置的数据结构，并使用 Pipeline 执行批量添加操作。 **/ @Test public void geoaddmulTest(){ // 使用 Pipeline 批量添加地理位置信息 Pipeline pipeline = jedis.pipelined(); // 创建一个 Map 用于存储城市和对应的地理位置信息 Map<String, GeoCoordinate> cityCoordinates = new HashMap<>(); cityCoordinates.put("shanghai", new GeoCoordinate(121.47, 31.23)); cityCoordinates.put("hangzhou", new GeoCoordinate(120.16, 30.24)); cityCoordinates.put("xian", new GeoCoordinate(108.96, 34.26)); cityCoordinates.put("chongqing", new GeoCoordinate(106.50, 29.53)); cityCoordinates.put("shenzhen", new GeoCoordinate(114.05, 22.52)); cityCoordinates.put("beijing", new GeoCoordinate(116.40, 39.90)); // 添加更多城市... // 使用 Pipeline 一次性添加多个城市的地理位置信息 for (Map.Entry<String, GeoCoordinate> entry : cityCoordinates.entrySet()) { String city = entry.getKey(); GeoCoordinate coordinate = entry.getValue(); pipeline.geoadd("china:city", coordinate.getLongitude(), coordinate.getLatitude(), city); } // 执行 Pipeline pipeline.sync(); // 输出地理位置信息 for (String city : new String[]{"beijing","shanghai","hangzhou", "xian","chongqing","shenzhen"}) { System.out.println( city + "的地理位置信息是： " + jedis.geopos("china:city", city)); } } /* * 4.GEODIST 是 Redis 中用于计算地理位置距离的命令。该命令用于计算两个位置之间的距离，单位是米（m）。 * m 表示单位为米。 * km 表示单位为千米。 * mi 表示单位为英里。 * ft 表示单位为英尺 **/ @Test public void geodistTest(){ // 计算 上海到北京的直线距离，默认单位为米 Double distance1 = jedis.geodist("china:city", "shanghai", "beijing",M); System.out.println("上海到北京的直线距离: " + distance1 + " 米"); // 计算 重庆到北京的直线距离，单位为千米 Double distance2= jedis.geodist("china:city", "chongqing", "beijing",KM); System.out.println("重庆到北京的直线距离: " + distance2 + " 公里"); } /* * 5.georadius 以给定的经纬度为中心， 找出某一半径内的元素 (附近的人) * 获得指定数量的人，200 * 所有数据应该都录入：china:city ，才会让结果更加请求！ * withcoord:带上坐标； * withdist:带上距离，单位与半径单位相同； * COUNT n : 只显示前n个(按距离递增排序) **/ @Test public void georadiusTest(){ double radius = 1000; // 以110，30 这个经纬度为中心，寻找方圆1000km内的城市 List<GeoRadiusResponse> georadius = jedis.georadius("china:city", 110, 30, radius, KM, GeoRadiusParam.geoRadiusParam().sortAscending()); // 打印结果 找城市 System.out.println("找到的城市有："); for (GeoRadiusResponse city : georadius) { System.out.printf("%s 在" + radius + "公里范围内%n", city.getMemberByString()); } } @Test public void georadiuswithdistTest(){ //查询经纬度(110,30)坐标500km半径内的成员，带距离 double radius = 1000; // 中心点经纬度 double centerLongitude = 110; double centerLatitude = 30; // 查询方圆 500 公里内的城市，并获取坐标信息 List<GeoRadiusResponse> georadiusWithDist = jedis.georadius("china:city", centerLongitude, centerLatitude, radius,KM, GeoRadiusParam.geoRadiusParam().withDist().sortAscending()); // 打印结果 System.out.println("找到的城市有："); for (GeoRadiusResponse city : georadiusWithDist) { // 打印输出，显示城市名称和坐标信息 System.out.printf("%s 在" + radius + "公里范围内，距离中心点 %.2f 千米%n", city.getMemberByString(),city.getDistance()); } } @Test public void georadiuswithcoordTest(){ //查询经纬度(110,30)坐标500km半径内的成员，带坐标 double radius = 500; // 中心点经纬度 double centerLongitude = 110; double centerLatitude = 30; // 查询方圆 500 公里内的城市，并获取坐标信息 List<GeoRadiusResponse> georadiusWithCoord = jedis.georadius("china:city", centerLongitude, centerLatitude, radius,KM, GeoRadiusParam.geoRadiusParam().withCoord().sortAscending()); // 打印结果 System.out.println("找到的城市有："); for (GeoRadiusResponse city : georadiusWithCoord) { GeoCoordinate coordinates = city.getCoordinate(); double latitude = coordinates.getLatitude(); double longitude = coordinates.getLongitude(); // 打印输出，显示城市名称和坐标信息 System.out.printf("%s 在" + radius + "公里范围内，坐标：(%f, %f)%n", city.getMemberByString(), longitude, latitude); } } /* * 6.GEORADIUSBYMEMBER 找出位于指定元素周围的其他元素 **/ @Test public void georadiusbymemberTest(){ // 查询以 "beijing" 为中心，方圆 1000 公里内的城市 double radius = 1000; String location = "xian"; List<GeoRadiusResponse> georadiusByMember = jedis.georadiusByMember("china:city", location, radius,KM, GeoRadiusParam.geoRadiusParam().sortAscending()); // 打印结果 System.out.println("找到的城市有："); for (GeoRadiusResponse city : georadiusByMember) { System.out.printf("%s 在" +location + "的方圆"+ radius + "公里范围内%n", city.getMemberByString()); } } /* *7. GEO 底层的实现原理其实�