用Delphi10.3 写一段 接收事件订阅 的代码

好的，以下是一个简单的 Delphi 10.3 代码示例，用于接收事件订阅：

unit MainForm;

interface

uses
  Winapi.Windows, Winapi.Messages, System.SysUtils, System.Variants, System.Classes,
  Vcl.Graphics, Vcl.Controls, Vcl.Forms, Vcl.Dialogs, Vcl.StdCtrls, Vcl.ExtCtrls,
  System.JSON;

type
  TMainForm = class(TForm)
    MemoLog: TMemo;
    ButtonSubscribe: TButton;
    TimerLog: TTimer;
    procedure ButtonSubscribeClick(Sender: TObject);
    procedure TimerLogTimer(Sender: TObject);
    procedure FormCreate(Sender: TObject);
  private
    { Private declarations }
    FSubscriber: TEventSubscriber;
  public
    { Public declarations }
  end;

var
  MainForm: TMainForm;

implementation

{$R *.dfm}

type
  TEventSubscriber = class(TThread)
  private
    FEvent: THandle;
    FLogMemo: TMemo;
  protected
    procedure Execute; override;
  public
    constructor Create(Event: THandle; LogMemo: TMemo);
  end;

constructor TEventSubscriber.Create(Event: THandle; LogMemo: TMemo);
begin
  inherited Create(False);
  FEvent := Event;
  FLogMemo := LogMemo;
end;

procedure TEventSubscriber.Execute;
var
  WaitResult: DWORD;
  Buffer: array [0..255] of Char;
  JsonValue: TJSONValue;
begin
  while not Terminated do
  begin
    WaitResult := WaitForSingleObject(FEvent, INFINITE);
    if WaitResult = WAIT_OBJECT_0 then
    begin
      if ReadConsole(GetStdHandle(STD_INPUT_HANDLE), @Buffer, SizeOf(Buffer), nil, nil) then
      begin
        JsonValue := TJSONObject.ParseJSONValue(Buffer);
        if Assigned(JsonValue) then
        begin
          Synchronize(
            procedure
            begin
              FLogMemo.Lines.Add(JsonValue.ToString);
            end
          );
          JsonValue.Free;
        end;
      end;
    end;
  end;
end;

procedure TMainForm.ButtonSubscribeClick(Sender: TObject);
var
  Event: THandle;
begin
  Event := CreateEvent(nil, True, False, nil);
  if Event <> 0 then
  begin
    FSubscriber := TEventSubscriber.Create(Event, MemoLog);
    SetConsoleMode(GetStdHandle(STD_INPUT_HANDLE), ENABLE_PROCESSED_INPUT or ENABLE_LINE_INPUT or ENABLE_ECHO_INPUT);
    ButtonSubscribe.Enabled := False;
    MemoLog.Lines.Add('正在等待事件...');
    FSubscriber.Start;
  end;
end;

procedure TMainForm.TimerLogTimer(Sender: TObject);
begin
  MemoLog.Lines.Add('正在等待事件...');
end;

procedure TMainForm.FormCreate(Sender: TObject);
begin
  TimerLog.Enabled := True;
end;

end.

这个示例代码创建了一个 `TEventSubscriber` 类，用于在后台线程中接收事件订阅。在主窗体上，有一个按钮 `ButtonSubscribe`，点击这个按钮会创建一个 `TEventSubscriber` 对象，并在后台线程中等待事件的到来。`TEventSubscriber` 等待事件的方式是调用 `WaitForSingleObject` 函数，当事件到来时，`ReadConsole` 函数将读取控制台输入的数据，并使用 `TJSONObject.ParseJSONValue` 函数解析 JSON 数据。如果 JSON 数据解析成功，就将 JSON 字符串添加到主窗体的 `TMemo` 控件上。

在 `ButtonSubscribeClick` 事件处理程序中，我们使用 `CreateEvent` 函数创建一个事件对象，并将它传递给 `TEventSubscriber` 对象。`SetConsoleMode` 函数用于配置控制台输入模式，以便可以读取控制台输入的数据。在 `TEventSubscriber.Execute` 方法中，我们使用 `Synchronize` 函数将日志消息添加到主窗体的 `TMemo` 控件上。