问如何在运行空间池中多次使用相同的Exchange会话状态信息？
EN

Stack Overflow用户

提问于 2017-07-19 21:46:17

回答 1查看 524关注 0票数 1

我正在尝试创建一个多线程脚本，完全是为了提高速度，我写的同步版本工作得很好，但速度很慢。我遇到了一个难题，因为每个线程都在导入Exchange会话信息，所以它比同步代码慢甚至慢，特别是在服务器数量增加的情况下。

我相信有更好的方法，而且我相信正确的方法是加载pssession一次，并将其附加到运行空间池，但在我的搜索中，我找不到如何使用Exchange执行此操作的有效示例？

下面是我的异步和同步比较。异步代码的运行时间是12:41，同步代码的运行时间是15:02。

cls
$stopWatch = [System.Diagnostics.Stopwatch]::StartNew();
[DateTime]::Now.ToString();




    # Fill in these two values
$connectionUri = "http://[something]/powershell";   
$servers = @("server1","server2","server3","server4","server5","server6","server7","server8","server9","server10","server11","server12");
    # /fill




# asynchronous
Write-Host "Asynchronous";

# Create session state

$myString = "this is session state!";
$sessionState = [System.Management.Automation.Runspaces.InitialSessionState]::CreateDefault();
$sessionstate.Variables.Add((New-Object -TypeName System.Management.Automation.Runspaces.SessionStateVariableEntry -ArgumentList "myString" ,$myString, "example string"));

# Create runspace pool consisting of $numThreads runspaces
$minimumAmountOfThreads = 1;
$maximumAmountOfThreads= 15;
$RunspacePool = [RunspaceFactory]::CreateRunspacePool($minimumAmountOfThreads, $maximumAmountOfThreads, $sessionState, $Host);
$RunspacePool.Open();


$threads = @();
$Jobs = @();
$asynchronousThreadCount = 0;
[int]$index = 0;
foreach ($server in $servers)
{
    $scriptBlock = "import-pssession (new-pssession -ConfigurationName Microsoft.Exchange -ConnectionUri $connectionUri) -AllowClobber; `$returnValue = @(); `$returnValue += Get-ExchangeServer -Identity $server; `$returnValue += Get-MailboxDatabase -Server $server; `$returnValue += Get-MailboxDatabase -Server $server -status; return `$returnValue;"; # working

    $asynchronousThreadCount ++;
    $runspaceObject = [PSCustomObject] @{
        Runspace = [PowerShell]::Create()
        Invoker = $null
    }
    $runspaceObject.Runspace.RunSpacePool = $runspacePool;
    $runspaceObject.Runspace.AddScript($scriptBlock) | Out-Null;
    $runspaceObject.Runspace.AddArgument($server) | Out-Null;
    $runspaceObject.Invoker = $runspaceObject.Runspace.BeginInvoke();
    $threads += $runspaceObject;
    $elapsed = $StopWatch.Elapsed;

    Write-Host "Asynchronous created thread $asynchronousThreadCount " $elapsed;
    $index++;
}

Write-Host $threads.Count;
Write-Host "";
Write-Host "Waiting.." -NoNewline;
Do {
   Write-Host "." -NoNewline;
   Start-Sleep -Seconds 1;
} While ( $runspaceObject.Invoker.IsCompleted -contains $false ); 

$resultsAsynchronous = @();

foreach ($tr in $threads)
{
    $resultsAsynchronous += $tr.Runspace.EndInvoke($tr.Invoker);
    $tr.Runspace.Dispose();
}

$runspacePool.Close();
$runspacePool.Dispose();    

$elapsed = $StopWatch.Elapsed;
Write-Host "";
Write-Host "Multithread elapsed time: $elapsed";
Write-Host "Asynchronous return value count " $resultsAsynchronous.Count;

Write-Host "";
Write-Host "";
Write-Host "";







# synchronous
Write-Host "Synchronous";

$StopWatch.Reset | Out-Null;
import-pssession (new-pssession -ConfigurationName Microsoft.Exchange -ConnectionUri $connectionUri) -AllowClobber;
$resultsSynchronous = @();
foreach ($server in $servers)
{
    $resultsSynchronous += Get-ExchangeServer -Identity $server; 
    $resultsSynchronous += Get-MailboxDatabase -Server $server; 
    $resultsSynchronous += Get-MailboxDatabase -Server $server -status;
}

$elapsed = $StopWatch.Elapsed;
Write-Host "";
Write-Host "Single thread elapsed time: $elapsed";
Write-Host "Synchronous return value count " $resultsSynchronous.Count;

powershell

exchange-server

session-state

runspace

multithreading

回答 1

Stack Overflow用户

回答已采纳

发布于 2017-07-24 04:52:10

同步列表也不是我想要的，只是将实时会话作为一个参数传入即可工作。在循环之前解析会话：

$importSession = new-pssession -ConfigurationName Microsoft.Exchange -ConnectionUri $connectionUri

执行foreach，然后将params添加到脚本块，并为要导入的会话添加一个参数：

foreach ($server in $servers)
{
    $scriptBlock = {
        param( $importSession, $server )
        import-pssession $importSession
        Get-ExchangeServer -Identity $server
        Get-MailboxDatabase -Server $server
        Get-MailboxDatabase -Server $server -status
    }

    $asynchronousThreadCount++;
    $runspaceObject = [PSCustomObject] @{
        Runspace = [PowerShell]::Create()
        Invoker = $null
    }
    $runspaceObject.Runspace.RunSpacePool = $runspacePool;
    $runspaceObject.Runspace.AddScript($scriptBlock) | Out-Null;
    $runspaceObject.Runspace.AddArgument($importSession) | Out-Null;
    $runspaceObject.Runspace.AddArgument($server) | Out-Null;
    $runspaceObject.Invoker = $runspaceObject.Runspace.BeginInvoke();
    $threads += $runspaceObject;
    $elapsed = $StopWatch.Elapsed;

    Write-Host "Asynchronous created thread $asynchronousThreadCount " $elapsed;
    $index++;
}