编写主题发布/订阅系统

Question

我正在编写一个将发布和订阅主题的客户端/服务器应用程序。 我对这个项目的架构和实现几乎没有疑问。

首先设置基础，我将使用 c# (.NET 3.5)，并且我想明确使用原始套接字/AIO/线程（起初没有 WCF，因为我确实想根据我的需要微调服务器和客户端）。客户端主要订阅主题，但有时可能会向服务器发送命令，甚至发布数据。有些客户也可能只是发布者。

1. 你认为应该是什么 我的服务器的基本构建块（ 每个客户端的线程数, iocp, ....)。

2. 客户是否应该使用相同的 NetworkStream 监听订阅 主题并发送命令/发布到 服务器？如何等待数据和 同时将数据写入 流，这应该在 同一个线程？

（示例代码将不胜感激:)）

Answer 1

1. 我会尽可能多地使用异步套接字，因为这样您就无需管理自己的线程池来处理请求。

2. 客户端应使用两个流 - 一个用于列表，另一个用于发送。这将大大简化客户端和服务器端的事情。同样，使用异步套接字来避免管理多个线程。

请务必小心管理异步回调使用的共享资源的锁定。如果可能，请尽可能避免共享资源。管理对事物的并发访问通常是此类应用程序中最糟糕的部分。

Answer 2

您检查过 ActiveMQ 吗？我相信它已经做了主题，并且 C# 有能力通过他们的 NMS API 与它对话。