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-02-05 10:55:13 +08:00
parent 790666b221
commit 50ee82779e
40 changed files with 146 additions and 188 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
taoyao-media-server/README.md
View File

@@ -6,9 +6,6 @@
```
sudo npm install
# 跳过mediasoup
npm install --skip=mediasoup
```
## Mediasoup

1
taoyao-media-server/src/Server.js
View File

@@ -190,7 +190,6 @@ async function onmessage(message, session) {
data.message = "授权失败";
session.send(JSON.stringify(data));
}
// 不要传递授权信息
return;
}
// 处理信令

2
taoyao-signal-server/README.md
View File

@@ -29,6 +29,8 @@
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| taoyao-signal |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| taoyao-node |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| taoyao-boot |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
```

2
taoyao-signal-server/taoyao-media/README.md
View File

@@ -22,7 +22,7 @@
### 终端
#### 授权信息
#### 授权信息（6000）
```
```

26
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/MediasoupClient.java
View File

@@ -59,6 +59,15 @@ public class MediasoupClient {
@Autowired
private AuthorizeProtocol authorizeProtocol;
/**
* 最大重试次数
*/
private static final int MAX_RETRY = 12;
/**
* 重试次数
*/
private int retry = 1;
/**
* Mediasoup WebSocket通道
*/
@@ -95,7 +104,10 @@ public class MediasoupClient {
.get();
} catch (InterruptedException | ExecutionException e) {
log.error("连接Mediasoup异常：{}", uri, e);
this.taskSchedulerl.schedule(this::buildClient, Instant.now().plusSeconds(5));
this.taskSchedulerl.schedule(
this::buildClient,
Instant.now().plusSeconds(Math.min(this.retry++, MAX_RETRY) * 5)
);
}
}
@@ -181,6 +193,8 @@ public class MediasoupClient {
if(MediasoupClient.this.webSocket != null && !(MediasoupClient.this.webSocket.isInputClosed() && MediasoupClient.this.webSocket.isOutputClosed())) {
MediasoupClient.this.webSocket.abort();
}
// 重置重试次数
MediasoupClient.this.retry = 1;
// 设置新的通道
MediasoupClient.this.webSocket = webSocket;
// 发送授权消息
@@ -206,7 +220,10 @@ public class MediasoupClient {
try {
return Listener.super.onClose(webSocket, statusCode, reason);
} finally {
MediasoupClient.this.taskSchedulerl.schedule(MediasoupClient.this::buildClient, Instant.now().plusSeconds(5));
MediasoupClient.this.taskSchedulerl.schedule(
MediasoupClient.this::buildClient,
Instant.now().plusSeconds(Math.min(MediasoupClient.this.retry++, MAX_RETRY) * 5)
);
}
}
@@ -216,7 +233,10 @@ public class MediasoupClient {
try {
Listener.super.onError(webSocket, error);
} finally {
MediasoupClient.this.taskSchedulerl.schedule(MediasoupClient.this::buildClient, Instant.now().plusSeconds(5));
MediasoupClient.this.taskSchedulerl.schedule(
MediasoupClient.this::buildClient,
Instant.now().plusSeconds(Math.min(MediasoupClient.this.retry++, MAX_RETRY) * 5)
);
}
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ApplyNetworkThrottleProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ApplyNetworkThrottleProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ChangeDisplayNameProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ChangeDisplayNameProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/CloseProducerProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class CloseProducerProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ConnectWebRtcTransportProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ConnectWebRtcTransportProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/CreateWebRtcTransportProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class CreateWebRtcTransportProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/GetConsumerStatsProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class GetConsumerStatsProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/GetDataConsumerStatsProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class GetDataConsumerStatsProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/GetDataProducerStatsProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class GetDataProducerStatsProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/GetProducerStatsProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class GetProducerStatsProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/GetTransportStatsProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class GetTransportStatsProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/NewPeerProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class NewPeerProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/PauseConsumerProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class PauseConsumerProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/PauseProducerProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class PauseProducerProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ProduceDataProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ProduceDataProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ProduceProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ProduceProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ProducerScoreProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ProducerScoreProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/RequestConsumerKeyFrameProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class RequestConsumerKeyFrameProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ResetNetworkThrottleProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ResetNetworkThrottleProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/RestartIceProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class RestartIceProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ResumeConsumerProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ResumeConsumerProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/ResumeProducerProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class ResumeProducerProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/SetConsumerPreferredLayersProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class SetConsumerPreferredLayersProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/SetConsumerPriorityProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class SetConsumerPriorityProtocol {
}

5
taoyao-signal-server/taoyao-media/src/main/java/com/acgist/taoyao/mediasoup/protocol/media/VideoorientationchangeProtocol.java Normal file
View File

@@ -0,0 +1,5 @@
package com.acgist.taoyao.mediasoup.protocol.media;
public class VideoorientationchangeProtocol {
}

30
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaAnswerProtocol.java
View File

@@ -1,30 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
import java.util.Map;
import com.acgist.taoyao.boot.annotation.Protocol;
import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.ClientSession;
import com.acgist.taoyao.signal.event.media.MediaAnswerEvent;
import com.acgist.taoyao.signal.protocol.ProtocolMapAdapter;
/**
* Answer信令
*
* @author acgist
*/
@Protocol
public class MediaAnswerProtocol extends ProtocolMapAdapter {
public static final Integer PID = 5998;
public MediaAnswerProtocol() {
super(PID, "Answer信令");
}
@Override
public void execute(String sn, Map<?, ?> body, Message message, ClientSession session) {
this.publishEvent(new MediaAnswerEvent(sn, body, message, session));
}
}

30
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaCandidateProtocol.java
View File

@@ -1,30 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
import java.util.Map;
import com.acgist.taoyao.boot.annotation.Protocol;
import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.ClientSession;
import com.acgist.taoyao.signal.event.media.MediaCandidateEvent;
import com.acgist.taoyao.signal.protocol.ProtocolMapAdapter;
/**
* 候选信令
*
* @author acgist
*/
@Protocol
public class MediaCandidateProtocol extends ProtocolMapAdapter {
public static final Integer PID = 5999;
public MediaCandidateProtocol() {
super(PID, "候选信令");
}
@Override
public void execute(String sn, Map<?, ?> body, Message message, ClientSession session) {
this.publishEvent(new MediaCandidateEvent(sn, body, message, session));
}
}

30
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaOfferProtocol.java
View File

@@ -1,30 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
import java.util.Map;
import com.acgist.taoyao.boot.annotation.Protocol;
import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.ClientSession;
import com.acgist.taoyao.signal.event.media.MediaOfferEvent;
import com.acgist.taoyao.signal.protocol.ProtocolMapAdapter;
/**
* Offer信令
*
* @author acgist
*/
@Protocol
public class MediaOfferProtocol extends ProtocolMapAdapter {
public static final Integer PID = 5997;
public MediaOfferProtocol() {
super(PID, "Offer信令");
}
@Override
public void execute(String sn, Map<?, ?> body, Message message, ClientSession session) {
this.publishEvent(new MediaOfferEvent(sn, body, message, session));
}
}

5
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaPauseProtocol.java
View File

@@ -1,5 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
public class MediaPauseProtocol {
}

30
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaPublishProtocol.java
View File

@@ -1,30 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
import java.util.Map;
import com.acgist.taoyao.boot.annotation.Protocol;
import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.ClientSession;
import com.acgist.taoyao.signal.event.media.MediaPublishEvent;
import com.acgist.taoyao.signal.protocol.ProtocolMapAdapter;
/**
* 发布信令
*
* @author acgist
*/
@Protocol
public class MediaPublishProtocol extends ProtocolMapAdapter {
public static final Integer PID = 5000;
public MediaPublishProtocol() {
super(PID, "发布信令");
}
@Override
public void execute(String sn, Map<?, ?> body, Message message, ClientSession session) {
this.publishEvent(new MediaPublishEvent(sn, body, message, session));
}
}

5
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaResumeProtocol.java
View File

@@ -1,5 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
public class MediaResumeProtocol {
}

5
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaStartRecordProtocol.java
View File

@@ -1,5 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
public class MediaStartRecordProtocol {
}

5
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaStopRecordProtocol.java
View File

@@ -1,5 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
public class MediaStopRecordProtocol {
}

30
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaSubscribeProtocol.java
View File

@@ -1,30 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
import java.util.Map;
import com.acgist.taoyao.boot.annotation.Protocol;
import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.ClientSession;
import com.acgist.taoyao.signal.event.media.MediaSubscribeEvent;
import com.acgist.taoyao.signal.protocol.ProtocolMapAdapter;
/**
* 订阅指令
*
* @author acgist
*/
@Protocol
public class MediaSubscribeProtocol extends ProtocolMapAdapter {
public static final Integer PID = 5002;
public MediaSubscribeProtocol() {
super(PID, "订阅指令");
}
@Override
public void execute(String sn, Map<?, ?> body, Message message, ClientSession session) {
this.publishEvent(new MediaSubscribeEvent(sn, body, message, session));
}
}

5
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaUnpublishProtocol.java
View File

@@ -1,5 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
public class MediaUnpublishProtocol {
}

5
taoyao-signal-server/taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/media/MediaUnsubscribeProtocol.java
View File

@@ -1,5 +0,0 @@
package com.acgist.taoyao.signal.protocol.media;
public class MediaUnsubscribeProtocol {
}