2

我使用命名管道在一个程序内部进行内部通信（在 Windows XP 上）。当我连接 2-3 个客户端时，命名管道适用于多个连接。但是，当我同时应用多个连接（例如 10 个）时，它似乎被卡住了，ConnectNamedPipe() 只能接受几个连接，并且通信似乎被卡住了。

但是当我在客户端代码中调试时，我发现所有客户端 CreateFile 函数都正确返回了文件句柄（似乎是正确的）。这很令人困惑，因为我观看了 CreateNamedPipe 循环，它只创建了大约一半的句柄......

服务器部分：

       while (!isPipeServerClosed)
        {
            try
            {
                filehandle = CreateNamedPipe(
                this.pipeName,
                DUPLEX | FILE_FLAG_OVERLAPPED,
                PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE,
                255,
                InBufferSize,
                InBufferSize,
                0,
                IntPtr.Zero);
                if (ConnectNamedPipe(filehandle, IntPtr.Zero) > 0)
                {

                    PipeThread pipe = new PipeThread(filehandle);
                    sPipeThreadList.Add(pipe);
                }
            }
            catch (Exception exp)
            {
                System.Console.WriteLine(exp.StackTrace);
            }

        }

客户端部分，简单的 Delphi 代码（即使我尝试使用 WaitNamedPipe 也表现相同）：

  FHandle := INVALID_HANDLE_VALUE;
  FHandle := CreateFile(PChar(FPipeName),GENERIC_READ or GENERIC_WRITE,
        0,0,OPEN_EXISTING,FILE_FLAG_OVERLAPPED,0);
  // create the class
  if FHandle = INVALID_HANDLE_VALUE then
  begin
    Connected := false;
  end

我能知道我错过了什么吗？谢谢！

4

1 回答 1

1

您没有正确使用重叠操作。特别是：

如果使用 FILE_FLAG_OVERLAPPED 打开 hNamedPipe，则 lpOverlapped 参数不得为 NULL。它必须指向一个有效的 OVERLAPPED 结构。如果使用 FILE_FLAG_OVERLAPPED 打开 hNamedPipe 并且 lpOverlapped 为 NULL，则该函数可能会错误地报告连接操作已完成。

另外，我想有时您的ConnectNamedPipe调用会返回错误，因为客户端尚未连接（ERROR_IO_PENDING）。在这些情况下，当他们的连接完成时，您的客户将被“孤立”，因为您不会PipeThread为他们创建一个。

如果你想使用重叠模式，你应该做更多的研究并正确实施。或者，如果您从 CreateNamedPipe 的参数中删除 FILE_FLAG_OVERLAPPED，则 ConnectNamedPipe 将阻塞，直到客户端连接并且不会发生此问题，尽管您将遇到不同的问题：当您想要停止服务器时如何解除阻塞（您我会在 SO，IIRC 上找到一些答案）。

于 2013-06-12T14:05:07.153 回答