| | |
|---|
| | | }
|
|---|
| | | redisCatchStorage.updateStreamAuthorityInfo(param.getApp(), param.getStream(), streamAuthorityInfo);
|
|---|
| | |
|
|---|
| | | if (!"broadcast".equals(param.getApp()) && !"talk".equals(param.getApp())) {
|
|---|
| | | Map<String, String> params = MediaServerUtils.urlParamToMap(param.getParams());
|
|---|
| | | param.setParamMap(params);
|
|---|
| | | StreamInfo streamInfoByAppAndStream = mediaService.getStreamInfoByAppAndStream(mediaInfo,
|
|---|
| | |
|---|
| | | redisCatchStorage.addPushListItem(param.getApp(), param.getStream(), param);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }else {
|
|---|
| | | redisCatchStorage.removePushListItem(param.getApp(), param.getStream(), param.getMediaServerId());
|
|---|
| | | }
|
|---|
| | | // TODO 修改为第一个为准 后续不再处理
|
|---|
| | | if ("rtsp".equals(param.getSchema())) {
|
|---|
| | | logger.info("流变化：注册->{}, app->{}, stream->{}", param.isRegist(), param.getApp(), param.getStream());
|
|---|
