You've already forked OpenIntegrations
mirror of
https://github.com/Bayselonarrend/OpenIntegrations.git
synced 2026-06-20 09:19:27 +02:00
Main build (Jenkins)
This commit is contained in:
Vitaly the Alpaca (bot)
Vendored
-4
@@ -2046,10 +2046,6 @@ def test_tcp(){
|
||||
powershell encoding: 'UTF-8', script:'./oint.exe tcp ProcessRequest --address "test" --data "test" --string "test" --debug --test '
|
||||
}
|
||||
|
||||
catchError(buildResult: 'FAILURE', stageResult: 'FAILURE') {
|
||||
powershell encoding: 'UTF-8', script:'./oint.exe tcp ActualiseIncomingConnections --srv "test" --debug --test '
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -1,40 +0,0 @@
|
||||
---
|
||||
sidebar_position: 3
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Close incoming connection
|
||||
Closes an existing connection by identifier
|
||||
|
||||
|
||||
|
||||
`Function CloseIncomingConnection(Val ConnectionID, Val TCPHandler = "") Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| ConnectionID | - | String, Number | ✔ | Active connection ID. See AwaitingConnection |
|
||||
| TCPHandler | - | Arbitrary | ✖ | TCP server or empty value for standalone processing |
|
||||
|
||||
|
||||
Returns: Structure Of KeyAndValue - Execution information
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,41 +0,0 @@
|
||||
---
|
||||
sidebar_position: 1
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# GetRequest
|
||||
Gets data from the flow stream of an existing connection
|
||||
|
||||
|
||||
|
||||
`Function GetRequest(Val ConnectionID, Val MaxSize = 0, Val TCPHandler = "") Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| ConnectionID | - | String, Number | ✔ | Active connection ID. See AwaitingConnection |
|
||||
| MaxSize | - | Number | ✖ | Max data size. 0 > to the end of the stream |
|
||||
| TCPHandler | - | Arbitrary | ✖ | TCP server or empty value for standalone processing |
|
||||
|
||||
|
||||
Returns: Structure Of KeyAndValue, BinaryData - Binary data on success or structure with error description
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,44 +0,0 @@
|
||||
---
|
||||
sidebar_position: 2
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# SendResponse
|
||||
Sends data to the client by connection ID
|
||||
|
||||
|
||||
|
||||
`Function SendResponse(Val ConnectionID, Val Data, Val TCPHandler = "") Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| ConnectionID | - | String, Number | ✔ | Active connection ID. See AwaitingConnection |
|
||||
| Data | - | BinaryData | ✔ | Sending data |
|
||||
| TCPHandler | - | Arbitrary | ✖ | TCP server or empty value for standalone processing |
|
||||
|
||||
|
||||
Returns: Structure Of KeyAndValue - Execution information
|
||||
|
||||
<br/>
|
||||
|
||||
:::tip
|
||||
Parameters with Binary data type can also accept file paths on disk and URLs
|
||||
:::
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,4 +0,0 @@
|
||||
{
|
||||
"label": "Connection handling methods",
|
||||
"position": "4"
|
||||
}
|
||||
@@ -1,34 +0,0 @@
|
||||
---
|
||||
sidebar_position: 6
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# ActualiseIncomingConnections
|
||||
Removes inactive connections from the pool
|
||||
|
||||
|
||||
|
||||
`Function ActualiseIncomingConnections(Val TCPServer) Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| TCPServer | --srv | Arbitrary | ✔ | TCP server. See CreateServer |
|
||||
|
||||
|
||||
Returns: Structure Of KeyAndValue - Execution information
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
-40
@@ -1,40 +0,0 @@
|
||||
---
|
||||
sidebar_position: 1
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Create server
|
||||
Creates a new TCP server and sets the port
|
||||
|
||||
|
||||
|
||||
`Function CreateServer(Val Port, Start = False) Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| Port | - | Number | ✔ | Available port number for the server |
|
||||
| Start | - | Boolean | ✖ | True > immediately starts the created server |
|
||||
|
||||
|
||||
Returns: Arbitrary - Returns a running TCP server object on successful creation or a structure with an error description
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,42 +0,0 @@
|
||||
---
|
||||
sidebar_position: 5
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Get incoming connections
|
||||
Gets the list of connections in the pool
|
||||
|
||||
|
||||
|
||||
`Function GetIncomingConnections(Val TCPServer) Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| TCPServer | - | Arbitrary | ✔ | TCP server. See CreateServer |
|
||||
|
||||
|
||||
Returns: Structure Of KeyAndValue - Execution information
|
||||
|
||||
<br/>
|
||||
|
||||
:::tip
|
||||
The presence of a connection in the pool does not guarantee that it is active. The ActualiseIncomingConnections function is used to clear the pool of inactive connections
|
||||
:::
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
-39
@@ -1,39 +0,0 @@
|
||||
---
|
||||
sidebar_position: 7
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Is server
|
||||
Specifies if the value passed is a TCP server object
|
||||
|
||||
|
||||
|
||||
`Function IsServer(Val Value) Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| Value | - | Arbitrary | ✔ | arbitrary value to check |
|
||||
|
||||
|
||||
Returns: Boolean - Is server
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
-39
@@ -1,39 +0,0 @@
|
||||
---
|
||||
sidebar_position: 2
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Start server
|
||||
Starts a previously created server
|
||||
|
||||
|
||||
|
||||
`Function StartServer(Val TCPServer) Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| TCPServer | - | Arbitrary | ✔ | TCP server. See CreateServer |
|
||||
|
||||
|
||||
Returns: Structure Of KeyAndValue - Structure with information about the startup success
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
-39
@@ -1,39 +0,0 @@
|
||||
---
|
||||
sidebar_position: 3
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Stop server
|
||||
Stops a running server
|
||||
|
||||
|
||||
|
||||
`Function StopServer(Val TCPServer) Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| TCPServer | - | Arbitrary | ✔ | TCP server. See CreateServer |
|
||||
|
||||
|
||||
Returns: Structure Of KeyAndValue - Execution information
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,73 +0,0 @@
|
||||
---
|
||||
sidebar_position: 4
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Wait incoming connections
|
||||
Blocks programm execution until a new connection is established
|
||||
|
||||
|
||||
|
||||
`Function WaitIncomingConnections(Val TCPServer, Val Timeout = 0) Export`
|
||||
|
||||
| Parameter | CLI option | Type | Required | Description |
|
||||
|-|-|-|-|-|
|
||||
| TCPServer | - | Arbitrary | ✔ | TCP server. See CreateServer |
|
||||
| Timeout | - | Number | ✖ | Maximum waiting time for connections. 0 > unlimited |
|
||||
|
||||
|
||||
Returns: Structure Of KeyAndValue - Structure with new connection ID or error information
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** this method is not available in CLI version
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="1C:Enterprise/OneScript code example"
|
||||
// -- Test request for server
|
||||
|
||||
ClientKey = New UUID;
|
||||
Message = "Test data sending to the server";
|
||||
|
||||
ClientParams = New Array;
|
||||
ClientParams.Add("127.0.0.1:7788"); // Our server
|
||||
ClientParams.Add(Message); // Test string
|
||||
ClientParams.Add("UTF-8"); // Encoding
|
||||
ClientParams.Add("20000"); // Timeout, for make it in time launch server
|
||||
|
||||
// Sending a test request via TCP client methods
|
||||
ClientBackground = BackgroundJobs.Execute("OPI_TCP.SendLine", ClientParams, ClientKey);
|
||||
|
||||
// --
|
||||
|
||||
TCPServer = OPI_TCP.CreateServer(7788, True);
|
||||
|
||||
NewConnection = OPI_TCP.WaitIncomingConnections(TCPServer, 20);
|
||||
|
||||
If NewConnection["result"] Then
|
||||
|
||||
Connection = NewConnection["connection"]["id"];
|
||||
|
||||
ProcessingParameterArray = New Array;
|
||||
ProcessingParameterArray.Add(Connection); // String: "1:7788"
|
||||
|
||||
BackgroundProcessing = BackgroundJobs.Execute("OPI_Tests.TCP_ProcessConnection", ProcessingParameterArray);
|
||||
|
||||
TCP_ProcessConnection(Connection);
|
||||
|
||||
EndIf;
|
||||
|
||||
Shutdown = OPI_TCP.StopServer(TCPServer);
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,4 +0,0 @@
|
||||
{
|
||||
"label": "Server methods",
|
||||
"position": "3"
|
||||
}
|
||||
@@ -1,40 +0,0 @@
|
||||
---
|
||||
sidebar_position: 3
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Закрыть входящее соединение
|
||||
Закрывает существующее соединение по идентификатору
|
||||
|
||||
|
||||
|
||||
`Функция ЗакрытьВходящееСоединение(Знач IDПодключения, Знач TCPОбработчик = "") Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| IDПодключения | - | Строка, Число | ✔ | ID активного подключения. См. ОжидатьПодключение |
|
||||
| TCPОбработчик | - | Произвольный | ✖ | TCP сервер или пустое значение при обособленной обоработке |
|
||||
|
||||
|
||||
Возвращаемое значение: Структура Из КлючИЗначение - Информация о выполнении
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,41 +0,0 @@
|
||||
---
|
||||
sidebar_position: 1
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Получить запрос
|
||||
Получает данные из потока существующего соединения
|
||||
|
||||
|
||||
|
||||
`Функция ПолучитьЗапрос(Знач IDПодключения, Знач МаксимальныйРазмер = 0, Знач TCPОбработчик = "") Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| IDПодключения | - | Строка, Число | ✔ | ID активного подключения. См. ОжидатьПодключение |
|
||||
| МаксимальныйРазмер | - | Число | ✖ | Максимальный размер данных. 0 > до конца потока |
|
||||
| TCPОбработчик | - | Произвольный | ✖ | TCP сервер или пустое значение при обособленной обоработке |
|
||||
|
||||
|
||||
Возвращаемое значение: Структура Из КлючИЗначение, ДвоичныеДанные - Двоичные данные при успехе или структура с описанием ошибки
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,44 +0,0 @@
|
||||
---
|
||||
sidebar_position: 2
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Отправить ответ
|
||||
Отправляет данные клиенту по идентификатору подключения
|
||||
|
||||
|
||||
|
||||
`Функция ОтправитьОтвет(Знач IDПодключения, Знач Данные, Знач TCPОбработчик = "") Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| IDПодключения | - | Строка, Число | ✔ | ID активного подключения. См. ОжидатьПодключение |
|
||||
| Данные | - | ДвоичныеДанные | ✔ | Данные для отправки |
|
||||
| TCPОбработчик | - | Произвольный | ✖ | TCP сервер или пустое значение при обособленной обоработке |
|
||||
|
||||
|
||||
Возвращаемое значение: Структура Из КлючИЗначение - Информация о выполнении
|
||||
|
||||
<br/>
|
||||
|
||||
:::tip
|
||||
Параметры с типом данных Двоичные данные могут принимать также пути к файлам на диске и URL
|
||||
:::
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,4 +0,0 @@
|
||||
{
|
||||
"label": "Методы обработки соединений",
|
||||
"position": "4"
|
||||
}
|
||||
@@ -1,39 +0,0 @@
|
||||
---
|
||||
sidebar_position: 6
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Актуализировать входящие соединения
|
||||
Удаляет неактивные соединения из пула
|
||||
|
||||
|
||||
|
||||
`Функция АктуализироватьВходящиеСоединения(Знач TCPСервер) Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| TCPСервер | - | Произвольный | ✔ | TCP сервер. См. СоздатьСервер |
|
||||
|
||||
|
||||
Возвращаемое значение: Структура Из КлючИЗначение - Информация о выполнении
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
-40
@@ -1,40 +0,0 @@
|
||||
---
|
||||
sidebar_position: 1
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Создать сервер
|
||||
Создает новый TCP сервер и устаналивает порт
|
||||
|
||||
|
||||
|
||||
`Функция СоздатьСервер(Знач Порт, Запустить = Ложь) Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| Порт | - | Число | ✔ | Номер свободного порта для сервера |
|
||||
| Запустить | - | Булево | ✖ | Истина > сразу запускает созданный сервер |
|
||||
|
||||
|
||||
Возвращаемое значение: Произвольный - Возвращает объект запущенного TCP сервера при успешном создании или структуру с описанием ошибки
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,42 +0,0 @@
|
||||
---
|
||||
sidebar_position: 5
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Получить входящие соединения
|
||||
Получает список соединений в пуле
|
||||
|
||||
|
||||
|
||||
`Функция ПолучитьВходящиеСоединения(Знач TCPСервер) Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| TCPСервер | - | Произвольный | ✔ | TCP сервер. См. СоздатьСервер |
|
||||
|
||||
|
||||
Возвращаемое значение: Структура Из КлючИЗначение - Информация о выполнении
|
||||
|
||||
<br/>
|
||||
|
||||
:::tip
|
||||
Наличие соединения в пуле не гарантирует его активности. Для очистки пула от неактивных соединений используется функция АктуализироватьВходящиеСоединения
|
||||
:::
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
-39
@@ -1,39 +0,0 @@
|
||||
---
|
||||
sidebar_position: 7
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Это сервер
|
||||
Определяет, является ли переданное значение объектом TCP сервера
|
||||
|
||||
|
||||
|
||||
`Функция ЭтоСервер(Знач Значение) Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| Значение | - | Произвольный | ✔ | произвольное значение для проверки |
|
||||
|
||||
|
||||
Возвращаемое значение: Булево - Это сервер
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
-39
@@ -1,39 +0,0 @@
|
||||
---
|
||||
sidebar_position: 2
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Запустить сервер
|
||||
Запускает ранее созданный сервер
|
||||
|
||||
|
||||
|
||||
`Функция ЗапуститьСервер(Знач TCPСервер) Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| TCPСервер | - | Произвольный | ✔ | TCP сервер. См. СоздатьСервер |
|
||||
|
||||
|
||||
Возвращаемое значение: Структура Из КлючИЗначение - Структура с информацией об успешности запуска
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
-39
@@ -1,39 +0,0 @@
|
||||
---
|
||||
sidebar_position: 3
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Отключить сервер
|
||||
Останавливает запущенный сервер
|
||||
|
||||
|
||||
|
||||
`Функция ОтключитьСервер(Знач TCPСервер) Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| TCPСервер | - | Произвольный | ✔ | TCP сервер. См. СоздатьСервер |
|
||||
|
||||
|
||||
Возвращаемое значение: Структура Из КлючИЗначение - Информация о выполнении
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,73 +0,0 @@
|
||||
---
|
||||
sidebar_position: 4
|
||||
---
|
||||
|
||||
import Tabs from '@theme/Tabs';
|
||||
import TabItem from '@theme/TabItem';
|
||||
|
||||
# Ожидать входящие соединения
|
||||
Блокирует выполнение программы до появления нового подключения
|
||||
|
||||
|
||||
|
||||
`Функция ОжидатьВходящиеСоединения(Знач TCPСервер, Знач Таймаут = 0) Экспорт`
|
||||
|
||||
| Параметр | CLI опция | Тип | Обяз. | Назначение |
|
||||
|-|-|-|-|-|
|
||||
| TCPСервер | - | Произвольный | ✔ | TCP сервер. См. СоздатьСервер |
|
||||
| Таймаут | - | Число | ✖ | Максимальное время ожидания подключений. 0 > бесконечно |
|
||||
|
||||
|
||||
Возвращаемое значение: Структура Из КлючИЗначение - Структура с идентификатором нового подключения или ошибкой
|
||||
|
||||
<br/>
|
||||
|
||||
|
||||
:::caution
|
||||
**NOCLI:** данный метод недоступен для использования в CLI версии
|
||||
:::
|
||||
<br/>
|
||||
|
||||
|
||||
|
||||
```bsl title="Пример использования для 1С:Предприятие/OneScript"
|
||||
// -- Тестовый запрос для сервера
|
||||
|
||||
КлючКлиента = Новый УникальныйИдентификатор;
|
||||
Сообщение = "Тестовая отправка данных на сервер";
|
||||
|
||||
ПараметрыКлиента = Новый Массив;
|
||||
ПараметрыКлиента.Добавить("127.0.0.1:7788"); // Наш сервер
|
||||
ПараметрыКлиента.Добавить(Сообщение); // Тестовая строка
|
||||
ПараметрыКлиента.Добавить("UTF-8"); // Кодировка
|
||||
ПараметрыКлиента.Добавить("20000"); // Таймаут, чтобы успеть запустить сервер
|
||||
|
||||
// Отправка тестового запроса через клиентские методы TCP
|
||||
ФоновоеКлиента = ФоновыеЗадания.Выполнить("OPI_TCP.ОтправитьСтроку", ПараметрыКлиента, КлючКлиента);
|
||||
|
||||
// --
|
||||
|
||||
TCPСервер = OPI_TCP.СоздатьСервер(7788, Истина);
|
||||
|
||||
НовоеПодключение = OPI_TCP.ОжидатьВходящиеСоединения(TCPСервер, 20);
|
||||
|
||||
Если НовоеПодключение["result"] Тогда
|
||||
|
||||
Подключение = НовоеПодключение["connection"]["id"];
|
||||
|
||||
МассивПараметровОбработки = Новый Массив;
|
||||
МассивПараметровОбработки.Добавить(Подключение); // Строка: "1:7788"
|
||||
|
||||
ФоновоеОбработки = ФоновыеЗадания.Выполнить("OPI_Тесты.TCP_ОбработатьПодключение", МассивПараметровОбработки);
|
||||
|
||||
TCP_ОбработатьПодключение(Подключение);
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Отключение = OPI_TCP.ОтключитьСервер(TCPСервер);
|
||||
```
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,4 +0,0 @@
|
||||
{
|
||||
"label": "Методы сервера",
|
||||
"position": "3"
|
||||
}
|
||||
Vendored
+6363
-6363
File diff suppressed because it is too large
Load Diff
Vendored
-291
@@ -105,10 +105,6 @@ Function ReadBinaryData(Val Connection
|
||||
OPI_TypeConversion.GetNumber(Timeout);
|
||||
OPI_TypeConversion.GetNumber(MaxSize);
|
||||
|
||||
If TypeOf(Connection) = Type("String") Then
|
||||
Connection = CreateConnection(Connection);
|
||||
EndIf;
|
||||
|
||||
If TypeOf(Marker) = Type("String") Then
|
||||
Marker = ПолучитьДвоичныеДанныеИзСтроки(Marker);
|
||||
Else
|
||||
@@ -161,10 +157,6 @@ EndFunction
|
||||
// Boolean - Flag of successful delivery
|
||||
Function SendBinaryData(Val Connection, Val Data, Val Timeout = 5000) Export
|
||||
|
||||
If TypeOf(Connection) = Type("String") Then
|
||||
Connection = CreateConnection(Connection);
|
||||
EndIf;
|
||||
|
||||
OPI_TypeConversion.GetBinaryData(Data);
|
||||
OPI_TypeConversion.GetNumber(Timeout);
|
||||
|
||||
@@ -236,272 +228,6 @@ EndFunction
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region ServerMethods
|
||||
|
||||
// Create server !NOCLI
|
||||
// Creates a new TCP server and sets the port
|
||||
//
|
||||
// Parameters:
|
||||
// Port - Number - Available port number for the server - port
|
||||
// Start - Boolean - True > immediately starts the created server - start
|
||||
//
|
||||
// Returns:
|
||||
// Arbitrary - Returns a running TCP server object on successful creation or a structure with an error description
|
||||
Function CreateServer(Val Port, Start = False) Export
|
||||
|
||||
OPI_TypeConversion.GetNumber(Port);
|
||||
OPI_TypeConversion.GetBoolean(Start);
|
||||
|
||||
TCPServer = AttachAddInOnServer("OPI_TCPServer", "Server");
|
||||
TCPServer.Port = Port;
|
||||
|
||||
If Start Then
|
||||
Result = StartServer(TCPServer);
|
||||
|
||||
Success = Undefined;
|
||||
FlagExist = OPI_Tools.CollectionFieldExist(Result, "result", Success);
|
||||
Success = ?(FlagExist, Success, False);
|
||||
|
||||
Return ?(Success, TCPServer, Result);
|
||||
|
||||
Else
|
||||
Return TCPServer;
|
||||
EndIf;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Start server !NOCLI
|
||||
// Starts a previously created server
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Structure with information about the startup success
|
||||
Function StartServer(Val TCPServer) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
Result = TCPServer.Start();
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Stop server !NOCLI
|
||||
// Stops a running server
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function StopServer(Val TCPServer) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
Result = TCPServer.Stop();
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Wait incoming connections !NOCLI
|
||||
// Blocks programm execution until a new connection is established
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
// Timeout - Number - Maximum waiting time for connections. 0 > unlimited - timeout
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Structure with new connection ID or error information
|
||||
Function WaitIncomingConnections(Val TCPServer, Val Timeout = 0) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
OPI_TypeConversion.GetNumber(Timeout);
|
||||
|
||||
Result = TCPServer.Wait(Timeout);
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Get incoming connections !NOCLI
|
||||
// Gets the list of connections in the pool
|
||||
//
|
||||
// Note
|
||||
// The presence of a connection in the pool does not guarantee that it is active.^^
|
||||
// The ActualiseIncomingConnections function is used to clear the pool of inactive connections
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function GetIncomingConnections(Val TCPServer) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
Result = TCPServer.ListConnections();
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// ActualiseIncomingConnections
|
||||
// Removes inactive connections from the pool
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function ActualiseIncomingConnections(Val TCPServer) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
Result = TCPServer.UpdateConnections();
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Is server !NOCLI
|
||||
// Specifies if the value passed is a TCP server object
|
||||
//
|
||||
// Parameters:
|
||||
// Value - Arbitrary - arbitrary value to check - value
|
||||
//
|
||||
// Returns:
|
||||
// Boolean - Is server
|
||||
Function IsServer(Val Value) Export
|
||||
|
||||
Return String(TypeOf(Value)) = "AddIn.OPI_TCPServer.Server";
|
||||
|
||||
EndFunction
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region ConnectionHandlingMethods
|
||||
|
||||
// GetRequest !NOCLI
|
||||
// Gets data from the flow stream of an existing connection
|
||||
//
|
||||
// Parameters:
|
||||
// ConnectionID - String, Number - Active connection ID. See AwaitingConnection - conn
|
||||
// MaxSize - Number - Max data size. 0 > to the end of the stream - maxsize
|
||||
// TCPHandler - Arbitrary - TCP server or empty value for standalone processing - hnd
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue, BinaryData - Binary data on success or structure with error description
|
||||
Function GetRequest(Val ConnectionID, Val MaxSize = 0, Val TCPHandler = "") Export
|
||||
|
||||
OPI_TypeConversion.GetLine(ConnectionID);
|
||||
OPI_TypeConversion.GetNumber(MaxSize);
|
||||
|
||||
If Not IsServerOrHandler(TCPHandler) Then
|
||||
TCPHandler = AttachAddInOnServer("OPI_TCPServer", "Handler");
|
||||
EndIf;
|
||||
|
||||
Data = TCPHandler.Receive(ConnectionID, MaxSize);
|
||||
|
||||
If TypeOf(Data) = Type("String") Then
|
||||
Try
|
||||
Result = OPI_Tools.JsonToStructure(Data, False);
|
||||
Except
|
||||
Result = New Structure("result,error", False, Data);
|
||||
EndTry;
|
||||
|
||||
Else
|
||||
Result = Data;
|
||||
EndIf;
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// SendResponse !NOCLI
|
||||
// Sends data to the client by connection ID
|
||||
//
|
||||
// Parameters:
|
||||
// ConnectionID - String, Number - Active connection ID. See AwaitingConnection - conn
|
||||
// Data - BinaryData - Sending data - data
|
||||
// TCPHandler - Arbitrary - TCP server or empty value for standalone processing - hnd
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function SendResponse(Val ConnectionID, Val Data, Val TCPHandler = "") Export
|
||||
|
||||
OPI_TypeConversion.GetLine(ConnectionID);
|
||||
OPI_TypeConversion.GetBinaryData(Data);
|
||||
|
||||
If Not IsServerOrHandler(TCPHandler) Then
|
||||
TCPHandler = AttachAddInOnServer("OPI_TCPServer", "Handler");
|
||||
EndIf;
|
||||
|
||||
Result = TCPHandler.Send(ConnectionID, Data);
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Close incoming connection !NOCLI
|
||||
// Closes an existing connection by identifier
|
||||
//
|
||||
// Parameters:
|
||||
// ConnectionID - String, Number - Active connection ID. See AwaitingConnection - conn
|
||||
// TCPHandler - Arbitrary - TCP server or empty value for standalone processing - hnd
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function CloseIncomingConnection(Val ConnectionID, Val TCPHandler = "") Export
|
||||
|
||||
OPI_TypeConversion.GetLine(ConnectionID);
|
||||
|
||||
If Not IsServerOrHandler(TCPHandler) Then
|
||||
TCPHandler = AttachAddInOnServer("OPI_TCPServer", "Handler");
|
||||
EndIf;
|
||||
|
||||
Result = TCPHandler.Close(ConnectionID);
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
#EndRegion
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region Private
|
||||
@@ -521,21 +247,4 @@ Function AttachAddInOnServer(Val AddInName, Val Class = "Main")
|
||||
|
||||
EndFunction
|
||||
|
||||
Function IsServerOrHandler(Val Value)
|
||||
|
||||
Return String(TypeOf(Value)) = "AddIn.OPI_TCPServer.Server"
|
||||
Or String(TypeOf(Value)) = "AddIn.OPI_TCPServer.Handler";
|
||||
|
||||
EndFunction
|
||||
|
||||
Procedure ProcessResult(Result)
|
||||
|
||||
Try
|
||||
Result = OPI_Tools.JsonToStructure(Result, False);
|
||||
Except
|
||||
Result = New Structure("result,error", False, Result);
|
||||
EndTry;
|
||||
|
||||
EndProcedure
|
||||
|
||||
#EndRegion
|
||||
|
||||
-95
@@ -2241,14 +2241,6 @@ Procedure TC_Client() Export
|
||||
|
||||
EndProcedure
|
||||
|
||||
Procedure TC_Server() Export
|
||||
|
||||
TestParameters = New Structure;
|
||||
|
||||
TCP_WaitIncomingConnections(TestParameters);
|
||||
|
||||
EndProcedure
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region SQLite
|
||||
@@ -16454,93 +16446,6 @@ Procedure TCP_SendLine(FunctionParameters) Export
|
||||
|
||||
EndProcedure
|
||||
|
||||
Procedure TCP_WaitIncomingConnections(FunctionParameters) Export
|
||||
|
||||
// -- Test request for server
|
||||
|
||||
ClientKey = New UUID;
|
||||
Message = "Test data sending to the server";
|
||||
|
||||
ClientParams = New Array;
|
||||
ClientParams.Add("127.0.0.1:7788"); // Our server
|
||||
ClientParams.Add(Message); // Test string
|
||||
ClientParams.Add("UTF-8"); // Encoding
|
||||
ClientParams.Add("20000"); // Timeout, for make it in time launch server
|
||||
|
||||
// Sending a test request via TCP client methods
|
||||
ClientBackground = BackgroundJobs.Execute("OPI_TCP.SendLine", ClientParams, ClientKey);
|
||||
|
||||
// --
|
||||
|
||||
TCPServer = OPI_TCP.CreateServer(7788, True);
|
||||
|
||||
NewConnection = OPI_TCP.WaitIncomingConnections(TCPServer, 20);
|
||||
|
||||
If NewConnection["result"] Then
|
||||
|
||||
Connection = NewConnection["connection"]["id"];
|
||||
|
||||
ProcessingParameterArray = New Array;
|
||||
ProcessingParameterArray.Add(Connection); // String: "1:7788"
|
||||
|
||||
BackgroundProcessing = BackgroundJobs.Execute("OPI_Tests.TCP_ProcessConnection", ProcessingParameterArray);
|
||||
|
||||
TCP_ProcessConnection(Connection);
|
||||
|
||||
EndIf;
|
||||
|
||||
Shutdown = OPI_TCP.StopServer(TCPServer);
|
||||
|
||||
// END
|
||||
|
||||
ClientTask = ClientBackground.WaitForExecutionCompletion();
|
||||
ProcessingTask = BackgroundProcessing.WaitForExecutionCompletion();
|
||||
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(TCPServer, "WaitIncomingConnections (server)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_AddIn(TCPServer, "AddIn.OPI_TCPServer.Server");
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(NewConnection, "WaitIncomingConnections", "TCP");
|
||||
OPI_TestDataRetrieval.Check_ResultTrue(NewConnection);
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(Connection, "WaitIncomingConnections (connection)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_String(Connection, "7788:1");
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(Shutdown, "WaitIncomingConnections (disconnect)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_ResultTrue(Shutdown);
|
||||
|
||||
State = String(ClientTask.State);
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(State, "WaitIncomingConnections (bgj)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_String(State, "Job Completed");
|
||||
|
||||
EndProcedure
|
||||
|
||||
Procedure TCP_ProcessConnection(Connection) Export
|
||||
|
||||
// Connection - String: "1:7788"
|
||||
|
||||
RequestBinary = OPI_TCP.GetRequest(Connection);
|
||||
RequestText = ПолучитьСтрокуИзДвоичныхДанных(RequestBinary);
|
||||
|
||||
ResponseSending = OPI_TCP.SendResponse(Connection, ПолучитьДвоичныеДанныеИзСтроки("Yo"));
|
||||
ConnectionShutdown = OPI_TCP.CloseIncomingConnection(Connection);
|
||||
|
||||
// END
|
||||
|
||||
Message = "Test data sending to the server";
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(Message, "WaitIncomingConnections (message)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_String(RequestText, Message);
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(ResponseSending, "WaitIncomingConnections (response)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_ResultTrue(ResponseSending);
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(ConnectionShutdown, "WaitIncomingConnections (shutdown)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_ResultTrue(ConnectionShutdown);
|
||||
|
||||
EndProcedure
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region SQLite
|
||||
|
||||
@@ -268,7 +268,6 @@ Function GetTestTable() Export
|
||||
NewTest(TestTable, "AWS_BucketsManagement" , "Buckets management" , S3_);
|
||||
NewTest(TestTable, "AWS_ObjectsManagement" , "Objects management" , S3_);
|
||||
NewTest(TestTable, "TC_Client" , "TCP Client" , TCP);
|
||||
NewTest(TestTable, "TC_Server" , "TCP Host" , TCP);
|
||||
NewTest(TestTable, "SQLL_CommonMethods" , "Common methods" , SQLite);
|
||||
NewTest(TestTable, "SQLL_ORM" , "ORM" , SQLite);
|
||||
|
||||
|
||||
-291
@@ -105,10 +105,6 @@ Function ReadBinaryData(Val Connection
|
||||
OPI_TypeConversion.GetNumber(Timeout);
|
||||
OPI_TypeConversion.GetNumber(MaxSize);
|
||||
|
||||
If TypeOf(Connection) = Type("String") Then
|
||||
Connection = CreateConnection(Connection);
|
||||
EndIf;
|
||||
|
||||
If TypeOf(Marker) = Type("String") Then
|
||||
Marker = GetBinaryDataFromString(Marker);
|
||||
Else
|
||||
@@ -161,10 +157,6 @@ EndFunction
|
||||
// Boolean - Flag of successful delivery
|
||||
Function SendBinaryData(Val Connection, Val Data, Val Timeout = 5000) Export
|
||||
|
||||
If TypeOf(Connection) = Type("String") Then
|
||||
Connection = CreateConnection(Connection);
|
||||
EndIf;
|
||||
|
||||
OPI_TypeConversion.GetBinaryData(Data);
|
||||
OPI_TypeConversion.GetNumber(Timeout);
|
||||
|
||||
@@ -236,272 +228,6 @@ EndFunction
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region ServerMethods
|
||||
|
||||
// Create server !NOCLI
|
||||
// Creates a new TCP server and sets the port
|
||||
//
|
||||
// Parameters:
|
||||
// Port - Number - Available port number for the server - port
|
||||
// Start - Boolean - True > immediately starts the created server - start
|
||||
//
|
||||
// Returns:
|
||||
// Arbitrary - Returns a running TCP server object on successful creation or a structure with an error description
|
||||
Function CreateServer(Val Port, Start = False) Export
|
||||
|
||||
OPI_TypeConversion.GetNumber(Port);
|
||||
OPI_TypeConversion.GetBoolean(Start);
|
||||
|
||||
TCPServer = AttachAddInOnServer("OPI_TCPServer", "Server");
|
||||
TCPServer.Port = Port;
|
||||
|
||||
If Start Then
|
||||
Result = StartServer(TCPServer);
|
||||
|
||||
Success = Undefined;
|
||||
FlagExists = OPI_Tools.CollectionFieldExists(Result, "result", Success);
|
||||
Success = ?(FlagExists, Success, False);
|
||||
|
||||
Return ?(Success, TCPServer, Result);
|
||||
|
||||
Else
|
||||
Return TCPServer;
|
||||
EndIf;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Start server !NOCLI
|
||||
// Starts a previously created server
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Structure with information about the startup success
|
||||
Function StartServer(Val TCPServer) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
Result = TCPServer.Start();
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Stop server !NOCLI
|
||||
// Stops a running server
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function StopServer(Val TCPServer) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
Result = TCPServer.Stop();
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Wait incoming connections !NOCLI
|
||||
// Blocks programm execution until a new connection is established
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
// Timeout - Number - Maximum waiting time for connections. 0 > unlimited - timeout
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Structure with new connection ID or error information
|
||||
Function WaitIncomingConnections(Val TCPServer, Val Timeout = 0) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
OPI_TypeConversion.GetNumber(Timeout);
|
||||
|
||||
Result = TCPServer.Wait(Timeout);
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Get incoming connections !NOCLI
|
||||
// Gets the list of connections in the pool
|
||||
//
|
||||
// Note
|
||||
// The presence of a connection in the pool does not guarantee that it is active.^^
|
||||
// The ActualiseIncomingConnections function is used to clear the pool of inactive connections
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function GetIncomingConnections(Val TCPServer) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
Result = TCPServer.ListConnections();
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// ActualiseIncomingConnections
|
||||
// Removes inactive connections from the pool
|
||||
//
|
||||
// Parameters:
|
||||
// TCPServer - Arbitrary - TCP server. See CreateServer - srv
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function ActualiseIncomingConnections(Val TCPServer) Export
|
||||
|
||||
If Not IsServer(TCPServer) Then
|
||||
Raise "The passed value is not a TCP server!";
|
||||
EndIf;
|
||||
|
||||
Result = TCPServer.UpdateConnections();
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Is server !NOCLI
|
||||
// Specifies if the value passed is a TCP server object
|
||||
//
|
||||
// Parameters:
|
||||
// Value - Arbitrary - arbitrary value to check - value
|
||||
//
|
||||
// Returns:
|
||||
// Boolean - Is server
|
||||
Function IsServer(Val Value) Export
|
||||
|
||||
Return String(TypeOf(Value)) = "AddIn.OPI_TCPServer.Server";
|
||||
|
||||
EndFunction
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region ConnectionHandlingMethods
|
||||
|
||||
// GetRequest !NOCLI
|
||||
// Gets data from the flow stream of an existing connection
|
||||
//
|
||||
// Parameters:
|
||||
// ConnectionID - String, Number - Active connection ID. See AwaitingConnection - conn
|
||||
// MaxSize - Number - Max data size. 0 > to the end of the stream - maxsize
|
||||
// TCPHandler - Arbitrary - TCP server or empty value for standalone processing - hnd
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue, BinaryData - Binary data on success or structure with error description
|
||||
Function GetRequest(Val ConnectionID, Val MaxSize = 0, Val TCPHandler = "") Export
|
||||
|
||||
OPI_TypeConversion.GetLine(ConnectionID);
|
||||
OPI_TypeConversion.GetNumber(MaxSize);
|
||||
|
||||
If Not IsServerOrHandler(TCPHandler) Then
|
||||
TCPHandler = AttachAddInOnServer("OPI_TCPServer", "Handler");
|
||||
EndIf;
|
||||
|
||||
Data = TCPHandler.Receive(ConnectionID, MaxSize);
|
||||
|
||||
If TypeOf(Data) = Type("String") Then
|
||||
Try
|
||||
Result = OPI_Tools.JsonToStructure(Data, False);
|
||||
Except
|
||||
Result = New Structure("result,error", False, Data);
|
||||
EndTry;
|
||||
|
||||
Else
|
||||
Result = Data;
|
||||
EndIf;
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// SendResponse !NOCLI
|
||||
// Sends data to the client by connection ID
|
||||
//
|
||||
// Parameters:
|
||||
// ConnectionID - String, Number - Active connection ID. See AwaitingConnection - conn
|
||||
// Data - BinaryData - Sending data - data
|
||||
// TCPHandler - Arbitrary - TCP server or empty value for standalone processing - hnd
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function SendResponse(Val ConnectionID, Val Data, Val TCPHandler = "") Export
|
||||
|
||||
OPI_TypeConversion.GetLine(ConnectionID);
|
||||
OPI_TypeConversion.GetBinaryData(Data);
|
||||
|
||||
If Not IsServerOrHandler(TCPHandler) Then
|
||||
TCPHandler = AttachAddInOnServer("OPI_TCPServer", "Handler");
|
||||
EndIf;
|
||||
|
||||
Result = TCPHandler.Send(ConnectionID, Data);
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
// Close incoming connection !NOCLI
|
||||
// Closes an existing connection by identifier
|
||||
//
|
||||
// Parameters:
|
||||
// ConnectionID - String, Number - Active connection ID. See AwaitingConnection - conn
|
||||
// TCPHandler - Arbitrary - TCP server or empty value for standalone processing - hnd
|
||||
//
|
||||
// Returns:
|
||||
// Structure Of KeyAndValue - Execution information
|
||||
Function CloseIncomingConnection(Val ConnectionID, Val TCPHandler = "") Export
|
||||
|
||||
OPI_TypeConversion.GetLine(ConnectionID);
|
||||
|
||||
If Not IsServerOrHandler(TCPHandler) Then
|
||||
TCPHandler = AttachAddInOnServer("OPI_TCPServer", "Handler");
|
||||
EndIf;
|
||||
|
||||
Result = TCPHandler.Close(ConnectionID);
|
||||
|
||||
ProcessResult(Result);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Return Result;
|
||||
|
||||
EndFunction
|
||||
|
||||
#EndRegion
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region Private
|
||||
@@ -521,21 +247,4 @@ Function AttachAddInOnServer(Val AddInName, Val Class = "Main")
|
||||
|
||||
EndFunction
|
||||
|
||||
Function IsServerOrHandler(Val Value)
|
||||
|
||||
Return String(TypeOf(Value)) = "AddIn.OPI_TCPServer.Server"
|
||||
Or String(TypeOf(Value)) = "AddIn.OPI_TCPServer.Handler";
|
||||
|
||||
EndFunction
|
||||
|
||||
Procedure ProcessResult(Result)
|
||||
|
||||
Try
|
||||
Result = OPI_Tools.JsonToStructure(Result, False);
|
||||
Except
|
||||
Result = New Structure("result,error", False, Result);
|
||||
EndTry;
|
||||
|
||||
EndProcedure
|
||||
|
||||
#EndRegion
|
||||
|
||||
@@ -268,7 +268,6 @@ Function GetTestTable() Export
|
||||
NewTest(TestTable, "AWS_BucketsManagement" , "Buckets management" , S3_);
|
||||
NewTest(TestTable, "AWS_ObjectsManagement" , "Objects management" , S3_);
|
||||
NewTest(TestTable, "TC_Client" , "TCP Client" , TCP);
|
||||
NewTest(TestTable, "TC_Server" , "TCP Host" , TCP);
|
||||
NewTest(TestTable, "SQLL_CommonMethods" , "Common methods" , SQLite);
|
||||
NewTest(TestTable, "SQLL_ORM" , "ORM" , SQLite);
|
||||
|
||||
|
||||
@@ -2241,14 +2241,6 @@ Procedure TC_Client() Export
|
||||
|
||||
EndProcedure
|
||||
|
||||
Procedure TC_Server() Export
|
||||
|
||||
TestParameters = New Structure;
|
||||
|
||||
TCP_WaitIncomingConnections(TestParameters);
|
||||
|
||||
EndProcedure
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region SQLite
|
||||
@@ -16454,93 +16446,6 @@ Procedure TCP_SendLine(FunctionParameters) Export
|
||||
|
||||
EndProcedure
|
||||
|
||||
Procedure TCP_WaitIncomingConnections(FunctionParameters) Export
|
||||
|
||||
// -- Test request for server
|
||||
|
||||
ClientKey = New UUID;
|
||||
Message = "Test data sending to the server";
|
||||
|
||||
ClientParams = New Array;
|
||||
ClientParams.Add("127.0.0.1:7788"); // Our server
|
||||
ClientParams.Add(Message); // Test string
|
||||
ClientParams.Add("UTF-8"); // Encoding
|
||||
ClientParams.Add("20000"); // Timeout, for make it in time launch server
|
||||
|
||||
// Sending a test request via TCP client methods
|
||||
ClientBackground = BackgroundJobs.Execute("OPI_TCP.SendLine", ClientParams, ClientKey);
|
||||
|
||||
// --
|
||||
|
||||
TCPServer = OPI_TCP.CreateServer(7788, True);
|
||||
|
||||
NewConnection = OPI_TCP.WaitIncomingConnections(TCPServer, 20);
|
||||
|
||||
If NewConnection["result"] Then
|
||||
|
||||
Connection = NewConnection["connection"]["id"];
|
||||
|
||||
ProcessingParameterArray = New Array;
|
||||
ProcessingParameterArray.Add(Connection); // String: "1:7788"
|
||||
|
||||
BackgroundProcessing = BackgroundJobs.Execute("OPI_Tests.TCP_ProcessConnection", ProcessingParameterArray);
|
||||
|
||||
TCP_ProcessConnection(Connection);
|
||||
|
||||
EndIf;
|
||||
|
||||
Shutdown = OPI_TCP.StopServer(TCPServer);
|
||||
|
||||
// END
|
||||
|
||||
ClientTask = ClientBackground.WaitForExecutionCompletion();
|
||||
ProcessingTask = BackgroundProcessing.WaitForExecutionCompletion();
|
||||
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(TCPServer, "WaitIncomingConnections (server)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_AddIn(TCPServer, "AddIn.OPI_TCPServer.Server");
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(NewConnection, "WaitIncomingConnections", "TCP");
|
||||
OPI_TestDataRetrieval.Check_ResultTrue(NewConnection);
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(Connection, "WaitIncomingConnections (connection)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_String(Connection, "7788:1");
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(Shutdown, "WaitIncomingConnections (disconnect)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_ResultTrue(Shutdown);
|
||||
|
||||
State = String(ClientTask.State);
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(State, "WaitIncomingConnections (bgj)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_String(State, "Job Completed");
|
||||
|
||||
EndProcedure
|
||||
|
||||
Procedure TCP_ProcessConnection(Connection) Export
|
||||
|
||||
// Connection - String: "1:7788"
|
||||
|
||||
RequestBinary = OPI_TCP.GetRequest(Connection);
|
||||
RequestText = GetStringFromBinaryData(RequestBinary);
|
||||
|
||||
ResponseSending = OPI_TCP.SendResponse(Connection, GetBinaryDataFromString("Yo"));
|
||||
ConnectionShutdown = OPI_TCP.CloseIncomingConnection(Connection);
|
||||
|
||||
// END
|
||||
|
||||
Message = "Test data sending to the server";
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(Message, "WaitIncomingConnections (message)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_String(RequestText, Message);
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(ResponseSending, "WaitIncomingConnections (response)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_ResultTrue(ResponseSending);
|
||||
|
||||
OPI_TestDataRetrieval.WriteLog(ConnectionShutdown, "WaitIncomingConnections (shutdown)", "TCP");
|
||||
OPI_TestDataRetrieval.Check_ResultTrue(ConnectionShutdown);
|
||||
|
||||
EndProcedure
|
||||
|
||||
#EndRegion
|
||||
|
||||
#Region SQLite
|
||||
|
||||
@@ -1,13 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<mdclass:CommonTemplate xmlns:mdclass="http://g5.1c.ru/v8/dt/metadata/mdclass" uuid="4c9ebab6-8e20-4690-b509-2e32b293ad76">
|
||||
<name>OPI_TCPServer</name>
|
||||
<synonym>
|
||||
<key>en</key>
|
||||
<value>TCPServer</value>
|
||||
</synonym>
|
||||
<synonym>
|
||||
<key></key>
|
||||
<value>OPI TCPServer</value>
|
||||
</synonym>
|
||||
<templateType>AddIn</templateType>
|
||||
</mdclass:CommonTemplate>
|
||||
@@ -40,7 +40,6 @@
|
||||
</configurationInformationAddress>
|
||||
<subsystems>Subsystem.OPI_Integrations</subsystems>
|
||||
<commonTemplates>CommonTemplate.OPI_TCPClient</commonTemplates>
|
||||
<commonTemplates>CommonTemplate.OPI_TCPServer</commonTemplates>
|
||||
<commonTemplates>CommonTemplate.OPI_SQLite</commonTemplates>
|
||||
<commonModules>CommonModule.OPI_Airtable</commonModules>
|
||||
<commonModules>CommonModule.OPI_Bitrix24</commonModules>
|
||||
|
||||
-11
@@ -40,17 +40,6 @@
|
||||
NewLine.Описание = "An attribute of receiving the response as a string (optional, def. val. - Yes)";
|
||||
NewLine.Область = "Client methods";
|
||||
|
||||
|
||||
NewLine = CompositionTable.Add();
|
||||
NewLine.Библиотека = "tcp";
|
||||
NewLine.Модуль = "OPI_TCP";
|
||||
NewLine.Метод = "ActualiseIncomingConnections";
|
||||
NewLine.МетодПоиска = "ACTUALISEINCOMINGCONNECTIONS";
|
||||
NewLine.Параметр = "--srv";
|
||||
NewLine.Описание = "TCP server. See CreateServer";
|
||||
NewLine.Область = "Server methods";
|
||||
NewLine.ОписаниеМетода = "Removes inactive connections from the pool";
|
||||
|
||||
Return CompositionTable;
|
||||
EndFunction
|
||||
|
||||
|
||||
Vendored
-291
@@ -105,10 +105,6 @@
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(Таймаут);
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(МаксимальныйРазмер);
|
||||
|
||||
Если ТипЗнч(Соединение) = Тип("Строка") Тогда
|
||||
Соединение = ОткрытьСоединение(Соединение);
|
||||
КонецЕсли;
|
||||
|
||||
Если ТипЗнч(Маркер) = Тип("Строка") Тогда
|
||||
Маркер = ПолучитьДвоичныеДанныеИзСтроки(Маркер);
|
||||
Иначе
|
||||
@@ -161,10 +157,6 @@
|
||||
// Булево - Признак успешного выполнения
|
||||
Функция ОтправитьДвоичныеДанные(Знач Соединение, Знач Данные, Знач Таймаут = 5000) Экспорт
|
||||
|
||||
Если ТипЗнч(Соединение) = Тип("Строка") Тогда
|
||||
Соединение = ОткрытьСоединение(Соединение);
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьДвоичныеДанные(Данные);
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(Таймаут);
|
||||
|
||||
@@ -236,272 +228,6 @@
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область МетодыСервера
|
||||
|
||||
// Создать сервер !NOCLI
|
||||
// Создает новый TCP сервер и устаналивает порт
|
||||
//
|
||||
// Параметры:
|
||||
// Порт - Число - Номер свободного порта для сервера - port
|
||||
// Запустить - Булево - Истина > сразу запускает созданный сервер - start
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Произвольный - Возвращает объект запущенного TCP сервера при успешном создании или структуру с описанием ошибки
|
||||
Функция СоздатьСервер(Знач Порт, Запустить = Ложь) Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(Порт);
|
||||
OPI_ПреобразованиеТипов.ПолучитьБулево(Запустить);
|
||||
|
||||
TCPСервер = ПодключитьКомпонентуНаСервере("OPI_TCPServer", "Server");
|
||||
TCPСервер.Port = Порт;
|
||||
|
||||
Если Запустить Тогда
|
||||
Результат = ЗапуститьСервер(TCPСервер);
|
||||
|
||||
Успех = Неопределено;
|
||||
ЕстьПризнак = OPI_Инструменты.ПолеКоллекцииСуществует(Результат, "result", Успех);
|
||||
Успех = ?(ЕстьПризнак, Успех, Ложь);
|
||||
|
||||
Возврат ?(Успех, TCPСервер, Результат);
|
||||
|
||||
Иначе
|
||||
Возврат TCPСервер;
|
||||
КонецЕсли;
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Запустить сервер !NOCLI
|
||||
// Запускает ранее созданный сервер
|
||||
//
|
||||
// Параметры:
|
||||
// TCPСервер - Произвольный - TCP сервер. См. СоздатьСервер - srv
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение - Структура с информацией об успешности запуска
|
||||
Функция ЗапуститьСервер(Знач TCPСервер) Экспорт
|
||||
|
||||
Если Не ЭтоСервер(TCPСервер) Тогда
|
||||
ВызватьИсключение "Переданное значение не является TCP-сервером!";
|
||||
КонецЕсли;
|
||||
|
||||
Результат = TCPСервер.Start();
|
||||
|
||||
ОбработатьРезультат(Результат);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Отключить сервер !NOCLI
|
||||
// Останавливает запущенный сервер
|
||||
//
|
||||
// Параметры:
|
||||
// TCPСервер - Произвольный - TCP сервер. См. СоздатьСервер - srv
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение - Информация о выполнении
|
||||
Функция ОтключитьСервер(Знач TCPСервер) Экспорт
|
||||
|
||||
Если Не ЭтоСервер(TCPСервер) Тогда
|
||||
ВызватьИсключение "Переданное значение не является TCP-сервером!";
|
||||
КонецЕсли;
|
||||
|
||||
Результат = TCPСервер.Stop();
|
||||
|
||||
ОбработатьРезультат(Результат);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Ожидать входящие соединения !NOCLI
|
||||
// Блокирует выполнение программы до появления нового подключения
|
||||
//
|
||||
// Параметры:
|
||||
// TCPСервер - Произвольный - TCP сервер. См. СоздатьСервер - srv
|
||||
// Таймаут - Число - Максимальное время ожидания подключений. 0 > бесконечно - timeout
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение - Структура с идентификатором нового подключения или ошибкой
|
||||
Функция ОжидатьВходящиеСоединения(Знач TCPСервер, Знач Таймаут = 0) Экспорт
|
||||
|
||||
Если Не ЭтоСервер(TCPСервер) Тогда
|
||||
ВызватьИсключение "Переданное значение не является TCP-сервером!";
|
||||
КонецЕсли;
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(Таймаут);
|
||||
|
||||
Результат = TCPСервер.Wait(Таймаут);
|
||||
|
||||
ОбработатьРезультат(Результат);
|
||||
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Получить входящие соединения !NOCLI
|
||||
// Получает список соединений в пуле
|
||||
//
|
||||
// Примечание:
|
||||
// Наличие соединения в пуле не гарантирует его активности.^^
|
||||
// Для очистки пула от неактивных соединений используется функция АктуализироватьВходящиеСоединения
|
||||
//
|
||||
// Параметры:
|
||||
// TCPСервер - Произвольный - TCP сервер. См. СоздатьСервер - srv
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение - Информация о выполнении
|
||||
Функция ПолучитьВходящиеСоединения(Знач TCPСервер) Экспорт
|
||||
|
||||
Если Не ЭтоСервер(TCPСервер) Тогда
|
||||
ВызватьИсключение "Переданное значение не является TCP-сервером!";
|
||||
КонецЕсли;
|
||||
|
||||
Результат = TCPСервер.ListConnections();
|
||||
|
||||
ОбработатьРезультат(Результат);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Актуализировать входящие соединения !NOCLI
|
||||
// Удаляет неактивные соединения из пула
|
||||
//
|
||||
// Параметры:
|
||||
// TCPСервер - Произвольный - TCP сервер. См. СоздатьСервер - srv
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение - Информация о выполнении
|
||||
Функция АктуализироватьВходящиеСоединения(Знач TCPСервер) Экспорт
|
||||
|
||||
Если Не ЭтоСервер(TCPСервер) Тогда
|
||||
ВызватьИсключение "Переданное значение не является TCP-сервером!";
|
||||
КонецЕсли;
|
||||
|
||||
Результат = TCPСервер.UpdateConnections();
|
||||
|
||||
ОбработатьРезультат(Результат);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Это сервер !NOCLI
|
||||
// Определяет, является ли переданное значение объектом TCP сервера
|
||||
//
|
||||
// Параметры:
|
||||
// Значение - Произвольный - произвольное значение для проверки - value
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Булево - Это сервер
|
||||
Функция ЭтоСервер(Знач Значение) Экспорт
|
||||
|
||||
Возврат Строка(ТипЗнч(Значение)) = "AddIn.OPI_TCPServer.Server";
|
||||
|
||||
КонецФункции
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область МетодыОбработкиСоединений
|
||||
|
||||
// Получить запрос !NOCLI
|
||||
// Получает данные из потока существующего соединения
|
||||
//
|
||||
// Параметры:
|
||||
// IDПодключения - Строка, Число - ID активного подключения. См. ОжидатьПодключение - conn
|
||||
// МаксимальныйРазмер - Число - Максимальный размер данных. 0 > до конца потока - maxsize
|
||||
// TCPОбработчик - Произвольный - TCP сервер или пустое значение при обособленной обоработке - hnd
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение, ДвоичныеДанные - Двоичные данные при успехе или структура с описанием ошибки
|
||||
Функция ПолучитьЗапрос(Знач IDПодключения, Знач МаксимальныйРазмер = 0, Знач TCPОбработчик = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(IDПодключения);
|
||||
OPI_ПреобразованиеТипов.ПолучитьЧисло(МаксимальныйРазмер);
|
||||
|
||||
Если Не ЭтоСерверИлиОбработчик(TCPОбработчик) Тогда
|
||||
TCPОбработчик = ПодключитьКомпонентуНаСервере("OPI_TCPServer", "Handler");
|
||||
КонецЕсли;
|
||||
|
||||
Данные = TCPОбработчик.Receive(IDПодключения, МаксимальныйРазмер);
|
||||
|
||||
Если ТипЗнч(Данные) = Тип("Строка") Тогда
|
||||
Попытка
|
||||
Результат = OPI_Инструменты.JsonВСтруктуру(Данные, Ложь);
|
||||
Исключение
|
||||
Результат = Новый Структура("result,error", Ложь, Данные);
|
||||
КонецПопытки;
|
||||
|
||||
Иначе
|
||||
Результат = Данные;
|
||||
КонецЕсли;
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Отправить ответ !NOCLI
|
||||
// Отправляет данные клиенту по идентификатору подключения
|
||||
//
|
||||
// Параметры:
|
||||
// IDПодключения - Строка, Число - ID активного подключения. См. ОжидатьПодключение - conn
|
||||
// Данные - ДвоичныеДанные - Данные для отправки - data
|
||||
// TCPОбработчик - Произвольный - TCP сервер или пустое значение при обособленной обоработке - hnd
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение - Информация о выполнении
|
||||
Функция ОтправитьОтвет(Знач IDПодключения, Знач Данные, Знач TCPОбработчик = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(IDПодключения);
|
||||
OPI_ПреобразованиеТипов.ПолучитьДвоичныеДанные(Данные);
|
||||
|
||||
Если Не ЭтоСерверИлиОбработчик(TCPОбработчик) Тогда
|
||||
TCPОбработчик = ПодключитьКомпонентуНаСервере("OPI_TCPServer", "Handler");
|
||||
КонецЕсли;
|
||||
|
||||
Результат = TCPОбработчик.Send(IDПодключения, Данные);
|
||||
|
||||
ОбработатьРезультат(Результат);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
// Закрыть входящее соединение !NOCLI
|
||||
// Закрывает существующее соединение по идентификатору
|
||||
//
|
||||
// Параметры:
|
||||
// IDПодключения - Строка, Число - ID активного подключения. См. ОжидатьПодключение - conn
|
||||
// TCPОбработчик - Произвольный - TCP сервер или пустое значение при обособленной обоработке - hnd
|
||||
//
|
||||
// Возвращаемое значение:
|
||||
// Структура Из КлючИЗначение - Информация о выполнении
|
||||
Функция ЗакрытьВходящееСоединение(Знач IDПодключения, Знач TCPОбработчик = "") Экспорт
|
||||
|
||||
OPI_ПреобразованиеТипов.ПолучитьСтроку(IDПодключения);
|
||||
|
||||
Если Не ЭтоСерверИлиОбработчик(TCPОбработчик) Тогда
|
||||
TCPОбработчик = ПодключитьКомпонентуНаСервере("OPI_TCPServer", "Handler");
|
||||
КонецЕсли;
|
||||
|
||||
Результат = TCPОбработчик.Close(IDПодключения);
|
||||
|
||||
ОбработатьРезультат(Результат);
|
||||
|
||||
//@skip-check constructor-function-return-section
|
||||
Возврат Результат;
|
||||
|
||||
КонецФункции
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область СлужебныеПроцедурыИФункции
|
||||
@@ -521,21 +247,4 @@
|
||||
|
||||
КонецФункции
|
||||
|
||||
Функция ЭтоСерверИлиОбработчик(Знач Значение)
|
||||
|
||||
Возврат Строка(ТипЗнч(Значение)) = "AddIn.OPI_TCPServer.Server"
|
||||
Или Строка(ТипЗнч(Значение)) = "AddIn.OPI_TCPServer.Handler";
|
||||
|
||||
КонецФункции
|
||||
|
||||
Процедура ОбработатьРезультат(Результат)
|
||||
|
||||
Попытка
|
||||
Результат = OPI_Инструменты.JsonВСтруктуру(Результат, Ложь);
|
||||
Исключение
|
||||
Результат = Новый Структура("result,error", Ложь, Результат);
|
||||
КонецПопытки;
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
-95
@@ -2241,14 +2241,6 @@
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура TC_Сервер() Экспорт
|
||||
|
||||
ПараметрыТеста = Новый Структура;
|
||||
|
||||
TCP_ОжидатьВходящиеСоединения(ПараметрыТеста);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область SQLite
|
||||
@@ -16454,93 +16446,6 @@
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура TCP_ОжидатьВходящиеСоединения(ПараметрыФункции) Экспорт
|
||||
|
||||
// -- Тестовый запрос для сервера
|
||||
|
||||
КлючКлиента = Новый УникальныйИдентификатор;
|
||||
Сообщение = "Тестовая отправка данных на сервер";
|
||||
|
||||
ПараметрыКлиента = Новый Массив;
|
||||
ПараметрыКлиента.Добавить("127.0.0.1:7788"); // Наш сервер
|
||||
ПараметрыКлиента.Добавить(Сообщение); // Тестовая строка
|
||||
ПараметрыКлиента.Добавить("UTF-8"); // Кодировка
|
||||
ПараметрыКлиента.Добавить("20000"); // Таймаут, чтобы успеть запустить сервер
|
||||
|
||||
// Отправка тестового запроса через клиентские методы TCP
|
||||
ФоновоеКлиента = ФоновыеЗадания.Выполнить("OPI_TCP.ОтправитьСтроку", ПараметрыКлиента, КлючКлиента);
|
||||
|
||||
// --
|
||||
|
||||
TCPСервер = OPI_TCP.СоздатьСервер(7788, Истина);
|
||||
|
||||
НовоеПодключение = OPI_TCP.ОжидатьВходящиеСоединения(TCPСервер, 20);
|
||||
|
||||
Если НовоеПодключение["result"] Тогда
|
||||
|
||||
Подключение = НовоеПодключение["connection"]["id"];
|
||||
|
||||
МассивПараметровОбработки = Новый Массив;
|
||||
МассивПараметровОбработки.Добавить(Подключение); // Строка: "1:7788"
|
||||
|
||||
ФоновоеОбработки = ФоновыеЗадания.Выполнить("OPI_Тесты.TCP_ОбработатьПодключение", МассивПараметровОбработки);
|
||||
|
||||
TCP_ОбработатьПодключение(Подключение);
|
||||
|
||||
КонецЕсли;
|
||||
|
||||
Отключение = OPI_TCP.ОтключитьСервер(TCPСервер);
|
||||
|
||||
// END
|
||||
|
||||
ЗаданиеКлиента = ФоновоеКлиента.ОжидатьЗавершенияВыполнения();
|
||||
ЗаданиеОбработки = ФоновоеОбработки.ОжидатьЗавершенияВыполнения();
|
||||
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(TCPСервер, "ОжидатьВходящиеСоединения (сервер)", "TCP");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_Компонента(TCPСервер, "AddIn.OPI_TCPServer.Server");
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(НовоеПодключение, "ОжидатьВходящиеСоединения", "TCP");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(НовоеПодключение);
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Подключение, "ОжидатьВходящиеСоединения (подключение)", "TCP");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_Строка(Подключение, "7788:1");
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Отключение, "ОжидатьВходящиеСоединения (отключение)", "TCP");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(Отключение);
|
||||
|
||||
Состояние = Строка(ЗаданиеКлиента.Состояние);
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Состояние, "ОжидатьВходящиеСоединения (фоновое)", "TCP");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_Строка(Состояние, "Задание выполнено");
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
Процедура TCP_ОбработатьПодключение(Подключение) Экспорт
|
||||
|
||||
// Подключение - Строка: "1:7788"
|
||||
|
||||
ЗапросДвочиные = OPI_TCP.ПолучитьЗапрос(Подключение);
|
||||
ЗапросТекст = ПолучитьСтрокуИзДвоичныхДанных(ЗапросДвочиные);
|
||||
|
||||
ОтправкаОтвета = OPI_TCP.ОтправитьОтвет(Подключение, ПолучитьДвоичныеДанныеИзСтроки("Yo"));
|
||||
ЗакрытиеПодключения = OPI_TCP.ЗакрытьВходящееСоединение(Подключение);
|
||||
|
||||
// END
|
||||
|
||||
Сообщение = "Тестовая отправка данных на сервер";
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(Сообщение, "ОжидатьВходящиеСоединения (сообщение)", "TCP");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_Строка(ЗапросТекст, Сообщение);
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(ОтправкаОтвета, "ОжидатьВходящиеСоединения (ответ)", "TCP");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(ОтправкаОтвета);
|
||||
|
||||
OPI_ПолучениеДанныхТестов.ЗаписатьЛог(ЗакрытиеПодключения, "ОжидатьВходящиеСоединения (закрытие)", "TCP");
|
||||
OPI_ПолучениеДанныхТестов.Проверка_РезультатИстина(ЗакрытиеПодключения);
|
||||
|
||||
КонецПроцедуры
|
||||
|
||||
#КонецОбласти
|
||||
|
||||
#Область SQLite
|
||||
|
||||
@@ -268,7 +268,6 @@
|
||||
НовыйТест(ТаблицаТестов, "AWS_РаботаСБакетами" , "Работа с бакетами" , S3_);
|
||||
НовыйТест(ТаблицаТестов, "AWS_РаботаСОбъектами" , "Работа с объектами" , S3_);
|
||||
НовыйТест(ТаблицаТестов, "TC_Клиент" , "TCP Клиент" , TCP);
|
||||
НовыйТест(ТаблицаТестов, "TC_Сервер" , "TCP Сервер" , TCP);
|
||||
НовыйТест(ТаблицаТестов, "SQLL_ОсновныеМетоды" , "Основные методы" , SQLite);
|
||||
НовыйТест(ТаблицаТестов, "SQLL_ORM" , "ORM" , SQLite);
|
||||
|
||||
|
||||
@@ -247,4 +247,4 @@
|
||||
|
||||
КонецФункции
|
||||
|
||||
#КонецОбласти
|
||||
#КонецОбласти
|
||||
|
||||
Reference in New Issue
Block a user