Предоставляет транспорт основанный на сокетах. Поддерживаются интернет и UNIX сокеты. Интернет сокет использует TCP, UDP и RAWCAN протоколы.
Лицензия:
GPL
Введение
Модуль транспорта Sockets предоставляет в систему поддержку транспортов, основанных на сокетах. Поддерживаются входящие и исходящие транспорты, основанные на интернет сокетах: TCP, UDP и UNIX. Добавить новые входящие и исходящие сокеты можно посредством конфигурации транспортной подсистемы в любом конфигураторе системы OpenSCADA.
1. Входящие транспорты
Сконфигурированный и запущенный входящий транспорт открывает серверный сокет для ожидания соединения клиентов, кроме инициативного подключения. В случае с UNIX сокетом создаётся файл UNIX сокета. Сокеты TCP и UNIX являются многопоточными, т.е. при подключении клиента к сокетам данных типов создаётся клиентский сокет и новый поток, в котором производиться обслуживание клиента. Серверный сокет в этот момент переходит к ожиданию запросов от нового клиента. Таким образом достигается параллельное обслуживание клиентов. RAWCAN сокет осуществляет прием CAN кадров из интерфейса согласно настроенному фильтру.
Каждый входящий сокет связывается с одним из доступных транспортных протоколов, которому передаются входящие сообщения. В связке с транспортным протоколом поддерживается механизм объединения кусков разрозненных при передаче запросов.
Диалог конфигурации входящего сокета изображён на рис.1.
Рис.1. Диалог конфигурации входящего сокета.
С помощью этого диалога можно установить:
Состояние транспорта, а именно: "Статус", "Запущен", имя БД (содержащей конфигурацию) и список с информацией о текущих подключениях.
Идентификатор, имя и описание транспорта.
Адрес транспорта. Формат адреса описан в таблице ниже.
Выбор транспортного протокола.
Пустое значение выбора протокола переключает транспорт в режим создания ассоциированного исходящего транспорта для каждого подключения на данный входящий.
Режим ассоциированных исходящих транспортов для входящего предусматривает наличие некоей внешней для транспорта процедуры, выполняющей роль протокола, которая должна "обходить" все ассоциированные исходящие транспорты, и выполнять запросы на чтение или запись-чтение.
Отсутствие такой процедуры неизбежно приведёт к росту ассоциированных исходящих транспортов в виду отсутствия сущности останавливающей транспорты с закрытыми соединениями и возможности последующего удаления остановленных исходящих транспортов данным входящим транспортом.
Состояние, в которое переводить транспорт при загрузке: "Запускать".
Длина очереди сокетов, максимальное количество обслуживаемых клиентов, максимальное количество обслуживаемых клиентов по хостам (для TCP) и размер входного буфера.
Приоритет задач транспорта.
Максимальный размер сегмента (MSS), для ограничения размера отправляемых пакетов (сегментов TCP) на плохих каналах связи. Установить в 0 для снятия пользовательского ограничения размера.
Keep alive запросов. Закрытие подключения после указанного количества запросов. Нулевое значение для отключения (не закрывается никогда).
Keep alive время ожидания (сек.). Закрытие подключения после отсутствия запросов в течении указанного времени. Нулевое значение для отключения (не закрывается никогда).
Отключать данную функцию не рекомендуется поскольку свойство сетей TCP/IP не гарантирует уведомления сервера об отключении соединения, скажем в случае пропадания питания на клиенте. В результате чего могут навсегда оставаться открытые клиентские подключения, а при достижении лимита сервер перестанет принимать новые!
Особенности формирования адресов входящих сокетов приведены в таблице ниже:
Тип сокета
Адрес
TCP
TCP:{адрес}:{порт}:{режим}
где:
адрес — Адрес, на котором открывается сокет. Должен быть одним из адресов хоста. Если ничего не указано, то сокет будет доступен на всех интерфейсах хоста. Допускаются как символьное, так и IP представление адреса.
порт — Сетевой порт, на котором открывается сокет. Возможно указание символьного имени порта (в соответствии с /etc/services).
режим — режим работы входящего сокета:
'0' — Принудительно разрывать соединение после сеанса приём-ответ.
'1' — Не разрывать соединение, только с учётом параметров KeepAlive.
'2' — Инициативное подключение. Включает режим инициативы подключения данного входного транспорта к удалённому хосту (адрес вместо локального) и переход в режим ожидания запросов от этого хоста. Значение "Keep alive время ожидания (сек.)" используется как таймаут переподключения данного транспорта по отсутствию активности, с целью восстановления возможно потерянного подключения.
Пример: "TCP::10001:1" — TCP-сокет доступен на всех интерфейсах, открыт на порту 10001 и соединения не разрывает.
UDP
UDP:{адрес}:{порт}
где:
адрес — тоже что в TCP;
порт — тоже что в TCP.
Пример: "UDP:localhost:10001" — UDP-сокет доступен только на интерфейсе "localhost" и открыт на порту 10001.
RAWCAN
RAWCAN:{интерфейс}:{маска}:{идентификатор}
где:
интерфейс — имя CAN интерфейса;
маска, идентификатор — маска и идентификатор для фильтрации CAN кадров.
Пример: "RAWCAN:can0:0:0" — принимать все CAN кадры на интерфейсе can0.
Идентификатор CAN фрейма помещается в поле sender, данные - в request, длина поля данных — request.length. Признаком расширенного идентификатора является наличие старшего бита в идентификаторе (0x80000000)
UNIX
UNIX:{имя}:{режим}
где:
имя — имя файла UNIX сокета;
режим — тоже что в TCP.
Пример: "UNIX:/tmp/oscada:1" — UNIX-сокет доступен через файл "/tmp/oscada" и соединения не разрывает.
2. Исходящие транспорты
Сконфигурированный и запущенный исходящий транспорт открывает соединение с указанным сервером. При разрыве соединения исходящий транспорт отключается. Для возобновления соединения транспорт нужно снова запустить.
Главная вкладка страницы конфигурации исходящего сокета изображёна на рис.2.
Рис.2. Главная вкладка страницы конфигурации исходящего сокета.
С помощью этого диалога можно установить:
Состояние транспорта, а именно: "Статус", "Запущен" и имя БД, содержащей конфигурацию.
Идентификатор, имя и описание транспорта.
Адрес транспорта. Формат адреса описан в таблице ниже.
Состояние, в которое переводить транспорт при загрузке: "Запускать".
Максимальный размер сегмента (MSS), для ограничения размера отправляемых пакетов (сегментов TCP) на плохих каналах связи. Установить в 0 для снятия пользовательского ограничения размера.
Временные интервалы соединения в формате: "conn:next[:rep]". Где:
conn — максимальное время ожидания ответа соединения, в секундах;
next — максимальное время ожидания продолжения ответа, в секундах;
rep — минимальный таймаут ожидания повтора запроса, в секундах.
Адреса исходящих сокетов различного типа формируются следующим образом:
Тип сокета
Адрес
TCP/UDP
TCP:{адрес}:{порт} UDP:{адрес}:{порт}
где:
адрес — Адрес, с которым выполняется соединение. Допускаются как символьное так и IP представление адреса.
порт — Сетевой порт, с которым выполняется соединение. Возможно указание символьного имени порта (в соответствии с /etc/services).
Пример: "TCP:127.0.0.1:7634" — соединится с портом 7634 на хосте 127.0.0.1.
RAWCAN
RAWCAN:{интерфейс}:{маска}:{идентификатор}
где:
интерфейс — имя CAN интерфейса;
маска, идентификатор — маска и идентификатор CAN кадров.
Пример: "RAWCAN:can0:0:0" — принимать все CAN кадры на интерфейсе can0.
Отправка CAN фреймов в транспорт осуществляется в виде структуры struct can_frame. Размер структуры - 16 байт. 4 байта - идентификатор, 4 байта длина, 8 байт данные.