程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 更多編程語言 >> Delphi >> [DIOCP3/MyBean/QDAC開源項目] DataModule-DB例子基於MyBean的插件實例<三層數據庫方案>,qdacdatamodule-db

[DIOCP3/MyBean/QDAC開源項目] DataModule-DB例子基於MyBean的插件實例<三層數據庫方案>,qdacdatamodule-db

編輯:Delphi

[DIOCP3/MyBean/QDAC開源項目] DataModule-DB例子基於MyBean的插件實例<三層數據庫方案>,qdacdatamodule-db


【說明】

這個例子答應大家很久了,一直沒有時間弄,現在正式結合MyBean插件可以很方便的在客戶端共享操作連接,執行數據庫的各項工作,屏蔽了底層的通信解碼器編碼等工作,直接傳遞Variant,給了開發者足夠的領活和自由。

 

【服務端使用技術】

diocp3:擔當底層的通信任務。

qworker/iocpTask:擔當業務邏輯的處理工作,diocp3接受數據解碼後用qworker/iocpTask將數據包投遞出來,這樣不用占用通信線程。

qmsgpack:負責將傳遞的將variant數據打包到流,從流中解碼成variant

dataModule:對應連接的對象,方便進行開發。

 

【客戶端】

myBean:制作基於MyBean框架的插件,可以在MyBean的框架模塊中直接使用。

RawTcpClient:用於和服務端進行通信,阻塞的tcp客戶端,類似IdTcpClient的精簡版本,操作容易。

 

【DEMO使用】

說 明:客戶端依賴diocp_bean.dll插件與服務器進行數據交換,DIOCP_DBDEMO.dll是演示窗體插件的宿主。

存放路徑:MyBean\samples\diocp-DBDEMO

啟動服務:SERVER_EXE\diocp3Server.exe  <點擊start按鈕啟動服務>

function TdmMain.Execute(pvCmdIndex: Integer; var vData: OleVariant): Boolean; begin case pvCmdIndex of 0: begin // 返回服務端時間給客戶端 vData := Now(); Result := true; end; 1: // 查詢數據 begin // vData 認為是傳入的SQL語句 // 執行後, vData為查詢的數據,可以用於對ClientData.Data的賦值 qryMain.Close; qryMain.SQL.Clear; qryMain.SQL.Add(vData); qryMain.Open; vData := dspMain.Data; Result := true; qryMain.Close; end; 2: begin // vData 為執行的語句 conMain.BeginTrans; try qryMain.Close; qryMain.SQL.Clear; qryMain.SQL.Add(vData); qryMain.ExecSQL; conMain.CommitTrans; VarClear(vData); Result := true; except conMain.RollbackTrans; raise; end; end; end; end;

   vData,是客戶端傳遞過來的參數,也是返回給客戶端的數據。vData是OleVariant可以容納任何的數據<配合qmsgPack可以達到任何的數據格式要求>, 如果還達不到你的格式要求,你可以在MyClientContext的dataReceived函數做些修改,下面代碼的處理過程依次是:

解壓收到的數據->QmsgPack解包->取出客戶端傳入的參數->調用dmMain.Execute處理邏輯->qmsgPack編碼數據->壓縮數據->回傳數據到客戶端

procedure TMyClientContext.dataReceived(const pvDataObject: TObject);
var
  lvMsgPack:TQMsgPack;
  lvStream :TStream;
  lvStream2:TMemoryStream;
  vData:OleVariant;
  lvResult:Boolean;
begin
  lvMsgPack := TQMsgPack.Create;
  try
    try
      if FdmMain = nil then FdmMain := TdmMain.Create(nil);

      lvStream := TStream(pvDataObject);
      lvStream.Position := 0;

      // upZip
      TZipTools.unCompressStreamEX(lvStream);

      lvStream.Position := 0;
      
      // unpack
      lvMsgPack.LoadFromStream(lvStream);

      // get param
      vData := lvMsgPack.ForcePath('cmd.data').AsVariant;

      // invoke dataModule function
      lvResult := FdmMain.Execute(lvMsgPack.ForcePath('cmd.index').AsInteger, vData);

      // write result info
      lvMsgPack.Clear;
      lvMsgPack.ForcePath('__result.result').AsBoolean := lvResult;
      lvMsgPack.ForcePath('__result.data').AsVariant := vData;
    except
      on E:Exception do
      begin
        lvMsgPack.Clear;
        lvMsgPack.ForcePath('__result.result').AsBoolean := false;
        lvMsgPack.ForcePath('__result.msg').AsString := e.Message;
      end;
    end;

    lvStream.Size := 0;
    lvMsgPack.SaveToStream(lvStream);

    lvStream.Position := 0;

    // zipStream
    TZipTools.compressStreamEX(lvStream);
    lvStream.Position := 0;

    // send to client
    self.writeObject(lvStream);
  finally
    lvMsgPack.Free;
  end;

end;

 

客戶端處理:

   編譯的 DLL 放到和EXE同一個目錄下面就可以進行自動加載。

   客戶端diocp_bean工程中

library diocp_bean;

uses
  SysUtils,
  Classes,
  mybean.core.beanFactoryForNoVcl,
  uRemoteServerDIOCPImpl in 'Service\uRemoteServerDIOCPImpl.pas';

{$R *.res}

begin
  beanFactory.RegisterBean('diocpRemoteSvr', TRemoteServerDIOCPImpl).Singleton := true;
end.

注冊的diocpRemoteSvr插件實現了IRemoteServer接口和IRemoteServerConnector接口,而且該插件為單件模式。其他任何地方調用都只會產生一個連接實例。

type
  IRemoteServer = interface(IInterface)
    ['{20B5F070-461C-41F4-AA0C-E500A36E18E4}']

    /// <summary>
    ///   執行遠程動作
    /// </summary>
    function Execute(pvCmdIndex: Integer; var vData: OleVariant): Boolean; stdcall;
  end;

  IRemoteServerConnector = interface(IInterface)
    ['{65931F56-07BA-42F8-BD5C-7409053F5B2C}']
    procedure setHost(pvHost: PAnsiChar);
    procedure setPort(pvPort:Integer);
    procedure open;
  end;

 

 

演示操作窗體:<服務端是13K的成語記錄>

constructor TfrmMain.Create(AOwner: TComponent); begin inherited; // 通過注冊的插件ID獲取單實例的遠程連接操作接口 FRemoteSvr := TMyBeanFactoryTools.getBean('diocpRemoteSvr') as IRemoteServer; end; procedure TfrmMain.btnConnectClick(Sender: TObject); begin // 打開遠程連接,如果打開過可以不用打開,其他插件中可以直接使用 (FRemoteSvr as IRemoteServerConnector).setHost(PAnsiChar(AnsiString(edtHost.Text))); (FRemoteSvr as IRemoteServerConnector).setPort(StrToInt(edtPort.Text)); (FRemoteSvr as IRemoteServerConnector).open; ShowMessage('open succ!'); end; procedure TfrmMain.btnOpenClick(Sender: TObject); var vData:OleVariant; l : Cardinal; begin vData := mmoSQL.Lines.Text; l := GetTickCount; // 在遠程打開SQL if FRemoteSvr.Execute(1, vData) then begin self.cdsMain.Data := vData; Self.Caption := Format('query: count:%d, time:%d', [self.cdsMain.RecordCount, GetTickCount - l]); end; end;

 

PS: 其他功能大家自己去實現,該文章寫了好幾個中午,希望對大家有用。

由於qdac開源項目 >=D2007,所以D7下面不能編譯服務端,和diocp_bean.項目(你可以在D2007中編譯好diocp_bean和服務端工程,其他插件可以在d7中完成)

 

-----------------------------------------------------------------------------------------------------

MyBean 輕量級配置開源框架 開源地址

https://git.oschina.net/ymofen/delphi-framework-MyBean

DIOCP3開源地址

https://github.com/ymofen/diocp3

 

qdac項目信息

官方網站:http://www.qdac.cc

官方QQ群:250530692

QDAC項目網址:http://sourceforge.net/p/qdac3

在線源碼浏覽:http://sourceforge.net/p/qdac3/code/HEAD/tree/

SVN檢出地址:

http://svn.code.sf.net/p/qdac3/code/
svn://svn.code.sf.net/p/qdac3/code/




  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved