如何：使用匿名管道进行本地进程间通信

link管理

链接快照平台

输入网页链接，自动生成快照
标签化管理网页链接

相关文章推荐

正直的作业本 · 直接用bat命令对Inno ...· 8 月前 ·

强健的松鼠 · 如何在Python中拆分字符串并提取一个单词？· 1 年前 ·

精明的蘑菇 · oracle查看存储过程修改记录-掘金· 1 年前 ·

卖萌的烤地瓜 · 使用 WSL 访问网络应用程序 | ...· 1 年前 ·

欢快的冰棍 · Android低版本 ...· 1 年前 ·

匿名管道在本地计算机上提供进程间通信。它们提供的功能比命名管道少，但所需要的系统开销也少。使用匿名管道，可以在本地计算机上更轻松地进行进程间通信。不能使用匿名管道进行网络通信。

若要实现匿名管道，请使用 AnonymousPipeServerStream 和 AnonymousPipeClientStream 类。

下面的示例展示了如何使用匿名管道将字符串从父进程发送到子进程。本示例在父进程中创建一个 AnonymousPipeServerStream 对象，其 PipeDirection 值为 Out 。然后，父进程通过使用客户端句柄创建 AnonymousPipeClientStream 对象来创建子进程。子进程的 PipeDirection 值为 In 。

接下来，父进程将用户提供的字符串发送给子进程。字符串在子进程的控制台中显示。

下面的示例展示了服务器进程。

#using <System.dll>
#using <System.Core.dll>
using namespace System;
using namespace System::IO;
using namespace System::IO::Pipes;
using namespace System::Diagnostics;
ref class PipeServer
public:
    static void Main()
        Process^ pipeClient = gcnew Process();
        pipeClient->StartInfo->FileName = "pipeClient.exe";
        AnonymousPipeServerStream^ pipeServer =
            gcnew AnonymousPipeServerStream(PipeDirection::Out,
            HandleInheritability::Inheritable);
        Console::WriteLine("[SERVER] Current TransmissionMode: {0}.",
            pipeServer->TransmissionMode);
        // Pass the client process a handle to the server.
        pipeClient->StartInfo->Arguments =
            pipeServer->GetClientHandleAsString();
        pipeClient->StartInfo->UseShellExecute = false;
        pipeClient->Start();
        pipeServer->DisposeLocalCopyOfClientHandle();
            // Read user input and send that to the client process.
            StreamWriter^ sw = gcnew StreamWriter(pipeServer);
            sw->AutoFlush = true;
            // Send a 'sync message' and wait for client to receive it.
            sw->WriteLine("SYNC");
            pipeServer->WaitForPipeDrain();
            // Send the console input to the client process.
            Console::Write("[SERVER] Enter text: ");
            sw->WriteLine(Console::ReadLine());
            sw->Close();
        // Catch the IOException that is raised if the pipe is broken
        // or disconnected.
        catch (IOException^ e)
            Console::WriteLine("[SERVER] Error: {0}", e->Message);
        pipeServer->Close();
        pipeClient->WaitForExit();
        pipeClient->Close();
        Console::WriteLine("[SERVER] Client quit. Server terminating.");
int main()
    PipeServer::Main();

using System;
using System.IO;
using System.IO.Pipes;
using System.Diagnostics;
class PipeServer
    static void Main()
        Process pipeClient = new Process();
        pipeClient.StartInfo.FileName = "pipeClient.exe";
        using (AnonymousPipeServerStream pipeServer =
            new AnonymousPipeServerStream(PipeDirection.Out,
            HandleInheritability.Inheritable))
            Console.WriteLine("[SERVER] Current TransmissionMode: {0}.",
                pipeServer.TransmissionMode);
            // Pass the client process a handle to the server.
            pipeClient.StartInfo.Arguments =
                pipeServer.GetClientHandleAsString();
            pipeClient.StartInfo.UseShellExecute = false;
            pipeClient.Start();
            pipeServer.DisposeLocalCopyOfClientHandle();
                // Read user input and send that to the client process.
                using (StreamWriter sw = new StreamWriter(pipeServer))
                    sw.AutoFlush = true;
                    // Send a 'sync message' and wait for client to receive it.
                    sw.WriteLine("SYNC");
                    pipeServer.WaitForPipeDrain();
                    // Send the console input to the client process.
                    Console.Write("[SERVER] Enter text: ");
                    sw.WriteLine(Console.ReadLine());
            // Catch the IOException that is raised if the pipe is broken
            // or disconnected.
            catch (IOException e)
                Console.WriteLine("[SERVER] Error: {0}", e.Message);
        pipeClient.WaitForExit();
        pipeClient.Close();
        Console.WriteLine("[SERVER] Client quit. Server terminating.");

Imports System.IO
Imports System.IO.Pipes
Imports System.Diagnostics
Class PipeServer
    Shared Sub Main()
        Dim pipeClient As New Process()
        pipeClient.StartInfo.FileName = "pipeClient.exe"
        Using pipeServer As New AnonymousPipeServerStream(PipeDirection.Out, _
            HandleInheritability.Inheritable)
            Console.WriteLine("[SERVER] Current TransmissionMode: {0}.",
                pipeServer.TransmissionMode)
            ' Pass the client process a handle to the server.
            pipeClient.StartInfo.Arguments = pipeServer.GetClientHandleAsString()
            pipeClient.StartInfo.UseShellExecute = false
            pipeClient.Start()
            pipeServer.DisposeLocalCopyOfClientHandle()
                ' Read user input and send that to the client process.
                Using sw As New StreamWriter(pipeServer)
                    sw.AutoFlush = true
                    ' Send a 'sync message' and wait for client to receive it.
                    sw.WriteLine("SYNC")
                    pipeServer.WaitForPipeDrain()
                    ' Send the console input to the client process.
                    Console.Write("[SERVER] Enter text: ")
                    sw.WriteLine(Console.ReadLine())
                End Using
            Catch e As IOException
                ' Catch the IOException that is raised if the pipe is broken
                ' or disconnected.
                Console.WriteLine("[SERVER] Error: {0}", e.Message)
            End Try
        End Using
        pipeClient.WaitForExit()
        pipeClient.Close()
        Console.WriteLine("[SERVER] Client quit. Server terminating.")
    End Sub
End Class
下面的示例展示了客户端进程。 服务器进程启动客户端进程，并为此进程提供客户端句柄。 客户端代码生成的可执行文件应命名为 pipeClient.exe，并在运行服务器进程前复制到服务器可执行文件所在的相同目录中。
#using <System.Core.dll>
using namespace System;
using namespace System::IO;
using namespace System::IO::Pipes;
ref class PipeClient
public:
    static void Main(array<String^>^ args)
        if (args->Length > 1)
            PipeStream^ pipeClient = gcnew AnonymousPipeClientStream(PipeDirection::In, args[1]);
            Console::WriteLine("[CLIENT] Current TransmissionMode: {0}.",
                pipeClient->TransmissionMode);
            StreamReader^ sr = gcnew StreamReader(pipeClient);
            // Display the read text to the console
            String^ temp;
            // Wait for 'sync message' from the server.
                Console::WriteLine("[CLIENT] Wait for sync...");
                temp = sr->ReadLine();
            while (!temp->StartsWith("SYNC"));
            // Read the server data and echo to the console.
            while ((temp = sr->ReadLine()) != nullptr)
                Console::WriteLine("[CLIENT] Echo: " + temp);
            sr->Close();
            pipeClient->Close();
        Console::Write("[CLIENT] Press Enter to continue...");
        Console::ReadLine();
int main()
    array<String^>^ args = Environment::GetCommandLineArgs();
    PipeClient::Main(args);
using System;
using System.IO;
using System.IO.Pipes;
class PipeClient
    static void Main(string[] args)
        if (args.Length > 0)
            using (PipeStream pipeClient =
                new AnonymousPipeClientStream(PipeDirection.In, args[0]))
                Console.WriteLine("[CLIENT] Current TransmissionMode: {0}.",
                   pipeClient.TransmissionMode);
                using (StreamReader sr = new StreamReader(pipeClient))
                    // Display the read text to the console
                    string temp;
                    // Wait for 'sync message' from the server.
                        Console.WriteLine("[CLIENT] Wait for sync...");
                        temp = sr.ReadLine();
                    while (!temp.StartsWith("SYNC"));
                    // Read the server data and echo to the console.
                    while ((temp = sr.ReadLine()) != null)
                        Console.WriteLine("[CLIENT] Echo: " + temp);
        Console.Write("[CLIENT] Press Enter to continue...");
        Console.ReadLine();
Imports System.IO
Imports System.IO.Pipes
Class PipeClient
    Shared Sub Main(args() as String)
        If args.Length > 0 Then
            Using pipeClient As New AnonymousPipeClientStream(PipeDirection.In, args(0))
                Console.WriteLine("[CLIENT] Current TransmissionMode: {0}.", _
                   pipeClient.TransmissionMode)
                Using sr As New StreamReader(pipeClient)
                    ' Display the read text to the console
                    Dim temp As String
                    ' Wait for 'sync message' from the server.
                        Console.WriteLine("[CLIENT] Wait for sync...")
                        temp = sr.ReadLine()
                    Loop While temp.StartsWith("SYNC") = False
                    ' Read the server data and echo to the console.
                    temp = sr.ReadLine()
                    While Not temp = Nothing
                        Console.WriteLine("[CLIENT] Echo: " + temp)
                        temp = sr.ReadLine()
                    End While
                End Using
            End Using
        End If
        Console.Write("[CLIENT] Press Enter to continue...")
        Console.ReadLine()
    End Sub
End Class
如何：使用命名管道进行网络进程间通信