[*] 日常优化

This commit is contained in:
acgist
2023-07-03 08:17:15 +08:00
parent 1235d13333
commit 4bdb2395a2
4 changed files with 38 additions and 12 deletions

View File

@@ -1454,8 +1454,6 @@ class Taoyao {
} }
} }
// TODOcontinue
/** /**
* 路由RTP协商信令 * 路由RTP协商信令
* *
@@ -1463,9 +1461,10 @@ class Taoyao {
* @param {*} body 消息主体 * @param {*} body 消息主体
*/ */
mediaRouterRtpCapabilities(message, body) { mediaRouterRtpCapabilities(message, body) {
const me = this;
const { roomId } = body; const { roomId } = body;
const room = this.rooms.get(roomId); const room = me.rooms.get(roomId);
message.body.rtpCapabilities = room.mediasoupRouter.rtpCapabilities; message.body.rtpCapabilities = room?.mediasoupRouter.rtpCapabilities;
this.push(message); this.push(message);
} }
@@ -1476,17 +1475,20 @@ class Taoyao {
* @param {*} body 消息主体 * @param {*} body 消息主体
*/ */
async mediaTransportClose(message, body) { async mediaTransportClose(message, body) {
const me = this;
const { roomId, transportId } = body; const { roomId, transportId } = body;
const room = this.rooms.get(roomId); const room = me.rooms.get(roomId);
const transport = room?.transports.get(transportId); const transport = room?.transports.get(transportId);
if(transport) { if(transport) {
console.info("关闭传输通道", transportId); console.info("关闭传输通道", transportId);
transport.close(); await transport.close();
} else { } else {
console.info("关闭传输通道无效", transportId); console.debug("关闭传输通道无效", transportId);
} }
} }
// TODOcontinue
/** /**
* 创建RTP输入通道信令 * 创建RTP输入通道信令
* *

View File

@@ -1781,10 +1781,22 @@ class Taoyao extends RemoteClient {
); );
return response.body; return response.body;
} }
async roomClientListId(clientId) {
const me = this;
const response = await this.request(
protocol.buildMessage("room::client::list::id", {
roomId : me.roomId,
clientId: clientId
})
);
return response.body;
}
async roomClientList() { async roomClientList() {
const me = this; const me = this;
const response = await this.request( const response = await this.request(
protocol.buildMessage("room::client::list", { roomId: me.roomId }) protocol.buildMessage("room::client::list", {
roomId: me.roomId
})
); );
return response.body; return response.body;
} }

View File

@@ -30,7 +30,7 @@ import com.acgist.taoyao.signal.protocol.ProtocolRoomAdapter;
} }
""" """
}, },
flow = { "终端->信令服务->媒体服务->信令服务->终端"} flow = { "终端=>信令服务->媒体服务->信令服务->终端"}
) )
public class MediaRouterRtpCapabilitiesProtocol extends ProtocolRoomAdapter { public class MediaRouterRtpCapabilitiesProtocol extends ProtocolRoomAdapter {

View File

@@ -2,6 +2,8 @@ package com.acgist.taoyao.signal.protocol.media;
import java.util.Map; import java.util.Map;
import com.acgist.taoyao.boot.annotation.Description;
import com.acgist.taoyao.boot.annotation.Protocol;
import com.acgist.taoyao.boot.model.Message; import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.Client; import com.acgist.taoyao.signal.client.Client;
import com.acgist.taoyao.signal.client.ClientType; import com.acgist.taoyao.signal.client.ClientType;
@@ -14,6 +16,16 @@ import com.acgist.taoyao.signal.protocol.ProtocolRoomAdapter;
* *
* @author acgist * @author acgist
*/ */
@Protocol
@Description(
body = """
{
"roomId": "房间ID"
"routerType": "路由类型"
}
""",
flow = "终端->信令服务->终端"
)
public class MediaSetRouterTypeProtocol extends ProtocolRoomAdapter { public class MediaSetRouterTypeProtocol extends ProtocolRoomAdapter {
public static final String SIGNAL = "media::set::router::type"; public static final String SIGNAL = "media::set::router::type";