Codemaru.Services.FfmpegHlsService에 대한 상속 다이어그램 :

Codemaru.Services.FfmpegHlsService에 대한 협력 다이어그램:

[범례]

Public 멤버 함수
	FfmpegHlsService (ILogger< FfmpegHlsService > log, IOptions< FfmpegOptions > opt, IOptions< List< StreamConfig > > streams, IWebHostEnvironment env)
override Task	StopAsync (CancellationToken cancellationToken)

Protected 멤버 함수
override async Task	ExecuteAsync (CancellationToken ct)

Private 멤버 함수
string	GetOutputRoot ()
string string segFmt	GetOutputPaths (StreamConfig s)
void	SafeRestart (StreamConfig s)
void	TryStartOne (StreamConfig s)
void	InitWatchStats (StreamConfig s)
long DateTime lastWrite	ReadSeqAndTime (string m3u8Path)

Private 속성
readonly ILogger< FfmpegHlsService >	_log
readonly FfmpegOptions	_opt
readonly IReadOnlyList< StreamConfig >	_streams
readonly IWebHostEnvironment	_env
readonly Dictionary< string, Process >	_procs = new()
readonly Dictionary< string, long >	_lastSeq = new()
readonly Dictionary< string, DateTime >	_lastWrite = new()
string	m3u8Path
long	seq

정적 Private 속성
static readonly Regex	MediaSeqRegex = new(@"#EXT-X-MEDIA-SEQUENCE:(\d+)", RegexOptions.Compiled)

상세한 설명

ffmpeg 프로세스를 관리하는 HostedService(워치독 포함).

FfmpegHlsService.cs 파일의 31 번째 라인에서 정의되었습니다.

생성자 & 소멸자 문서화

◆ FfmpegHlsService()

Codemaru.Services.FfmpegHlsService.FfmpegHlsService	(	ILogger< FfmpegHlsService >	log,
		IOptions< FfmpegOptions >	opt,
		IOptions< List< StreamConfig > >	streams,
		IWebHostEnvironment	env )

inline

생성자.

매개변수

log	log에 사용할 `ILogger<FfmpegHlsService>` 값입니다.
opt	opt에 사용할 `IOptions<FfmpegOptions>` 값입니다.
streams	streams에 사용할 `IOptions<List<StreamConfig>>` 값입니다.
env	env에 사용할 `IWebHostEnvironment` 값입니다.

FfmpegHlsService.cs 파일의 151 번째 라인에서 정의되었습니다.

        {
            _log = log;
            _opt = opt.Value;
            _streams = streams.Value;
            _env = env;
        }

다음을 참조함 : _env, _log, _opt, _streams.

멤버 함수 문서화

◆ ExecuteAsync()

override async Task Codemaru.Services.FfmpegHlsService.ExecuteAsync ( CancellationToken ct )

inlineprotected

서비스 시작 시 각 스트림 ffmpeg 실행 + 워치독 루프 가동.

매개변수

ct	취소 요청을 감시하는 토큰입니다.

반환값: Execute Async 작업에서 생성한 Task 결과입니다.

FfmpegHlsService.cs 파일의 187 번째 라인에서 정의되었습니다.

        {
            Directory.CreateDirectory(GetOutputRoot());
 
            foreach (var s in _streams)
            {
                TryStartOne(s);
                InitWatchStats(s);
            }
 
            // 주기적으로 프로세스 상태와 m3u8 갱신을 점검
            while (!ct.IsCancellationRequested)
            {
                foreach (var s in _streams)
                {
                    // 1) ffmpeg 죽었으면 재시작
                    if (!_procs.TryGetValue(s.Name, out var p) || p.HasExited)
                    {
                        _log.LogWarning("ffmpeg 재시작(프로세스 종료 감지): {Name}", s.Name);
                        TryStartOne(s);
                        InitWatchStats(s);
                        continue;
                    }
 
                    // 2) m3u8 갱신 감시(워치독)
                    var (m3u8Path, _) = GetOutputPaths(s);
                    if (File.Exists(m3u8Path))
                    {
                        var (seq, write) = ReadSeqAndTime(m3u8Path);
                        var lastSeq = _lastSeq[s.Name];
                        var lastWrite = _lastWrite[s.Name];
 
                        // 시퀀스 증가 또는 수정 시간이 갱신되면 정상
                        if (seq > lastSeq || write > lastWrite)
                        {
                            _lastSeq[s.Name] = Math.Max(seq, lastSeq);
                            _lastWrite[s.Name] = write > lastWrite ? write : lastWrite;
                        }
                        else
                        {
                            // 일정 시간 이상 변화가 없으면 재시작
                            var idleSec = (DateTime.UtcNow - lastWrite.ToUniversalTime()).TotalSeconds;
                            var idleLimit = Math.Max(_opt.WatchdogIdleSeconds, _opt.HlsSegmentSeconds * _opt.HlsListSize);
                            if (idleSec >= idleLimit)
                            {
                                _log.LogWarning("m3u8 갱신 정지 감지({Idle}s >= {Limit}s): {Name} → ffmpeg 재시작",
                                    idleSec, idleLimit, s.Name);
                                SafeRestart(s);
                                InitWatchStats(s);
                                continue;
                            }
                        }
                    }
                    else
                    {
                        // 파일이 없으면 ffmpeg가 아직 시작 중이거나 실패→ 잠시 후 다시 확인
                        _log.LogDebug("m3u8 미존재: {Name} ({Path})", s.Name, m3u8Path);
                    }
                }
 
                await Task.Delay(TimeSpan.FromSeconds(_opt.WatchdogIntervalSeconds), ct);
            }
        }

다음을 참조함 : _lastSeq, _lastWrite, _log, _opt, _procs, _streams, GetOutputPaths(), GetOutputRoot(), InitWatchStats(), m3u8Path, ReadSeqAndTime(), SafeRestart(), seq, TryStartOne().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

◆ GetOutputPaths()

string string segFmt Codemaru.Services.FfmpegHlsService.GetOutputPaths ( StreamConfig s )

inlineprivate

FfmpegHlsService.cs 파일의 341 번째 라인에서 정의되었습니다.

        {
            var outRoot = GetOutputRoot();
            var outDir = Path.Combine(outRoot, s.Name);
            Directory.CreateDirectory(outDir);
 
            // 가독성 및 캐싱 안전성 위해 seg_%05d.ts 권장
            var m3u8Path = Path.Combine(outDir, "index.m3u8");
            var segFmt = Path.Combine(outDir, "seg_%05d.ts");
            return (m3u8Path, segFmt);
        }

다음을 참조함 : GetOutputRoot(), m3u8Path, Codemaru.Models.StreamConfig.Name.

다음에 의해서 참조됨 : ExecuteAsync(), TryStartOne().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ GetOutputRoot()

string Codemaru.Services.FfmpegHlsService.GetOutputRoot ( )

inlineprivate

HLS 출력 루트의 절대경로를 반환합니다.

반환값: Get Output Root 작업에서 생성한 string 결과입니다.

FfmpegHlsService.cs 파일의 309 번째 라인에서 정의되었습니다.

        {
            // appsettings에 상대경로("wwwroot\\hls")인 경우 ContentRoot 기준으로 절대경로화
            return Path.IsPathRooted(_opt.OutputRoot)
                ? _opt.OutputRoot
                : Path.Combine(_env.ContentRootPath, _opt.OutputRoot);
        }

다음을 참조함 : _env, _opt.

다음에 의해서 참조됨 : ExecuteAsync(), GetOutputPaths().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ InitWatchStats()

void Codemaru.Services.FfmpegHlsService.InitWatchStats ( StreamConfig s )

inlineprivate

워치독 초기 통계값을 리셋합니다.

매개변수

s	이벤트를 발생시킨 객체입니다.

FfmpegHlsService.cs 파일의 502 번째 라인에서 정의되었습니다.

        {
            _lastSeq[s.Name] = -1;
            _lastWrite[s.Name] = DateTime.MinValue;
        }

다음을 참조함 : _lastSeq, _lastWrite, Codemaru.Models.StreamConfig.Name.

다음에 의해서 참조됨 : ExecuteAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ ReadSeqAndTime()

long DateTime lastWrite Codemaru.Services.FfmpegHlsService.ReadSeqAndTime ( string m3u8Path )

inlineprivate

FfmpegHlsService.cs 파일의 532 번째 라인에서 정의되었습니다.

        {
            try
            {
                var text = File.ReadAllText(m3u8Path);
                var m = MediaSeqRegex.Match(text);
                var seq = m.Success ? long.Parse(m.Groups[1].Value) : -1;
                var info = new FileInfo(m3u8Path);
                return (seq, info.LastWriteTimeUtc);
            }
            catch (Exception ex)
            {
                _log.LogDebug("m3u8 읽기 실패: {Path} - {Msg}", m3u8Path, ex.Message);
                return (-1, DateTime.MinValue);
            }
        }

다음을 참조함 : _log, m3u8Path, MediaSeqRegex, seq.

다음에 의해서 참조됨 : ExecuteAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ SafeRestart()

void Codemaru.Services.FfmpegHlsService.SafeRestart ( StreamConfig s )

inlineprivate

한 개 스트림 ffmpeg 시작(이미 있으면 종료 후 재시작).

매개변수

s	이벤트를 발생시킨 객체입니다.

FfmpegHlsService.cs 파일의 369 번째 라인에서 정의되었습니다.

        {
            if (_procs.TryGetValue(s.Name, out var old))
            {
                try
                {
                    if (!old.HasExited)
                    {
                        old.Kill(entireProcessTree: true);
                        old.WaitForExit(2000);
                    }
                }
                catch { /* ignore */ }
            }
            TryStartOne(s);
        }

다음을 참조함 : _procs, Codemaru.Models.StreamConfig.Name, TryStartOne().

다음에 의해서 참조됨 : ExecuteAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ StopAsync()

override Task Codemaru.Services.FfmpegHlsService.StopAsync ( CancellationToken cancellationToken )

inline

서비스 중지 시 모든 ffmpeg 종료.

매개변수

cancellationToken 취소 요청을 감시하는 토큰입니다.

반환값: Stop Async 작업에서 생성한 Task 결과입니다.

FfmpegHlsService.cs 파일의 275 번째 라인에서 정의되었습니다.

        {
            foreach (var p in _procs.Values)
            {
                try
                {
                    if (!p.HasExited)
                    {
                        p.Kill(entireProcessTree: true);
                        p.WaitForExit(2000);
                    }
                }
                catch { /* ignore */ }
            }
            _procs.Clear();
            return Task.CompletedTask;
        }

다음을 참조함 : _procs.

◆ TryStartOne()

void Codemaru.Services.FfmpegHlsService.TryStartOne ( StreamConfig s )

inlineprivate

ffmpeg 시작 시도(성공 시 딕셔너리 등록).

매개변수

s	이벤트를 발생시킨 객체입니다.

FfmpegHlsService.cs 파일의 402 번째 라인에서 정의되었습니다.

        {
            var (m3u8Path, segFmt) = GetOutputPaths(s);
 
            // 입력 옵션: TCP 강제(안정), 타임스탬프 보정
            var inputOpts = "-rtsp_transport tcp -rtsp_flags prefer_tcp -fflags +genpts -use_wallclock_as_timestamps 1";
 
            // 인코딩/복사 분기
            var v = (s.VideoCodec ?? _opt.VideoCodec).ToLowerInvariant();
            var a = (s.AudioCodec ?? _opt.AudioCodec).ToLowerInvariant();
 
            // 비디오 파트
            // - 트랜스코딩: GOP 고정 (hls_time 2초라면 gop≈50@25fps / 60@30fps 등으로 맞추세요)
            var videoPart =
                v == "copy"
                ? "-c:v copy -bsf:v h264_mp4toannexb"
                : "-c:v libx264 -preset veryfast -tune zerolatency -profile:v high -level 4.1 -pix_fmt yuv420p " +
                  "-g 50 -keyint_min 50 -sc_threshold 0 -force_key_frames \"expr:gte(t,n_forced*2)\"";
 
            // 오디오 파트
            var audioPart =
                a == "an" ? "-an"
                : $"-c:a {a} -b:a {_opt.AudioBitrate} -ar {_opt.AudioRate} -ac {_opt.AudioChannels}";
 
            // HLS 파트(독립 세그먼트 + 프로그램 시간 + 삭제)
            var hlsPart = string.Join(' ', new[]
            {
                "-f hls",
                $"-hls_time {_opt.HlsSegmentSeconds}",
                $"-hls_list_size {_opt.HlsListSize}",
                "-hls_flags delete_segments+program_date_time+independent_segments",
                $"-hls_segment_filename \"{segFmt}\"",
                $"\"{m3u8Path}\""
            });
 
            // 전체 인자 조합
            var args = string.Join(' ', new[]
            {
                inputOpts,
                $"-i \"{s.RtspUrl}\"",
                videoPart,
                audioPart,
                hlsPart
            });
 
            var psi = new ProcessStartInfo
            {
                FileName = _opt.Path,
                Arguments = args,
                UseShellExecute = false,
                RedirectStandardError = true,
                RedirectStandardOutput = true,
                CreateNoWindow = true
            };
 
            var proc = new Process { StartInfo = psi, EnableRaisingEvents = true };
            proc.ErrorDataReceived += (_, e) =>
            {
                if (!string.IsNullOrEmpty(e.Data))
                    _log.LogInformation("[{name}] {line}", s.Name, e.Data);
            };
            proc.OutputDataReceived += (_, e) =>
            {
                if (!string.IsNullOrEmpty(e.Data))
                    _log.LogDebug("[{name}] {line}", s.Name, e.Data);
            };
            proc.Exited += (_, __) =>
            {
                _log.LogWarning("ffmpeg 종료 감지: {Name} (ExitCode={Code})", s.Name, proc.ExitCode);
            };
 
            if (proc.Start())
            {
                proc.BeginErrorReadLine();
                proc.BeginOutputReadLine();
                _procs[s.Name] = proc;
                _log.LogInformation("ffmpeg 시작: {Name} → {Out}", s.Name, Path.GetDirectoryName(m3u8Path));
            }
            else
            {
                _log.LogError("ffmpeg 시작 실패: {Name}", s.Name);
            }
        }

다음을 참조함 : _log, _opt, _procs, GetOutputPaths(), m3u8Path, Codemaru.Models.StreamConfig.Name.

다음에 의해서 참조됨 : ExecuteAsync(), SafeRestart().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

멤버 데이터 문서화

◆ _env

readonly IWebHostEnvironment Codemaru.Services.FfmpegHlsService._env

private

env 값을 보관합니다.

FfmpegHlsService.cs 파일의 68 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : FfmpegHlsService(), GetOutputRoot().

◆ _lastSeq

readonly Dictionary<string, long> Codemaru.Services.FfmpegHlsService._lastSeq = new()

private

last Seq 값을 보관합니다.

FfmpegHlsService.cs 파일의 90 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ExecuteAsync(), InitWatchStats().

◆ _lastWrite

readonly Dictionary<string, DateTime> Codemaru.Services.FfmpegHlsService._lastWrite = new()

private

last Write 값을 보관합니다.

FfmpegHlsService.cs 파일의 99 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ExecuteAsync(), InitWatchStats().

◆ _log

readonly ILogger<FfmpegHlsService> Codemaru.Services.FfmpegHlsService._log

private

log 값을 보관합니다.

FfmpegHlsService.cs 파일의 41 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ExecuteAsync(), FfmpegHlsService(), ReadSeqAndTime(), TryStartOne().

◆ _opt

readonly FfmpegOptions Codemaru.Services.FfmpegHlsService._opt

private

opt 값을 보관합니다.

FfmpegHlsService.cs 파일의 50 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ExecuteAsync(), FfmpegHlsService(), GetOutputRoot(), TryStartOne().

◆ _procs

readonly Dictionary<string, Process> Codemaru.Services.FfmpegHlsService._procs = new()

private

procs 값을 보관합니다.

FfmpegHlsService.cs 파일의 79 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ExecuteAsync(), SafeRestart(), StopAsync(), TryStartOne().

◆ _streams

readonly IReadOnlyList<StreamConfig> Codemaru.Services.FfmpegHlsService._streams

private

streams 값을 보관합니다.

FfmpegHlsService.cs 파일의 59 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ExecuteAsync(), FfmpegHlsService().

◆ m3u8Path

string Codemaru.Services.FfmpegHlsService.m3u8Path

private

스트림별 m3u8/세그먼트 경로를 반환합니다.

매개변수

s	이벤트를 발생시킨 객체입니다.

반환값: Get Output Paths 작업에서 생성한 (string m3u8Path, string segFmt) 결과입니다.

FfmpegHlsService.cs 파일의 341 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ExecuteAsync(), GetOutputPaths(), ReadSeqAndTime(), TryStartOne().

◆ MediaSeqRegex

readonly Regex Codemaru.Services.FfmpegHlsService.MediaSeqRegex = new(@"#EXT-X-MEDIA-SEQUENCE:(\d+)", RegexOptions.Compiled)

staticprivate

Media Seq Regex 값을 보관합니다.

FfmpegHlsService.cs 파일의 109 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ReadSeqAndTime().

◆ seq

long Codemaru.Services.FfmpegHlsService.seq

private

m3u8에서 MEDIA-SEQUENCE와 파일 수정시각을 읽습니다.

반환값: (seq, lastWrite)

매개변수

m3u8Path m3u8 Path에 사용할 string 값입니다.

반환값: Read Seq And Time 작업에서 생성한 (long seq, DateTime lastWrite) 결과입니다.

FfmpegHlsService.cs 파일의 532 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ExecuteAsync(), ReadSeqAndTime().

이 클래스에 대한 문서화 페이지는 다음의 파일로부터 생성되었습니다.:

FfmpegHlsService.cs

Public 멤버 함수

Protected 멤버 함수

Private 멤버 함수

Private 속성

정적 Private 속성

상세한 설명

생성자 & 소멸자 문서화

◆ FfmpegHlsService()

멤버 함수 문서화

◆ ExecuteAsync()

◆ GetOutputPaths()

◆ GetOutputRoot()

◆ InitWatchStats()

◆ ReadSeqAndTime()

◆ SafeRestart()

◆ StopAsync()

◆ TryStartOne()

멤버 데이터 문서화

◆ _env

◆ _lastSeq

◆ _lastWrite

◆ _log

◆ _opt

◆ _procs

◆ _streams

◆ m3u8Path

◆ MediaSeqRegex

◆ seq