原创

java代码,通过geoserver-manager,与geoserver交互

1、前言

springboot项目,引入geoserver-manager,通过java代码,与geoserver交互

2、引入maven依赖

<dependency>
    <groupId>nl.pdok</groupId>
    <artifactId>geoserver-manager</artifactId>
    <version>1.7.0-pdok2</version>
</dependency>

3、测试代码

package com.example.demo;

import it.geosolutions.geoserver.rest.GeoServerRESTManager;
import it.geosolutions.geoserver.rest.GeoServerRESTPublisher;
import it.geosolutions.geoserver.rest.decoder.RESTDataStore;
import it.geosolutions.geoserver.rest.encoder.GSResourceEncoder;

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

/**
 * 测试,通过geoserver-manager与geoserver交互
 * @author liushengbing
 * @date 2021/9/7 9:58
 */
public class GeoServerManagerDemo {

    public static String url = "http://127.0.0.1:8080/geoserver";// geoserver 访问地址
    public static String username = "";// 用户名
    public static String passwd = "";// 密码
    public static String ws = "workspace-test-6";// 待创建的工作空间名称
    public static String store_name = "store-test-6";// 待创建的存储名称
    public static String coverage_name = "coverage-test-6";// 图层名称
    public static String filePath = "D:\\test\\test.tif";// tif文件路径

    /**
     * 发布图层
     * 执行了下面的步骤
     * 1、如果没有工作空间,创建工作空间
     * 2、如果没有store,创建store
     * 3、创建图层
     * 4、发布图层
     * @author liushengbing
     * @date 2021/9/7 9:48
     */
    public static void publishLayer(){
        try{
            URL u = new URL(url);
            GeoServerRESTManager manager = new GeoServerRESTManager(u, username, passwd);
            // 判断工作空间是否存在,不存在则创建
            List<String> workspaces = manager.getReader().getWorkspaceNames();
            if (!workspaces.contains(ws)) {
                boolean createws = manager.getPublisher().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) {
                /*
                适用于 tif 文件,与geoserver不在同一个服务器上的情况
                通过 http请求 将tif文件,发送到geoserver内部
                // 创建存储
                GSGeoTIFFDatastoreEncoder gsGeoTIFFDatastoreEncoder = new GSGeoTIFFDatastoreEncoder(store_name);
                gsGeoTIFFDatastoreEncoder.setWorkspaceName(ws);
                gsGeoTIFFDatastoreEncoder.setUrl(new URL("file:" + filePath));
                boolean createStore = manager.getStoreManager().create(ws, gsGeoTIFFDatastoreEncoder);
                System.out.println("create store (TIFF文件创建状态) : " + createStore);
                // 发布图层
                boolean publish = manager.getPublisher().publishGeoTIFF(ws, store_name, new File(filePath));
                System.out.println("publish (TIFF文件发布状态) : " + publish);
                */
                // 适用于 tif 文件,与geoserver在同一个服务器上的情况
                // 发布 外部tif文件,不需要将tif文件,发送到geoserver内部
                // 发布图层
                boolean status = manager.getPublisher().publishExternalGeoTIFF(ws, store_name, new File(filePath),coverage_name,GeoServerRESTPublisher.DEFAULT_CRS, GSResourceEncoder.ProjectionPolicy.NONE,"raster");
                System.out.println("publish (TIFF文件发布状态) : " + status);
            } else {
                System.out.println("数据存储已经存在了,store:" + store_name);
            }

        }catch (Exception e){
            e.printStackTrace();
        }
    }

    /**
     * 删除工作空间
     * @author liushengbing
     * @date 2021/9/7 9:47
     */
    public static void deleteWorkSpace() {
        try{
            URL u = new URL(url);
            GeoServerRESTManager manager = new GeoServerRESTManager(u, username, passwd);
            boolean result = manager.getPublisher().removeWorkspace(ws,true);
            System.out.println("删除工作空间:" + result);
        }catch(Exception e){
            e.printStackTrace();
        }
    }

    /**
     * 删除数据存储
     * @author liushengbing
     * @date 2021/9/7 10:24
     */
    public static void deleteStore(){
        try{
            URL u = new URL(url);
            GeoServerRESTManager manager = new GeoServerRESTManager(u, username, passwd);
            boolean result = manager.getPublisher().removeCoverageStore(ws,store_name,true);
            System.out.println("删除数据存储:" + result);
        }catch(Exception e){
            e.printStackTrace();
        }
    }

    /**
     * 删除图层
     * @author liushengbing
     * @date 2021/9/7 10:33
     */
    public static void deleteCoverage(){
        try{
            URL u = new URL(url);
            GeoServerRESTManager manager = new GeoServerRESTManager(u, username, passwd);
            boolean result = manager.getPublisher().removeLayer(ws,coverage_name);
            System.out.println("删除图层:" + result);
        }catch(Exception e){
            e.printStackTrace();
        }
    }

    public static void main(String args[]){

        //发布图层
        //publishLayer();

        //删除工作空间
        //deleteWorkSpace();

        //删除数据存储
        //deleteStore();

        //删除图层
        //deleteCoverage();

    }

}
正文到此结束