Интеграция Delphi и Node.js: Обмен сообщениями в реальном времени через WebSockets

Delphi , Интернет и Сети , Сокеты

В современном программировании часто возникает необходимость обмена данными между приложениями, написанными на разных языках программирования. В данном случае, рассматривается задача обмена сообщениями между крупным приложением на Delphi и небольшим приложением на Node.js. Пользователь хочет, чтобы Node.js-приложение отправляло сообщения в приложение на Delphi в зависимости от данных, получаемых от сервиса в реальном времени.

Проблема

Пользователь столкнулся с задачей интеграции двух приложений для обмена сообщениями. Он уже начал исследования, но не нашел четких решений. Первоначально, он склоняется к использованию WebSockets как к единственно возможному решению для обмена сообщениями в реальном времени, но также упомянул, что он пытался написать код для Node.js-приложения с использованием socket.io.

Решение

Для реализации обмена сообщениями между Node.js и Delphi приложениями можно использовать различные подходы. Один из вариантов - запуск встроенного HTTP-сервера в приложении на Delphi, который сможет принимать HTTP-запросы от Node.js-приложения. Например, можно использовать компоненты Indy, такие как TIdHTTPServer.

Другой подход - разработка собственного протокола и запуск встроенного TCP-сервера в приложении на Delphi с использованием TIdTCPServer.

Также, стоит рассмотреть другие протоколы и библиотеки для обмена сообщениями. Одним из вариантов может служить библиотека 0MQ (ZeroMQ), которая поддерживается как для Delphi, так и для Node.js.

Альтернативные подходы

В качестве альтернативы, можно использовать API Ably напрямую из Delphi, что исключает необходимость в Node.js. Также, можно рассмотреть техники межпроцессного взаимодействия (IPC), но они потребуют опроса данных.

Более сложный, но потенциально более эффективный подход - встраивание JavaScript-двига в приложение на Delphi и регистрация обратных вызовов для уведомлений о сообщениях, что позволит избежать межпроцессного взаимодействия.

Другой вариант - использование .NET в процессе через interop (неуправляемые экспорты, RemObjects Hydra, COM и т.д.).

Подтвержденное решение

Пользователь нашел решение в создании простого локального веб-сервера в приложении на Delphi, который хорошо интегрируется с Node.js. Это решение оказалось легким в реализации и эффективным для обмена сообщениями в реальном времени.

Пример кода на Delphi

program WebSocketServer;

{$APPTYPE CONSOLE}

uses
  System.SysUtils,
  IdGlobal,
  IdHTTPServer,
  IdContext,
  IdCustomTCPServer,
  IdCustomWebSocketServer,
  IdStackOrion;

type
  TWebSocketServer = class(TIdCustomWebSocketServer)
  protected
    function DoHandshake(AContext: TIdContext; ARequestInfo: TRequestInfo): Boolean; override;
  end;

  TWebSocketHandler = class(TIdTCPConnectionHandler)
  private
    FWebSocket: TWebSocketServer;
  public
    constructor Create(AWebSocketServer: TIdCustomWebSocketServer); override;
    procedure Execute; override;
  end;

{ TWebSocketServer }

constructor TWebSocketHandler.Create(AWebSocketServer: TIdCustomWebSocketServer);
begin
  inherited Create(True);
  FWebSocket := AWebSocketServer;
end;

procedure TWebSocketHandler.Execute;
var
  Message: string;
begin
  inherited;
  while Connected do
  begin
    Message := GetIdGlobal().IdStackOrion1.ReceiveText(1000);
    if Message = '' then
      Exit;
    FWebSocket.Context.Connection.IOHandler.Write(TPersistent.StringToUTF8BOM(Message));
  end;
end;

function TWebSocketServer.DoHandshake(AContext: TIdContext; ARequestInfo: TRequestInfo): Boolean;
begin
  Result := inherited;
  if Result then
  begin
    with AContext.Connection.IOHandler do
    begin
      OnRead := TWebSocketHandler.Create(Self);
      Active := True;
    end;
  end;
end;

var
  WebServer: TIdHTTPServer;
  WebSocketServer: TWebSocketServer;
begin
  WebServer := TIdHTTPServer.Create(nil);
  try
    WebServer.DefaultPort := 80;
    WebServer.WorkingDirectory := '.';
    WebServer.OnCommandGet := procedure(Context: TIdContext)
      begin
        Context.Response.ContentTextType := 'text/html';
        Context.Response.Content := '<html><body>Server is ready</body></html>';
      end;
    WebSocketServer := TWebSocketServer.Create(WebServer);
    try
      WebSocketServer.OnMessage := procedure(const AContext: TIdContext; const AData: string)
        begin
          // Обработка полученного сообщения от Node.js
        end;
      WebServer.Active := True;
      {$IFNDEF UNIX}
      ReadLn;
      {$ELSE}
      GetChar;
      {$ENDIF}
    finally
      WebSocketServer.Free;
    end;
  finally
    WebServer.Free;
  end;
end.

Этот код создает простой HTTP-сервер с поддержкой WebSockets, который может быть использован в приложении на Delphi для приема сообщений от Node.js-приложения.

Заключение

Обмен сообщениями между приложениями на Delphi и Node.js может быть реализован с использованием различных технологий, включая WebSockets, HTTP, TCP и другие протоколы. Важно выбрать подход, который наилучшим образом соответствует требованиям проекта и возможностям обеих платформ.

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

Пользователь стремится интегрировать приложение на Delphi с приложением на Node.js для обмена сообщениями в реальном времени через WebSockets.

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

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

:: Главная :: Сокеты ::