|  |  |  | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Qualifier; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Value; | 
|---|
|  |  |  | // import org.springframework.context.annotation.ComponentScan; | 
|---|
|  |  |  | import org.springframework.context.annotation.DependsOn; | 
|---|
|  |  |  | import org.springframework.context.annotation.Lazy; | 
|---|
|  |  |  | import org.springframework.stereotype.Component; | 
|---|
|  |  |  | 
|---|
|  |  |  | // 添加订阅 | 
|---|
|  |  |  | JSONObject subscribeKey = new JSONObject(); | 
|---|
|  |  |  | subscribeKey.put("app", "rtp"); | 
|---|
|  |  |  | subscribeKey.put("id", streamId); | 
|---|
|  |  |  | subscribeKey.put("stream", streamId); | 
|---|
|  |  |  | subscribeKey.put("regist", true); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | subscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_publish, subscribeKey, event); | 
|---|
|  |  |  | subscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey, json->{ | 
|---|
|  |  |  | if (json.getJSONArray("tracks") == null) return; | 
|---|
|  |  |  | event.response(json); | 
|---|
|  |  |  | subscribe.removeSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey); | 
|---|
|  |  |  | }); | 
|---|
|  |  |  | // | 
|---|
|  |  |  | StringBuffer content = new StringBuffer(200); | 
|---|
|  |  |  | content.append("v=0\r\n"); | 
|---|
|  |  |  | 
|---|
|  |  |  | // 添加订阅 | 
|---|
|  |  |  | JSONObject subscribeKey = new JSONObject(); | 
|---|
|  |  |  | subscribeKey.put("app", "rtp"); | 
|---|
|  |  |  | subscribeKey.put("id", streamId); | 
|---|
|  |  |  | subscribeKey.put("stream", streamId); | 
|---|
|  |  |  | subscribeKey.put("regist", true); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | subscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_publish, subscribeKey, event); | 
|---|
|  |  |  | subscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey, json->{ | 
|---|
|  |  |  | if (json.getJSONArray("tracks") == null) return; | 
|---|
|  |  |  | event.response(json); | 
|---|
|  |  |  | subscribe.removeSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey); | 
|---|
|  |  |  | }); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | StringBuffer content = new StringBuffer(200); | 
|---|
|  |  |  | content.append("v=0\r\n"); | 
|---|