.NET网络编程学习(二)

System.Net.Sockets有很多类,其中最重要的就是Socket类.

Socket类
public class Socket : IDisposable
Socket 类为网络通信提供了一套丰富的方法和属性。Socket 类允许您使用 ProtocolType 枚举中所列出的任何一种协议执行异步和同步数据传输。

public Socket(AddressFamily addressFamily,SocketType socketType,ProtocolType protocolType);

其中&＃xff0c;addressFamily 参数指定Socket使用的寻址方案&＃xff0c;比如AddressFamily.InterNetwork表明为IP版本4的地址&＃xff1b;socketType参数指定 Socket的类型&＃xff0c;比如SocketType.Stream表明连接是基于流套接字的&＃xff0c;而SocketType.Dgram表示连接是基于数据报套接字的。protocolType参数指定Socket使用的协议&＃xff0c;比如ProtocolType.Tcp表明连接协议是运用TCP协议的&＃xff0c;而 Protocol.Udp则表明连接协议是运用UDP协议的。

Socket 类对异步方法遵循 .NET Framework 命名模式。例如&＃xff0c;同步的 Receive 方法对应于异步的 BeginReceive 和 EndReceive 方法。

(1)如果当前使用的是面向连接的协议&＃xff08;如 TCP&＃xff09;&＃xff0c;则服务器可以使用 Listen 方法侦听连接。Accept 方法处理任何传入的连接请求&＃xff0c;并返回可用于与远程主机进行数据通信的 Socket。可以使用此返回的 Socket 来调用 Send 或 Receive 方法。如果要指定本地 IP 地址和端口号&＃xff0c;请在调用 Listen 方法之前先调用 Bind 方法。如果您希望基础服务提供程序为您分配可用端口&＃xff0c;请使用端口号 0。如果希望连接到侦听主机&＃xff0c;请调用 Connect 方法。若要进行数据通信&＃xff0c;请调用 Send 或 Receive 方法。

(2)如果当前使用的是无连接协议&＃xff08;如 UDP&＃xff09;&＃xff0c;则根本不需要侦听连接。调用 ReceiveFrom 方法可接受任何传入的数据报。使用 SendTo 方法可将数据报发送到远程主机。

同步模式的Socket编程的基本过程如下&＃xff1a;
(1)创建一个Socket实例对象。
(2)将上述实例对象连接到一个具体的终结点&＃xff08;EndPoint&＃xff09;。
(3)连接完毕&＃xff0c;就可以和服务器进行通讯&＃xff1a;接收并发送信息。
(4)通讯完毕&＃xff0c;用ShutDown()方法来禁用Socket。
(5)最后用Close()方法来关闭Socket。

对于基于Tcp的Socket,涉及到服务器端的侦听(Listen)和客户端的连接(Connect)

以下通过一个简单的Http服务器程序来看看服务器端的程序设计:

(1)BaseConnection是个封装Socket表示一个连接的类.

Code
public class BaseConnection
{
        Socket sock;
        public BaseConnection(Socket sock)
        {
            this.sock &＃61; sock;
        }
        //把客户端请求文件中的字符替换掉
        string ProcessString(string input)
        {
            StringBuilder result &＃61; new StringBuilder();
            for (int i &＃61; 0; i < input.Length; i&＃43;&＃43;)
            {
                if (input[i] &＃61;&＃61; &＃39;/&＃39;)
                {
                    result.Append(&＃39;\\&＃39;);
                }
                else
                {
                    result.Append(input[i]);
                }
            }
            return result.ToString();
        }
        /// 

        /// 读取请求信息,返回客户端请求的文件名
        /// 

        /// 
        public string getRequest()  
        {
            string s &＃61; null ;
            byte[] buff &＃61; new byte[1024];
            int recCount &＃61; 0;
            try
            {
                //从socket读取请求信息
                recCount &＃61; sock.Receive(buff, buff.Length, SocketFlags.None);
                s &＃61; ASCIIEncoding.ASCII.GetString(buff, 0, recCount);
                Console.WriteLine("请求的详细信息是:" &＃43; s);
                if (s.IndexOf("GET") > -1)
                {
                    s &＃61; s.Substring(5);
                    int fend &＃61; s.IndexOf(" ");
                    s &＃61; s.Substring(0, fend); //取得请求文件的路径及文件名
                }
                return ProcessString(s);
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
            return "";
        }
        /// 

        /// 返回客户端请求的文件
        /// 

        /// 
        public void sendResponse(string fname) 
        {
            byte[] buff &＃61; new byte[1024];
            string filePath &＃61; &＃64;"C:\Inetpub\wwwroot\" &＃43; fname;

            int count &＃61; 0;
            if (filePath.IndexOf("..") > -1) //使访问的文件限制在目录C:\Inetpub\wwwroot\下
            {
                Console.WriteLine("没有权限访问!");
                return;
            }
            Console.WriteLine("look for " &＃43; filePath);
            if (File.Exists(filePath)) //检查文件是否存在
            {
                using (BinaryReader fs &＃61; new BinaryReader(File.Open(filePath, FileMode.Open)))
                {
                    while ((count &＃61; fs.Read(buff, 0, 1024)) > 0)
                    {
                        sock.Send(buff, count, SocketFlags.None);//发送信息
                    }
                }
            }
            else
            {
                throw new FileNotFoundException("文件:" &＃43; filePath &＃43; "不存在!");
            }
        }
        public void ConClose()  //关闭socket
        {
            sock.Shutdown(SocketShutdown.Both);
            sock.Close();
        }
}

(2)Main方法

Code
        static void Main(string[] args)
        {
            Socket ssock &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Stream,ProtocolType.Tcp);

            IPAddress hostIp &＃61; Dns.GetHostEntry("localhost").AddressList[0];
            IPEndPoint ep &＃61; new IPEndPoint(hostIp, 80);
            ssock.Bind(ep); //绑定

            Console.WriteLine("开始侦听.");
            //开始侦听
            ssock.Listen(32);
            while (true)
            {
                Socket sock &＃61; ssock.Accept(); //等待客户端请求

                Console.WriteLine("有一个客户端请求");
                BaseConnection client &＃61; new BaseConnection(sock);
                try
                {
                    string file &＃61; client.getRequest();
                    Console.WriteLine("客户端请求的文件是:" &＃43; file);
                    client.sendResponse(file);
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.Message);
                }
                finally
                {
                    client.ConClose(); //关闭连接
                }
                Console.WriteLine("结束一个请求");
                Console.WriteLine("");
            }
        }

启动服务器端:

打开浏览器输入:http://localhost/info.html

 结果如下:

同时服务器端输出:

虽然很简单,但我们却的确写了一个http服务器程序.

主要参考资料:MSDN