用VC 6.0撰寫Proxy代理伺服器 2000-08-31 14:13:15 作者:葉敏 資料來源:<< 軟體世界 >> 常用的代理服務器軟件有proxy severs 2.0以及WinGate等等。利用VC 6.0強大功能也可以編寫出自己的代理伺服器應用軟體。本文介紹了具體的可行方法。 一﹒ 原理 本程式的結構原理如下﹕ 對於每一個用戶的請求〔Internet 請求﹐由瀏覽器發出〕﹐本程式將啟動兩個Request Message﹐一個把本地用戶的請求數據傳送到遠端的Internet主機﹐另一個Request Message把遠端主機的回應數據傳送到本地請求用戶。 二﹒ 主要函數 UserToProxyThread ( void * pParam ) ﹕它是用來把本地用戶請求數據發送到遠端主機的﹐起動Proxy Sever狀態。當接到本地〔區域網路〕用戶的請求﹐它就啟動另一個自身線程﹐以監聽別的用戶的請求﹐並讀出已接收到的請求數據﹐接著啟動第二個要求訊息ProxyToServer()〔這個Request Message用來連接遠程主機〕﹐當遠程主機連接成功後﹐它把已讀出的本地用戶請求數據發送到遠程主機。 ProxyToServer ( void * pParam) ﹐可以被當作是客戶端服務﹐它把遠端主機發送來的數據發送給本地用戶請求。 三﹒ 開發運行環境 本程式是在VC 6.0環境下開發的﹐在Win95 和 WinNT4.0下運行正常。 四﹒ 詳細代碼 #include "stdafx.h" #include "Proxy.h" #include < winsock2.h > //WINSOCKET API 2。0 #include < stdlib.h > #include < stdio.h > #include < string.h > #ifdef _DEBUG #define new DEBUG_NEW #undef THIS_FILE static char THIS_FILE[] = __FILE__; #endif //////////////////////////////////////////////////////////////// #define HTTP "http://" #define FTP "ftp://" #define PROXYPORT 5001 //Proxy Prot #define BUFSIZE 10240 //緩衝區大小 CWinApp theApp; using namespace std; UINT ProxyToServer(LPVOID pParam); UINT UserToProxyThread(void *pParam); struct SocketPair{ SOCKET user_proxy; //socket : 本地機器到PROXY 伺服器 SOCKET proxy_server; //socket : PROXY 服務機到遠端主機 BOOL IsUser_ProxyClosed; // 本地機器到PROXY Sever狀態 BOOL IsProxy_ServerClosed; // PROXY sever 到遠端主機狀態 }; struct ProxyParam{ char Address[256]; // 遠端主機地址 HANDLE User_SvrOK; // PROXY sever到遠端主機的聯結狀態 SocketPair *pPair; // 維護一組SOCKET的指標 int Port; // 用來聯結遠端主機的Port }; //這個結構用來PROXY SERVER與遠端主機的訊息交換. SOCKET gListen_Socket; //用來監聽的SOCKET。 int StartServer() //啟動服務 { WSADATA wsaData; sockaddr_in local; SOCKET listen_socket; if(::WSAStartup(0x202,&wsaData)!=0) {printf("\nError in Startup session.\n");WSACleanup();return -1;}; local.sin_family=AF_INET; local.sin_addr.s_addr=INADDR_ANY; local.sin_port=htons(PROXYPORT); listen_socket=socket(AF_INET,SOCK_STREAM,0); if(listen_socket==INVALID_SOCKET) {printf("\nError in New a Socket.");WSACleanup();return -2;} if(::bind(listen_socket,(sockaddr *)&local,sizeof(local))!=0) {printf("\n Error in Binding socket."); WSACleanup();return -3; }; if(::listen(listen_socket,5)!=0) {printf("\n Error in Listen."); WSACleanup(); return -4;} gListen_Socket=listen_socket; AfxBeginThread(UserToProxyThread,NULL); //啟動監聽 return 1; } int CloseServer() //關閉服務狀態 { closesocket(gListen_Socket); WSACleanup(); return 1; } //分析接收到的字串﹐得到遠端主機地址 int GetAddressAndPort( char * str, char *address, int * port) { char buf[BUFSIZE], command[512], proto[128], *p; int j; sscanf(str,"%s%s%s",command,buf,proto); p=strstr(buf,HTTP); //HTTP if(p) { p =strlen(HTTP); for(int i=0;i< strlen(p);i ) if( *(p i)==`/`) break; *(p i)=0; strcpy(address,p); p=strstr(str,HTTP); for(int j=0;j< i strlen(HTTP);j ) *(p j)=` `; //關閉遠程主機%C。 摘自《軟體世界》 葉敏/文