1

我已经为此苦苦挣扎了一个星期，并且已经用尽了我在网上找到的所有方法和选项。我希望这里有人能够帮助我解决这个问题。

我正在使用 powershell 启动 8 个作业，每个作业运行 FFmpeg 以将 7 分钟的文件流式传输到远程 RTMP 服务器。这是从磁盘上的文件中提取的，并且每个作业都使用不同的文件。该命令处于 do while 循环中，因此它不断地重新流式传输。

这导致我从中启动作业的 shell 积累了大量内存，消耗了它所能消耗的所有内存。在 24 小时内，它消耗了我服务器 32 GB 中的 30 个。

这是我的启动代码，任何帮助将不胜感激。

start-job -Name v6 -scriptblock {
do { $d = $true; $f = Invoke-Expression -Command "ffmpeg -re -i `"C:\Shares\Matthew\180p_3000k.mp4`" -vcodec copy -acodec copy -f flv -y rtmp://<ip>/<appName>/<streamName>"; $f = $null }
while ($d = $true)

}

我尝试接收作业并将其通过管道输出为空，我尝试在启动 do while 循环之前将 $f 设置为 $null，以及我在网上找到的其他一些东西，但无济于事。感谢大家的时间！

4

2 回答 2

4

我猜迟到总比没有好。在 Powershell 作业中运行 ffmpeg 时，我遇到了同样的内存消耗问题。问题的核心是 Powershell 作业会将任何/所有输出存储到内存中，而 ffmpeg 非常乐意将输出记录到标准输出和标准错误流。

我的解决方案是将参数“-loglevel quiet”添加到 ffmpeg。或者，您可以将标准流和错误流都重定向到 null（仅重定向标准流是不够的）。有关如何重定向标准流的更多信息，请参阅此问题：Redirection of standard and error output appending to the same log-file

于 2016-07-14T13:53:05.137 回答
2

调用 PowerShell 脚本或表达式的方法有很多。

我的最爱之一是使用 RunspacePool。在 RunspacePool 中，每个任务都从一个新的运行空间开始。当任务完成时，运行空间被处理掉。这应该保持内存消耗相当稳定。这不是最简单的方法，但这里有一个可能对你有用的简单示例。

$Throttle = 10 # Maximum jobs that can run simultaneously in a runpool
$maxjobs = 8 # Maximum jobs that will run simultaneously
[System.Collections.ArrayList]$jobs = @()
$script:currentjobs = 0
$jobindex = 0
$jobaction = "ffmpeg -re -i `"C:\Shares\Matthew\180p_3000k.mp4`" -vcodec copy -acodec copy -f flv -y rtmp://<ip>/<appName>/<streamName>"

$sessionstate = [system.management.automation.runspaces.initialsessionstate]::CreateDefault()
$runspace = [runspacefactory]::CreateRunspacePool(1, $Throttle, $sessionstate, $Host)
$runspace.Open()


function QueueJob{
    param($jobindex)
    $job = "" | Select-Object JobID,Script,Errors,PS,Runspace,Handle
    $job.JobID = $jobindex
    $job.Script = $jobaction
    $job.PS = [System.Management.Automation.PowerShell]::create()
    $job.PS.RunspacePool = $runspace
    [void]$job.PS.AddScript($job.Script)
    $job.Runspace = $job.PS.BeginInvoke()
    $job.Handle = $job.Runspace.AsyncWaitHandle
    Write-Host "----------------- Starting Job: $("{0:D4}" -f $job.JobID) --------------------" -ForegroundColor Blue
    $jobs.add($job)
    $script:currentjobs++
}

Function ServiceJobs{
    foreach($job in $Jobs){
        If ($job.Runspace.isCompleted) {
            $result = $job.PS.EndInvoke($job.Runspace)
            $job.PS.dispose()
            $job.Runspace = $null
            $job.PS = $null
            $script:currentjobs--
            Write-Host "----------------- Job Completed: $("{0:D4}" -f $job.JobID) --------------------" -ForegroundColor Yellow
            Write-Host $result
            $Jobs.Remove($job)
            return
        }
    }
}

while ($true) {
    While ($script:currentjobs -le $maxjobs){
        QueueJob $jobindex
        $jobindex++
    }
    ServiceJobs
    Start-Sleep 1
}

$runspace.Close()
[gc]::Collect()

它使用了一个没有正确终止的无限循环，并且缺乏任何类型的错误检查，但希望它足以证明该技术。

于 2015-04-01T00:49:04.543 回答