IdHTTPserver：共享 ADOConnection

Question

我正在使用 TIdHTTPServer 创建一个简单的 Indy 网络服务器。几乎所有请求服务器都需要与数据库通信（通过TAdoConnection）。看到数据库连接在资源方面有点昂贵，我想创建一个池机制来重用连接；而不是在每个请求上建立连接。

我没有成功地寻找例子。 Embarcadero 讨论论坛上的此链接建议对 TIdSchedulerOfThreadPool< 的后代进行子类化/strong> 和 TIdThreadWithTask。但我仍然无法把它们整合在一起。

我是否需要重写 TIdSchedulerOfThreadPool.NewThread 方法并让它返回我的子类 TIdThreadWithTask 对象，而该对象又将拥有自己的 TAdoConnection 对象？

有人有例子吗？我是否应该不担心这一点，只在每个请求上打开数据库连接？

Answer 1

你为什么不自己管理这个池呢？

您有一个连接列表。它开始是空的。每次请求到来时，您都会查找可用连接（处于活动状态但未使用的连接）。如果没有找到，则创建一个并将其放入列表中，因为不可用。请求结束后，您将连接设置为可用。

去过那里，做过那件事，一点也不后悔！关注的几点：

• 时刻牢记线程安全：
  • 当您查询列表时
  • 当您查询连接的可用性时
  • 当您设置连接的可用性时
• 时 有时，请检查是否有太多未使用的可用连接，可能会超出您的需要，因此必须将它们设置为不可用，从列表中删除，然后关闭。

Answer 2

您还必须通过调用 CoInitialize/CoUnitialize 对来确保在每个线程中正确设置 COM。

下面是要包含在项目中的示例单元。在您的 HTTP 服务器构造函数中，只需创建自定义调度程序，Indy 将使用它而不是默认的调度程序。

如果这样做，那么每个客户端线程都将为 COM 正确初始化，并且您还可以添加将由所有客户端线程共享的其他项目。

我还为每个连接创建一个自定义 TIdServerContext 后代（并在 HTTP Server 构造函数中设置 ContextClass 属性。）不同类型的服务器具有不同的 TIdServerContext 后代，但它们都利用 TsoIndyCOMEnabledSchedulerOfThread 基线程类，因为它们都执行某些 COM 操作。种类。

我不会将 ADO 连接放入线程中，而是放入上下文中......特别是如果您将其进一步放入线程池中。

unit ExampleStackOverflow;

interface

uses
  SysUtils, Classes,
  ActiveX,
  IdThread, IdSchedulerOfThreadDefault;

type
  //Meant to be used with a custom TIdSchedulerOfThreadDefault descendant
  //to ensure COM support on child threads.
  TsoIndyComThreadWithTask = class(TIdThreadWithTask)
  protected
    //Ensure COM is setup before client connection/thread work
    procedure BeforeExecute; override;
    //Graceful COM cleanup on client connection/thread
    procedure AfterExecute; override;
  end;


  TsoIndyCOMEnabledSchedulerOfThread = class(TIdSchedulerOfThreadDefault)
  public
    constructor Create(AOwner:TComponent); reintroduce;
  end;



implementation

procedure TsoIndyComThreadWithTask.BeforeExecute;
begin
  CoInitialize(nil);
  inherited;
end;


procedure TsoIndyComThreadWithTask.AfterExecute;
begin
  inherited;
  CoUninitialize();
end;


constructor TsoIndyCOMEnabledSchedulerOfThread.Create(AOwner:TComponent);
begin
  inherited;
  //the whole reason for overriding default scheduler of thread is to setup COM
  //on client threads
  ThreadClass := TsoIndyComThreadWithTask;
  Name := Name + 'COMEnabledScheduler';
end;