Асинхронный RPC

Нужно реализовать простейший RPC. Использование стандартный не позволяет религия
На стороне сервера идет обработка входящих команд, а так же отправка собственных событий.
Вся обработка - вызов обычных синхронных методов.

На стороне клиента создаются N потоков обработки. Каждый поток имеет уникальный идентификатор.
С ним он и отправляет запрос. Сервер ему отвечает с данным идентификатором.

Но сложность заключается в том, что сервер может не зависимо от времени посылать
собственные события с идентификатором созданного объекта обработки на стороне клиента.

Так вот и возникает вопрос, как на стороне клиента из приходящего замеса понять, что это ответ на посланную
команду. Нужно как-то дождаться ответа.

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

Тут и возникаю вопросы:
1. Обработку сетевого взаимодействия лучше делать в отдельном потоке ?
2. Как ожидать событие очереди ? Вычитывать и выбрасывать неподходящее ? Но тогда потеря событий...

0

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

Добавлено через 8 минут
xbarmaglot, Тебе стоит начать изучение сокетов с более простых задач.... Тогда сложные пойдут значительно проще. Когда поймешь работу асинхронных механизмов, работу со структурами данных и классами, тогда решение данной задачи будет для тебя очевидно.

1

QxtRPCPeer
QxtRPCService

0