Отправка Электронных Писем в Фоновом Режиме с Использованием Механизма Очереди в Delphi

Delphi , Компоненты и Классы , Потоки

Вопрос пользователя касается разработки класса в Delphi для реализации механизма очереди отправки электронных писем в фоновом режиме. Суть проблемы заключается в том, что при сохранении деталей вызова такси, система должна отправлять уведомление водителю в фоновом потоке, не блокируя основной интерфейс. Важно, чтобы Mechanism of email sending is a queue, meaning an email in the queue must wait until processing for an email that is being sent has completed. Для этого используется отдельный поток от основного VCL.

Для реализации такого механизма подойдет OmniThreadLibrary, которая облегчает работу с потоками в Delphi. Однако, можно рассмотреть и другие варианты реализации, включая использование базового TThread. Но для более масштабируемой и модульной системы, рекомендуется применить паттерн "Pipeline", который позволит в будущем без труда добавлять новые способы уведомления (например, SMS) и расширять функционал системы.

Примерный шаблон класса для реализации очереди почтовых сообщений:

unit uEmailQueue;

interface

uses
  Classes;

type
  TEmailServer = record
    SMTPHost: String;
    SMTPPort: Integer;
    SMTPUseSSL: Boolean;
    SMTPUserName: String;
    SMTPPassword: String;
    SMTPSenderName: String;
  end;

  TEmailMessage = record
    RecipientEmailAddr: String;
    EmailSubject: String;
    EmailMessage: String;
  end;

  TEmailQueue = class(TObject)
  private
    FEmailServer: TEmailServer;
    FQueue: TQueue<IInterface>;
    FWorkerThread: TThread;
    FIsRunning: Boolean;
    procedure Worker;
    function IsQueueEmpty: Boolean;
    procedure Enqueue(const AEmailMessage: TEmailMessage);
  public
    constructor Create;
    destructor Destroy; override;
    procedure Start;
    procedure Stop;
  end;

implementation

uses
  SysUtils,
  Classes,
  SyncObjs;

{ TEmailQueue }

constructor TEmailQueue.Create;
begin
  inherited Create;
  FEmailServer := TEmailServer.Create;
  FQueue := TQueue<IInterface>.Create;
  FWorkerThread := TThread.CreateAnonymousThread(
    procedure
    begin
      Worker;
    end);
  FWorkerThread.Start;
end;

destructor TEmailQueue.Destroy;
begin
  Stop;
  FQueue.Free;
  FEmailServer.Free;
  inherited;
end;

procedure TEmailQueue.Start;
begin
  FIsRunning := True;
end;

procedure TEmailQueue.Stop;
begin
  FIsRunning := False;
  FQueue.Post(nil);
  FWorkerThread.WaitFor;
end;

procedure TEmailQueue.Enqueue(const AEmailMessage: TEmailMessage);
begin
  FQueue.Post(TObject(AEmailMessage).Self);
end;

function TEmailQueue.IsQueueEmpty: Boolean;
begin
  Result := FQueue.Count = 0;
end;

procedure TEmailQueue.Worker;
var
  AEmailMessage: TEmailMessage;
  ATask: TObject;
begin
  while FIsRunning do
  begin
    ATask := FQueue.Take;
    if Assigned(ATask) and ATask is TEmailMessage then
    begin
      AEmailMessage := ATask as TEmailMessage;
      // Здесь должен быть код отправки письма
    end;
  end;
end;

end.

Обработка ответов:

procedure TEmailQueue.Worker;
begin
  // Обертка для обращения к OmniThreadLibrary для безопасной обработки
  // Отсюда можно использовать "double accounting" механизм для получения количества ожидающих отправки писем
  // Например, через объект с механизмом блокировки, который ведет двойной учет задач.
  ...
end;

Паттерн "Pipeline" можно реализовать через OmniThreadLibrary, используя блокировочные коллекции и механизмы для обработки задач в потоке.

uses
  OTLCommon,
  OTLTBB;

var
  TaxiInQueue: iOmniBlockingCollection;
begin
  TaxiInQueue := TOmniBlockingCollection.Create;
  // Настройка коллекции
  TaxiInQueue.Start;

  // Добавление задачи в очередь
  var NewTask: TEmailMessage;
  begin
    NewTask.RecipientEmailAddr := 'some@email.com';
    TaxiInQueue.Add(TOmniValue.FromRecord(NewTask));
  end;

  // Ожидание завершения всех задач
  TaxiInQueue.Stop;
  TaxiInQueue.WaitAll;
end.

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

Этот код дает основу для создания класса TEmailQueue, который обеспечивает возможность добавления задач отправки электронных писем в очередь и их асинхронную обработку в фоновом потоке. Это позволяет избежать блокировки главного потока и обеспечивает выполнение задач в строгом порядке их поступления, что критично для работы с ограниченным ресурсом (одним экземпляром IdSMTP).

Создано по материалам из источника по ссылке.

Разработка класса в Delphi для фоновой отправки электронных писем с использованием механизма очереди.

Комментарии и вопросы

Получайте свежие новости и обновления по Object Pascal, Delphi и Lazarus прямо в свой смартфон. Подпишитесь на наш Telegram-канал delphi_kansoftware и будьте в курсе последних тенденций в разработке под Linux, Windows, Android и iOS

:: Главная :: Потоки ::