648540858
2021-09-02 77bf85342b9d5a7954c85f05a54e6a46d41f0bf6
src/main/java/com/genersoft/iot/vmp/conf/ProxyServletConfig.java
@@ -1,6 +1,6 @@
package com.genersoft.iot.vmp.conf;
import com.genersoft.iot.vmp.media.zlm.dto.IMediaServerItem;
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
import com.genersoft.iot.vmp.service.IMediaServerService;
import org.apache.catalina.connector.ClientAbortException;
import org.apache.http.HttpHost;
@@ -49,7 +49,7 @@
        @Override
        protected String rewriteQueryStringFromRequest(HttpServletRequest servletRequest, String queryString) {
            String queryStr = super.rewriteQueryStringFromRequest(servletRequest, queryString);
            IMediaServerItem mediaInfo = getMediaInfoByUri(servletRequest.getRequestURI());
            MediaServerItem mediaInfo = getMediaInfoByUri(servletRequest.getRequestURI());
            if (mediaInfo != null) {
                if (!StringUtils.isEmpty(queryStr)) {
                    queryStr += "&secret=" + mediaInfo.getSecret();
@@ -88,7 +88,7 @@
        @Override
        protected String getTargetUri(HttpServletRequest servletRequest) {
            String requestURI = servletRequest.getRequestURI();
            IMediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            String uri = null;
            if (mediaInfo != null) {
@@ -106,7 +106,7 @@
        @Override
        protected HttpHost getTargetHost(HttpServletRequest servletRequest) {
            String requestURI = servletRequest.getRequestURI();
            IMediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            HttpHost host;
            if (mediaInfo != null) {
                host = new HttpHost(mediaInfo.getIp(), mediaInfo.getHttpPort());
@@ -120,7 +120,7 @@
        /**
         * 根据uri获取流媒体信息
         */
        IMediaServerItem getMediaInfoByUri(String uri){
        MediaServerItem getMediaInfoByUri(String uri){
            String[] split = uri.split("/");
            String mediaServerId = split[2];
            return mediaServerService.getOne(mediaServerId);
@@ -132,7 +132,7 @@
        @Override
        protected String rewriteUrlFromRequest(HttpServletRequest servletRequest) {
            String requestURI = servletRequest.getRequestURI();
            IMediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            String url = super.rewriteUrlFromRequest(servletRequest);
            if (mediaInfo == null) {
                return  url;
@@ -140,8 +140,6 @@
            return url.replace(mediaInfo.getId() + "/", "");
        }
    }
    @Bean
    public ServletRegistrationBean recordServletRegistrationBean(){
@@ -186,7 +184,7 @@
        @Override
        protected String getTargetUri(HttpServletRequest servletRequest) {
            String requestURI = servletRequest.getRequestURI();
            IMediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            String uri = null;
            if (mediaInfo != null) {
@@ -204,7 +202,7 @@
        @Override
        protected HttpHost getTargetHost(HttpServletRequest servletRequest) {
            String requestURI = servletRequest.getRequestURI();
            IMediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            HttpHost host;
            if (mediaInfo != null) {
                host = new HttpHost(mediaInfo.getIp(), mediaInfo.getRecordAssistPort());
@@ -218,7 +216,7 @@
        /**
         * 根据uri获取流媒体信息
         */
        IMediaServerItem getMediaInfoByUri(String uri){
        MediaServerItem getMediaInfoByUri(String uri){
            String[] split = uri.split("/");
            String mediaServerId = split[2];
            return mediaServerService.getOne(mediaServerId);
@@ -230,7 +228,7 @@
        @Override
        protected String rewriteUrlFromRequest(HttpServletRequest servletRequest) {
            String requestURI = servletRequest.getRequestURI();
            IMediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);
            String url = super.rewriteUrlFromRequest(servletRequest);
            if (mediaInfo == null) {
                return  url;