WebSocket および HTTP/2 を備えた DataSnap

· 機能

sgcWebSockets 4.4.3 以降、DataSnap サーバーアプリケーションを WebSocket サーバーに置き換え、以下のような新機能を活用できます。



デフォルトの Indy サーバーである TIdHTTPWebBrokerBridge の置き換えとして使用できるサーバーは 3 種類あります。 

サーバー 主な機能 説明
TsgcWSHTTPWebBrokerBridgeServer WebSocket プロトコル
HTTP 1.* プロトコル
XHR プロトコル
IOCP
Indy ライブラリに基づき、同一ポート上で WebSocket と HTTP プロトコルをサポートします。IOCP も有効化できます。
TsgcWSHTTP2WebBrokerBridgeServerWebSocket プロトコル
HTTP 1.* プロトコル
HTTP/2 プロトコル
XHR プロトコル
IOCP
Indy ライブラリに基づき、同一ポート上で WebSocket と HTTP/2 プロトコルをサポートします。IOCP も有効化できます。
TsgcWSServer_HTTPAPI_WebBrokerBridgeWebSocket プロトコル
HTTP 1.* プロトコル
HTTP/2 プロトコル
XHR プロトコル
IOCP
Microsoft の HTTP.SYS API に基づき、同一ポート上で WebSocket と HTTP/2 プロトコルをサポートします。IOCP がデフォルトで使用されます。最高のパフォーマンスを得るために推奨されます。

これらのサーバーのいずれかを使用すると、同一のリスニングポートで HTTP と WebSocket プロトコルを使用できます。これらのサーバーで利用可能な OnHTTPRequest イベントを使用して、カスタム HTTP リクエストをディスパッチできます。

サンプルコード

これらのサーバーのいずれかを使用するには、デフォルトの Indy WebBrokerBridge サーバーを置き換え、実行に必要なプロパティを設定する必要があります。

以下のコードでは、デフォルトのサーバーを置き換え、TsgcWSHTTPWebBrokerBridgeServer (HTTP + WebSocket プロトコルをサポート) を使用しています。

unit FormUnit1;
interface
uses
  Winapi.Messages, System.SysUtils, System.Variants,
  System.Classes, Vcl.Graphics, Vcl.Controls, Vcl.Forms, Vcl.Dialogs,
  Vcl.AppEvnts, Vcl.StdCtrls, sgcWebSocket_Server_WebBrokerBridge, Web.HTTPApp,
  sgcWebSocket_Classes, sgcWebSocket_Types;
type
  TForm1 = class(TForm)
    ButtonStart: TButton;
    ButtonStop: TButton;
    EditPort: TEdit;
    Label1: TLabel;
    ApplicationEvents1: TApplicationEvents;
    ButtonOpenBrowser: TButton;
    Button1: TButton;
    chkSSL: TCheckBox;
    procedure FormCreate(Sender: TObject);
    procedure ApplicationEvents1Idle(Sender: TObject; var Done: Boolean);
    procedure Button1Click(Sender: TObject);
    procedure ButtonStartClick(Sender: TObject);
    procedure ButtonStopClick(Sender: TObject);
    procedure ButtonOpenBrowserClick(Sender: TObject);
  private
    FServer: TsgcWSHTTPWebBrokerBridgeServer;
    procedure StartServer;
  private
    procedure OnWebSocketMessage(aConnection: TsgcWSConnection; const aText:
        string);
  end;
var
  Form1: TForm1;
implementation
{$R *.dfm}
uses
  WinApi.Windows, Winapi.ShellApi, Datasnap.DSSession;
procedure TForm1.ApplicationEvents1Idle(Sender: TObject; var Done: Boolean);
begin
  ButtonStart.Enabled := not FServer.Active;
  ButtonStop.Enabled := FServer.Active;
  EditPort.Enabled := not FServer.Active;
end;
procedure TForm1.ButtonOpenBrowserClick(Sender: TObject);
var
  vURL: string;
  vProtocol: string;
begin
  StartServer;
  vProtocol := 'http';
  if chkSSL.Checked then
    vProtocol := vProtocol + 's';
  vURL := Format(vProtocol + '://127.0.0.1:%s', [EditPort.Text]);
  ShellExecute(0,
        nil,
        PChar(vURL), nil, nil, SW_SHOWNOACTIVATE);
end;
procedure TForm1.ButtonStartClick(Sender: TObject);
begin
  StartServer;
end;
procedure TerminateThreads;
begin
  if TDSSessionManager.Instance <> nil then
    TDSSessionManager.Instance.TerminateAllSessions;
end;
procedure TForm1.Button1Click(Sender: TObject);
var
  vURL: string;
  vProtocol: string;
begin
  StartServer;
  vProtocol := 'http';
  if chkSSL.Checked then
    vProtocol := vProtocol + 's';
  vURL := Format(vProtocol + '://127.0.0.1:%s/sgcWebSockets.html', [EditPort.Text]);
  ShellExecute(0,
        nil,
        PChar(vURL), nil, nil, SW_SHOWNOACTIVATE);
end;
procedure TForm1.ButtonStopClick(Sender: TObject);
begin
  TerminateThreads;
  FServer.Active := False;
  FServer.Bindings.Clear;
end;
procedure TForm1.FormCreate(Sender: TObject);
begin
  FServer := TsgcWSHTTPWebBrokerBridgeServer.Create(Self);
  FServer.OnMessage := OnWebSocketMessage;
end;
procedure TForm1.OnWebSocketMessage(aConnection: TsgcWSConnection; const aText:
    string);
begin
  aConnection.WriteData(aText);
end;
procedure TForm1.StartServer;
begin
  if not FServer.Active then
  begin
    FServer.Bindings.Clear;
    FServer.DefaultPort := StrToInt(EditPort.Text);
    if chkSSL.Checked then
    begin
      FServer.SSLOptions.CertFile := 'sgc.pem';
      FServer.SSLOptions.KeyFile := 'sgc.pem';
      FServer.SSLOptions.RootCertFile := 'sgc.pem';
      FServer.SSLOptions.Port := StrToInt(EditPort.Text);
      FServer.SSLOptions.Version := tls1_2;
    end;
    FServer.SSL := chkSSL.Checked;
    FServer.Active := True;
  end;
end;
end.