Протокол взаимодействия приложений. Сокеты

Имеется приложение П, которое работает самостоятельно. Данное приложение в своей памяти хранит некоторые данные, которые мне необходимо получить.

Допустим, я хочу получать данные через web интерфейс. У меня есть сервер на flask. Я хочу использовать приложение П в качестве источника данных.

В момент запуска определенной функции в приложении П, я создаю сокет localhost (и приложение П и сервер работают на одной системе). В момент запуска сервера, я подключаюсь к сокету, отрытому в приложении П.

На сервер каждую секунду отправляется GET запрос. В параметрах запроса указывается строка вида "var1,var2,...,varn". Эта строка с помощью split(',') разбивается на список имен переменных, значения которых нужно получить от приложения П.

Была поставлена задача разработать протокол взаимодействия сервера и приложения П через сокет.

Выбрал следующую структуру: [N0 ... N7][T0][L0 ... L22], где

N (8 бит) - номер запроса.

T (1 бит) - тип запроса GET:0/SET:1

L (23 бита) - длина данных, которые нужно принять в следующем сообщении. (наверное здесь будет использоваться len(pickle.dumps(список_переменных_после _сплит)))

После этого идут данные.

Вопрос: как правильно передавать биты в сокет? Ведь socket.send принимает только объекты типа bytes. Например, как правильно в этом случае передать длину? Или нужно самому извернуться и передавать строку вида b'0xaa8000ff', а затем парсить ее?

0

ioprst, из профинтереса (когда то занимался сокетами на Джава) - а почему опускаться до байтов и собственных протоколов? просто жсон слать/принимать не вариант?

1

Welemir1, спасибо, погуглю на эту тему.
Протокол хотел использовать, чтобы знать точное количество байт, которое нужно принять из сокета. Иначе, как полагаю, можно захватить данные уже из следующего пакета, например (если всегда читать, например, по 1024).

0

ioprst, понял, но насколько я помню сокет сам легко определяет что больше ничего не передают(то есть конец сообщения), просто условие нужно -пока есть что читать -читаем. Запросы же раз в секунду. Я бы рекомендовал проверить, даже на пересылке простых сообщений, мне кажется нормально он будет отличать один запрос от другого, но могу ошибаться.

0

Сообщение от Welemir1 кет сам легко определяет что больше ничего не передают

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

Для ТСа тоже советую обратить внимание на json и не трогать сокеты, а пользоваться высокоуровневыми библиотеками (requests для http).

1

Рыжий Лис, спасибо за совет. Не могли бы, пожалуйста, уточнить. Как именно здесь должна будет использоваться библиотека requests?
Мне необходимо связать два процесса, чтобы обмениваться данными. Один процесс (основной) в режиме реального времени выполняет какие-то действия и в некотором словаре хранит текущие значения некоторых данных. Мне необходимо эти данные перенаправить в другой процесс, запущенный на той же linux системе (тот сервер на flask). А уже с сервера клиенты получают данные, которые сейчас в основной программе.
Можно, конечно, запускать сервер непосредственно в основной программе, но этого хотелось бы избежать. Т.к. предполагается, что сервер является отдельной службой. Плюс, основной процесс иногда неактивен, а сервер должен работать всегда.

0

Сообщение от ioprst Мне необходимо связать два процесса, чтобы обмениваться данными.

Посмотреть в сторону redis. БД, кэш и брокер в одном флаконе.

1