qq27800734/taoyao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[*] 逻辑优化

Browse Source
This commit is contained in:
acgist
2023-03-05 16:27:25 +08:00
parent a50fb071d7
commit 01810fba20
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/party/media/ClientWrapper.java
View File

@@ -94,10 +94,12 @@ public class ClientWrapper implements AutoCloseable {
private Transport recvTransport;
/**
* 生产者
* 生产者里面的消费者是其他终端消费当前终端的消费者
*/
private final Map<String, Producer> producers;
/**
* 消费者
* 当前终端消费其他终端的消费者
*/
private final Map<String, Consumer> consumers;
/**
@@ -154,7 +156,7 @@ public class ClientWrapper implements AutoCloseable {
*/
public void remove(ClientWrapper wrapper) {
this.consumers.entrySet().stream()
.filter(v -> v.getValue().getConsumeClient() == wrapper)
.filter(v -> v.getValue().getProducer().getProduceClient() == wrapper)
.map(Map.Entry::getKey)
.forEach(this.consumers::remove);
// TODO：资源释放

6
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaConsumeProtocol.java
View File

@@ -117,9 +117,13 @@ public class MediaConsumeProtocol extends ProtocolRoomAdapter implements Applica
if(consumeClientWrapper.consume(producer)) {
// TODO：回调媒体服务准备完成
if(log.isDebugEnabled()) {
log.debug("已经消费：{}", consumeClientWrapper.getClientId(), producer.getStreamId());
log.debug("已经消费媒体：{} - {}", consumeClientWrapper.getClientId(), producer.getStreamId());
}
return;
} else {
if(log.isDebugEnabled()) {
log.debug("消费媒体：{} - {}", consumeClientWrapper.getClientId(), producer.getStreamId());
}
}
final String clientId = consumeClientWrapper.getClientId();
final String streamId = producer.getStreamId() + "->" + clientId;