管道通讯 C++

Question

我正在编写两个必须通信的小型 C++ 应用程序。第一个是一项服务，每隔一段时间就必须提醒用户一些事情。由于服务无法创建窗口，因此我将应用程序设计为两个单独的可执行文件。

该服务将使用通知程序进行通信。

该服务只需向通知程序发送短信，通知程序就会在系统托盘中显示一个气球。

我正在尝试使用命名管道，我想我已经差不多完成了，但还没有完全完成。到目前为止我所拥有的是：

在通知方：

  m_hInPipe = CreateNamedPipe(L"\\\\.\\pipe\\nhsupspipe", PIPE_ACCESS_INBOUND,
                PIPE_WAIT, 1, 1024, 1024, 60, NULL);

这意味着我创建了一个名为 nhsupspipe 的管道，一个入站管道。

在服务端：

if (!WriteFile(m_hOutPipe, "My message to the user?", 23, &escritos, &o))
     std::cout << "ERROR: " << GetLastError();

调试我可以看到一切正常，管道已创建，并且 WriteFile 将我的 23 个字节写入管道。

我的问题是：在通知方，我如何能够读取这些字节？是否有任何消息发送到进程？我必须为管道编写处理程序吗？任何事物？

Answer 1

来自客户（您的服务）和的一些简单片段服务器（通知者）
[注意：这是改编自我不久前完成的一个项目，该项目又受到 CreateNamedPipe 和 CreateNamedPipe 的 MSDN 示例的严重“影响”。 co]：

服务器端：

HANDLE hPipe = INVALID_HANDLE_VALUE;
bool bConnected = false;

 hPipe = CreateNamedPipe( L"\\\\.\\pipe\\nhsupspipe",
                          PIPE_ACCESS_DUPLEX,
                          PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
                          PIPE_UNLIMITED_INSTANCES,
                          sizeof( Message ),
                          0,
                          0,
                          NULL );

 // failed to create pipe?
 if( hPipe == INVALID_HANDLE_VALUE ){
   return -1;
 }

 // Wait for the client to connect; if it succeeds, 
 // the function returns a nonzero value. If the function
 // returns zero, GetLastError returns ERROR_PIPE_CONNECTED. 
 bConnected = ConnectNamedPipe( hPipe, NULL ) ? true : ( GetLastError() == ERROR_PIPE_CONNECTED );

 if( bConnected ){
  while( true ){ 
   unsigned long ulBytesRead = 0;
   // read client requests from the pipe. 
   bool bReadOk = ReadFile( hPipe,
                            &message,
                            sizeof( message ),
                            &ulBytesRead,
                            NULL );

   // bail if read failed [error or client closed connection]
   if( !bReadOk || ulBytesRead == 0 )
    break;

   // all ok, process the message received

  }
 }
 else{
   // the client could not connect, so close the pipe. 
   CloseHandle( hPipe );
 }

 return 0;

客户端：

HANDLE hPipe = INVALID_HANDLE_VALUE;

 // create the named pipe handle
 hPipe = CreateFile( L"\\\\.\\pipe\\nhsupspipe",
                     GENERIC_READ | GENERIC_WRITE,
                     0, 
                     NULL, 
                     OPEN_EXISTING,
                     0,
                     NULL );

 // if everything ok set mode to message mode
 if( INVALID_HANDLE_VALUE != hPipe ){
  DWORD dwMode = PIPE_READMODE_MESSAGE;
  // if this fails bail out
  if( !SetNamedPipeHandleState( hPipe, &dwMode, NULL, NULL ) ){
   CloseHandle( hPipe ); 

   return -1;
  }
 }

 unsigned long ulBytesWritten = 0;
 bool bWriteOk = WriteFile( hPipe, 
                            ( LPCVOID )&message, 
                            sizeof( Message ), 
                            &ulBytesWritten, 
                            NULL );

 // check if the writing was ok
 if( !bWriteOk || ulBytesWritten < sizeof( Message ) ){
  return -1;
 }

 // written ok

 return 0;

上面提到的消息是一个将成为您的消息的结构，您可能需要包。

因为在您的场景中，客户端（服务）可能会启动并启动。在服务器（通知程序）之前运行，您需要在客户端制定某种重新连接策略。

稍微不同的一点是，您应该仔细考虑奥斯特曼先生在他的回复中所说的话（甚至不为别的，只因为他是拉里·奥斯特曼）。

Answer 2

您需要使用 ReadFile 或 ReadFileEx（用于重叠 I/O）通常位于通知方在线程或消息循环中。另请参阅 CreateNamedPipe 和 < a href="http://msdn.microsoft.com/en-us/library/aa365800(VS.85).aspx" rel="nofollow noreferrer">等待NamedPipe。

Answer 3

在这种情况下，我可能会使用 RPC 而不是原始命名管道。使用原始命名管道，您必须解析来自客户端的数据，这可能会出现安全错误。使用 RPC，您可以让 RPC 为您解析数据，这减少了引入错误的机会。

Answer 4

不完全是问题，但另一个选择是 CreateEvent() 和内存映射文件。

Answer 5

如果我这样做，我会让服务端执行 CreateNamedPipe（出站），然后调用 ConnectNamedPipe 等待通知程序连接。

在通知程序方面，我将 CreateFile 与 FILE_FLAG_OVERLAPPED 一起使用。这样，当数据可供读取时，管道的句柄将收到信号。您的通知程序（大概）还将维护一个 GUI，因此您可能希望让它在其事件循环中调用 MsgWaitForMultipleObjects。这将等待消息被处理或等待管道上传入的数据被处理。这几乎像普通的事件循环一样工作，只是它的返回值与 GetMessage() 略有不同 - 如果您的句柄收到信号，它将返回 WAIT_OBJECT_0，或者WAIT_OBJECT_0 + 1 如果您有一条消息（假设您只让它在一个句柄上等待 - 它实际上是 WAIT_OBJECT_0 + N，其中 N是您让它等待的句柄数）。在大多数情况下，它就像一个普通的 PeekMessage 或 GetMessage 循环 - 等待，直到有事情要做，做，再等待。