ПотокВПамяти.На основании буфера

Конструкторы

Создает поток, в качестве нижележащего хранилища для которого используется заданный байтовый буфер. Ёмкость потока ограничена размером буфера. При выходе за границы буфера будет сгенерировано исключение. Возможность записи в поток зависит от возможности изменения передаваемого буфера.

Синтаксис

Новый ПотокВПамяти(<Буфер>)
Полное описание, параметры и ограничения

ПотокВПамяти.На основании буфера

ПотокВПамяти (MemoryStream)

На основании буфера

Доступен, начиная с версии 8.3.9.

Синтаксис:
Новый ПотокВПамяти(<Буфер>)
Параметры:

<Буфер> (обязательный)
Тип: БуферДвоичныхДанных.
Буфер, на основании которого будет создан поток.
Описание:

Создает поток, в качестве нижележащего хранилища для которого используется заданный байтовый буфер. Ёмкость потока ограничена размером буфера. При выходе за границы буфера будет сгенерировано исключение.
Возможность записи в поток зависит от возможности изменения передаваемого буфера.

Использование в версии:

Доступен, начиная с версии 8.3.9.

Методическая информация

Практические примеры

Записать байты в поток, прочитать часть и скопировать остаток

Поток хранит текущую позицию. Начальная ёмкость не означает заполненный размер; после записи чтение начинается с конца, пока позиция не изменена.

Где и как запускать

Учебная база: создайте серверный общий модуль УчебныеЗадачи (флаг Сервер). Код без директив вставьте в тело процедуры ВыполнитьПример() Экспорт. Вызовите её из серверного обработчика команды учебной обработки. Не запускайте в рабочей базе.

Подготовка

  1. Выполняйте на сервере; все потоки в памяти, файлов нет.

  2. Исходные четыре байта: 1, 2, 3, 4; ёмкость первого потока 64 — резерв памяти, не число данных.

Буфер = Новый БуферДвоичныхДанных(4);
Для Номер = 0 По 3 Цикл
    Буфер.Установить(Номер, Номер + 1);
КонецЦикла;
Поток = Новый ПотокВПамяти(64);
Копия = Новый ПотокВПамяти;
Попытка
    Сообщить(Поток.Размер());
    Сообщить(Поток.ДоступнаЗапись);
    Сообщить(Поток.ДоступноЧтение);
    Сообщить(Поток.ДоступноИзменениеПозиции);
    Поток.Записать(Буфер, 0, 4);
    Поток.СброситьБуферы();
    Сообщить(Поток.ТекущаяПозиция());
    Поток.Перейти(0, ПозицияВПотоке.Начало);
    Прочитанное = Новый БуферДвоичныхДанных(2);
    Прочитано = Поток.Прочитать(Прочитанное, 0, 2);
    Сообщить(Прочитано);
    Сообщить(Прочитанное.Получить(0));
    Поток.КопироватьВ(Копия, 2);
    Сообщить(Копия.Размер());
    ДанныеКопии = Копия.ЗакрытьИПолучитьДвоичныеДанные();
    Копия = Неопределено;
    Сообщить(ПолучитьHexСтрокуИзДвоичныхДанных(ДанныеКопии));
    Поток.УстановитьРазмер(3);
    Данные = Поток.ЗакрытьИПолучитьДвоичныеДанные();
    Поток = Неопределено;
Исключение
    Если Копия <> Неопределено Тогда
        Копия.Закрыть();
    КонецЕсли;
    Если Поток <> Неопределено Тогда
        Поток.Закрыть();
    КонецЕсли;
    ВызватьИсключение;
КонецПопытки;
Сообщить(ПолучитьHexСтрокуИзДвоичныхДанных(Данные));
Основа = ПолучитьБуферДвоичныхДанныхИзДвоичныхДанных(Данные);
ПотокИзБуфера = Новый ПотокВПамяти(Основа);
Сообщить(ПотокИзБуфера.Размер());
ПотокИзБуфера.Закрыть();

Разбор по шагам

  1. Создаём два потока и проверяем размер пустого потока: 0.

  2. После записи позиция 4; Перейти перемещает её к началу для чтения.

  3. Прочитать возвращает фактическое число байтов. КопироватьВ начинает с текущей позиции, поэтому копирует только 3 и 4.

  4. УстановитьРазмер сокращает первый поток до трёх байтов; ЗакрытьИПолучитьДвоичныеДанные выдаёт содержимое и закрывает поток.

Как проверить результат

  1. Прочитано 2 байта, первый равен 1; содержимое копии в Hex — 0304.

  2. После сокращения исходные данные в Hex — 010203; поток, созданный на их буфере, имеет размер 3.

Ожидаемый результат

Частичное чтение, копирование остатка и сокращение потока выполнены без файлов.

На что обратить внимание

  1. После ЗакрытьИПолучитьДвоичныеДанные поток больше не используйте.

  2. Прочитать может вернуть меньше запрошенного количества, особенно у сетевых потоков: всегда проверяйте возвращённое число.

  3. НачальнаяЁмкость — объём резервирования, УстановитьРазмер — изменение фактических данных; это разные операции.

Пример не запускался в вашей базе. Перед применением проверьте его в указанном учебном контексте.

Прочитать вложение цепочкой оповещений

Полный модуль формы показывает callbacks Открыть → ПолучитьВложения → Закрыть, отдельный обработчик ошибки и запрет повторного старта до завершения.

Где и как запускать

Полный модуль пустой управляемой формы учебной внешней обработки; серверный генератор PDF и клиентские callbacks Windows.

Подготовка

  1. В отдельной учебной базе создайте внешнюю обработку с пустой управляемой формой, командой УчебныйПример и кнопкой. В Действие команды выберите процедуру УчебныйПример.

  2. Вставьте полный приведённый модуль формы. Функция ПодготовитьСвойPDF находится на сервере, обработчики оповещений — на клиенте и обязательно Экспорт.

  3. Запускайте в тонком или толстом клиенте Windows 8.5.1.1343. Веб-клиент и расширения браузера не входят в подготовку этого урока.

  4. PDF создаётся этим же модулем из одной учебной ячейки. Сервер возвращает только собственные ДвоичныеДанные; файлов, реальных сертификатов и персональных сведений нет.

Перем Выполняется;

&НаКлиенте
Процедура УчебныйПример(Команда)
    Если Выполняется = Истина Тогда
        Сообщить("Дождитесь завершения своего предыдущего PDF-примера");
        Возврат;
    КонецЕсли;
    Данные = ПодготовитьСвойPDF(Истина);
    Буфер = ПолучитьБуферДвоичныхДанныхИзДвоичныхДанных(Данные);
    Состояние = Новый Структура("Поток,Чтение,Запись", Новый ПотокВПамяти(Буфер), Неопределено, Неопределено);
    Выполняется = Истина;
    Попытка
        Состояние.Чтение = Новый ЧтениеPDF;
        Состояние.Чтение.НачатьОткрытие(ОповещениеДля("ПослеОткрытияЧтения", Состояние), Состояние.Поток);
    Исключение
        ОсвободитьРесурсы(Состояние);
        Выполняется = Ложь;
        ВызватьИсключение;
    КонецПопытки;
КонецПроцедуры

&НаКлиенте
Функция ОповещениеДля(Обработчик, Состояние)
    Возврат Новый ОписаниеОповещения(Обработчик, ЭтотОбъект, Состояние, "ОшибкаОперации", ЭтотОбъект);
КонецФункции

&НаКлиенте
Процедура ОшибкаОперации(Ошибка, СтандартнаяОбработка, Состояние) Экспорт
    ОсвободитьРесурсы(Состояние);
    Выполняется = Ложь;
    СтандартнаяОбработка = Истина;
КонецПроцедуры

&НаКлиенте
Процедура ОсвободитьРесурсы(Состояние)
    Если Состояние.Чтение <> Неопределено Тогда
        Попытка
            Состояние.Чтение.Закрыть();
        Исключение
            Сообщить("Не удалось закрыть свой объект чтения PDF: " + ОписаниеОшибки());
        КонецПопытки;
        Состояние.Чтение = Неопределено;
    КонецЕсли;
    Если Состояние.Поток <> Неопределено Тогда
        Попытка
            Состояние.Поток.Закрыть();
        Исключение
            Сообщить("Не удалось закрыть свой поток PDF: " + ОписаниеОшибки());
        КонецПопытки;
        Состояние.Поток = Неопределено;
    КонецЕсли;
КонецПроцедуры

&НаКлиенте
Процедура ПослеОткрытияЧтения(Состояние) Экспорт
    Попытка
        Состояние.Чтение.НачатьПолучениеВложений(ОповещениеДля("ПослеПолученияВложений", Состояние));
    Исключение
        ОсвободитьРесурсы(Состояние);
        Выполняется = Ложь;
        ВызватьИсключение;
    КонецПопытки;
КонецПроцедуры

&НаКлиенте
Процедура ПослеПолученияВложений(Прочитанные, Состояние) Экспорт
    Попытка
        Сообщить(Прочитанные.Количество() = 1);
        ФайлJSON = Прочитанные.Найти("товар.json");
        Если ФайлJSON = Неопределено Тогда
            ВызватьИсключение "Нет собственного вложения после PDF-операции";
        КонецЕсли;
        Текст = ПолучитьСтрокуИзДвоичныхДанных(ФайлJSON.Содержимое, КодировкаТекста.UTF8);
        Сообщить(Текст = "{""товар"":""Книга"",""количество"":3}");
        Состояние.Чтение.НачатьЗакрытие(ОповещениеДля("ПослеЗакрытияЧтения", Состояние));
    Исключение
        ОсвободитьРесурсы(Состояние);
        Выполняется = Ложь;
        ВызватьИсключение;
    КонецПопытки;
КонецПроцедуры

&НаКлиенте
Процедура ПослеЗакрытияЧтения(Состояние) Экспорт
    Попытка
        Состояние.Чтение = Неопределено;
        ОсвободитьРесурсы(Состояние);
        Выполняется = Ложь;
        Сообщить("Собственная цепочка PDF завершена, ресурсы освобождены");
    Исключение
        ОсвободитьРесурсы(Состояние);
        Выполняется = Ложь;
        ВызватьИсключение;
    КонецПопытки;
КонецПроцедуры

&НаСервереБезКонтекста
Функция ПодготовитьСвойPDF(СВложением)
    Вложения = Новый КоллекцияВложенийPDF;
    ТекстJSON = "{""товар"":""Книга"",""количество"":3}";
    БайтыJSON = ПолучитьДвоичныеДанныеИзСтроки(ТекстJSON, КодировкаТекста.UTF8, Ложь);
    Вложения.Добавить("товар.json", БайтыJSON, "application/json", ТипСвязиВложенияPDF.Данные);
    Если Не СВложением Тогда
        Вложения.Очистить();
    КонецЕсли;
    Документ = Новый ТабличныйДокумент;
    Документ.Область("A1").Текст = "Книга: 3 шт.";
    Поток = Новый ПотокВПамяти;
    Попытка
        Документ.Записать(Поток, ТипФайлаТабличногоДокумента.PDF, Вложения);
        Возврат Поток.ЗакрытьИПолучитьДвоичныеДанные();
    Исключение
        Поток.Закрыть();
        ВызватьИсключение;
    КонецПопытки;
КонецФункции

Разбор по шагам

  1. Сервер строит свой PDF с JSON и возвращает байты; клиент создаёт поток на основании собственного буфера.

  2. НачатьОткрытие получает сначала ОписаниеОповещения, затем поток. Завершение открытия вызывает ПослеОткрытияЧтения(Состояние).

  3. НачатьПолучениеВложений возвращает результат в ПослеПолученияВложений(Прочитанные, Состояние). Проверяем имя и содержимое.

  4. НачатьЗакрытие завершает работу читателя до закрытия нашего потока. Флаг Выполняется снимаем только при завершении или ошибке.

  5. ОшибкаОперации и исключения запуска следующего шага освобождают ресурсы; ошибка операции остаётся в стандартной обработке.

Как проверить результат

  1. Два сравнения Истина и сообщение о завершении цепочки.

  2. Нажмите кнопку повторно до окончания: вместо второго запуска должна быть просьба дождаться завершения.

  3. Поставьте точки останова в трёх обработчиках: они вызываются в указанном порядке, коллекция поступает только во второй.

Ожидаемый результат

Собственное вложение прочитано последовательными оповещениями с освобождением ресурсов.

На что обратить внимание

  1. Процедуры обработки оповещений должны быть Экспорт и иметь документированные параметры.

  2. Не вызывайте следующий шаг сразу после НачатьОткрытие: эта операция ещё не закончилась.

  3. Синхронное аварийное освобождение рассчитано на Windows-клиент этого урока; веб-клиент здесь не проверен.

Пример не запускался в вашей базе. Перед применением проверьте его в указанном учебном контексте.

Не хотите разбираться сами?

Адаптируем это решение под вашу базу. Оценка бесплатно.

Оставить задачу

1С, 1С:Предприятие — товарные знаки ООО «1С». Сайт не является официальным представительством фирмы «1С» и не аффилирован с ней.