У меня есть два процесса, процесс A, который собирает информацию из канала, выполняет некоторые вычисления и выводит некоторые данные в процесс B, который использует эти данные.
Процесс A, вероятно, отправляет около 50 сообщений в секунду для процесса B. Мне не требуется, чтобы все сообщения доходили до процесса B.
В настоящее время у меня есть процесс A, работающий в качестве веб-сервера, а процесс B подписывается как клиент веб-сокета на процесс A. Это выглядит довольно странно, и я чувствую, что, возможно, есть лучшее решение.
Я знаю о различных очередях обмена сообщениями, таких как модели RabbitMQ и Pub / Sub, таких как Redis Pub Sub, но мне кажется, что а) Я перерабатываю вещи и добавляю слой сложности, и б) это, вероятно, замедлит время, необходимое для того, чтобы сообщения достигли процесса B.
Есть ли лучшее решение, которое быстрее, чем запуск одного процесса в качестве локального веб-сервера для другого процесса? Что-то не так с тем, что я сейчас делаю?