0

我正在尝试使用Parallel.Invoke() 两个 exe 并行运行 2 个 exe 都试图访问同一个数据库（但不同的表）。此外，exe 将在两个不同的服务器上运行。我正在使用带有 C# 的 WMI 来启动远程服务器中的批处理文件（它将调用另一个 exe 文件）。

Parallel.Invoke(() =>
            {
                RunInParallel();
            },
            () =>
            {
                InvokeModule("EmiCalculator.exe");
            } 
            );

void RunInParallel()
{
                var connoptions = new ConnectionOptions();
                var managementScope = new ManagementScope
                    (String.Format(@"\\{0}\ROOT\CIMV2", REMOTE_COMPUTER), connoptions);
                var wmiProc = new ManagementClass(managementScope, new ManagementPath("Win32_Process"), new ObjectGetOptions());
                string commandLineInput = @"\\win-server1\D$\Data\Run.bat";
                var processToRun = new[] { commandLineInput };
                wmiProc.InvokeMethod("Create", processToRun);
}

Run.bat 正在调用 SalaryCalculator.exe

这两个 exe 都有一个带有 ConnectionString 的配置文件，如下所示。

<add name="CONN" connectionString="Data Source=SERVER1-LAB1;Initial Catalog=Loan;Integrated Security=True"/>

运行时，远程计算机中的 exe 崩溃并抛出异常：

Application: SalaryCalculator.exe
Framework Version: v4.0.30319
Description: The process was terminated due to an unhandled exception.
Exception Info: System.AggregateException
Stack:
   at System.Threading.Tasks.Task.WaitAll(System.Threading.Tasks.Task[], Int32, System.Threading.CancellationToken)
   at System.Threading.Tasks.Task.WaitAll(System.Threading.Tasks.Task[], Int32)
   at System.Threading.Tasks.Task.WaitAll(System.Threading.Tasks.Task[])

注意：如果我在连接到远程机器后运行批处理文件，它工作得很好。使用 with 时只会抛出错误Parallel.Invoke()

我怎样才能在这里进行？任何帮助表示赞赏。

4

1 回答 1

-2

我能够完成这项工作。问题是连接字符串，因为提到了集成安全。我只是将连接字符串更改为使用SQL server authentication而不是 Windows 身份验证。它工作得很好。

< add name="CONN" connectionString="Data Source=SERVER1-LAB1;Initial Catalog=Loan;User Id=sa;Password=xxxx12345678" />
于 2013-02-07T13:36:58.073 回答