调整

ChannelManagers/Embedded/EmbeddedChannelManager.cs

@@ -11,28 +11,33 @@ namespace WingRtmpService.ChannelManagers.Embedded
 {
     class EmbeddedChannelManager : IChannelManager
     {
+        private string _url = "";
+
         public EmbeddedChannelManager()
         {
+            _url = EnvironmentConfigs.Rtmp.RTMPPushUrl;
         }
 
         private string GetPushUrl(string streamName)
         {
-            return $"{EnvironmentConfigs.Rtmp.RTMPPushUrl.TrimEnd('/')}/{streamName}";
+            var rtmpPrefix = _url.Replace("http://", "").Replace("https://", "");
+            return $"rtmp://{rtmpPrefix.TrimEnd('/')}/{streamName}";
         }
 
         private string GetPullUrl(string streamName)
         {
-            return $"{EnvironmentConfigs.Rtmp.RTMPPlayUrl.TrimEnd('/')}/{streamName}";
+            var rtmpPrefix = _url.Replace("http://", "").Replace("https://", "");
+            return $"rtmp://{rtmpPrefix.TrimEnd('/')}/{streamName}";
         }
 
         private string GetHlsPullUrl(string streamName)
         {
-            return $"{EnvironmentConfigs.Rtmp.RTMPPushUrl.TrimEnd('/')}/{streamName}/play.m3u8";
+            return $"{_url.TrimEnd('/')}/{streamName}/play.m3u8";
         }
 
         private string GetHttpPullUrl(string streamName)
         {
-            return $"{EnvironmentConfigs.Rtmp.RTMPPushUrl.TrimEnd('/')}/{streamName}.flv";
+            return $"{_url.TrimEnd('/')}/{streamName}.flv";
         }
 
         public ICreateChannelResult CreateChannel(ChannelParameter channel)