图01:代理服务的模型
二.Visual C#实现Web代理服务程序
Web代理服务是代理服务中最常用的一种代理服务,按照代理服务的层次,它属于应用层代理,是对TCP/IP参考模型中的应用层的HTTP协议的代理。
Web代理服务也是代理服务中的一种,所以它也要满足代理服务的基本条件。在下面介绍的代理服务程序中,是按照下列的顺序来实现其功能的。
(1). 代理服务器程序侦听端口,接收客户端浏览器发送来的Web请求信息。
(2). 代理服务器程序接收到客户端Web请求信息后,解析出Web服务器的地址,并创建一个Socket实例,并以此实例连接Web服务器上。
(3). 通过创建的Socket传送客户端的Web请求数据包到Web服务器的80端口。
(4). 代理服务器程序接收Web服务器返回页面数据。
(5). 代理服务器程序把接收来的数据传送到客户端,实现Web代理。
由于客户端的对一个地址的浏览,要传送很多的Web请求信息,为了更快、更准确的处理这些信息,Web代理服务程序采用了多线程来处理每一个Web请求。细心的读者可能会发现,处理每一个客户端的Web请求信息,代理服务器软件都要使用二个Socket,一个是用来接收/传送客户机的信息,一个是和Web服务器进行交流。为了区分这二个Socket,我们把他们都命名,和服务器对话的Socket,称为服务Socket;和客户端机器对话的Scoket,称为客户Socket。
下面就开始Web代理服务程序的编写工作。
这个示例主要包含三个部分内容:
创建一个Web代理类。
Web代理服务的类的实例化。
如何通过这个Web代理类的实例实现Web代理服务。
下面就是第一部分的具体的实现步骤。
(一).创建一个Web代理类
以下是具体的操作步骤如下:
1. 首先启动Visual Studio .Net,依次选择"文件"、"新建"、"项目"菜单后,在弹出"新建项目"对话框中将"项目类型"设置为"Visual C#项目",将"模板"设置为"Windows应用程序",在"名称"文本框中输入"WebProxy",在"位置"的文本框中输入"E:VS.NET项目",然后单击"确定"按钮。这样在"E:VS.NET项目"目录中就创建了一个新名称为"WebProxy"文件夹,里面存放的就是"WebProxy"的项目文件。
2. 选择菜单|,弹出对话框
3. 将设置
4. 在文本框中输入,单击按钮,具体如图02所示。
图02:Web代理项目中对话框
5. 在窗口中,双击Proxy.cs文件,进入Proxy.cs文件的编辑界面。
6. 在Proxy.cs源文件的开头,添加下列代码,下列代码是导入Proxy.cs中要使用到的命名空间:
using System ;using System.Net ;using System.Net.Sockets ;using System.Text ;using System.IO ;
7. 用下列构造函数替代默认的构造函数。下面的代码是在Proxy类中创建一个构造函数。 Proxy类只有一个构造函数,并且这个构造函数只有一个参数,这个参数是Socket对象,它主要用来和客户端进行数据交换,是一个客户Socket.。
public Proxy ( Socket socket ){ // // TODO: 在此处添加构造函数逻辑 // this.clientSocket = socket ;}
8. 创建Proxy类中的Run方法,Run方法是Proxy类中唯一的方法。其功能是从客户端接收HTTP请求,并传送到Web服务器,然后从Web服务器接收反馈来的数据,并传送到客户端。为了实现这二个不同方面的数据传送,Run方法中是通过二个Socket实例来实现的。在编写Run方法的时候,要注意下面几点:
(1). 由于HTTP是TCP/IP参考模型中的应用层协议,它建立于TCP协议之上,所以创建的Socket实例使用的协议类型应该为TCP协议。下面代码是创建可以传送HTTP请求命令到Web服务器和接收来自Web服务器反馈来信息的Socket实例:
Socket IPsocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream,ProtocolType.Tcp);
(2). 另外一个Socket是在代理服务程序侦听端口号,接收挂起的连接请求时候得到的,以此Socket为参数,利用Proxy类中的构造函数,来创建一个Proxy实例的。此Socket实现从客户端接收HTTP请求信息,并传送数据到客户端。
Socket创建和使用是实现Web代理软件的关键,具体实现方法是在构造函数代码后面,输入下列代码,创建Proxy类的Run方法:
public void Run ( ){ string clientmessage = " " ; //存放来自客户端的HTTP请求字符串 string URL = " " ; //存放解析出地址请求信息 int bytes = ReadMessage ( read , ref clientSocket , ref clientmessage ) ; if ( bytes == 0 ) { return ; } int index1 = clientmessage.IndexOf ( ' ' ) ; int index2 = clientmessage.IndexOf ( ' ' , index1 + 1 ) ; if ( ( index1 == -1 ) || ( index2 == -1 ) ) { throw new IOException ( ) ; } string part1 = clientmessage.Substring ( index1 + 1 , index2 - index1 ) ; int index3 = part1.IndexOf ( '/' , index1 + 8 ) ; int index4 = part1.IndexOf ( ' ' , index1 + 8 ) ; int index5 = index4 - index3 ; URL = part1.Substring ( index1 + 4 , ( part1.Length - index5 ) - 8 ) ; try { IPHostEntry IPHost = Dns.Resolve ( URL ) ; Console.WriteLine ( "远程主机名: " + IPHost.HostName ) ; string [] aliases = IPHost.Aliases ; IPAddress[] address = IPHost.AddressList ; Console.WriteLine ( "Web服务器IP地址:" + address[0] ) ; //解析出要访问的服务器地址 IPEndPoint ipEndpoint = new IPEndPoint ( address[0] , 80 ) ; Socket IPsocket = new Socket ( AddressFamily.InterNetwork , SocketType.Stream , ProtocolType.Tcp ) ; //创建连接Web服务器端的Socket对象 IPsocket.Connect ( ipEndpoint ) ; //Socket连Web接服务器 if ( IPsocket.Connected ) Console.WriteLine ( "Socket 正确连接!" ) ; string GET = clientmessage ; Byte[] ByteGet = ASCII.GetBytes ( GET ) ; IPsocket.Send ( ByteGet , ByteGet.Length , 0 ) ; //代理访问软件对服务器端传送HTTP请求命令 Int32 rBytes = IPsocket.Receive ( RecvBytes , RecvBytes.Length , 0 ) ; //代理访问软件接收来自Web服务器端的反馈信息 Console.WriteLine ( "接收字节数:" + rBytes.ToString ( ) ) ; String strRetPage = null ; strRetPage = strRetPage + ASCII.GetString ( RecvBytes , 0 , rBytes ) ; while ( rBytes 0 ) { rBytes = IPsocket.Receive ( RecvBytes , RecvBytes.Length , 0 ) ; strRetPage = strRetPage + ASCII.GetString ( RecvBytes , 0 , rBytes ) ; } IPsocket.Shutdown ( SocketShutdown.Both ) ; IPsocket.Close ( ) ; SendMessage ( clientSocket , strRetPage ) ; //代理服务软件往客户端传送接收到的信息 } catch ( Exception exc2 ) { Console.WriteLine ( exc2.ToString ( ) ) ; }}//接收客户端的HTTP请求数据private int ReadMessage ( byte [ ] ByteArray , ref Socket s , ref String clientmessage ){ int bytes = s.Receive ( ByteArray , 1024 , 0 ) ; string messagefromclient = Encoding.ASCII.GetString ( ByteArray ) ; clientmessage = ( String )messagefromclient ; return bytes ;}//传送从Web服务器反馈的数据到客户端private void SendMessage ( Socket s , string message ){ Buffer = new Byte[message.Length + 1] ; int length = ASCII.GetBytes ( message , 0 , message.Length , Buffer , 0 ) ; Console.WriteLine ( "传送字节数:" + length.ToString ( ) ) ; s.Send ( Buffer , length , 0 ) ;}