1

пишу программу на C и нужно реализовать такую штуку: Есть 2 потока, 1 который вынимает из базы запись ( если она есть ) и отсылает по указанному адресу данные через сокет, второй поток стои на приеме данных, т.е. если нам отсылают данные мы через сокет (на том же порту, что и поток для отправки работает) принимаем данные, обрабатываем и записываем в бд. Вопрос следующий, как это реализовать? 2 сокета на одинаковом порту открыть нельзя, по этому я подумал сделать флаг, который был бы false если поток для приема простаивает и в это время отсылал бы данные, но тут загвостка, не понятно по какому условию переключать флаг. Есть ли какое-то решение данного вопроса через потоки?

5
  • А как это «отправить через определённый порт»?
    – yolosora
    Commented 24 окт. 2018 в 15:26
  • не понял вашего вопроса. Я имел в виду, что поток отправки и поток приема должны работать на одном порте
    – Corle
    Commented 24 окт. 2018 в 15:30
  • 1
    Ну я к тому, что понимаем что такое причём на порте, а отправка на порте это что-то странное оО
    – yolosora
    Commented 24 окт. 2018 в 15:36
  • Используйте select,poll,epoll - по вкусу, два сокета не требуется в принципе, это не правильно. По событиям работайте с базой на чтение/запись. И кому отсылает поток? Там должен быть конкретный сокет прицепленного клиента. Делайте пул из изменений, и при коннекте клиента посылайте ему этот пул.. хотя надо понять какая архитектура и схема связи приложения.
    – NewView
    Commented 24 окт. 2018 в 16:15
  • 1
    А что вам мешает использовать таким способом один и тот же fd сокета в обоих потоках (posix threads)?
    – avp
    Commented 24 окт. 2018 в 20:19

1 ответ 1

0

Специально для решения этой проблемы в *NIX существует системный вызов select. Когда мы передаём этому вызову некоторый сокет, то select информирует нас о том, какое именно событие произошло на сокете:

  • если появились данные для чтения - можете их забирать и ложить в БД
  • если завершена запись в канал, можете проверить наличие данных для отправки и попытаться их передать.

Рекомендую Вам почитать раздел "6.3. Функция select" в книге У. Р. Стивенс, Б. Феннер, Э. М. Рудофф "UNIX Разработка сетевых приложений"

5
  • А получится на одном сокете и ожидать соединений и передавать через него данные?
    – Hivemaster
    Commented 25 окт. 2018 в 3:12
  • select именно для этого и предназначен.
    – Sergey
    Commented 25 окт. 2018 в 3:42
  • Может быть я и ошибаюсь, но select предназначен для мультиплексирования множества сокетов, а не перевода одного сокета из состояния ожидания соединений в состояние передачи и обратно.
    – Hivemaster
    Commented 25 окт. 2018 в 8:36
  • Этот системный вызов работает с множеством сокетов. Оно так и называется - socket set. По каждому элементу множества выполняется анализ событий - что произошло на данном сокете - поступили данные, ушли данные, произошла ошибка. Но ведь множество может состоять из одного сокета! И Вы так же будете отслеживать его состояние.
    – Sergey
    Commented 26 окт. 2018 в 2:08
  • Ага, если это серверный сокет, принимающий соединения, то единственное событие, которое будет на нём возникать - это событие нового соединения.
    – Hivemaster
    Commented 26 окт. 2018 в 7:45

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.