From 38f29e38fcc668171dc05c53d40a36b895c86102 Mon Sep 17 00:00:00 2001 From: liusuyi <1951119284@qq.com> Date: 星期四, 10 十月 2024 13:34:28 +0800 Subject: [PATCH] init --- ard-work/src/main/java/com/ruoyi/utils/forest/MediaClient.java | 98 +++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 87 insertions(+), 11 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/utils/forest/MediaClient.java b/ard-work/src/main/java/com/ruoyi/utils/forest/MediaClient.java index 0f8adfc..1f37783 100644 --- a/ard-work/src/main/java/com/ruoyi/utils/forest/MediaClient.java +++ b/ard-work/src/main/java/com/ruoyi/utils/forest/MediaClient.java @@ -1,10 +1,10 @@ package com.ruoyi.utils.forest; -import com.dtflys.forest.annotation.Get; -import com.dtflys.forest.annotation.JSONBody; -import com.dtflys.forest.annotation.Post; -import com.dtflys.forest.annotation.Var; -import com.ruoyi.media.domain.Conf; +import com.dtflys.forest.annotation.*; +import com.ruoyi.media.domain.*; + +import java.nio.file.Path; +import java.util.List; /** * @Description: mediamtx娴佸獟浣撳鎴风 @@ -13,14 +13,90 @@ * @Date: 2023骞�07鏈�06鏃�9:51 * @Version: 1.0 **/ +@BaseRequest(baseURL = "http://#{mediamtx.host}:9997/v3") public interface MediaClient { + /** + * 澧炲姞璺緞 + */ + @Post("/config/paths/add/{name}") + public String addPath(@Var("name") String name, @JSONBody Conf body); - @Post("{apiUrl}/config/paths/add/{name}") - String add(@Var("apiUrl") String apiUrl,@Var("name") String name, @JSONBody Conf body); + /** + * 淇敼璺緞 + */ + @Patch("/config/paths/patch/{name}") + public String editPath(@Var("name") String name, @JSONBody Conf body); - @Post("{apiUrl}/config/paths/remove/{name}") - String remove(@Var("apiUrl") String apiUrl,@Var("name") String name); + /** + * 绉婚櫎璺緞 + */ + @Delete("/config/paths/delete/{name}") + public String removePath(@Var("name") String name); - @Get("{apiUrl}/paths/list") - String list(@Var("apiUrl") String apiUrl); + /** + * 鑾峰彇璺緞璇︽儏 + */ + @Get(url = "/config/paths/get/{name}") + public Conf getPathInfo(@Var("name") String name); + + /** + * 鏌ヨ鎵�鏈夎矾寰� + */ + @Get("/paths/list?page={pageNum}&itemsPerPage={pageSize}") + public Paths paths(@Var("pageNum") Integer pageNum, @Var("pageSize") Integer pageSize); + + /** + * 鏌ヨ鎵�鏈塺tsp浼氳瘽 + */ + @Get("/rtspsessions/list?page={pageNum}&itemsPerPage={pageSize}") + public RtspSessions rtspsessions(@Var("pageNum") Integer pageNum, @Var("pageSize") Integer pageSize); + + /** + * 鏌ヨ鎵�鏈墂ebrt浼氳瘽 + */ + @Get("/webrtcsessions/list?page={pageNum}&itemsPerPage={pageSize}") + public WebrtcSessions webrtcsessions(@Var("pageNum") Integer pageNum, @Var("pageSize") Integer pageSize); + + /** + * 鏌ヨ鎵�鏈塺tmp浼氳瘽 + */ + @Get("/rtmpsessions/list?page={pageNum}&itemsPerPage={pageSize}") + public RtmpSessions rtmpsessions(@Var("pageNum") Integer pageNum, @Var("pageSize") Integer pageSize); + + /** + * 鎸塻essionId鏌ヨrtsp浼氳瘽 + */ + @Get("/rtspsessions/get/{sessionId}") + public RtspSession getRtspsessionById(@Var("sessionId") String sessionId); + + /** + * 鎸塻essionId鏌ヨwebrtc浼氳瘽 + */ + @Get("/webrtcsessions/get/{sessionId}") + public WebrtcSession getWebrtcsessionById(@Var("sessionId") String sessionId); + + /** + * 鎸塻essionId鏌ヨrtmp浼氳瘽 + */ + @Get("/rtmpconns/get/{sessionId}") + public RtmpSession getRtmpsessionById(@Var("sessionId") String sessionId); + + /** + * 鎸塻essionId鍒犻櫎rtsp浼氳瘽 + */ + @Post("/rtspsessions/kick/{sessionId}") + public String kickRtspSessions(@Var("sessionId") String sessionId); + + /** + * 鎸塻essionId鍒犻櫎rtmp杩炴帴 + */ + @Post("/rtmpconns/kick/{sessionId}") + public String kickRtmpSessions(@Var("sessionId") String sessionId); + + /** + * 鎸塻essionId鍒犻櫎webrtc浼氳瘽 + */ + @Post("/webrtcsessions/kick/{sessionId}") + public String kickWebrtcSessions(@Var("sessionId") String sessionId); + } -- Gitblit v1.9.3