ZLMediaKit+wvp-GB28181-pro，搭建28181协议视频平台

clone地址：https://gitee.com/pan648540858/wvp-GB28181-pro.git，将项目clone到本地

这里强烈建议去github，去clone wvp 代码，因为 gitee 上面的代码很久没有做更新了，有很多bug，我这边是自己把bug解决了，希望你在部署的时候，去 github上面去拉取在最新代码，少走一些弯路

将项目里面的mysql.sql里面的文件，创建数据库

修改 ProxyServletConfig.class,这里主要是将serverPort，zlmProxy，recordProxy提取出来做配置化

package com.genersoft.iot.vmp.conf;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;
import org.apache.http.HttpRequest;
import org.apache.http.HttpResponse;
import org.mitre.dsmiley.httpproxy.ProxyServlet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.ObjectUtils;import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.net.ConnectException;/*** @author lin*/
@SuppressWarnings(value = {"rawtypes", "unchecked"})
@Configuration
public class ProxyServletConfig {private final static Logger logger = LoggerFactory.getLogger(ProxyServletConfig.class);@Autowiredprivate IMediaServerService mediaServerService;@Value("${server.port}")private int serverPort;@Value("${zlm.zlmproxy}")private String zlmProxy;@Value("${zlm.recordproxy}")private String recordProxy;@Beanpublic ServletRegistrationBean zlmServletRegistrationBean(){ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new ZlmProxyServlet(),"/zlm/*");servletRegistrationBean.setName("zlm_Proxy");servletRegistrationBean.addInitParameter("targetUri", zlmProxy);servletRegistrationBean.addUrlMappings();if (logger.isDebugEnabled()) {servletRegistrationBean.addInitParameter("log", "true");}return servletRegistrationBean;}class ZlmProxyServlet extends ProxyServlet{@Overrideprotected String rewriteQueryStringFromRequest(HttpServletRequest servletRequest, String queryString) {String queryStr = super.rewriteQueryStringFromRequest(servletRequest, queryString);MediaServerItem mediaInfo = getMediaInfoByUri(servletRequest.getRequestURI());if (mediaInfo != null) {if (!ObjectUtils.isEmpty(queryStr)) {queryStr += "&secret=" + mediaInfo.getSecret();}else {queryStr = "secret=" + mediaInfo.getSecret();}}return queryStr;}/*** 异常处理*/@Overrideprotected void handleRequestException(HttpRequest proxyRequest, HttpResponse proxyResonse, Exception e){try {super.handleRequestException(proxyRequest, proxyResonse, e);} catch (ServletException servletException) {logger.error("zlm 代理失败： ", e);} catch (IOException ioException) {if (ioException instanceof ConnectException) {logger.error("zlm 连接失败");} else if (ioException instanceof ClientAbortException) {logger.error("zlm: 用户已中断连接，代理终止");} else {logger.error("zlm 代理失败： ", e);}} catch (RuntimeException exception){logger.error("zlm 代理失败： ", e);}}/*** 对于为按照格式请求的可以直接返回404*/@Overrideprotected String getTargetUri(HttpServletRequest servletRequest) {String requestURI = servletRequest.getRequestURI();MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);String uri = null;if (mediaInfo != null) {
//                String realRequestURI = requestURI.substring(requestURI.indexOf(mediaInfo.getId())+ mediaInfo.getId().length());uri = String.format("http://%s:%s", mediaInfo.getIp(), mediaInfo.getHttpPort());}else {uri = "http://127.0.0.1:" + serverPort +"/index/hook/null"; // 只是一个能返回404的请求而已， 其他的也可以}return uri;}/*** 动态替换请求目标*/@Overrideprotected HttpHost getTargetHost(HttpServletRequest servletRequest) {String requestURI = servletRequest.getRequestURI();MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);HttpHost host;if (mediaInfo != null) {host = new HttpHost(mediaInfo.getIp(), mediaInfo.getHttpPort());}else {host = new HttpHost("127.0.0.1", serverPort);}return host;}/*** 根据uri获取流媒体信息*/MediaServerItem getMediaInfoByUri(String uri){String[] split = uri.split("/");String mediaServerId = split[2];if ("default".equalsIgnoreCase(mediaServerId)) {return mediaServerService.getDefaultMediaServer();}else {return mediaServerService.getOne(mediaServerId);}}/*** 去掉url中的标志信息*/@Overrideprotected String rewriteUrlFromRequest(HttpServletRequest servletRequest) {String requestURI = servletRequest.getRequestURI();MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);String url = super.rewriteUrlFromRequest(servletRequest);if (mediaInfo == null) {logger.error("[ZLM服务访问代理]，错误：处理url信息时未找到流媒体信息=>{}", requestURI);return  url;}if (!ObjectUtils.isEmpty(mediaInfo.getId())) {url = url.replace(mediaInfo.getId() + "/", "");}return url.replace("default/", "");}}@Beanpublic ServletRegistrationBean recordServletRegistrationBean(){ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new RecordProxyServlet(),"/record_proxy/*");servletRegistrationBean.setName("record_proxy");servletRegistrationBean.addInitParameter("targetUri", recordProxy);servletRegistrationBean.addUrlMappings();if (logger.isDebugEnabled()) {servletRegistrationBean.addInitParameter("log", "true");}return servletRegistrationBean;}class RecordProxyServlet extends ProxyServlet{@Overrideprotected String rewriteQueryStringFromRequest(HttpServletRequest servletRequest, String queryString) {String queryStr = super.rewriteQueryStringFromRequest(servletRequest, queryString);MediaServerItem mediaInfo = getMediaInfoByUri(servletRequest.getRequestURI());String remoteHost = String.format("http://%s:%s", mediaInfo.getIp(), mediaInfo.getHttpPort());if (mediaInfo != null) {if (!ObjectUtils.isEmpty(queryStr)) {queryStr += "&remoteHost=" + remoteHost;}else {queryStr = "remoteHost=" + remoteHost;}}return queryStr;}/*** 异常处理*/@Overrideprotected void handleRequestException(HttpRequest proxyRequest, HttpResponse proxyResponse, Exception e){try {super.handleRequestException(proxyRequest, proxyResponse, e);} catch (ServletException servletException) {logger.error("录像服务 代理失败： ", e);} catch (IOException ioException) {if (ioException instanceof ConnectException) {logger.error("录像服务 连接失败");} else if (ioException instanceof ClientAbortException) {logger.error("录像服务:用户已中断连接，代理终止");} else {logger.error("录像服务 代理失败： ", e);}} catch (RuntimeException exception){logger.error("录像服务 代理失败： ", e);}}/*** 对于为按照格式请求的可以直接返回404*/@Overrideprotected String getTargetUri(HttpServletRequest servletRequest) {String requestURI = servletRequest.getRequestURI();MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);String uri = null;if (mediaInfo != null) {
//                String realRequestURI = requestURI.substring(requestURI.indexOf(mediaInfo.getId())+ mediaInfo.getId().length());uri = String.format("http://%s:%s", mediaInfo.getIp(), mediaInfo.getRecordAssistPort());}else {uri = "http://127.0.0.1:" + serverPort +"/index/hook/null"; // 只是一个能返回404的请求而已， 其他的也可以}return uri;}/*** 动态替换请求目标*/@Overrideprotected HttpHost getTargetHost(HttpServletRequest servletRequest) {String requestURI = servletRequest.getRequestURI();MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);HttpHost host;if (mediaInfo != null) {host = new HttpHost(mediaInfo.getIp(), mediaInfo.getRecordAssistPort());}else {host = new HttpHost("127.0.0.1", serverPort);}return host;}/*** 根据uri获取流媒体信息*/MediaServerItem getMediaInfoByUri(String uri){String[] split = uri.split("/");String mediaServerId = split[2];if ("default".equalsIgnoreCase(mediaServerId)) {return mediaServerService.getDefaultMediaServer();}else {return mediaServerService.getOne(mediaServerId);}}/*** 去掉url中的标志信息*/@Overrideprotected String rewriteUrlFromRequest(HttpServletRequest servletRequest) {String requestURI = servletRequest.getRequestURI();MediaServerItem mediaInfo = getMediaInfoByUri(requestURI);String url = super.rewriteUrlFromRequest(servletRequest);if (mediaInfo == null) {logger.error("[录像服务访问代理]，错误：处理url信息时未找到流媒体信息=>{}", requestURI);return  url;}if (!ObjectUtils.isEmpty(mediaInfo.getId())) {url = url.replace(mediaInfo.getId() + "/", "");}return url.replace("default/", "");}}}

application.yml

spring:# [可选]上传文件大小限制servlet:multipart:max-file-size: 10MBmax-request-size: 100MB# REDIS数据库配置redis:# [必须修改] Redis服务器IP, REDIS安装在本机的,使用127.0.0.1host: 127.0.0.1# [必须修改] 端口号port: 6379# [可选] 数据库 DBdatabase: 8# [可选] 访问密码,若你的redis服务器没有设置密码，就不需要用密码去连接password:# [可选] 超时时间timeout: 10000# mysql数据源datasource:type: com.alibaba.druid.pool.DruidDataSourcedriver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/wvp_db?useUnicode=true&characterEncoding=UTF8&rewriteBatchedStatements=true&serverTimezone=PRC&useSSL=false&allowMultiQueries=trueusername: rootpassword: 123456druid:initialSize: 10                       # 连接池初始化连接数maxActive: 200                        # 连接池最大连接数minIdle: 5                            # 连接池最小空闲连接数maxWait: 60000                        # 获取连接时最大等待时间，单位毫秒。配置了maxWait之后，缺省启用公平锁，并发效率会有所下降，如果需要可以通过配置useUnfairLock属性为true使用非公平锁。keepAlive: true                       # 连接池中的minIdle数量以内的连接，空闲时间超过minEvictableIdleTimeMillis，则会执行keepAlive操作。validationQuery: select 1             # 检测连接是否有效sql，要求是查询语句，常用select 'x'。如果validationQuery为null，testOnBorrow、testOnReturn、testWhileIdle都不会起作用。testWhileIdle: true                   # 建议配置为true，不影响性能，并且保证安全性。申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效。testOnBorrow: false                   # 申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。testOnReturn: false                   # 归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。poolPreparedStatements: false         # 是否開啟PSCache，並且指定每個連線上PSCache的大小timeBetweenEvictionRunsMillis: 60000  # 配置間隔多久才進行一次檢測，檢測需要關閉的空閒連線，單位是毫秒minEvictableIdleTimeMillis: 300000    # 配置一個連線在池中最小生存的時間，單位是毫秒filters: stat,slf4j             # 配置监控统计拦截的filters，监控统计用的filter:sta, 日志用的filter:log4juseGlobalDataSourceStat: true         # 合并多个DruidDataSource的监控数据# 通过connectProperties属性来打开mergeSql功能；慢SQL记录connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=1000#stat-view-servlet.url-pattern: /admin/druid/*#[可选] WVP监听的HTTP端口, 网页和接口调用都是这个端口
server:port: 18080# 作为28181服务器的配置
sip:# [必须修改] 本机的IPip: 192.168.2.138# [可选] 28181服务监听的端口port: 5060# 根据国标6.1.2中规定，domain宜采用ID统一编码的前十位编码。国标附录D中定义前8位为中心编码（由省级、市级、区级、基层编号组成，参照GB/T 2260-2007）# 后两位为行业编码，定义参照附录D.3# 3701020049标识山东济南历下区 信息行业接入# [可选]domain: 4401020049# [可选]id: 44010200492000000001# [可选] 默认设备认证密码，后续扩展使用设备单独密码, 移除密码将不进行校验password: admin123#zlm 默认服务器配置
media:id: PX5YGOUtvK56qhTq# [必须修改] zlm服务器的内网IPip: 内网IP# [必须修改] zlm服务器的http.porthttp-port: 8180# [可选] zlm服务器的hook.admin_params=secretsecret: 035c73f7-bb6b-4889-a715-d9eb2d1925cc# 启用多端口模式, 多端口模式使用端口区分每路流，兼容性更好。 单端口使用流的ssrc区分， 点播超时建议使用多端口测试rtp:# [可选] 是否启用多端口模式, 开启后会在portRange范围内选择端口用于媒体流传输enable: true# [可选] 在此范围内选择端口用于媒体流传输, 必须提前在zlm上配置该属性，不然自动配置此属性可能不成功port-range: 30000,30500 # 端口范围# [可选] 国标级联在此范围内选择端口发送媒体流,send-port-range: 30000,30500 # 端口范围# 录像辅助服务， 部署此服务可以实现zlm录像的管理与下载， 0 表示不使用record-assist-port: 0
# [可选] 日志配置, 一般不需要改
logging:config: classpath:logback-spring-local.xmlzlm:zlmproxy: http://公网ip:6080recordproxy: http://公网ip:18081

使用maven 打包为jar

mvn install

部署到服务器即可