去除hook 自动识别127.0.0.1

648540858

2020-12-07 42ebf24ad4e19b6dcb5d3704f11523ab4e93cf9e

 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java

@@ -1,152 +1,354 @@
package com.genersoft.iot.vmp.media.zlm;



import java.math.BigInteger;

import java.text.DecimalFormat;

import java.util.ArrayList;

import java.util.List;



import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONArray;

import com.genersoft.iot.vmp.common.StreamInfo;

import com.genersoft.iot.vmp.conf.MediaServerConfig;

import com.genersoft.iot.vmp.storager.IVideoManagerStorager;

import com.genersoft.iot.vmp.utils.IpUtil;

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.http.HttpStatus;

import org.springframework.http.ResponseEntity;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.ResponseBody;

import org.springframework.web.bind.annotation.RestController;



import com.alibaba.fastjson.JSONObject;

import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommander;



import javax.servlet.http.HttpServletRequest;



/**    

 * @Description:针对 ZLMediaServer的hook事件监听

 * @author: songww

 * @author: swwheihei

 * @date:   2020年5月8日 上午10:46:48     

 */

@RestController

@RequestMapping("/hook/zlm")

@RequestMapping("/index/hook")

public class ZLMHttpHookListener {



   private final static Logger logger = LoggerFactory.getLogger(ZLMHttpHookListener.class);

	




   @Autowired

   private SIPCommander cmder;



   @Autowired

   private IVideoManagerStorager storager;



   @Autowired

   private ZLMRESTfulUtils zlmresTfulUtils;



   @Value("${media.ip}")

   private String mediaIp;



   @Value("${media.port}")

   private int mediaPort;



   /**

    * 流量统计事件，播放器或推流器断开时并且耗用流量超过特定阈值时会触发此事件，阈值通过配置文件general.flowThreshold配置；此事件对回复不敏感。

    *  

    */

   @PostMapping("/on_flow_report")

   public ResponseEntity onFlowReport(){

      // TODO Auto-generated method stub

   @ResponseBody

   @PostMapping(value = "/on_flow_report", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onFlowReport(@RequestBody JSONObject json){

      

      return null;

      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_flow_report API调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub



		
      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * 访问http文件服务器上hls之外的文件时触发。

    *  

    */

   @PostMapping("/on_http_access")

   public ResponseEntity onHttpAccess(){

   @ResponseBody

   @PostMapping(value = "/on_http_access", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onHttpAccess(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_http_access API 调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub

      

      return null;

      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("err", "");

      ret.put("path", "");

      ret.put("second", 600);

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * 播放器鉴权事件，rtsp/rtmp/http-flv/ws-flv/hls的播放都将触发此鉴权事件。

    *  

    */

   @PostMapping("/on_play")

   public ResponseEntity onPlay(){

   @ResponseBody

   @PostMapping(value = "/on_play", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onPlay(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_play API调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub

      

      return null;

      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * rtsp/rtmp/rtp推流鉴权事件。

    *  

    */

   @PostMapping("/on_publish")

   public ResponseEntity onPublish(){

   @ResponseBody

   @PostMapping(value = "/on_publish", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onPublish(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_publish API调用，参数：" + json.toString());

      }

      String app = json.getString("app");

      String streamId = json.getString("id");

      if ("rtp".equals(app)) {

         String ssrc = new DecimalFormat("0000000000").format(Integer.parseInt(streamId, 16));

         StreamInfo streamInfoForPlay = storager.queryPlayBySSRC(ssrc);

         if ("rtp".equals(app) && streamInfoForPlay != null ) {

            MediaServerConfig mediaInfo = storager.getMediaInfo();

            streamInfoForPlay.setFlv(String.format("http://%s:%s/rtp/%s.flv", mediaInfo.getWanIp(), mediaInfo.getHttpPort(), streamId));

            streamInfoForPlay.setWs_flv(String.format("ws://%s:%s/rtp/%s.flv", mediaInfo.getWanIp(), mediaInfo.getHttpPort(), streamId));

            streamInfoForPlay.setRtmp(String.format("rtmp://%s:%s/rtp/%s", mediaInfo.getWanIp(), mediaInfo.getRtmpPort(), streamId));

            streamInfoForPlay.setHls(String.format("http://%s:%s/rtp/%s/hls.m3u8", mediaInfo.getWanIp(), mediaInfo.getHttpPort(), streamId));

            streamInfoForPlay.setRtsp(String.format("rtsp://%s:%s/rtp/%s", mediaInfo.getWanIp(), mediaInfo.getRtspPort(), streamId));

            storager.startPlay(streamInfoForPlay);

         }



         StreamInfo streamInfoForPlayBack = storager.queryPlaybackBySSRC(ssrc);

         if ("rtp".equals(app) && streamInfoForPlayBack != null ) {

            MediaServerConfig mediaInfo = storager.getMediaInfo();

            streamInfoForPlayBack.setFlv(String.format("http://%s:%s/rtp/%s.flv", mediaInfo.getWanIp(), mediaInfo.getHttpPort(), streamId));

            streamInfoForPlayBack.setWs_flv(String.format("ws://%s:%s/rtp/%s.flv", mediaInfo.getWanIp(), mediaInfo.getHttpPort(), streamId));

            streamInfoForPlayBack.setRtmp(String.format("rtmp://%s:%s/rtp/%s", mediaInfo.getWanIp(), mediaInfo.getRtmpPort(), streamId));

            streamInfoForPlayBack.setHls(String.format("http://%s:%s/rtp/%s/hls.m3u8", mediaInfo.getWanIp(), mediaInfo.getHttpPort(), streamId));

            streamInfoForPlayBack.setRtsp(String.format("rtsp://%s:%s/rtp/%s", mediaInfo.getWanIp(), mediaInfo.getRtspPort(), streamId));

            storager.startPlayback(streamInfoForPlayBack);

         }

      }



      // TODO Auto-generated method stub

      

      return null;

      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

      ret.put("enableHls", true);

      ret.put("enableMP4", false);

      ret.put("enableRtxp", true);

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * 录制mp4完成后通知事件；此事件对回复不敏感。

    *  

    */

   @PostMapping("/on_record_mp4")

   public ResponseEntity onRecordMp4(){

   @ResponseBody

   @PostMapping(value = "/on_record_mp4", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onRecordMp4(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_record_mp4 API调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub

      

      return null;

   }

	
   /**

    * 该rtsp流是否开启rtsp专用方式的鉴权事件，开启后才会触发on_rtsp_auth事件。需要指出的是rtsp也支持url参数鉴权，它支持两种方式鉴权。

    *  
    */

   @PostMapping("/on_rtsp_auth")

   public ResponseEntity onRtspAuth(){

      // TODO Auto-generated method stub

		
      return null;

      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * rtsp专用的鉴权事件，先触发on_rtsp_realm事件然后才会触发on_rtsp_auth事件。

    *  

    */

   @PostMapping("/on_rtsp_realm")

   public ResponseEntity onRtspRealm(){

   @ResponseBody

   @PostMapping(value = "/on_rtsp_realm", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onRtspRealm(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_rtsp_realm API调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub

      

      return null;

      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("realm", "");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

	
	
   /**

    * 该rtsp流是否开启rtsp专用方式的鉴权事件，开启后才会触发on_rtsp_auth事件。需要指出的是rtsp也支持url参数鉴权，它支持两种方式鉴权。

    *  
    */

   @ResponseBody

   @PostMapping(value = "/on_rtsp_auth", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onRtspAuth(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_rtsp_auth API调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub

		
      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("encrypted", false);

      ret.put("passwd", "test");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * shell登录鉴权，ZLMediaKit提供简单的telnet调试方式，使用telnet 127.0.0.1 9000能进入MediaServer进程的shell界面。

    *  

    */

   @PostMapping("/on_shell_login")

   public ResponseEntity onShellLogin(){

   @ResponseBody

   @PostMapping(value = "/on_shell_login", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onShellLogin(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_shell_login API调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub

      

      return null;

      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * rtsp/rtmp流注册或注销时触发此事件；此事件对回复不敏感。

    *  

    */

   @PostMapping("/on_stream_changed")

   public ResponseEntity onStreamChanged(){

      // TODO Auto-generated method stub

   @ResponseBody

   @PostMapping(value = "/on_stream_changed", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onStreamChanged(@RequestBody JSONObject json){

      

      return null;

      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_stream_changed API调用，参数：" + json.toString());

      }

      // 流消失移除redis play

      String app = json.getString("app");

      String streamId = json.getString("stream");

      boolean regist = json.getBoolean("regist");

//      String ssrc = String.format("%10d", Integer.parseInt(streamId, 16)); // ZLM 要求大写且首位补零

      String ssrc = new DecimalFormat("0000000000").format(Integer.parseInt(streamId, 16));

      StreamInfo streamInfo = storager.queryPlayBySSRC(ssrc);

      if ("rtp".equals(app) && !regist ) {

         if (streamInfo!=null){

            storager.stopPlay(streamInfo);

         }else{

            streamInfo = storager.queryPlaybackBySSRC(ssrc);

            storager.stopPlayback(streamInfo);

         }

      }





      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * 流无人观看时事件，用户可以通过此事件选择是否关闭无人看的流。

    *  

    */

   @PostMapping("/on_stream_none_reader")

   public ResponseEntity onStreamNoneReader(){

      // TODO Auto-generated method stub

   @ResponseBody

   @PostMapping(value = "/on_stream_none_reader", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onStreamNoneReader(@RequestBody JSONObject json){

      

      return null;

      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_stream_none_reader API调用，参数：" + json.toString());

      }

		
      BigInteger bigint=new BigInteger(json.getString("stream"), 16);

      int numb=bigint.intValue();

      String ssrc = String.format("%010d", numb); 
		
      cmder.streamByeCmd(ssrc);

      StreamInfo streamInfo = storager.queryPlayBySSRC(ssrc);

      if (streamInfo!=null){

         storager.stopPlay(streamInfo);

      }else{

         streamInfo = storager.queryPlaybackBySSRC(ssrc);

         storager.stopPlayback(streamInfo);

      }

		
      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("close", true);

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * 流未找到事件，用户可以在此事件触发时，立即去拉流，这样可以实现按需拉流；此事件对回复不敏感。

    *  

    */

   @PostMapping("/on_stream_not_found")

   public ResponseEntity onStreamNotFound(){

   @ResponseBody

   @PostMapping(value = "/on_stream_not_found", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onStreamNotFound(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_stream_not_found API调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub

      

      return null;

      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

   

   /**

    * 服务器启动事件，可以用于监听服务器崩溃重启；此事件对回复不敏感。

    *  

    */

   @PostMapping("/on_server_started")

   public ResponseEntity onServerStarted(){

   @ResponseBody

   @PostMapping(value = "/on_server_started", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onServerStarted(HttpServletRequest request, @RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_server_started API调用，参数：" + json.toString());

      }



//      String data = json.getString("data");

//      List<MediaServerConfig> mediaServerConfigs = JSON.parseArray(JSON.toJSONString(json), MediaServerConfig.class);

//      MediaServerConfig mediaServerConfig = mediaServerConfigs.get(0);

      MediaServerConfig mediaServerConfig = JSON.toJavaObject(json, MediaServerConfig.class);

      mediaServerConfig.setLocalIP(mediaIp);

      storager.updateMediaInfo(mediaServerConfig);

      // TODO Auto-generated method stub

      

      return null;

      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }

}