Фрилансеры предложат решение вашей задачи уже через несколько минут!
Публикация заказа не займет много времени.
2 месяца назад
Жданов Егор
32 года, Украина
5 месяцев в сервисе
Был онлайн 13 минут назад
2 месяца назад

Внимание, если нет опыта с pyZMQ и AsyncIO лучше не терять время ) 

Есть код: 

import zmq 
import datetime 
################################################## ################################################## ## 
port_01 = "5559" 
port_02 = "5579" 
################################################## ################################################## ## 
context_01 = zmq.Context() 
context_02 = zmq.Context() 
socket_01 = context_01.socket(zmq.PAIR) 
socket_02 = context_02.socket(zmq.PAIR) 
socket_01.bind("tcp://*:%s" % port_01) 
socket_02.bind("tcp://*:%s" % port_02) 
while True: 
    try: 
        start_time = datetime.datetime.now() 
        data_0 = json.loads(socket_01.recv()) 
        data_2 = json.loads(socket_02.recv()) 
        print(data_0) 
        print(data_2) 


Проблема в том что вызов socket_02.recv() блокирующий, соответственно пока не придут данные data_0 не принимаются данные data_2  

Скорость отправки сообщений разная, поэтому программа работает некорректно 

Нужно написать три функции: два не блокирующих получения данных, и третья, которая эти данные обрабатывает.  

Вот тема с похожим обсуждением – https://stackoverflow.com/questions/27183148/why-asyncio-queue-could-not-work-as-expected

https://pyzmq.readthedocs.io/en/latest/api/zmq.asyncio.html

В итоге должны независимо друг от друга непрерывно литься данные в две функции, а третья их параллельно обрабатывать

Заявки фрилансеров

Нет заявок от фрилансеров

Похожие заказы

Написать адд он позволяющий захватывать экран и переводить в формат Video 9

написать адд он позволяющий захватывать экран и переводить в формат Video 9.

Создание модуля DLL "Копирование базы данных в архив"

ПОСТАНОВКА ЗАДАЧИ Написать дополнительный модуль для программы, работающей с базой данных mdb (формат Microsoft Access 97). Задача модуля: сделать копию файла базы данных в другой каталог (это будет архив), а из оригинала файла базы данных удалить ст...

Создание программы обработки данных

Требуется написать программу на любом из языков. Если коротко, то набор объектов описывается неким числом параметров, которые должны заноситься и извлекаться из базы данных (лучше, если MS Access, но варианты рассматриваются). Сопоставляя эти парамет...

Обработка sms-компьютер+сотовый

Нужен разработчик программы для обработки sms-сообщений из сотового телефона и их записи в файл на компьютер.

"Разработка программы обработки и хранения изображений"

Необходимо реализовать функции стандартных эффектов обработки изображений, применение и использование анимации, 2-D графики, возможна реализация некоторых функций с использованием Flash, прорисовка скинов и анимации на скинах, проработка интеграции с...

Система передачи голосовых сообщений в почтовом сервисе

Необходимо создать Систему передачи голосовых сообщений, гол. разговоров. С ситемой регистрации пользователей обслуживающихся на нашем почтовом сервисе. Общение только между нашими пользователями! По аналогии с Google Talk. С передачей с исключительн...

Необходимо написать DLL/компонент

Необходимо написать DLL/компонент для отслеживания времени бездействия системы. Под бездействием понимается отсутствие нажатия клавиш на клавиатуре и движений мышью. Компонент должен работать во ВСЕХ операционных системах windows. Все дополнительные ...

Разработка модуля обмена сообщениями (почта+форум) для программы Delphi+MS

Кратко: Необходима реализация подсистемы обмена сообщениями между пользователями некоторой сетевой программы с архитектурой клиент-сервер. Клиент: Delphi, Сервер: MSSQL. Требуется: написать модуль/компонент, который может быть легко интегрирован в др...

Модуль для отправки и получения SMS сообщений

Необходимо создать DLL и пример работы с ней из VB Задача: Создать DLL с открытым кодом(!). в которой будут реализованы функции для отправки и получения SMS сообщения через мобильный телефон, подключенный к COM порту.

Написать программку для вычисления скорости сети во время игры в CS:source.

Нужно написать небольшую программу на Delphi. Задача такая, вполне не сложная: программа вычисляет скорость соединения между клиентом и сервером во время игры в Counter-strike source и показывает результаты в углу экрана шкалой (через direct draw или...