| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | if ("push".equals(gbStream.getStreamType())) { |
|---|
| | | if (streamPushItem != null && streamPushItem.isPushIng()) { |
|---|
| | | if (streamPushItem != null) { |
|---|
| | | // 从redis查询是否正在接收这个推流 |
|---|
| | | OnStreamChangedHookParam pushListItem = redisCatchStorage.getPushListItem(gbStream.getApp(), gbStream.getStream()); |
|---|
| | | if (pushListItem != null) { |
|---|
| | | StreamPushItem transform = streamPushService.transform(pushListItem); |
|---|
| | | transform.setSelf(userSetting.getServerId().equals(pushListItem.getSeverId())); |
|---|
| | | // 推流状态 |
|---|
| | | pushStream(evt, request, gbStream, streamPushItem, platform, callIdHeader, mediaServerItem, port, tcpActive, |
|---|
| | | pushStream(evt, request, gbStream, transform, platform, callIdHeader, mediaServerItem, port, tcpActive, |
|---|
| | | mediaTransmissionTCP, channelId, addressStr, ssrc, requesterId); |
|---|
| | | } else { |
|---|
| | | // 未推流 拉起 |
|---|
| | | notifyStreamOnline(evt, request, gbStream, streamPushItem, platform, callIdHeader, mediaServerItem, port, tcpActive, |
|---|
| | | mediaTransmissionTCP, channelId, addressStr, ssrc, requesterId); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else if ("proxy".equals(gbStream.getStreamType())) { |
|---|
| | | if (null != proxyByAppAndStream) { |
|---|
| | | if (proxyByAppAndStream.isStatus()) { |
|---|
