Написание темы pub/sub system

Question

Я пишу клиент/серверное приложение, которое опубликует и подписаться на темы. У меня мало вопросов об архитектуре и реализации этого проекта.

Прежде всего, чтобы настроить базу, я буду использовать C# (.NET 3.5), и я хочу явно использовать raw Sockets/AIO/Threads (сначала нет WCF, поскольку я хочу точно настроить сервер и клиентов на мои потребности) , Клиенты в основном подписываются на темы, но могут иногда отправлять команду на сервер и даже публиковать данные. Некоторые клиенты могут быть только издателями.

1. Как вы думаете, должны быть основные строительные блоки моего сервера ( нитей на клиента, IOCP, ....).

2. Если клиент использовать один и тот же NetworkStream слушать подписался темы и отправить команду/опубликовать сервер? Как дождаться данных и в то же время записать данные в поток , должно ли это быть сделано в той же теме?

(пример код будет понятно :))

Answer 1

1. Я хотел бы использовать асинхронные розетки как можно больше, как это устранит необходимость для вас, чтобы управлять своим собственным пулом потоков для обработки запроса.

2. Клиент должен использовать два потока - один для перечисления и другой для отправки. Это значительно упростит работу как на стороне клиента, так и на стороне сервера. Опять же, используйте асинхронные сокеты, чтобы избежать необходимости управлять несколькими потоками.

Просто следите за тем, чтобы быть осторожным в управлении блокировкой с использованием общих ресурсов, используемых вашими асинхронными обратными вызовами. Если это вообще возможно, избегайте использования общих ресурсов как можно больше. Managine одновременный доступ к вещам, как правило, является наихудшей частью любого приложения, подобного этому.

Answer 2

Вы проверили ActiveMQ? Я считаю, что это уже темы, и C# имеет возможность поговорить с ним через свой NMS API.