');}

使用Lucene索引存储空间数据

Author Avatar
Rico 3月 20, 2017

为何要对地理数据进行索引

问题

先思考个常见的问题：如何根据自己所在位置查询来查询附近1公里的POI(比如商家、ATM、景点等)

传统的解决思路

方法一： 暴力方法

该方法的思路很直接：计算位置与所有POI的距离(全世界,全中国,全杭州的POI?那数据量可不是一般的大呀)，并保留距离小于1000米的POI。

插句题外话，计算经纬度之间的距离不能像求欧式距离那样平方开根号，因为地球是个不规整的球体（图2a），按最简单的完美球体假设，两点之间的距离函数应该如图2b所示。

该方法的复杂度为：POI数量*距离函数

方法二:矩形过滤法

该方法分为两步：

a)先用矩形框过滤,排除大部分的点位（图4a），判断一个点在矩形框内很简单，只要进行两次判断（LtMin<lat<LtMax; LnMin<lng<LnMax），落在矩形框内的POI个数为n；

b)用球面距离公式计算位置与矩形框内n个POI的距离（图4b），并保留距离小于1000米的POI

矩形过滤方法的复杂度为：POI数量*矩形过滤函数 + n*距离函数。

相比于方法一查询时间大大降低，但是对于一次查询来说还是很长。时间长的原因在于遍历。

这时空间索引的需求就来了

空间索引思路

要实现地理位置空间搜索，我们首先需要对地理位置数据创建索引，比较容易想到的就是把经度和纬度存入索引，可是这样做，有个弊端，因为地理位置数据(经纬度)是非常精细的，一般两个地点相差就0.0几，这样我们需要构建的索引体积会很大，这会显著减慢你的搜索速度。在精确度上采取折衷的方法通常是将纬度和经度封装到层中。您可以将每个层看作是地图的特定部分的缩放级别，比如位于美国中央上方的第 2 层几乎包含了整个北美，而第 19 层可能只是某户人家的后院。尤其是，每个层都将地图分成 2层 # 的箱子或网格。然后给每个箱子分配一个号码并添加到文档索引中。如果希望使用一个字段，那么可以使用 Geohash编码方式将纬度/经度编码到一个 String 中。关于GeoHash可以去看这篇文章

​

如何对地理数据建立索引

大家都知道普通的业务数据存入数据库(例如Oracle)或者全文检索引擎(例如Lucene,ElasticSearch)的时候都会建索引，因为索引会加快搜索速度。 但是地理数据如何建立空间索引呢？我有传统地理数据(例如cad,shp)如何存入数据库或全文检索引擎并建立索引呢？且听我慢慢讲来。

shpfile介绍

通常,地理数据都是ShapeFile 格式的文件,GIS专业的童鞋应该对这个不陌生吧?说陌生的你老师棺材板我给你按住了，你赶紧复习复习

言归正传,shapefile它至少必须有3个文件,dbf ,shp shx. 通常由7个乃至更多文件组成

  • 主文件（*.shp） –存储地理要素的几何图形的文件。
  • 索引文件（*.shx） –存储图形要素与属性信息索引的文件。
  • dBASE表文件（*.dbf），–存储要素信息属性的dBase表文件。
  • 空间参考文件（*.prj）
  • 几何体的空间索引文件（*.sbn 和 *.sbx )
  • 以XML格式保存元数据（*.shp.xml)
  • .fix文件

此类文件如非使用专业的GIS软件例如 ArcMap, QGIS, Udig等是打不开的

如非使用例如 GeoServer, ArcGIS Server等服务软件是无法对外部提供各种能力和接口的,例如获取瓦片图层，空间查询等

空间数据和普通业务数据最大的不同就是业务数据基本上就是文本数据。例如电商的商品信息，信息系统的姓名年龄身高性别等,我们可以方便的对他们进行存储，分词等。 空间数据有着各种点，边 ，面，无法保存进传统数据库表的字段中

然而,Oracle Spatial和PostgreSQL就提供了对空间数据的支持。它们可以导入shp数据，建立空间索引，提供了文本查询和空间查询 ，各大应用都可以通过数据库的协议来对空间数据进行增删查改,特别是查，不单单像普通业务数据那样可以进行查询，还可以进行空间查询，例如查找最近的餐馆，一个面和一个面是否相交，相交的面又是怎样的？ 这就大大开放了地理数据的能力。原来只能通过IO读取的shp文件，现在能提供给不同的业务系统进行增删查改

Oracle Spatial和PG的确是解决了大部分的问题,但是比较麻烦，我得安装一个Oracle Spatial或PostgreSQL，导入数据，启动服务，项目连接配置。项目实施起来相对比较麻烦,Oracle Spatial还是商用收费的，只有企业版才有

如果能有一种形式,无需起服务,Java应用能直接读取地理数据,而且已经现成的就建好了空间索引,能快速方便的进行属性查询，空间查询,那该多好，答案就是Lucene了

一般Lucene被大家熟知都是因为它是性能强大的全文检索引擎,著名的分布式搜索引擎ElasticSearch就是基于Lucene写的，很少有人知道其实Lucene也提供了空间扩展，支持空间查询

那么如何读取shp数据并存入lucene中呢？

shp存入Lucene

引入第三方包

首先我们需要引入一些第三方的jar包

我们介绍3个开源库 一个是GeoTools 一个是JTS 一个是Spatial4J

GeoTools是英国利兹大学(University of Leeds)的James Macgll 从1996 年开始研发的一个操作和显示地图的开源Java 代码库, 提供了一系列符合规范的操作地理空间数据的方法，例如可以用它来实现一个地理信息系统（GIS）。GeoTools库在开发时执行OGC规范. 很多工具和软件都使用了这个库 。 最著名的就是Udig和GeoServer

JTS加拿大的 Vivid Solutions公司做的一套开放源码的 Java API。它提供了一套空间数据操作的核心算法。提供了兼容OGC标准的空间对象模型中进行基础的几何操作

Spatial4J是 空间拓扑计算的Java包

我们使用Maven引入GeoTools(GeoTools中已经引入了JTS)

  1.      <geotools.version>14.1</geotools.version>
  2.     <dependency>
  3.       <groupId>org.geotools</groupId>
  4.       <artifactId>geotools</artifactId>
  5.       <version>${geotools.version}</version>
  6.       <type>pom</type>
  7.     </dependency>
  8.     <dependency>
  9.       <groupId>org.geotools</groupId>
  10.       <artifactId>gt-main</artifactId>
  11.       <version>${geotools.version}</version>
  12.     </dependency>
  13.     <dependency><!--提供了ShapeFile数据源支持 -->
  14.       <groupId>org.geotools</groupId>
  15.       <artifactId>gt-shapefile</artifactId>
  16.       <version>${geotools.version}</version>
  17.     </dependency>

Java读取ShapeFile文件

  1.          ShapefileDataStoreFactory shpStoreFactory = new ShapefileDataStoreFactory();//工厂模式,首先构造ShapefileDataStoreFactory
  2.         ShapefileDataStore shapefileDataStore=null;
  3.         try {
  4.             shapefileDataStore = (ShapefileDataStore)shpStoreFactory.createDataStore(new File("/data/Airport_pt.shp").toURI().toURL());//打开一个shp文件连接到datastore
  5.             shapefileDataStore.setCharset(Charset.forName("GBK"));
  6.         } catch (IOException e) {
  7.             e.printStackTrace();
  8.         }
  9.         if(shapefileDataStore!=null){
  10.             String names[]=shapefileDataStore.getTypeNames();//获取datastore中所有的shp,因为一个datastore可能存储了很多的shp
  11.             System.out.println(Arrays.toString(names));
  12.             SimpleFeatureSource featureSource = shapefileDataStore.getFeatureSource();
  13.             //featureSource = dataStore.getFeatureSource(dataStore.getTypeNames()[0])//对于shp数据而言,等同于上面一行
  14.             System.out.println("shp名称:"+shapefileDataStore.getTypeNames()[0]);
  15.             System.out.println("坐标系:"+featureSource.getSchema().getGeometryDescriptor().getCoordinateReferenceSystem().toString());
  16.    shapefileDataStore.dispose();//释放资源

DataStore有很多实现类

  1. AbstractDataStore, AbstractFileDataStore, ArcSDEDataStore, ArrayDataStore, CollectionDataStore, ContentDataStore, DataStoreWrapper, DirectoryDataStore,
  2. JDBCDataStore, MemoryDataStore, OGRDataStore, OracleDatastoreWrapper, PostgisDatastoreWrapper, PreGeneralizedDataStore, PropertyDataStore,
  3. ShapefileDataStore, SingleFeatureSourceDataStore, WFS100DataStore, WFS110DataStore

提供了多种数据源的支持,例如Oracle,PostgreSQL,ShapeFile,WFS,内存,目录等 ,我们这边使用的是ShapefileDataStore

shpStoreFactory.createDataStore(URL url)返回的是FileDataStore 并不是 ShapefileDataStore ,它有2个实现类AbstractFileDataStore, ShapefileDataStore 所以直接强转就行了

DataStore.getTypeNames:Returns the names of all entries or types provided by the datastore.

结果:

Java读取shp内容

  1.              ArrayList<Airport> lists=new ArrayList<Airport>();
  2.             try {
  3.                 SimpleFeatureIterator itertor = featureSource.getFeatures().features();
  4.                 while (itertor.hasNext()) {
  5.                     Airport airport=new Airport();
  6.                     SimpleFeature feature = itertor.next();///迭代里面的要素,例如如果是路的shp,那么就是迭代一条条路
  7.                     Iterator<Property> it = feature.getProperties().iterator();//getProperties是获取某个条要素的属性信息(属性表)  迭代某条数据中的很多属性字段
  8.                     while (it.hasNext()) {
  9.                         Property pro = it.next();
  10.                         switch (pro.getName().toString()){
  11.                             case "Name":
  12.                                 airport.setName(pro.getValue().toString());
  13.                                 break;
  14.                             case "Address":
  15.                                 airport.setAddress(pro.getValue().toString());
  16.                                 break;
  17.                             case "PY":
  18.                                 airport.setPY(pro.getValue().toString());
  19.                                 break;
  20.                             case "Display_X":
  21.                                 airport.setDisplay_X(pro.getValue().toString());
  22.                                 break;
  23.                             case "Display_Y":
  24.                                 airport.setDisplay_Y(pro.getValue().toString());
  25.                                 break;
  26.                         }
  27.                         if(pro.getValue() instanceof Point){//该shp里面是点
  28.                             Point point=(Point)pro.getValue();
  29.                             airport.setWKT(point.toText());
  30.                         }
  31.                     }
  32.                     lists.add(airport);
  33.                 }
  34.                 itertor.close();
  35.                 System.out.println("数据条数:"+lists.size());
  36.             } catch (IOException e) {
  37.                 e.printStackTrace();
  38.             }

如果是线, 多线 ,面 

  1. if(pro.getValue() instanceof MultiLineString){
  2.     MultiLineString lineString=(MultiLineString)pro.getValue();
  3.     //lineString.getCoordinates();
  4.     System.out.println(lineString.toText());
  5. }
  6. if(pro.getValue() instanceof LineString){
  7.     MultiLineString lineString=(MultiLineString)pro.getValue();
  8.     //lineString.getCoordinates();
  9.     System.out.println(lineString.toText());
  10. }

存入lucene

  1.          File luceneDir=new File("/data/lucene");//索引存放路径
  2.         Path path= Paths.get(luceneDir.getAbsolutePath());
  3.         Directory indexDirectory= FSDirectory.open(path);
  4.         //------------------------构造wktreader,它需要JtsSpatialContext,由JtsSpatialContextFactory创建,这里要创建一个JtsSpatialContext,其需要一个Rectangle,其过程也创建了一个JtsSpatialContext,注意区分----------------------
  5.         //JtsSpatialContextFactory 当有Polygon多边形或者linestrings线段时，会使用jts(需要把jts.jar放到solr服务的lib下)，而基本形状使用SpatialContext (spatial4j的类)。
  6.         JtsSpatialContextFactory jtsSpatialContextFactory = new JtsSpatialContextFactory();//创建JtsSpatialContextFactory工厂类
  7.         //spatial4j/jts实现的 SpatialContext: 用于获得距离计算Calculator以及解析形状等。其属于spatial4j包中，该包中还有各种Shape及判断各Shape间的相交情况。JtsSpatialContext(jts包)用于处理多边形等情况。
  8.         jtsSpatialContextFactory.srid = 4326;// 赋予坐标系
  9.         jtsSpatialContextFactory.autoIndex = true;// 对于通过 ShapeReader获取的jtsGeometry几何图形进行优化,自动索引
  10.         // 根据srid不同获取不同的模型参数:4326采用椭球模型  sphere ,900913采用欧几里得平面坐标系flatPlane    4326不使用大地测量坐标系，而使用欧几里得平面坐标系进行计算
  11.         String model = "sphere";
  12.         jtsSpatialContextFactory.geo = true;//是否是地理坐标系  如果是flatPlane则是false  jtsSpatialContextFactory继承自SpatialContextFactory这个字段一同继承过来的
  13.         JtsSpatialContext jtsSpatialContext =new JtsSpatialContext(jtsSpatialContextFactory);//通过工厂创建  这样做只是为了创建一个Rectangle(世界模型,矩形),下面的new RectangleImpl需要用到
  14.         Envelope env = new Envelope(-180, 180, 90, -90);// mecator的全 球范围 如果是900913 new Envelope(-20037508.3427892, 20037508.3427892, 20037508.3427892, -20037508.3427892);// mecator的全 球范围
  15.         jtsSpatialContextFactory.worldBounds = new RectangleImpl(env.getMinX(), env.getMaxX(), env.getMinY(), env.getMaxY(), jtsSpatialContext);//为factory设置worldbounds，该属性来自父类SpatialContextFactory
  16.         JtsSpatialContext ctx = jtsSpatialContextFactory.newSpatialContext();//最终用的是这个JtsSpatialContext
  17.         WKTReader wktReader=new WKTReader(ctx, new SpatialContextFactory());//SpatialContext: 用于获得距离计算Calculator以及解析形状等。其属于spatial4j包中，该包中还有各种Shape及判断各Shape间的相交情况。JtsSpatialContext(jts包)用于处理多边形等情况。
  18.         //-------------------构造wktreader结束--------------------
  20.         //-----------------构造SpatialStrategy---------------------
  21.         SpatialPrefixTree spt = new GeohashPrefixTree(ctx, 23);//网格最大几层 最大精度24层
  22.         //如果是900913  new QuadPrefixTree(ctx, ctx.getWorldBounds(), 23);//四叉树，对应笛卡尔分层策略)。分层其实取的就是前缀
  23.         SpatialStrategy strategy = new RecursivePrefixTreeStrategy(spt, "Geometry");
  24.         /*索引和搜索的策略接口,两个主要实现类
  25.         * 1:RecursivePrefixTreeStrategy(支持任何Shape的索引和检索)
  26.         * 2: TermQueryPrefixTreeStrategy(仅支持Point Shape)
  27.         * 上述两个类继承PrefixTreeStrategy(有使用缓存)
  28.         */
  29.         //SpatialStrategy: 空间索引的核心，用来创建 索引域 以及 查询Query、查询Filter，以及用于score=distance等的打分策略(DistanceValueSource)。
  30.         IndexWriter indexWriter = new IndexWriter(indexDirectory,new IndexWriterConfig(new SmartChineseAnalyzer(true)));
  31.         for(int i=0;i<lists.size();i++){
  32.             Document doc = new Document();// org.apache.lucene.document // document代表索引库中的一条记录
  33.             StringField nameField= new StringField("Name",lists.get(i).getName(), Field.Store.YES);//名字 存储
  34.             doc.add(nameField);
  35.             StringField addressField= new StringField("Address",lists.get(i).getAddress(), Field.Store.YES);//地址 存储
  36.             doc.add(addressField);
  37.             StringField pyField= new StringField("PY",lists.get(i).getPY(), Field.Store.YES);//拼音 存储
  38.             doc.add(pyField);
  39.             StringField xField= new StringField("X",lists.get(i).getDisplay_X(), Field.Store.YES);//X 存储
  40.             doc.add(xField);
  41.             StringField yField= new StringField("Y",lists.get(i).getDisplay_Y(), Field.Store.YES);//X 存储
  42.             doc.add(yField);
  43.             SortedDocValuesField sortedField = new SortedDocValuesField("PYName", new BytesRef(lists.get(i).getPY()));// 根据name进行排序
  44.             doc.add(sortedField);
  45.             /* ---------------------------空间字段------------------------ */
  46.             // 空间字段，需要转换为shape后存储
  47.             Shape shp=null;
  48.             try {
  49.                 shp = wktReader.parse(lists.get(i).getWKT());
  50.                 /*
  51.                  * 注意,检索但不存储空间字段。 org.apache.lucene.spatial.SpatialStrategy类
  52.                  * createIndexableFields(org.locationtech.spatial4j.shape.Shape * shape) 返回值 abstract Field[] Returns the IndexableField(s) from
  53.                  * the shape that are to be added to the Document
  54.                  */
  55.                 for (Field shpField : strategy.createIndexableFields(shp)) {
  56.                     doc.add(shpField);
  57.                 }
  58.                 StoredField wkt = new StoredField("wkt", lists.get(i).getWKT());//wkt存储
  59.                 doc.add(wkt);
  60.             } catch (ParseException e) {
  61.                 e.printStackTrace();
  62.             }
  63.             indexWriter.addDocument(doc);
  64.         }
  65.         indexWriter.close();

一些函数api

生成一个默认的context

生成一个基于各种配置的context

  1. JtsSpatialContextFactory 也是继承的 SpatialContextFactory

执行程序,可以发现目录中已经有索引文件了

我们使用Luke工具来查看Lucene索引文件

我们上面代码写到我们生成了23层geohash网格，我们使用luke工具查看一下是否是23层

果然是23层

至此,空间数据索引并存储进Lucene完成了，接下来就要基于这些索引文件进行空间搜索了

PS:关于Lucene内部是如何实现存储,索引空间数据后续会有博文讲述

参考资料

solr空间索引原理及源码分析

Solr空间搜索原理分析与实践

Lucene Spatial构建地理空间索引

https://wiki.apache.org/solr/SolrAdaptersForLuceneSpatial4

https://sourceforge.net/projects/jts-topo-suite/

https://lucene.apache.org/core/7_2_1/spatial-extras/index.html

This blog is under a CC BY-NC-SA 3.0 Unported License
本文链接：http://hogwartsrico.github.io/2017/03/20/Index-SpatialData/