共1 條記錄, 每頁顯示 10 條, 頁簽: [1]

標(biāo)題：用Delphi設(shè)計代理服務(wù)器設(shè)計sessioni-1endbeginprocedureTObjectSender:

1樓

wangxinxin 發(fā)表于：2010-12-14 11:24:40

用Delphi設(shè)計自己的代理服務(wù)器
 
 　筆者在編寫一個上網(wǎng)計費軟件時，涉及到如何對局域網(wǎng)中各工作站上網(wǎng)計費問題。一般來講，這些工作站通過代理服務(wù)器上網(wǎng)，而采用現(xiàn)成的代理服務(wù)器軟件時，由于代理服務(wù)器軟件是封閉的系統(tǒng)，很難編寫程序獲取實時的上網(wǎng)計時信息。因此，考慮是否能編寫自己的代理服務(wù)器，一方面解決群體上網(wǎng)，另一方面又解決上網(wǎng)的計費問題呢？
 　經(jīng)過實驗性編程，終于圓滿地解決了該問題�，F(xiàn)寫出來，與各位同行分享。
 
 1、思路
 當(dāng)前流行的瀏覽器的系統(tǒng)選項中有一個參數(shù)，即“通過代理服務(wù)器連接”，經(jīng)過編程測
 試，當(dāng)局域網(wǎng)中一臺工作站指定了該屬性，再發(fā)出Internet請求時，請求數(shù)據(jù)將發(fā)送到所指定的代理服務(wù)器上，以下為請求數(shù)據(jù)包示例：
 　　　　　　　　GEThttp://home.microsoft.com/intl/cn/HTTP/1.0
 　　　　　　　　Accept:*/*
 　　　　　　　　Accept-Language:zh-cn
 　　　　　　　　Accept-Encoding:gzip,deflate
 　　　　　　　　User-Agent:Mozilla/4.0(compatible;MSIE5.0;WindowsNT)
 　　　　　　　　Host:home.microsoft.com
 　　　　　　　　Proxy-Connection:Keep-Alive
 其中第一行為目標(biāo)URL及相關(guān)方法、協(xié)議，“Host”行指定了目標(biāo)主機(jī)的地址。
 由此知道了代理服務(wù)的過程：接收被代理端的請求、連接真正的主機(jī)、接收主機(jī)返回的數(shù)據(jù)、將接收數(shù)據(jù)發(fā)送到被代理端。
 為此可編寫一個簡單的程序，完成上述網(wǎng)絡(luò)通信重定向問題。
 用Delphi設(shè)計時，選用ServerSocket作為與被代理工作站通信的套接字控件，選用ClientSocket動態(tài)數(shù)組作為與遠(yuǎn)程主機(jī)通信的套接字控件。
 編程時應(yīng)解決的一個重要問題是多重連接處理問題，為了加快代理服務(wù)的速度和被代理端的響應(yīng)速度，套接字控件的屬性應(yīng)設(shè)為非阻塞型；各通信會話與套接字動態(tài)綁定，用套接字的SocketHandle屬性值確定屬于哪一個會話。
 通信的銜接過程如下圖所示：
 
 　　　　　　　　　　　　　　　　代理服務(wù)器
 　　　　　　　　　　　　　　　　
 　　　　　　　　　　　　　　　　Serversocket
 　　　　　　　　　　　(1)　　　　　接　收
 　　　　被代理端　　　　　　　　　發(fā)　送　　　　　　　　　　　　遠(yuǎn)程主機(jī)
 　　　　　　　　　　　(6)　　　　(2)　　　(5)
 　　　　Browser　　　　　　　　　ClientSocket　　　(4)　　　　　　WebServer
 　　　　　　　　　　　　　　　　　接　收
 　　　　　　　　　　　　　　　　　發(fā)　送　　　　　(3)
 
 
 （1）、被代理端瀏覽器發(fā)出Web請求，代理服務(wù)器的Serversocket接收到請求。
 （2）、代理服務(wù)器程序自動創(chuàng)建一個ClientSocket，并設(shè)置主機(jī)地址、端口等屬性，然后連接遠(yuǎn)程主機(jī)。
 （3）、遠(yuǎn)程連通后激發(fā)發(fā)送事件，將Serversocket接收到的Web請求數(shù)據(jù)包發(fā)送到遠(yuǎn)程主機(jī)。
 （4）、當(dāng)遠(yuǎn)程主機(jī)返回頁面數(shù)據(jù)時，激發(fā)ClientSocket的讀事件，讀取頁面數(shù)據(jù)。
 （5）、代理服務(wù)器程序根據(jù)綁定信息確定屬于ServerSocket控件中的哪一個Socket應(yīng)該將從主機(jī)接收的頁面信息發(fā)送到被代理端。
 （6）、ServerSocket中的對應(yīng)Socket將頁面數(shù)據(jù)發(fā)送到被代理端。
 
 2、程序編寫
 使用Delphi設(shè)計以上通信過程非常簡單，主要是ServerSocket、ClientSocket的相關(guān)事
 件驅(qū)動程序的程序編寫。下面給出作者編寫的實驗用代理服務(wù)器界面與源程序清單，內(nèi)含簡要功能說明：
 
 unitmain;
 
 interface
 
 uses
 Windows,Messages,SysUtils,Classes,Graphics,Controls,Forms,Dialogs,
 ExtCtrls,ScktComp,TrayIcon,Menus,StdCtrls;
 
 type
 　session_record=record
 　　Used:boolean;　　　　　　　　　　　
 　　SS_Handle:integer;　　　　　　　　　
 　　CSocket:TClientSocket;　　　　　　　
 　　Lookingup:boolean;　　　　　　　　　
 　　LookupTime:integer;　　　　　　　　
 　　Request:boolean;　　　　　　　　　　
 　　request_str:string;　　　　　　　　
 　　client_connected:boolean;　　　　　
 　　remote_connected:boolean;　　　　　
 end;
 
 type
 TForm1=class(TForm)
 　ServerSocket1:TServerSocket;
 　ClientSocket1:TClientSocket;
 　Timer2:TTimer;
 　TrayIcon1:TTrayIcon;
 　PopupMenu1:TPopupMenu;
 　N11:TMenuItem;
 　N21:TMenuItem;
 　N1:TMenuItem;
 　N01:TMenuItem;
 　Memo1:TMemo;
 　Edit1:TEdit;
 　Label1:TLabel;
 　Timer1:TTimer;
 　procedureTimer2Timer(Sender:TObject);
 　procedureN11Click(Sender:TObject);
 　procedureFormCreate(Sender:TObject);
 　procedureFormClose(Sender:TObject;varAction:TCloseAction);
 　procedureN21Click(Sender:TObject);
 　procedureN01Click(Sender:TObject);
 　procedureServerSocket1ClientConnect(Sender:TObject;
 　　Socket:TCustomWinSocket);
 　procedureServerSocket1ClientDisconnect(Sender:TObject;
 　　Socket:TCustomWinSocket);
 　procedureServerSocket1ClientError(Sender:TObject;
 　　Socket:TCustomWinSocket;ErrorEvent:TErrorEvent;
 　　varErrorCode:Integer);
 　procedureServerSocket1ClientRead(Sender:TObject;
 　　Socket:TCustomWinSocket);
 　procedureClientSocket1Connect(Sender:TObject;
 　　Socket:TCustomWinSocket);
 　procedureClientSocket1Disconnect(Sender:TObject;
 　　Socket:TCustomWinSocket);
 　procedureClientSocket1Error(Sender:TObject;Socket:TCustomWinSocket;
 　　ErrorEvent:TErrorEvent;varErrorCode:Integer);
 　procedureClientSocket1Write(Sender:TObject;
 　　Socket:TCustomWinSocket);
 　procedureClientSocket1Read(Sender:TObject;Socket:TCustomWinSocket);
 　procedureServerSocket1Listen(Sender:TObject;
 　　Socket:TCustomWinSocket);
 　procedureAppException(Sender:TObject;E:Exception);
 　procedureTimer1Timer(Sender:TObject);
 **
 　{**declarations}
 public
 　Service_Enabled:boolean;　　　　　
 　session:arrayofsession_record;　　　
 　sessions:integer;　　　　　　　　　
 　LookUpTimeOut:integer;　　　　　
 　InvalidRequests:integer;　　　　　　
 end;
 
 var
 Form1:TForm1;
 
 implementation
 
 {$R*.DFM}
 
 file://系統(tǒng)啟動定時器，啟動窗顯示完成后，縮小到SystemTray…
 procedureTForm1.Timer2Timer(Sender:TObject);
 begin
 　timer2.Enabled:=false;　　
 　sessions:=0;　　　　　　　
 　Application.OnException:=AppException;　　
 　invalidRequests:=0;　　　　　
 　LookUpTimeOut:=60000;　　　
 　timer1.Enabled:=true;　　　　
 　n11.Enabled:=false;　　　　　
 　n21.Enabled:=true;　　　　　
 　serversocket1.Port:=988;　　　
 　serversocket1.Active:=true;　　
 　form1.hide;　　　　　　　　{隱藏界面，縮小到SystemTray上}
 end;
 
 file://開啟服務(wù)菜單項…
 procedureTForm1.N11Click(Sender:TObject);
 begin
 　serversocket1.Active:=true;　　
 end;
 
 
 file://停止服務(wù)菜單項…
 procedureTForm1.N21Click(Sender:TObject);
 begin
 　serversocket1.Active:=false;　　　
 　N11.Enabled:=True;
 　N21.Enabled:=False;
 　Service_Enabled:=false;　　　　　
 end;
 
 
 file://主窗口建立…
 procedureTForm1.FormCreate(Sender:TObject);
 begin
 　Service_Enabled:=false;
 　timer2.Enabled:=true;　　　　
 end;
 
 file://窗口關(guān)閉時…
 procedureTForm1.FormClose(Sender:TObject;varAction:TCloseAction);
 begin
 　timer1.Enabled:=false;　　　　　
 　ifService_Enabledthen
 　　serversocket1.Active:=false;　
 end;
 
 file://退出程序按鈕…
 procedureTForm1.N01Click(Sender:TObject);
 begin
 　form1.Close;　　　　　　　　　　
 end;
 
 file://開啟代理服務(wù)后…
 procedureTForm1.ServerSocket1Listen(Sender:TObject;
 Socket:TCustomWinSocket);
 begin
 　Service_Enabled:=true;　　　　　　
 　N11.Enabled:=false;
 　N21.Enabled:=true;
 end;
 
 file://被代理端連接到代理服務(wù)器后，建立一個會話，并與套接字綁定…
 procedureTForm1.ServerSocket1ClientConnect(Sender:TObject;
 Socket:TCustomWinSocket);
 var
 i,j:integer;
 begin
 　j:=-1;
 　fori:=1tosessionsdo　　　　　　　
 　　ifnotsession[i-1].Usedandnotsession[i-1].CSocket.activethen
 　　　　begin
 　　　　　j:=i-1;　　　　　　　　　　　
 　　　　　session[j].Used:=true;　　　
 　　　　　break;
 　　　　end
 　　else
 　　　　ifnotsession[i-1].Usedandsession[i-1].CSocket.activethen
 　　　　　　　session[i-1].CSocket.active:=false;
 　ifj=-1then
 　　begin　　　　　　　　　　　　　　　
 　　　　j:=sessions;
 　　　　inc(sessions);
 　　　　setlength(session,sessions);
 　　　　session[j].Used:=true;　　　　　　　　　　　　
 　　　　session[j].CSocket:=TClientSocket.Create(nil);
 　　　　session[j].CSocket.OnConnect:=ClientSocket1Connect;
 　　　　session[j].CSocket.OnDisconnect:=ClientSocket1Disconnect;
 　　　　session[j].CSocket.OnError:=ClientSocket1Error;
 　　　　session[j].CSocket.OnRead:=ClientSocket1Read;
 　　　　session[j].CSocket.OnWrite:=ClientSocket1Write;
 　　　　session[j].Lookingup:=false;
 　　end;
 　session[j].SS_Handle:=socket.socketHandle;　　
 　session[j].Request:=false;　　　　　　　　　　
 　session[j].client_connected:=true;　　　　　　
 　session[j].remote_connected:=false;　　　　　
 　edit1.text:=inttostr(sessions);
 end;
 
 file://被代理端斷開時…
 procedureTForm1.ServerSocket1ClientDisconnect(Sender:TObject;
 Socket:TCustomWinSocket);
 var
 i,j,k:integer;
 begin
 　fori:=1tosessionsdo
 　　if(session[i-1].SS_Handle=socket.SocketHandle)andsession[i-1].Usedthen
 　　　　begin
 　　　　　session[i-1].client_connected:=false;　
 　　　　　ifsession[i-1].remote_connectedthen
 　　　　　　　session[i-1].CSocket.active:=false　
 　　　　　else
 　　　　　　　session[i-1].Used:=false;　　　　　
 　　　　　break;
 　　　　end;
 　j:=sessions;
 　k:=0;
 　fori:=1tojdo　　　　　　　　　　　　
 　　begin
 　　　　ifsession[j-i].Usedthen
 　　　　　break;
 　　　　inc(k);
 　　end;
 　ifk%26gt;0then　　　　　　　　　　　　　
 　　begin
 　　　　sessions:=sessions-k;
 　　　　setlength(session,sessions);
 　　end;
 　edit1.text:=inttostr(sessions);
 end;
 
 file://通信錯誤出現(xiàn)時…
 procedureTForm1.ServerSocket1ClientError(Sender:TObject;
 Socket:TCustomWinSocket;ErrorEvent:TErrorEvent;
 varErrorCode:Integer);
 var
 i,j,k:integer;
 begin
 　fori:=1tosessionsdo
 　　if(session[i-1].SS_Handle=socket.SocketHandle)andsession[i-1].Usedthen
 　　　　begin
 　　　　　session[i-1].client_connected:=false;　
 　　　　　ifsession[i-1].remote_connectedthen
 　　　　　　　session[i-1].CSocket.active:=false　
 　　　　　else
 　　　　　　　session[i-1].Used:=false;　　　　　
 　　　　　break;
 　　　　end;
 　j:=sessions;
 　k:=0;
 　fori:=1tojdo
 　　begin
 　　　　ifsession[j-i].Usedthen
 　　　　　break;
 　　　　inc(k);
 　　end;
 　ifk%26gt;0then
 　　begin
 　　　　sessions:=sessions-k;
 　　　　setlength(session,sessions);
 　　end;
 　edit1.text:=inttostr(sessions);
 　errorcode:=0;
 end;
 
 file://被代理端發(fā)送來頁面請求時…
 procedureTForm1.ServerSocket1ClientRead(Sender:TObject;
 Socket:TCustomWinSocket);
 var
 tmp,line,host:string;
 i,j,port:integer;
 begin
 　fori:=1tosessionsdo　　　　　　　　
 　　ifsession[i-1].Usedand(session[i-1].SS_Handle=socket.sockethandle)then
 　　　　begin
 　　　　　　session[i-1].request_str:=socket.ReceiveText;　
 　　　　　　tmp:=session[i-1].request_str;　　　　　　　　
 　　　　　　memo1.lines.add(tmp);
 　　　　　　j:=pos(char(13)+char(10),tmp);　　　　　　　　
 　　　　　　whilej%26gt;0do　　　　　　　　　　　
 　　　　　　　begin
 　　　　　　　　　line:=copy(tmp,1,j-1);　　　　　　　　　
 　　　　　　　　　delete(tmp,1,j+1);　　　　　　　　　　　
 　　　　　　　　　j:=pos('Host',line);　　　　　　　　　　
 　　　　　　　　　ifj%26gt;0then
 　　　　　　　　　　begin
 　　　　　　　　　　　　delete(line,1,j+5);　　　　　　　
 　　　　　　　　　　　　j:=pos(':',line);
 　　　　　　　　　　　　ifj%26gt;0then
 　　　　　　　　　　　　　begin
 　　　　　　　　　　　　　　　host:=copy(line,1,j-1);
 　　　　　　　　　　　　　　　delete(line,1,j);
 　　　　　　　　　　　　　　　try
 　　　　　　　　　　　　　　　　port:=strtoint(line);
 　　　　　　　　　　　　　　　except
 　　　　　　　　　　　　　　　　port:=80;
 　　　　　　　　　　　　　　　end;
 　　　　　　　　　　　　　end
 　　　　　　　　　　　　else
 　　　　　　　　　　　　　begin
 　　　　　　　　　　　　　　　host:=trim(line);　　　　　　　　
 　　　　　　　　　　　　　　　port:=80;
 　　　　　　　　　　　　　end;
 　　　　　　　　　　　　ifnotsession[i-1].remote_connectedthen　
 　　　　　　　　　　　　　begin
 　　　　　　　　　　　　　　　session[i-1].Request:=true;

共1 條記錄, 每頁顯示 10 條, 頁簽: [1]