posts - 131, comments - 12, trackbacks - 0, articles - 0
  C++博客 :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理

Windows Socket编程

Posted on 2012-12-25 15:10 盛胜 阅读(606) 评论(0)  编辑 收藏 引用
http://www.cppblog.com/bujiwu/archive/2012/09/05/71707.html
Windows下Socket编程主要包括以下几部分:
服务端
   1、初始化Windows Socket库。
   2、创建Socket。
   3、绑定Socket。
   4、监听。
   5、Accept。
   6、接收、发送数据。

客户端
   1、初始化Windows Socket库。
   2、创建Socket。
   3、连接Socket。
   4、接收、发送数据。

服务端每接收到一个客户端的Socket,则创建一个线程。满足一个服务端连接多个客户端。

  1 //Server.cpp
  2 #include <iostream>
  3 #include <Windows.h>
  4 
  5 using namespace std;
  6 
  7 #define  PORT 4000
  8 #define  IP_ADDRESS "192.168.1.145"
  9 
 10 DWORD WINAPI ClientThread(LPVOID lpParameter)
 11 {
 12     SOCKET CientSocket = (SOCKET)lpParameter;
 13     int Ret = 0;
 14     char RecvBuffer[MAX_PATH];
 15 
 16     while ( true )
 17     {
 18         memset(RecvBuffer, 0x00sizeof(RecvBuffer));
 19         Ret = recv(CientSocket, RecvBuffer, MAX_PATH, 0);
 20         if ( Ret == 0 || Ret == SOCKET_ERROR ) 
 21         {
 22             cout<<"客户端退出!"<<endl;
 23             break;
 24         }
 25         cout<<"接收到客户信息为:"<<RecvBuffer<<endl;
 26     }
 27 
 28     return 0;
 29 }
 30 
 31 int main(int argc, char* argv[])
 32 {
 33     WSADATA  Ws;
 34     SOCKET ServerSocket, CientSocket;
 35     struct sockaddr_in LocalAddr, ClientAddr;
 36     int Ret = 0;
 37     int AddrLen = 0;
 38     HANDLE hThread = NULL;
 39 
 40     //Init Windows Socket
 41     if ( WSAStartup(MAKEWORD(2,2), &Ws) != 0 )
 42     {
 43         cout<<"Init Windows Socket Failed::"<<GetLastError()<<endl;
 44         return -1;
 45     }
 46     
 47     //Create Socket
 48     ServerSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
 49     if ( ServerSocket == INVALID_SOCKET )
 50     {
 51         cout<<"Create Socket Failed::"<<GetLastError()<<endl;
 52         return -1;
 53     }
 54 
 55     LocalAddr.sin_family = AF_INET;
 56     LocalAddr.sin_addr.s_addr = inet_addr(IP_ADDRESS);
 57     LocalAddr.sin_port = htons(PORT);
 58     memset(LocalAddr.sin_zero, 0x008);
 59 
 60     //Bind Socket
 61     Ret = bind(ServerSocket, (struct sockaddr*)&LocalAddr, sizeof(LocalAddr));
 62     if ( Ret != 0 )
 63     {
 64         cout<<"Bind Socket Failed::"<<GetLastError()<<endl;
 65         return -1;
 66     }
 67 
 68     Ret = listen(ServerSocket, 10);
 69     if ( Ret != 0 )
 70     {
 71         cout<<"listen Socket Failed::"<<GetLastError()<<endl;
 72         return -1;
 73     }
 74 
 75     cout<<"服务端已经启动"<<endl;
 76 
 77     while ( true )
 78     {
 79         AddrLen = sizeof(ClientAddr);
 80         CientSocket = accept(ServerSocket, (struct sockaddr*)&ClientAddr, &AddrLen);
 81         if ( CientSocket == INVALID_SOCKET )
 82         {
 83             cout<<"Accept Failed::"<<GetLastError()<<endl;
 84             break;
 85         }
 86 
 87         cout<<"客户端连接::"<<inet_ntoa(ClientAddr.sin_addr)<<":"<<ClientAddr.sin_port<<endl;
 88         
 89         hThread = CreateThread(NULL, 0, ClientThread, (LPVOID)CientSocket, 0, NULL);
 90         if ( hThread == NULL )
 91         {
 92             cout<<"Create Thread Failed!"<<endl;
 93             break;
 94         }
 95 
 96         CloseHandle(hThread);
 97     }
 98 
 99     closesocket(ServerSocket);
100     closesocket(CientSocket);
101     WSACleanup();
102 
103     return 0;
104 }

 1 //Client.cpp
 2 #include <iostream>
 3 #include <Windows.h>
 4 
 5 using namespace std;
 6 
 7 #define  PORT 4000
 8 #define  IP_ADDRESS "192.168.1.145"
 9 
10 
11 int main(int argc, char* argv[])
12 {
13     WSADATA  Ws;
14     SOCKET CientSocket;
15     struct sockaddr_in ServerAddr;
16     int Ret = 0;
17     int AddrLen = 0;
18     HANDLE hThread = NULL;
19     char SendBuffer[MAX_PATH];
20 
21     //Init Windows Socket
22     if ( WSAStartup(MAKEWORD(2,2), &Ws) != 0 )
23     {
24         cout<<"Init Windows Socket Failed::"<<GetLastError()<<endl;
25         return -1;
26     }
27 
28     //Create Socket
29     CientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
30     if ( CientSocket == INVALID_SOCKET )
31     {
32         cout<<"Create Socket Failed::"<<GetLastError()<<endl;
33         return -1;
34     }
35 
36     ServerAddr.sin_family = AF_INET;
37     ServerAddr.sin_addr.s_addr = inet_addr(IP_ADDRESS);
38     ServerAddr.sin_port = htons(PORT);
39     memset(ServerAddr.sin_zero, 0x008);
40 
41     Ret = connect(CientSocket,(struct sockaddr*)&ServerAddr, sizeof(ServerAddr));
42     if ( Ret == SOCKET_ERROR )
43     {
44         cout<<"Connect Error::"<<GetLastError()<<endl;
45         return -1;
46     }
47     else
48     {
49         cout<<"连接成功!"<<endl;
50     }
51 
52     while ( true )
53     {
54         cin.getline(SendBuffer, sizeof(SendBuffer));
55         Ret = send(CientSocket, SendBuffer, (int)strlen(SendBuffer), 0);
56         if ( Ret == SOCKET_ERROR )
57         {
58             cout<<"Send Info Error::"<<GetLastError()<<endl;
59             break;
60         }
61     }
62     
63     closesocket(CientSocket);
64     WSACleanup();
65 
66     return 0;
67 }

很幽默的讲解六种Windows Socket I/O模型

老陈有一个在外地工作的女儿,不能经常回来,老陈和她通过信件联系。他们的信会被邮递员投递到他们的信箱里。
这和Socket模型非常类似。下面我就以老陈接收信件为例讲解Socket I/O模型~~~

一:select模型

老陈非常想看到女儿的信。以至于他每隔10分钟就下楼检查信箱,看是否有女儿的信~~~~~
在这种情况下,"下楼检查信箱"然后回到楼上耽误了老陈太多的时间,以至于老陈无法做其他工作。
select模型和老陈的这种情况非常相似:周而复始地去检查......如果有数据......接收/ 发送.......

使用线程来select应该是通用的做法:
http://tangfeng.iteye.com/blog/518135

 


二:WSAAsyncSelect模型

后来,老陈使用了微软公司的新式信箱。这种信箱非常先进,一旦信箱里有新的信件,盖茨就会给老陈打电话:喂,大爷,你有新的信件了!从此,老陈再也不必频繁上下楼检查信箱了,牙也不疼了,你瞅准了,蓝天......不是,微软~~~~~~~~
微软提供的WSAAsyncSelect模型就是这个意思。

WSAAsyncSelect 模型是Windows下最简单易用的一种Socket I/O模型。使用这种模型时,Windows会把网络事件以消息的形势通知应用程序。

http://tangfeng.iteye.com/blog/518141

 

 

三:WSAEventSelect模型

后来,微软的信箱非常畅销,购买微软信箱的人以百万计数......以至于盖茨每天24小时给客户打电话,累得腰酸背痛,喝啥都不好使~~~~~~
微软改进了他们的信箱:在客户的家中添加一个附加装置,这个装置会监视客户的信箱,每当新的信件来临,此装置会发出"新信件到达"声,提醒老陈去收信。盖茨终于可以睡觉了。

http://tangfeng.iteye.com/blog/518142 

四:Overlapped I/O 事件通知模型

后来,微软通过调查发现,老陈不喜欢上下楼收发信件,因为上下楼其实很浪费时间。于是微软再次改进他们的信箱。新式的信箱采用了更为先进的技术,只要用户告诉微软自己的家在几楼几号,新式信箱会把信件直接传送到用户的家中,然后告诉用户,你的信件已经放到你的家中了!老陈很高兴,因为他不必再亲自收发信件了!

Overlapped I/O 事件通知模型和WSAEventSelect模型在实现上非常相似,主要区别在"Overlapped",Overlapped模型是让应用程序使用重叠数据结构(WSAOVERLAPPED),一次投递一个或多个Winsock I/O请求。这些提交的请求完成后,应用程序会收到通知。什么意思呢?就是说,如果你想从socket上接收数据,只需要告诉系统,由系统为你接收数据,而你需要做的只是为系统提供一个缓冲区~~~~~
http://tangfeng.iteye.com/blog/518146 

五:Overlapped I/O 完成例程模型

老陈接收到新的信件后,一般的程序是:打开信封----掏出信纸----阅读信件----回复信件......为了进一步减轻用户负担,微软又开发了一种新的技术:用户只要告诉微软对信件的操作步骤,微软信箱将按照这些步骤去处理信件,不再需要用户亲自拆信/阅读 /回复了!老陈终于过上了小资生活!

http://tangfeng.iteye.com/blog/518146 

六:IOCP模型

微软信箱似乎很完美,老陈也很满意。但是在一些大公司情况却完全不同!这些大公司有数以万计的信箱,每秒钟都有数以百计的信件需要处理,以至于微软信箱经常因超负荷运转而崩溃!需要重新启动!微软不得不使出杀手锏......
微软给每个大公司派了一名名叫"Completion Port"的超级机器人,让这个机器人去处理那些信件!

"Windows NT小组注意到这些应用程序的性能没有预料的那么高。特别的,处理很多同时的客户请求意味着很多线程并发地运行在系统中。因为所有这些线程都是可运行的 [没有被挂起和等待发生什么事],Microsoft意识到NT内核花费了太多的时间来转换运行线程的上下文[Context],线程就没有得到很多 CPU时间来做它们的工作。大家可能也都感觉到并行模型的瓶颈在于它为每一个客户请求都创建了一个新线程。创建线程比起创建进程开销要小,但也远不是没有开销的。我们不妨设想一下:如果事先开好N个线程,让它们在那hold[堵塞],然后可以将所有用户的请求都投递到一个消息队列中去。然后那N个线程逐一从消息队列中去取出消息并加以处理。就可以避免针对每一个用户请求都开线程。不仅减少了线程的资源,也提高了线程的利用率。理论上很不错,你想我等泛泛之辈都能想出来的问题,Microsoft又怎会没有考虑到呢?"-----摘自nonocast的《理解I/O Completion Port》

先看一下IOCP模型的实现:

http://tangfeng.iteye.com/blog/518148 

IOCP不是一个普通的对象,不需要考虑线程安全问题。它会自动调配访问它的线程:如果某个socket上有一个线程A正在访问,那么线程B的访问请求会被分配到另外一个socket。这一切都是由系统自动调配的,我们无需过问。


只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理