c#中使用管道进行进程间通信

Question

我正在写两个程序

• 第一个程序发送短信给第二个程序。
第二个程序将所有消息写入指定文件。一旦第二个程序终止，那么它需要通知第一个程序它将要关闭或终止。

如果第二个程序未启动，则不允许用户从第一个程序发送消息。如果用户再次打开第二个程序，那么第一个程序需要允许发送消息。如果第一个程序没有启动或关闭，那么第二个程序也需要自动关闭。

我试着写代码，但我不能得到所有的场景。在这段代码中，我能够发送文本并将文本保存在文件中。在那之后，我不能做

第一个程序代码在这里:

public void ThreadStartClient(object obj)
{
        ManualResetEvent syncServer = (ManualResetEvent)obj;
        using (NamedPipeClientStream pipeStream = new NamedPipeClientStream("PipeTo"))
        {
            pipeStream.Connect();
            Console.WriteLine("[First program] Pipe Connection established");
            using (StreamWriter sw = new StreamWriter(pipeStream))
            {
                sw.AutoFlush = true;
                string message;
                Console.WriteLine("Please type a message and press [ENTER], or type 'quit' to exit the program");
                while ((message = Console.ReadLine()) != null)
                {
                    if (message == "quit")
                    {
                        break;
                    }
                    try
                    {
                        sw.WriteLine(message);
                    }
                    catch (Exception ex)
                    {
                       // pipeStream.Connect();
                    }
                }
            }
        }
    }

第二个程序代码在这里:

 public void ThreadStartServer()
    {
        using (NamedPipeServerStream pipeStream = new NamedPipeServerStream("PipeTo"))
        {
            Console.WriteLine("[Second program] Pipe Created");
            pipeStream.WaitForConnection();
            Console.WriteLine("[Second program] Pipe connection established");
            StreamWriter sw1 = new StreamWriter("C:\ServerEXE\DemoTest.txt", true);

            using (StreamReader sr = new StreamReader(pipeStream))
            {
                string message;
                while ((message = sr.ReadLine()) != null)
                {
                    sw1.WriteLine(message);
                    sw1.Flush();
                    Console.WriteLine("{0}", message);
                }
            }
        }
        Console.WriteLine("Connection lost");
    }

Answer 1

我建议第二个程序创建一个名为EventWaitHandle的程序，并将其状态设置为有信号。第一个程序可以测试事件，看它是否有信号。如果是，那么它可以发送消息。

在第一个程序中，你写:

private EventWaitHandle SendMessageEvent;
private const string WaitHandleName = "UniqueNameForThisHandle";
void InitializeWaitHandle()
{
    SendMessageEvent = new EventWaitHandle(false, EventResetMode.ManualReset, WaitHandleName);
}

并且，要发送消息，您首先检查等待句柄:

if (SendMessageEvent.WaitOne(0))
{
    // event is signaled, so send the message
}

第二个程序打开等待句柄并将其状态设置为有信号:

void InitializeWaitHandle()
{
    SendMessageEvent = new EventWaitHandle(false, EventResetMode.ManualReset, WaitHandleName);
    SendMessageEvent.Set();
}

当第二个程序关闭时，或者如果您不想让它接收消息，只需调用Reset:

SendMessageEvent.Reset();

在两个程序中使用相同的等待句柄名称。但是要使用一个不太可能被其他程序使用的名称。