📄 vcc40.htm
字号:
<html>
<head>
<title>c++系列</title>
<meta content="text/html; charset=gb2312" http-equiv=Content-Type>
</head>
<p align="center"><script src="../../1.js"></script></a>
<body bgcolor="#ffffff" leftmargin="5" topmargin="1" marginheight="5" marginwidth="5">
<div align=center>
<table border=0 cellpadding=0 cellspacing=0 width=680 align="center">
<tbody>
<tr>
<td width=200 height="59">
</tr>
</tbody>
</table>
<table border=1 bordercolordark=#ffffff bordercolorlight=#ffffff cellpadding=0
cellspacing=0 width=685 align="center" height="70">
<tbody>
<tr>
<td bgcolor=#F9D23C height=14>
<div align=center class=H1> <b><font color="#FF0000"><b> <font color="#FFFFFF">用VC++6.0编写Proxy服务器</font></span></b>
</font><font
color=#ffa000><b></b></font></b></font></div>
</td>
</tr>
<tr valign=top>
<td class=H1 height=212>
<p align="left"><br>
<br>
我们一般常用的Internet代理服务器是用微软的Proxy Server 2.0 。但我们可以自己动手编写一个简单、小型的Proxy
Server 。下面介绍具体的实现方法。 <br>
<br>
一． 原理 <br>
<br>
本程序的结构原理如下： <br>
<br>
对于每一个用户的请求（Internet 请求，由浏览器发出），本程序将启动两个线程，一个把本地用户的请求数据发送到远程的Internet主机，另一个线程把远程主机的回应数据发送到本地请求用户。
<br>
<br>
二． 主要函数 <br>
<br>
UserToProxyThread ( void * pParam ) ：它是用来把本地用户请求数据发送到远程主机的，起服务器线程角色。当接到本地（局域网）用户的请求，它就启动另一个自身线程，以侦听别的用户的请求，并读出已接收到的请求数据，接着启动第二个线程ProxyToServer()（这个线程用来连接远程主机），当远程主机连接成功后，它把已读出的本地用户请求数据发送到远程主机。
<br>
<br>
ProxyToServer ( void * pParam) ，可以被当作是客户端服务，它把远程主机发送来的数据分发给本地请求用户。 <br>
三． 开发运行环境 <br>
<br>
本程序是在VC++6.0环境下开发的，在Win95 和 WinNT4.0下运行正常。 <br>
<br>
四． 详细代码<br>
#include "stdafx.h"<br>
#include "Proxy.h"<br>
#include < winsock2.h > //WINSOCKET API 2。0<br>
#include < stdlib.h ><br>
#include < stdio.h ><br>
#include < string.h ><br>
<br>
#ifdef _DEBUG<br>
#define new DEBUG_NEW<br>
#undef THIS_FILE<br>
static char THIS_FILE[] = __FILE__;<br>
#endif<br>
<br>
////////////////////////////////////////////////////////////////<br>
<br>
<br>
#define HTTP "http://"<br>
#define FTP "ftp://"<br>
#define PROXYPORT 5001 //Proxy 端口<br>
#define BUFSIZE 10240 //缓冲区大小<br>
<br>
<br>
CWinApp theApp;<br>
<br>
using namespace std;<br>
<br>
UINT ProxyToServer(LPVOID pParam);<br>
UINT UserToProxyThread(void *pParam);<br>
<br>
struct SocketPair{<br>
SOCKET user_proxy; //socket : 本地机器到PROXY 服务机<br>
SOCKET proxy_server; //socket : PROXY 服务机到远程主机<br>
BOOL IsUser_ProxyClosed; // 本地机器到PROXY 服务机状态<br>
BOOL IsProxy_ServerClosed; // PROXY 服务机到远程主机状态<br>
};<br>
<br>
<br>
struct ProxyParam{<br>
char Address[256]; // 远程主机地址<br>
HANDLE User_SvrOK; // PROXY 服务机到远程主机的联结状态<br>
SocketPair *pPair; // 维护一组SOCKET的指针<br>
int Port; // 用来联结远程主机的端口<br>
}; //这个结构用来PROXY SERVER与远程主机的信息交换.<br>
<br>
SOCKET gListen_Socket; //用来侦听的SOCKET。<br>
<br>
int StartServer() //启动服务<br>
{<br>
WSADATA wsaData;<br>
sockaddr_in local;<br>
SOCKET listen_socket;<br>
<br>
if(::WSAStartup(0x202,&wsaData)!=0)<br>
{printf("\nError in Startup session.\n");WSACleanup();return
-1;};<br>
<br>
local.sin_family=AF_INET;<br>
local.sin_addr.s_addr=INADDR_ANY;<br>
local.sin_port=htons(PROXYPORT);<br>
<br>
listen_socket=socket(AF_INET,SOCK_STREAM,0);<br>
if(listen_socket==INVALID_SOCKET)<br>
{printf("\nError in New a Socket.");WSACleanup();return -2;}<br>
<br>
if(::bind(listen_socket,(sockaddr *)&local,sizeof(local))!=0)<br>
{printf("\n Error in Binding socket."); WSACleanup();return
-3; };<br>
<br>
if(::listen(listen_socket,5)!=0)<br>
{printf("\n Error in Listen."); WSACleanup(); return -4;}<br>
gListen_Socket=listen_socket; <br>
AfxBeginThread(UserToProxyThread,NULL); //启动侦听<br>
return 1;<br>
}<br>
<br>
int CloseServer() //关闭服务<br>
{<br>
closesocket(gListen_Socket);<br>
WSACleanup();<br>
return 1;<br>
}<br>
<br>
//分析接收到的字符，得到远程主机地址<br>
int GetAddressAndPort( char * str, char *address, int * port)<br>
{<br>
char buf[BUFSIZE], command[512], proto[128], *p;<br>
int j;<br>
sscanf(str,"%s%s%s",command,buf,proto);<br>
p=strstr(buf,HTTP);<br>
//HTTP<br>
if(p)<br>
{<br>
p+=strlen(HTTP);<br>
for(int i=0;i< strlen(p);i++)<br>
if( *(p+i)==`/`) break;<br>
*(p+i)=0;<br>
strcpy(address,p);<br>
p=strstr(str,HTTP);<br>
for(int j=0;j< i+strlen(HTTP);j++)<br>
*(p+j)=` `; //去掉远程主机名: GET http://www.njust.edu.cn/ <br>
HTTP1.1 == > GET / HTTP1.1<br>
*port=80; //缺省的 http 端口 <br>
}<br>
else<br>
{//FTP, 不支持, 下面的代码可以省略.<br>
p=strstr(buf,FTP);<br>
if(!p) return 0;<br>
p+=strlen(FTP);<br>
for(int i=0;i< strlen(p);i++)<br>
if( *(p+i)==`/`) break; //Get The Remote Host<br>
*(p+i)=0;<br>
for(j=0;j< strlen(p);j++)<br>
if(*(p+j)==`:`) <br>
{*port=atoi(p+j+1); //Get The Port<br>
*(p+j)=0;<br>
}<br>
else *port=21; <br>
<br>
strcpy(address,p);<br>
p=strstr(str,FTP);<br>
for(j=0;j< i+strlen(FTP);j++)<br>
*(p+j)=` `; <br>
}<br>
return 1; <br>
}<br>
<br>
// 取到本地的数据，发往远程主机<br>
UINT UserToProxyThread(void *pParam)<br>
{<br>
char Buffer[BUFSIZE];<br>
int Len;<br>
sockaddr_in from;<br>
SOCKET msg_socket;<br>
int fromlen,retval;<br>
SocketPair SPair;<br>
ProxyParam ProxyP;<br>
CWinThread *pChildThread;<br>
fromlen=sizeof(from);<br>
msg_socket=accept(gListen_Socket,(struct sockaddr*)&from,&fromlen);<br>
AfxBeginThread(UserToProxyThread,pParam); //启动另一侦听.<br>
if( msg_socket==INVALID_SOCKET)<br>
{ printf( "\nError in accept "); return -5;}<br>
<br>
//读客户的第一行数据<br>
<br>
SPair.IsUser_ProxyClosed=FALSE;<br>
SPair.IsProxy_ServerClosed=TRUE;<br>
SPair.user_proxy=msg_socket;<br>
<br>
retval=recv(SPair.user_proxy,Buffer,sizeof(Buffer),0);<br>
<br>
if(retval==SOCKET_ERROR)<br>
{ printf("\nError Recv"); <br>
if(SPair.IsUser_ProxyClosed==FALSE)<br>
{closesocket(SPair.user_proxy);<br>
SPair.IsUser_ProxyClosed=TRUE;<br>
}<br>
}<br>
if(retval==0)<br>
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -