unit uServerMain;
interface
uses
  Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
  ScktComp, ToolWin, ComCtrls, ExtCtrls, StdCtrls, Buttons, OleCtrls,
  DBCOMLib_TLB;
const
    CMax=10;  //客戶端最大連接數
type
  client_record=record
     CHandle: integer;          //客戶端套接字句柄
     CSocket:TCustomWinSocket;    //客戶端套接字
     CName:string;                //客戶端計算機名稱
     CAddress:string;             //客戶端計算機IP地址
     CUsed: boolean;               //客戶端聯機標志
  end;
type
  TfrmServerMain = class(TForm)
    ServerSocket: TServerSocket;
    ControlBar1: TControlBar;
    ToolBar1: TToolBar;
    tbConnect: TToolButton;
    tbClose: TToolButton;
    tbDisconnected: TToolButton;
    Edit1: TEdit;
    Memo1: TMemo;
    StatusBar: TStatusBar;
    ListView1: TListView;
    Dbcom1: TDbcom;
    procedure tbConnectClick(Sender: TObject);
    procedure tbDisconnectedClick(Sender: TObject);
    procedure ServerSocketClientRead(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ServerSocketListen(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ServerSocketClientConnect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ServerSocketClientDisconnect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure tbCloseClick(Sender: TObject);
    procedure FormCreate(Sender: TObject);
    procedure FormClose(Sender: TObject; var Action: TCloseAction);
    procedure ServerSocketGetSocket(Sender: TObject; Socket: Integer;
      var ClientSocket: TServerClientWinSocket);
    procedure ServerSocketClientError(Sender: TObject;
      Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
      var ErrorCode: Integer);
    procedure Timer1Timer(Sender: TObject);
  private
    { Private declarations }
  public
    { Public declarations }
    session: array[0..CMax] of client_record;      //客戶端連接數組
    Sessions: integer;                             //客戶端連接數
  end;
var
  frmServerMain: TfrmServerMain;
implementation
{$R *.DFM}
//打開套接字連接，并使套接字進入監聽狀態
procedure TfrmServerMain.tbConnectClick(Sender: TObject);
begin
    ServerSocket.Open ;
    //Memo1.Lines.Add('服務器數據中心已經啟動端口1025'+Socket.RemoteAddress);
end;
//關閉套接字連接，不再監聽客戶端的請求
procedure TfrmServerMain.tbDisconnectedClick(Sender: TObject);
begin
    ServerSocket.Close;
    StatusBar.Panels[0].Text :=timetostr(now)+'服務器套接字連接已經關閉，無法接受客戶端的連接請求.';
end;
//從客戶端讀取信息
procedure TfrmServerMain.ServerSocketClientRead(Sender: TObject;
  Socket: TCustomWinSocket);
var
    i:integer;
    tempitem:tlistitem;
    content:string;

        count:Integer;
     result:Integer;
    pvTagPars: olevariant;
     pVdata:olevariant;

begin
    //將從客戶端讀取的信息添加到listitem中
    //Memo1.Lines.Add(Socket.ReceiveText);
    content:=Socket.ReceiveText;
    tempitem:=listview1.items.add;
  tempitem.caption:=timetostr(now);
  tempitem.subitems.add(content);
  tempitem.subitems.add(inttostr(length(content))+'bytes');

      count:=1;
    pvTagPars:='a1.PV';
    //數據名

    pVdata:=content;//數據值
     //調用DBcom的方法
    result:=DbCom1.SetStringData(count, pvTagPars, pVdata);



    for i:=0 to sessions do
    begin
        //取得匹配的客戶端
        if session[i].CHandle = Socket.SocketHandle then
        begin
session[i].CSocket.SendText('回復客戶端'+session[i].CAddress+' ==> '+Edit1.Text);
       end;
    end;
end;
//服務器端套接字進入監聽狀態，以便監聽客戶端的連接
procedure TfrmServerMain.ServerSocketListen(Sender: TObject;
  Socket: TCustomWinSocket);
begin
    StatusBar.Panels[0].Text :=timetostr(now)+'等待客戶端連接...';
    Memo1.Lines.Add('服務器數據中心已經啟動端口1025');
end;
//當客戶端連接到服務器端以后;
procedure TfrmServerMain.ServerSocketClientConnect(Sender: TObject;
  Socket: TCustomWinSocket);
var
    i,j:integer;
begin
    j:=-1;
    for i:=0 to sessions do
    begin
        //在原有的客戶端連接數組中有中斷的客戶端連接
        if not session[i].CUsed then
        begin
            session[i].CHandle := Socket.SocketHandle ;//客戶端套接字句柄
            session[i].CSocket := Socket;                //客戶端套接字
            session[i].CName := Socket.RemoteHost ;      //客戶端計算機名稱
            session[i].CAddress := Socket.RemoteAddress ;//客戶端計算機IP
            session[i].CUsed := True;                     //連接數組當前位置已經占用
            Break;
        end;
        j:=i;
    end;
    if j=sessions then
    begin
        inc(sessions);
        session[j].CHandle := Socket.SocketHandle ;
        session[j].CSocket := Socket;
        session[j].CName := Socket.RemoteHost ;
        session[j].CAddress := Socket.RemoteAddress ;
        session[j].CUsed := True;
    end;
    StatusBar.Panels[0].Text := timetostr(now)+'客戶端 '+Socket.RemoteHost + ' 已經連接';
      //Memo1.Lines.Add('服務器數據中心已經啟動端口1025'+'---'+Socket.RemoteAddress);
end;
//當客戶端斷開連接時
procedure TfrmServerMain.ServerSocketClientDisconnect(Sender: TObject;
  Socket: TCustomWinSocket);
var
    i:integer;
begin
    for i:=0 to sessions do
    begin
        if session[i].CHandle =Socket.SocketHandle then
        begin
            session[i].CHandle :=0;
            session[i].CUsed := False;
            Break;
        end;
    end;
    StatusBar.Panels[0].Text :=timetostr(now)+'客戶端 '+Socket.RemoteHost + ' 已經斷開';
end;
//關閉窗口
procedure TfrmServerMain.tbCloseClick(Sender: TObject);
begin
    Close;
end;
procedure TfrmServerMain.FormCreate(Sender: TObject);
begin
    sessions := 0;
end;
procedure TfrmServerMain.FormClose(Sender: TObject;
  var Action: TCloseAction);
begin
    ServerSocket.Close ;
end;
//當客戶端正在與服務器端連接時
procedure TfrmServerMain.ServerSocketGetSocket(Sender: TObject;
  Socket: Integer; var ClientSocket: TServerClientWinSocket);
begin
    StatusBar.Panels[0].Text :='客戶端正在連接...';
end;
//客戶端發生錯誤
procedure TfrmServerMain.ServerSocketClientError(Sender: TObject;
  Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
  var ErrorCode: Integer);
begin
    StatusBar.Panels[0].Text :=timetostr(now)+'客戶端'+Socket.RemoteHost +'發生錯誤！';
    ErrorCode := 0;
end;


end.