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

 

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

 

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

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

 

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

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

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

 

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

 

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

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

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

 BaseConnection
{
        Socket sock;
        public BaseConnection(Socket sock)
        {
            
this.sock = sock;
        }
        
//把客户端请求文件中的字符替换掉
        string ProcessString(string input)
        {
            StringBuilder result 
= new StringBuilder();
            
for (int i = 0; i < input.Length; i++)
            {
                
if (input[i] == '/')
                {
                    result.Append(
'\\');
                }
                
else
                {
                    result.Append(input[i]);
                }
            }
            
return result.ToString();
        }
        
/// <summary>
        
/// 读取请求信息,返回客户端请求的文件名
        
/// </summary>
        
/// <returns></returns>
        public string getRequest()  
        {
            
string s = null ;
            
byte[] buff = new byte[1024];
            
int recCount = 0;
            
try
            {
                
//从socket读取请求信息
                recCount = sock.Receive(buff, buff.Length, SocketFlags.None);
                s 
= ASCIIEncoding.ASCII.GetString(buff, 0, recCount);
                Console.WriteLine(
"请求的详细信息是:" + s);
                
if (s.IndexOf("GET"> -1)
                {
                    s 
= s.Substring(5);
                    
int fend = s.IndexOf(" ");
                    s 
= s.Substring(0, fend); //取得请求文件的路径及文件名
                }
                
return ProcessString(s);
            }
            
catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
            
return "";
        }
        
/// <summary>
        
/// 返回客户端请求的文件
        
/// </summary>
        
/// <param name="fname"></param>
        public void sendResponse(string fname) 
        {
            
byte[] buff = new byte[1024];
            
string filePath = @"C:\Inetpub\wwwroot\" + fname;

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

(2)Main方法

 

[] args)
        {
            Socket ssock = new Socket(AddressFamily.InterNetwork, SocketType.Stream,ProtocolType.Tcp);

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

            Console.WriteLine(
"开始侦听.NET网络编程学习(二).");
            
//开始侦听
            ssock.Listen(32);
            
while (true)
            {
                Socket sock 
= ssock.Accept(); //等待客户端请求

                Console.WriteLine(
"有一个客户端请求.NET网络编程学习(二)");
                BaseConnection client 
= new BaseConnection(sock);
                
try
                {
                    
string file = client.getRequest();
                    Console.WriteLine(
"客户端请求的文件是:" + file);
                    client.sendResponse(file);
                }
                
catch (Exception e)
                {
                    Console.WriteLine(e.Message);
                }
                
finally
                {
                    client.ConClose(); 
//关闭连接
                }
                Console.WriteLine(
"结束一个请求.NET网络编程学习(二)");
                Console.WriteLine(
"////////////////////////////////////////////////");
            }
        }

 

(3)测试
假设在你C:\Inetpub\wwwroot目录下有一个info.html

启动服务器端:

.NET网络编程学习(二)

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

 结果如下:

.NET网络编程学习(二)

同时服务器端输出:

.NET网络编程学习(二)

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

 

主要参考资料:MSDN

相关文章: