使用POSIX消息队列而不是TCP套接字 – 如何建立“连接”？
我有客户端和服务器程序，现在通过TCP进行通信。 我正在尝试使用POSIX消息队列（当然，在客户端和服务器位于同一台机器上的情况下）。 我希望它能提高性能（特别是通过减少延迟）。
我已经解决了大部分问题，但我不确定一件事：如何建立“连接”。 服务器同时接受来自多个客户端的连接，所以我很想模仿TCP连接建立过程，如下所示：
- 服务器打开一个具有已知名称的队列并连续读取它（它可以像使用TCP一样使用
select(2)）。 - 客户端打开三个队列：两个具有任意名称（包括一些唯一性，例如PID以避免冲突），以及一个具有服务器使用的已知名称的队列。
- 客户端向服务器的队列发送“连接”消息，包括客户端的队列名称（一个指定用于客户端到服务器的流量，另一个指定用于反向）。
- 服务器打开客户端连接消息中指定的队列，并开始从客户端到服务器读取（选择）。
- 客户端使用众所周知的名称关闭服务器队列。 使用客户端命名的两个队列（每个方向一个）进行双向通信。
您可能会看到此方案与常见的TCP方法类似，这并非偶然。 但是，我想知道：
- 你能想到更好的方法吗？
- 你看到我的方法有任何潜在的问题吗？
- 您是否有任何其他想法，包括在同一台计算机上使用消息队列而不是TCP实际上可以提高性能（延迟）的可能性？
请记住，之前我没有使用POSIX消息队列（我之前使用过IBM WebSphere MQ，但这有点不同）。 该平台是Linux。
-
你能想到更好的方法吗？
也许看看fifos（又名命名管道）。 它们就像网络套接字，但对于本地机器。 它们是单向的，因此您可能需要为每个方向创建两个，一个。 您的问题确实没有任何理由说明您为何具体进行此更改。 使用套接字进程来处理通信没有任何问题。 它们是双向的，高效的，广泛支持的，并且可以让您自由地在以后分离机器之间的过程。
-
你看到我的方法有任何潜在的问题吗？
System V消息队列和fifo命名管道都非常好。 Fifo管道就像常规管道，所以你可以用最少的代码更改来读取（）和write（）。 System V消息队列需要将数据放入结构并调用msgsnd（）。 无论哪种方法都没问题。
-
您是否有任何其他想法，包括在同一台计算机上使用消息队列而不是TCP实际上可以提高性能（延迟）的可能性？
我的其他想法是，正如你所说，你需要开发一种技术，以便每个客户都有一个唯一的标识符。 一种方法是将pid添加到您传递的结构中，或者在开头与父/ master协商唯一ID。 另外需要注意的是，System V消息队列的好处是您可以侦听“选择性”消息，因此您可以理想地使用从服务器到所有客户端的一个队列，每个客户端等待不同的消息。
我不知道哪种技术可以为您提供最佳的软件吞吐量。 使用System V消息队列确实可能不值得，但只有您可以做出决定。
Philluminati
我最终基本上按照我的描述实现了它，并进行了一些增强：
- 在步骤2中，我使用GUID作为队列名称，而不是合并客户端的PID。
- 在步骤4中，我添加了从服务器向客户端发送“接受”消息。
- 当任何一方希望结束通信时，它会发送“断开”消息。
握手比TCP简单，但似乎足够了。
至于延迟：它好多了。 在同一台计算机上使用POSIX消息队列而不是TCP的延迟大约减少75％。 我的消息大约是每个100字节。
我比较了posix MQ和一对TCP / IP套接字的性能。
演示程序有两个线程用于写入，另一个用于读取。
结果是posix MQ更快，
- MQ 460000 tps
- socketpair 400000 tps
我遇到了类似的问题，我开发了实时应用程序，需要IPC技术，类似于套接字function和最小延迟。
您是否仅将基于POSIX-MQ的解决方案与UNIX本地套接字或TCP套接字进行了比较？
谢谢
当select（）不能对消息队列起作用时，你是如何做到这一点的？ 什么是Sys V或POSIX？ 当PID保证唯一且存储量较小（整数）时，为什么要花费额外的精力来创建GUID到PID查找表？
/ blee /
您还可以在驻留在不同计算机上的程序中使用IPC的消息队列，在这种情况下，您可以使用ZeroMQ（ http://www.zeromq.org ）或其他消息队列API，我还建议您考虑它们，并测试他们也是。