Geoserver的rest接口使用(后台或者前端调实现自动发布服务)

Posted hpugisers

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Geoserver的rest接口使用(后台或者前端调实现自动发布服务)相关的知识,希望对你有一定的参考价值。

Geoserver提供许多服务的发布,我们可以通过控制台进行手动发布,至于至于如何在程序中利用代码发布服务,这如何做?可以通过两种思路进行一通过后台通过请求rest接口进行发布或者前端通过ajax,另一种通过xml方式详细的请参考该篇文章简析GeoServer服务的内部文件组织以及GeoServer自动化服务发布工具的开发思路本文主要介绍地第一种方式(java语言)如何发布,开始进入正题。
效果图
1、postgis数据

2、shapefile数据

一、maven中构造
通过Java构造请求我们需要用到geoserver-manager类库(api文档
1、添加依赖

   <repository>
      <id>GeoSolutions</id>
      <url>http://maven.geo-solutions.it/</url>
   </repository>
  <dependency>
    <groupId>it.geosolutions</groupId>
    <artifactId>geoserver-manager</artifactId>
    <version>1.7.0</version>
  </dependency>

2、几个重要的类对象

  1. GeoServerRESTManager该对象是一个最大的管理者可以获取以下两个对象,创建数据存储
  2. GeoServerRESTPublisher,发布对象,用来发布各种数据和创建工作空间(主要用来创建对象)
  3. GeoServerRESTReader,获取数据存储、图层、样式、图层组等(主要用来获取信息)
    二、demo示例(发布postgis数据和shapfile数据)
package com.hpu.geoserver;
import it.geosolutions.geoserver.rest.GeoServerRESTManager;
import it.geosolutions.geoserver.rest.GeoServerRESTPublisher;
import it.geosolutions.geoserver.rest.decoder.RESTDataStore;
import it.geosolutions.geoserver.rest.decoder.RESTLayer;
import it.geosolutions.geoserver.rest.encoder.GSLayerEncoder;
import it.geosolutions.geoserver.rest.encoder.datastore.GSPostGISDatastoreEncoder;
import it.geosolutions.geoserver.rest.encoder.datastore.GSShapefileDatastoreEncoder;
import it.geosolutions.geoserver.rest.encoder.feature.GSFeatureTypeEncoder;
import it.geosolutions.geoserver.rest.encoder.coverage.GSCoverageEncoder;

import java.io.File;
import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.List;

public class GeoserverPostGIS 
public static void main(String[] args) throws IOException 
	//GeoServer的连接配置
    String url = "http://localhost:8080/geoserver" ;
    String username = "admin" ;
    String passwd = "geoserver" ;
    //GeoserverPublishPostGISData(url, username, passwd);
    GeoserverPublishShapefileData(url, username, passwd);

//发布postgis中的数据
public static void GeoserverPublishPostGISData(String url,String username,String passwd) throws IOException
	
    //postgis连接配置
    String postgisHost = "localhost" ;
    int postgisPort = 5432 ;//端口号
    String postgisUser = "postgres" ;//用户名
    String postgisPassword = "postgres" ;//用户密码
    String postgisDatabase = "sqlView" ;//数据库名称

    String ws = "testNew" ;     //待创建和发布图层的工作区名称workspace
    String store_name = "testGeoserver" ; //待创建和发布图层的数据存储名称store
    String table_name = "roa_4m" ; // 数据库要发布的表名称,后面图层名称和表名保持一致
    //判断工作区(workspace)是否存在,不存在则创建
    URL u = new URL(url);
    GeoServerRESTManager manager = new GeoServerRESTManager(u, username, passwd);
   
    GeoServerRESTPublisher publisher = manager.getPublisher() ;
    List<String> workspaces = manager.getReader().getWorkspaceNames();
    if(!workspaces.contains(ws))
        boolean createws = publisher.createWorkspace(ws);
        System.out.println("create ws : " + createws);
    else 
        System.out.println("workspace已经存在了,ws :" + ws);
    


    //判断数据存储(datastore)是否已经存在,不存在则创建
    RESTDataStore restStore = manager.getReader().getDatastore(ws, store_name);
    if(restStore == null)
        GSPostGISDatastoreEncoder store = new GSPostGISDatastoreEncoder(store_name);
        store.setHost(postgisHost);//设置url
        store.setPort(postgisPort);//设置端口
        store.setUser(postgisUser);// 数据库的用户名
        store.setPassword(postgisPassword);// 数据库的密码
        store.setDatabase(postgisDatabase);// 那个数据库;
        store.setSchema("public"); //当前先默认使用public这个schema
        store.setConnectionTimeout(20);// 超时设置
        //store.setName(schema);
        store.setMaxConnections(20); // 最大连接数
        store.setMinConnections(1);     // 最小连接数
        store.setExposePrimaryKeys(true);
        boolean createStore = manager.getStoreManager().create(ws, store);
        System.out.println("create store : " + createStore);
     else 
        System.out.println("数据存储已经存在了,store:" + store_name);
    

    //判断图层是否已经存在,不存在则创建并发布
    RESTLayer layer = manager.getReader()..getLayer(ws, table_name);
    if(layer == null)
        GSFeatureTypeEncoder pds = new GSFeatureTypeEncoder();
        pds.setTitle(table_name);
        pds.setName(table_name);
        pds.setSRS("EPSG:4326");
        GSLayerEncoder layerEncoder = new GSLayerEncoder();
        
        boolean publish = manager.getPublisher().publishDBLayer(ws, store_name,  pds, layerEncoder);
        System.out.println("publish : " + publish);
    else 
        System.out.println("表已经发布过了,table:" + table_name);
    
	

//发布shapefile数据
public static void GeoserverPublishShapefileData(String url,String username,String passwd) throws IOException
  
    String ws = "testshape" ;     //待创建和发布图层的工作区名称workspace
    String store_name = "testShapeStore" ; //待创建和发布图层的数据存储名称store
    String srs="EPSG:4326";
    //压缩文件的完整路径
    File zipFile=new File("D:/软件安装/geoserver/GeoServer 2.14.0/data_dir/data/shapefiles/states.zip");
    String layername="states";//图层名称
    //shp文件所在的位置
    String urlDatastore="file:data/shapefiles/states.shp";
	//判断工作区(workspace)是否存在,不存在则创建
    URL u = new URL(url);
    //获取管理对象
    GeoServerRESTManager manager = new GeoServerRESTManager(u, username, passwd);
   //获取发布对象
    GeoServerRESTPublisher publisher = manager.getPublisher() ;
    //获取所有的工作空间名称
    List<String> workspaces = manager.getReader().getWorkspaceNames();
    //判断工作空间是否存在
    if(!workspaces.contains(ws))
    	//创建一个新的存储空间
        boolean createws = publisher.createWorkspace(ws);
        System.out.println("create ws : " + createws);
    else 
        System.out.println("workspace已经存在了,ws :" + ws);
    

    //判断数据存储(datastore)是否已经存在,不存在则创建
    URL urlShapefile = new URL(urlDatastore);
    RESTDataStore restStore = manager.getReader().getDatastore(ws, store_name);
    if(restStore == null)  
    	//创建shape文件存储
        GSShapefileDatastoreEncoder store = new GSShapefileDatastoreEncoder(store_name, urlShapefile);  
        boolean createStore = manager.getStoreManager().create(ws, store);
        System.out.println("create store : " + createStore);
     else 
        System.out.println("数据存储已经存在了,store:" + store_name);
    

    //判断图层是否已经存在,不存在则创建并发布
    RESTLayer layer = manager.getReader().getLayer(ws, layername);
    if(layer == null)
    	//发布图层
        boolean publish = manager.getPublisher().publishShp(ws, store_name, layername, zipFile, srs);
        System.out.println("publish : " + publish);
    else 
    	
        System.out.println("表已经发布过了,table:" + store_name);
    
	




三、踩的一些坑
1、首先类似于String store_name = "testGeoserver"写成String store_name = "testGeoserver "会报错在geoserver控制台中会报安全错误,空格被解析成分号(
2、在发布shapefile时候创建shapefile存储空间路径前面要加“file://”,最方便的方式如下图,直接新建一个数据源在浏览中找到shape文件所在路径位置,直接复制就好

3、这里的压缩文件只能为zip格式,不能是rar格式否则会报错
4、压缩文件的路径为全路径

以上是关于Geoserver的rest接口使用(后台或者前端调实现自动发布服务)的主要内容,如果未能解决你的问题,请参考以下文章

java后台接口怎么方便返回restful数据

前端调用后端的方法(基于restful接口的mvc架构)

后端提供给前端restful的接口,前端怎么操作

如何设计Restful风格的API

geoserver rest 导入shape文件错误

restful api接口介绍和数据返回及异常处理