1

13693261870

2023-02-19 a824fbd8a3972b2af07eb143b8776bc5620539fb

1

 src/main/java/com/lf/server/config/PropertiesConfig.java

@@ -34,7 +34,7 @@
    @Value("${sys.path.publish3dml}")
    private String publish3dmlPath;

    @Value("{sys.tile_path}")
    @Value("${sys.tile_path}")
    private String tilePath;

    public String getDownloadPath() {

 src/main/java/com/lf/server/controller/data/WmtsController.java

@@ -2,6 +2,7 @@

import com.lf.server.annotation.SysLog;
import com.lf.server.config.PropertiesConfig;
import com.lf.server.helper.StringHelper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
@@ -10,13 +11,27 @@
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.ClassPathResource;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.http.server.ServletServerHttpResponse;
import org.springframework.web.bind.annotation.*;

import javax.servlet.ServletOutputStream;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
import java.util.Date;
import java.util.List;

/**
 * WMTS服务
@@ -67,21 +82,91 @@
    @ApiOperation(value = "获取WMTS瓦片")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "token", value = "令牌", required = true, dataType = "String", defaultValue = "token", paramType = "path"),
            @ApiImplicitParam(name = "layer", value = "图层类型", required = true, dataType = "String", defaultValue = "TDTIMG"),
            @ApiImplicitParam(name = "tilematrix", value = "层级", required = true, dataType = "Integer"),
            @ApiImplicitParam(name = "tilerow", value = "行号", required = true, dataType = "Integer"),
            @ApiImplicitParam(name = "tilecol", value = "列号", required = true, dataType = "Integer")
            @ApiImplicitParam(name = "layer", value = "图层类型", required = true, dataType = "String", defaultValue = "img"),
            @ApiImplicitParam(name = "z", value = "层级", required = true, dataType = "Integer"),
            @ApiImplicitParam(name = "x", value = "行号", required = true, dataType = "Integer"),
            @ApiImplicitParam(name = "y", value = "列号", required = true, dataType = "Integer")
    })
    @GetMapping("select/{token}/tile")
    public void selectWmtsTile(@RequestParam("layer") String layer, @RequestParam("tilematrix") Integer l, @RequestParam("tilerow") Integer r,
                               @RequestParam("tilecol") Integer c, @RequestParam("format") String format, @PathVariable(name = "token") String token,
    public void selectWmtsTile(@RequestParam("LAYER") String layer, @RequestParam("TILEMATRIX") Integer z, @RequestParam("TILEROW") Integer x,
                               @RequestParam("TILECOL") Integer y, @PathVariable(name = "token") String token,
                               HttpServletRequest req, HttpServletResponse res) {
        try {
            // ServletServerHttpRequest ssRequest = new ServletServerHttpRequest(request)
            String base = config.getTilePath();
            if (StringHelper.isEmpty(layer) || null == z || null == x || null == y) {
                return;
            }

            ServletServerHttpRequest ssReq = new ServletServerHttpRequest(req);
            ServletServerHttpResponse ssRes = new ServletServerHttpResponse(res);

            // æ£€æŸ¥ç¼“存是否过期
            if (checkIfNotModify(ssReq, ssRes)) {
                // è®¾ç½®ç¼“存头
                setBrowerCache(ssRes);
                return;
            }

            // è®¾ç½®è¿”回图片类型
            res.setContentType("image/png");
            // è®¾ç½®ç¼“存参数
            setBrowerCache(ssRes);
            // é€šè¿‡response对象，获取到输出流
            ServletOutputStream outputStream = res.getOutputStream();
            // å®šä¹‰è¾“入流，通过输入流读取文件内容
            FileInputStream fileInputStream;

            String path = config.getTilePath() + File.separator + layer + File.separator + z + File.separator + x + File.separator + y + ".png";
            File file = new File(path);
            if (!file.exists() || file.isDirectory()) {
                ClassPathResource resource = new ClassPathResource("wmts/nofound.png");
                fileInputStream = new FileInputStream(resource.getFile());
            } else {
                fileInputStream = new FileInputStream(file);
            }

            int len = 0;
            byte[] bytes = new byte[1024];
            while ((len = fileInputStream.read(bytes)) != -1) {
                // é€šè¿‡è¾“入流读取文件数据，然后通过上述的输出流写回浏览器
                outputStream.write(bytes, 0, len);
                outputStream.flush();
            }

            // å…³é—­èµ„源
            outputStream.close();
            fileInputStream.close();

        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }
    }

    /**
     * è®¾ç½®æµè§ˆå™¨ç¼“存参数
     */
    private void setBrowerCache(ServerHttpResponse res) {
        HttpHeaders headers = res.getHeaders();
        headers.setCacheControl("public, must-revalidate");

        headers.setExpires(System.currentTimeMillis() + 24 * 60 * 60 * 1000);
        headers.setAccessControlMaxAge(Duration.ofHours(24));
        headers.setETag("\"" + new Date().toString() + "\"");
        // must-revalidate
        // response.Cache.SetRevalidation(HttpCacheRevalidation.AllCaches);
    }

    /**
     * éªŒè¯ç¼“存参数
     */
    boolean checkIfNotModify(ServerHttpRequest req, ServerHttpResponse res) {
        List<String> etags = req.getHeaders().getIfNoneMatch();
        if (0 == etags.size() || StringHelper.isEmpty(etags.get(0))) {
            return false;
        }

        res.setStatusCode(HttpStatus.NOT_MODIFIED);

        return true;
    }
}

 src/main/java/com/lf/server/helper/WebHelper.java

@@ -21,10 +21,7 @@
import java.io.PrintWriter;
import java.net.URLEncoder;
import java.sql.Timestamp;
import java.util.Calendar;
import java.util.Date;
import java.util.Random;
import java.util.UUID;
import java.util.*;

/**
 * Web帮助类
@@ -353,4 +350,40 @@
            log.error(ex.getMessage(), ex);
        }
    }

    /**
     * èŽ·å–请求的参数值
     *
     * @param req è¯·æ±‚
     * @param key å‚数名
     * @return å‚数值
     */
    public static String getReqParamVal(HttpServletRequest req, String key) {
        Map<String, String[]> maps = req.getParameterMap();
        for (Map.Entry<String, String[]> entry : maps.entrySet()) {
            if (entry.getKey().equalsIgnoreCase(key)) {
                return null == entry.getValue() || 0 == entry.getValue().length ? null : entry.getValue()[0];
            }
        }

        return null;
    }

    /**
     * èŽ·å–请求的参数值
     *
     * @param req è¯·æ±‚
     * @param key å‚数名
     * @return å‚数值
     */
    public static String[] getReqParamVals(HttpServletRequest req, String key) {
        Map<String, String[]> maps = req.getParameterMap();
        for (Map.Entry<String, String[]> entry : maps.entrySet()) {
            if (entry.getKey().equalsIgnoreCase(key)) {
                return entry.getValue();
            }
        }

        return null;
    }
}

 src/main/resources/wmts/˵Ã÷.txt

@@ -1,6 +1,8 @@
测试地址：
http://127.0.0.1:12316/server/wmts/select/token/WMTSCapabilities.xml

http://127.0.0.1:12316/server/wmts/select/token/tile?layer=img&tilematrix=1&tilerow=1&tilecol=1

http://127.0.0.1:12316/server/wmts/select/metas/token?service=WMTS&version=1.0.0&request=GetCapabilities