1
0
mirror of https://github.com/Bayselonarrend/OpenIntegrations.git synced 2025-08-10 22:41:43 +02:00

Доп тексты TCP

This commit is contained in:
Anton Titovets
2024-12-17 14:41:01 +03:00
parent c033602d85
commit 1b11e0d00a
4 changed files with 2900 additions and 2768 deletions

File diff suppressed because it is too large Load Diff

View File

@@ -2183,6 +2183,8 @@
TCP_ЗакрытьСоединение(ПараметрыТеста);
TCP_ПрочитатьДвоичныеДанные(ПараметрыТеста);
TCP_ОтправитьДвоичныеДанные(ПараметрыТеста);
TCP_ПрочитатьСтроку(ПараметрыТеста);
TCP_ОтправитьСтроку(ПараметрыТеста);
TCP_ОбработатьЗапрос(ПараметрыТеста);
КонецПроцедуры
@@ -15732,7 +15734,6 @@
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ПрочитатьДвоичныеДанные (таймаут)", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Сообщение);
КонецПроцедуры
Процедура TCP_ОтправитьДвоичныеДанные(ПараметрыФункции) Экспорт
@@ -15742,20 +15743,20 @@
Сообщение = "Hello server!" + Символы.ПС;
Данные = ПолучитьДвоичныеДанныеИзСтроки(Сообщение);
OPI_TCP.ОтправитьДвоичныеДанные(Соединение, Данные);
Результат = OPI_TCP.ОтправитьДвоичныеДанные(Соединение, Данные);
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
// Маркер конца сообщения для исключения ожидания конца таймаута
Маркер = Символы.ПС;
Результат = OPI_TCP.ПрочитатьДвоичныеДанные(Соединение, , Маркер);
Маркер = Символы.ПС;
Ответ = OPI_TCP.ПрочитатьДвоичныеДанные(Соединение, , Маркер);
OPI_TCP.ЗакрытьСоединение(Соединение);
// END
Результат = ПолучитьСтрокуИзДвоичныхДанных(Результат);
Ответ = ПолучитьСтрокуИзДвоичныхДанных(Ответ);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ОтправитьДвоичныеДанные", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Сообщение);
OPI_ПолучениеДанныхТестов.Проверка_Строка(Ответ, Сообщение);
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
@@ -15785,6 +15786,70 @@
КонецПроцедуры
Процедура TCP_ПрочитатьСтроку(ПараметрыФункции) Экспорт
Адрес = ПараметрыФункции["TCP_Address"];
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
Данные = "Hello server!" + Символы.ПС;
OPI_TCP.ОтправитьСтроку(Соединение, Данные);
// Маркер конца сообщения для исключения ожидания конца таймаута
Маркер = Символы.ПС;
Результат = OPI_TCP.ПрочитатьСтроку(Соединение, , Маркер);
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
OPI_TCP.ЗакрытьСоединение(Соединение);
// END
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ПрочитатьСтроку", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Данные);
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
OPI_TCP.ОтправитьСтроку(Соединение, Данные);
Результат = OPI_TCP.ПрочитатьСтроку(Соединение, , , 50000);
OPI_TCP.ЗакрытьСоединение(Соединение);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ПрочитатьСтроку (таймаут)", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Данные);
КонецПроцедуры
Процедура TCP_ОтправитьСтроку(ПараметрыФункции) Экспорт
Адрес = ПараметрыФункции["TCP_Address"];
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
Данные = "Hello server!" + Символы.ПС;
Результат = OPI_TCP.ОтправитьСтроку(Соединение, Данные);
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
// Маркер конца сообщения для исключения ожидания конца таймаута
Маркер = Символы.ПС;
Ответ = OPI_TCP.ПрочитатьСтроку(Соединение, , Маркер);
OPI_TCP.ЗакрытьСоединение(Соединение);
// END
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ОтправитьСтроку", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Ответ, Данные);
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
OPI_TCP.ОтправитьСтроку(Соединение, Данные);
Результат = OPI_TCP.ПрочитатьСтроку(Соединение, , , 50000);
OPI_TCP.ЗакрытьСоединение(Соединение);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ОтправитьСтроку (таймаут)", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Данные);
КонецПроцедуры
#КонецОбласти
#КонецОбласти

View File

@@ -2060,9 +2060,9 @@
КонецФункции
Функция ПолучитьОбщийМодуль(Знач Имя)
Модуль = Вычислить(Имя);
Возврат Модуль;
КонецФункции

View File

@@ -2183,6 +2183,8 @@
TCP_ЗакрытьСоединение(ПараметрыТеста);
TCP_ПрочитатьДвоичныеДанные(ПараметрыТеста);
TCP_ОтправитьДвоичныеДанные(ПараметрыТеста);
TCP_ПрочитатьСтроку(ПараметрыТеста);
TCP_ОтправитьСтроку(ПараметрыТеста);
TCP_ОбработатьЗапрос(ПараметрыТеста);
КонецПроцедуры
@@ -15732,7 +15734,6 @@
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ПрочитатьДвоичныеДанные (таймаут)", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Сообщение);
КонецПроцедуры
Процедура TCP_ОтправитьДвоичныеДанные(ПараметрыФункции) Экспорт
@@ -15742,20 +15743,20 @@
Сообщение = "Hello server!" + Символы.ПС;
Данные = ПолучитьДвоичныеДанныеИзСтроки(Сообщение);
OPI_TCP.ОтправитьДвоичныеДанные(Соединение, Данные);
Результат = OPI_TCP.ОтправитьДвоичныеДанные(Соединение, Данные);
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
// Маркер конца сообщения для исключения ожидания конца таймаута
Маркер = Символы.ПС;
Результат = OPI_TCP.ПрочитатьДвоичныеДанные(Соединение, , Маркер);
Маркер = Символы.ПС;
Ответ = OPI_TCP.ПрочитатьДвоичныеДанные(Соединение, , Маркер);
OPI_TCP.ЗакрытьСоединение(Соединение);
// END
Результат = ПолучитьСтрокуИзДвоичныхДанных(Результат);
Ответ = ПолучитьСтрокуИзДвоичныхДанных(Ответ);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ОтправитьДвоичныеДанные", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Сообщение);
OPI_ПолучениеДанныхТестов.Проверка_Строка(Ответ, Сообщение);
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
@@ -15785,6 +15786,70 @@
КонецПроцедуры
Процедура TCP_ПрочитатьСтроку(ПараметрыФункции) Экспорт
Адрес = ПараметрыФункции["TCP_Address"];
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
Данные = "Hello server!" + Символы.ПС;
OPI_TCP.ОтправитьСтроку(Соединение, Данные);
// Маркер конца сообщения для исключения ожидания конца таймаута
Маркер = Символы.ПС;
Результат = OPI_TCP.ПрочитатьСтроку(Соединение, , Маркер);
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
OPI_TCP.ЗакрытьСоединение(Соединение);
// END
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ПрочитатьСтроку", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Данные);
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
OPI_TCP.ОтправитьСтроку(Соединение, Данные);
Результат = OPI_TCP.ПрочитатьСтроку(Соединение, , , 50000);
OPI_TCP.ЗакрытьСоединение(Соединение);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ПрочитатьСтроку (таймаут)", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Данные);
КонецПроцедуры
Процедура TCP_ОтправитьСтроку(ПараметрыФункции) Экспорт
Адрес = ПараметрыФункции["TCP_Address"];
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
Данные = "Hello server!" + Символы.ПС;
Результат = OPI_TCP.ОтправитьСтроку(Соединение, Данные);
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
// Маркер конца сообщения для исключения ожидания конца таймаута
Маркер = Символы.ПС;
Ответ = OPI_TCP.ПрочитатьСтроку(Соединение, , Маркер);
OPI_TCP.ЗакрытьСоединение(Соединение);
// END
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ОтправитьСтроку", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Ответ, Данные);
Соединение = OPI_TCP.ОткрытьСоединение(Адрес);
OPI_TCP.ОтправитьСтроку(Соединение, Данные);
Результат = OPI_TCP.ПрочитатьСтроку(Соединение, , , 50000);
OPI_TCP.ЗакрытьСоединение(Соединение);
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Результат, "ОтправитьСтроку (таймаут)", "TCP");
OPI_ПолучениеДанныхТестов.Проверка_Строка(Результат, Данные);
КонецПроцедуры
#КонецОбласти
#КонецОбласти