用 Delphi 作 服務 + 多執行緒 的參考程式

bestlong

1. unit Unit_main;
   
2. interface
   
3. uses
   
4.   Windows, Messages, SysUtils, Classes, Graphics, Controls, SvcMgr,Dialogs,
   
5.   DB, ADODB,iniFiles,Forms,Unit_Import;
   
6. type
   
7.   TImportDataSVC = class(TService)
   
8.     ADOConn: TADOConnection;
   
9.     ADOStoredProc: TADOStoredProc;
   
10.     procedure ServiceContinue(Sender: TService; var Continued: Boolean);
    
11.     procedure ServiceExecute(Sender: TService);
    
12.     procedure ServicePause(Sender: TService; var Paused: Boolean);
    
13.     procedure ServiceShutdown(Sender: TService);
    
14.     procedure ServiceStart(Sender: TService; var Started: Boolean);
    
15.     procedure ServiceStop(Sender: TService; var Stopped: Boolean);
    
16.   private
    
17.     { Private declarations }
    
18.   public
    
19.     function GetServiceController: TServiceController; override;
    
20.     { Public declarations }
    
21.   end;
    
22. 
    
23. var
    
24.   ImportDataSVC: TImportDataSVC;
    
25.   ImportThread: TImport;
    
26. 
    
27. implementation
    
28. 
    
29. uses FunCrypt;
    
30. 
    
31. {$R *.DFM}
    
32. 
    
33. procedure ServiceController(CtrlCode: DWord); stdcall;
    
34. begin
    
35.   ImportDataSVC.Controller(CtrlCode);
    
36. end;
    
37. 
    
38. function TImportDataSVC.GetServiceController: TServiceController;
    
39. begin
    
40.   Result := ServiceController;
    
41. end;
    
42. 
    
43. procedure TImportDataSVC.ServiceContinue(Sender: TService; var Continued: Boolean);
    
44. begin
    
45.   while not Terminated do
    
46.   begin
    
47.     Sleep(10);
    
48.     ServiceThread.ProcessRequests(False);
    
49.   end;
    
50. end;
    
51. 
    
52. procedure TImportDataSVC.ServiceExecute(Sender: TService);
    
53. begin
    
54.   while not Terminated do
    
55.   begin
    
56.     Sleep(10);
    
57.     ServiceThread.ProcessRequests(False);
    
58.   end;
    
59. end;
    
60. 
    
61. procedure TImportDataSVC.ServicePause(Sender: TService; var Paused: Boolean);
    
62. begin
    
63.   Paused := True;
    
64. end;
    
65. 
    
66. procedure TImportDataSVC.ServiceShutdown(Sender: TService);
    
67. begin
    
68.   Status := csStopped;
    
69.   ReportStatus();
    
70. end;
    
71. 
    
72. procedure TImportDataSVC.ServiceStart(Sender: TService; var Started: Boolean);
    
73. var
    
74.   MyIniFile: TInifile;
    
75.   Pwd, DBConStr, MS_SQLSERVER, MS_SQLUsr, MS_SQLPwd: String;
    
76.   OracleParaList: TStringList;
    
77. begin
    
78.   //服務啟動時，取得資料庫參數
    
79.   MyIniFile := TIniFile.Create(ExtractFilePath(Application.ExeName) + 'Dbsetup.ini');
    
80.   OracleParaList.Create;
    
81.   MS_SQLSERVER := MyIniFile.ReadString('MS-SQL', 'Server', '');
    
82.   MS_SQLUsr    := MyIniFile.ReadString('MS-SQL', 'User', '');
    
83.   MS_SQLPwd    := MyIniFile.ReadString('MS-SQL', 'Password', '');
    
84.   MS_SQLPwd    := _Crypt(MS_SQLPwd, 65535, false);
    
85.   DBConStr := 'Provider=SQLOLEDB.1;Persist Security Info=True;'
    
86.     + 'User ID=' + MS_SQLUsr + ';Initial Catalog=GWBNMember;Data Source='
    
87.     + MS_SQLSERVER + ';Password=' + MS_SQLPwd;
    
88.   OracleParaList.Add(MyIniFile.ReadString('Oracle', 'Server', ''));
    
89.   OracleParaList.Add(MyIniFile.ReadString('Oracle', 'User', ''));
    
90.   Pwd := MyIniFile.ReadString('Oracle', 'Password', '');
    
91.   OracleParaList.Add(_Crypt(Pwd, 65535, false)); //解密密码
    
92.   ADOConn.ConnectionString := DBConStr;
    
93.   ADOConn.Connected := True;
    
94.   ImportThread := TImport.Create(false, ADOConn, OracleParaList);
    
95.   Started := True;
    
96. end;
    
97. 
    
98. procedure TImportDataSVC.ServiceStop(Sender: TService; var Stopped: Boolean);
    
99. begin
    
100.   Stopped := True;
     
101. end;
     
102. 
     
103. end.

複製代碼

此處為執行緒程式

1. unit Unit_Import;
   
2. interface
   
3. uses
   
4.   inifiles, Classes, Sysutils, DB, ADODB, Forms;
   
5. type
   
6.   TImport = class(TThread)
   
7.   private
   
8.     FADOConn: TADOConnection;
   
9.     FAdoStoredProc: TADOStoredProc;
   
10.     { Private declarations }
    
11.   protected
    
12.     procedure Execute; override;
    
13.   public
    
14.     constructor Create(Suspended:Boolean; ADOConn:TADOConnection; OracleParaList:TStringList);
    
15.   end;
    
16.   
    
17. implementation
    
18. { Import }
    
19. 
    
20. constructor TImport.Create(Suspended:Boolean; ADOConn:TADOConnection; OracleParaList:TStringList);
    
21. begin
    
22.   inherited Create(Suspended);
    
23.   FADOConn := ADOConn;
    
24.   FAdoStoredProc := TAdoStoredProc.Create(nil);
    
25.   FAdoStoredProc.Connection := FADOConn;
    
26.   FreeOnTerminate := False;
    
27. end;
    
28. 
    
29. procedure TImport.Execute;
    
30. var
    
31.   Hour, Min, Sec, MSec: Word;
    
32.   TimeStamp: String;
    
33.   MyIniFile: TIniFile;
    
34. begin
    
35.   { Place thread code here }
    
36.   {每次資料匯入執行時間}
    
37.   FreeOnTerminate := false;
    
38.   MyIniFile := TIniFile.Create(ExtractFilePath(Application.ExeName) + 'Options.ini');
    
39.   TimeStamp := MyIniFile.ReadString('Option', 'ImportTime', '00:00:00');
    
40.   while not Terminated do
    
41.   begin
    
42.     DecodeTime(Time, Hour, Min, Sec, MSec);
    
43.     if Trim(TimeStamp) = Format('%-2.2d:%-2.2d', [Hour, Min]) then //如果到匯入數據時間
    
44.     begin
    
45.       {匯入資料的程式部分}
    
46.       Sleep(60000);
    
47.     end;
    
48.   end;
    
49.   MyIniFile.free;
    
50. end;
    
51. 
    
52. end.

複製代碼