From 1ce76e9f565ab9dcac835c827b7fae127b39320a Mon Sep 17 00:00:00 2001 From: WenG <450292408@qq.com> Date: Fri, 22 Apr 2022 22:30:34 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9Esrs=20rtmp=E5=9B=9E=E8=B0=83?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/srs/rtmp/RtmpCallbackController.java | 58 -------- .../srs/rtmp/RtmpCallbackAppController.java | 74 +++++++++ .../pojo/vos/srs/rtmp/RtmpCallbackVO.java | 140 ++++++++++++++++++ 3 files changed, 214 insertions(+), 58 deletions(-) delete mode 100644 module-file-media/src/main/java/ink/wgink/module/file/media/controller/api/srs/rtmp/RtmpCallbackController.java create mode 100644 module-file-media/src/main/java/ink/wgink/module/file/media/controller/app/srs/rtmp/RtmpCallbackAppController.java diff --git a/module-file-media/src/main/java/ink/wgink/module/file/media/controller/api/srs/rtmp/RtmpCallbackController.java b/module-file-media/src/main/java/ink/wgink/module/file/media/controller/api/srs/rtmp/RtmpCallbackController.java deleted file mode 100644 index bc575b2d..00000000 --- a/module-file-media/src/main/java/ink/wgink/module/file/media/controller/api/srs/rtmp/RtmpCallbackController.java +++ /dev/null @@ -1,58 +0,0 @@ -package ink.wgink.module.file.media.controller.api.srs.rtmp; - -import ink.wgink.common.base.DefaultBaseController; -import ink.wgink.interfaces.consts.ISystemConstant; -import ink.wgink.pojo.result.SuccessResultCode; -import io.swagger.annotations.Api; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; - -/** - * @ClassName: RtmpController - * @Description: rtmp 回调 - * @Author: wanggeng - * @Date: 2022/4/22 10:39 - * @Version: 1.0 - */ -@Api(tags = ISystemConstant.API_TAGS_SYSTEM_PREFIX + "rtmp接口") -@RestController -@RequestMapping(ISystemConstant.API_PREFIX + "/rtmp") -public class RtmpCallbackController extends DefaultBaseController { - - @PostMapping("on-connect") - public SuccessResultCode onConnect() { - return new SuccessResultCode<>(0); - } - - @PostMapping("on-onClose") - public SuccessResultCode onClose() { - return new SuccessResultCode<>(0); - } - - @PostMapping("on-onPublish") - public SuccessResultCode onPublish() { - return new SuccessResultCode<>(0); - } - - @PostMapping("on-onUnPublish") - public SuccessResultCode onUnPublish() { - return new SuccessResultCode<>(0); - } - - @PostMapping("on-onPlay") - public SuccessResultCode onPlay() { - return new SuccessResultCode<>(0); - } - - @PostMapping("on-onStop") - public SuccessResultCode onStop() { - return new SuccessResultCode<>(0); - } - - @PostMapping("on-onDvr") - public SuccessResultCode onDvr() { - return new SuccessResultCode<>(0); - } - -} diff --git a/module-file-media/src/main/java/ink/wgink/module/file/media/controller/app/srs/rtmp/RtmpCallbackAppController.java b/module-file-media/src/main/java/ink/wgink/module/file/media/controller/app/srs/rtmp/RtmpCallbackAppController.java new file mode 100644 index 00000000..a80e96d0 --- /dev/null +++ b/module-file-media/src/main/java/ink/wgink/module/file/media/controller/app/srs/rtmp/RtmpCallbackAppController.java @@ -0,0 +1,74 @@ +package ink.wgink.module.file.media.controller.app.srs.rtmp; + +import ink.wgink.common.base.DefaultBaseController; +import ink.wgink.interfaces.consts.ISystemConstant; +import ink.wgink.module.file.media.pojo.vos.srs.rtmp.RtmpCallbackVO; +import ink.wgink.pojo.result.SuccessResultCode; +import io.swagger.annotations.Api; +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.RestController; + +/** + * @ClassName: RtmpController + * @Description: rtmp 回调 + * @Author: wanggeng + * @Date: 2022/4/22 10:39 + * @Version: 1.0 + */ +@Api(tags = ISystemConstant.API_TAGS_APP_PREFIX + "rtmp回调接口") +@RestController +@RequestMapping(ISystemConstant.APP_PREFIX + "/rtmp-callback") +public class RtmpCallbackAppController extends DefaultBaseController { + + @PostMapping("on-connect") + public SuccessResultCode onConnect(@RequestBody RtmpCallbackVO rtmpCallbackVO) { + System.out.println("onConnect"); + System.out.println(rtmpCallbackVO); + return new SuccessResultCode<>(0); + } + + @PostMapping("on-close") + public SuccessResultCode onClose(@RequestBody RtmpCallbackVO rtmpCallbackVO) { + System.out.println("onClose"); + System.out.println(rtmpCallbackVO); + return new SuccessResultCode<>(0); + } + + @PostMapping("on-publish") + public SuccessResultCode onPublish(@RequestBody RtmpCallbackVO rtmpCallbackVO) { + System.out.println("onPublish"); + System.out.println(rtmpCallbackVO); + return new SuccessResultCode<>(0); + } + + @PostMapping("on-unpublish") + public SuccessResultCode onUnPublish(@RequestBody RtmpCallbackVO rtmpCallbackVO) { + System.out.println("onUnPublish"); + System.out.println(rtmpCallbackVO); + return new SuccessResultCode<>(0); + } + + @PostMapping("on-play") + public SuccessResultCode onPlay(@RequestBody RtmpCallbackVO rtmpCallbackVO) { + System.out.println("onPlay"); + System.out.println(rtmpCallbackVO); + return new SuccessResultCode<>(0); + } + + @PostMapping("on-stop") + public SuccessResultCode onStop(@RequestBody RtmpCallbackVO rtmpCallbackVO) { + System.out.println("onStop"); + System.out.println(rtmpCallbackVO); + return new SuccessResultCode<>(0); + } + + @PostMapping("on-dvr") + public SuccessResultCode onDvr(@RequestBody RtmpCallbackVO rtmpCallbackVO) { + System.out.println("onDvr"); + System.out.println(rtmpCallbackVO); + return new SuccessResultCode<>(0); + } + +} diff --git a/module-file-media/src/main/java/ink/wgink/module/file/media/pojo/vos/srs/rtmp/RtmpCallbackVO.java b/module-file-media/src/main/java/ink/wgink/module/file/media/pojo/vos/srs/rtmp/RtmpCallbackVO.java index f3cfb13c..dbc0afaa 100644 --- a/module-file-media/src/main/java/ink/wgink/module/file/media/pojo/vos/srs/rtmp/RtmpCallbackVO.java +++ b/module-file-media/src/main/java/ink/wgink/module/file/media/pojo/vos/srs/rtmp/RtmpCallbackVO.java @@ -21,5 +21,145 @@ public class RtmpCallbackVO { private String pageUrl; private String send_bytes; private String recv_bytes; + private String stream; + private String param; + private String cwd; + private String file; + public String getAction() { + return action; + } + + public void setAction(String action) { + this.action = action; + } + + public String getClient_id() { + return client_id; + } + + public void setClient_id(String client_id) { + this.client_id = client_id; + } + + public String getIp() { + return ip; + } + + public void setIp(String ip) { + this.ip = ip; + } + + public String getVhost() { + return vhost; + } + + public void setVhost(String vhost) { + this.vhost = vhost; + } + + public String getApp() { + return app; + } + + public void setApp(String app) { + this.app = app; + } + + public String getTcUrl() { + return tcUrl; + } + + public void setTcUrl(String tcUrl) { + this.tcUrl = tcUrl; + } + + public String getPageUrl() { + return pageUrl; + } + + public void setPageUrl(String pageUrl) { + this.pageUrl = pageUrl; + } + + public String getSend_bytes() { + return send_bytes; + } + + public void setSend_bytes(String send_bytes) { + this.send_bytes = send_bytes; + } + + public String getRecv_bytes() { + return recv_bytes; + } + + public void setRecv_bytes(String recv_bytes) { + this.recv_bytes = recv_bytes; + } + + public String getStream() { + return stream; + } + + public void setStream(String stream) { + this.stream = stream; + } + + public String getParam() { + return param; + } + + public void setParam(String param) { + this.param = param; + } + + public String getCwd() { + return cwd; + } + + public void setCwd(String cwd) { + this.cwd = cwd; + } + + public String getFile() { + return file; + } + + public void setFile(String file) { + this.file = file; + } + + @Override + public String toString() { + return "{\"RtmpCallbackVO\":{" + + "\"action\":\"" + + action + '\"' + + ",\"client_id\":\"" + + client_id + '\"' + + ",\"ip\":\"" + + ip + '\"' + + ",\"vhost\":\"" + + vhost + '\"' + + ",\"app\":\"" + + app + '\"' + + ",\"tcUrl\":\"" + + tcUrl + '\"' + + ",\"pageUrl\":\"" + + pageUrl + '\"' + + ",\"send_bytes\":\"" + + send_bytes + '\"' + + ",\"recv_bytes\":\"" + + recv_bytes + '\"' + + ",\"stream\":\"" + + stream + '\"' + + ",\"param\":\"" + + param + '\"' + + ",\"cwd\":\"" + + cwd + '\"' + + ",\"file\":\"" + + file + '\"' + + "}}"; + + } }