TCP流式套接字的阻塞模式编程

在Windows环境下，套接口的通信方式分为两种：阻塞方式和非阻塞方式。阻塞方式下工作的套接口在进行I/O操作时，函数要等待到相关操作完成以后才能返回(或者可以使用WSACancelBlockingCall( )调用唤起一个阻塞操作)。 阻塞方式的套接口编程简单，易于实现。正因为如此，一个套接口的默认操作模式被设置为阻塞方式。

以下为测试阻塞模式TCP流式套接字编程，一个服务器两个客户端
服务器端程序：

#include < WinSock2.h> 
#pragma comment ( lib, "ws2_32" ) 
#include < stdio.h> 
int main() 
{ 
    printf( "服务器端程序/n" ); 
    //---------------①加载-------------------------
    WSADATA wsaData; 
    WORD wVersionRequested= MAKEWORD( 2 ,2 ); 
    if ( WSAStartup( wVersionRequested,& wsaData)!= 0 )
    { 
        printf( "WSAStartup() Failed,Error=【%d】/n" , WSAGetLastError()); 
        return 1 ;
    } 
    else 
        printf( "①加载成功/n" ); 
    //----------------②创建流式套接字--------------
    SOCKET s= socket( AF_INET, SOCK_STREAM, 0 ); 
    if ( s== INVALID_SOCKET) 
    { 
        printf( "socket() Failed,Error=【%d】/n" , WSAGetLastError()); 
        return 1 ;
    } 
    else 
        printf( "②已创建监听套接口:【%d】/n" , s); 
    //-----------------③绑定本地地址------------------
    struct sockaddr_in Sadd; 
    Sadd.sin_family= AF_INET; 
    Sadd.sin_port= htons( 1111 ); 
    Sadd.sin_addr.s_addr= inet_addr( "192.168.31.1" ); 
    if ( bind( s,( sockaddr*)& Sadd, sizeof ( Sadd))== SOCKET_ERROR) 
    { 
        printf( "bind() Failed,Error=【%d】/n" , WSAGetLastError()); 
        return 1 ;
    } 
    else 
        printf( "③绑定成功，本地IP地址：【%s】，端口号：【%d】/n" , inet_ntoa( Sadd.sin_addr), ntohs( Sadd.sin_port)); 
    //------------------④进入监听状态--------------------
    if ( listen( s, 5 )== SOCKET_ERROR) 
    { 
        printf( "listen() Failed,Error=【%d】/n" , WSAGetLastError()); 
        return 1 ;
    } 
    else 
        printf( "④进入监听状态/n" ); 
    //------------------⑤循环接受客户的连接请求-----------------
    printf( "⑤等待客户连接请求/n/n" ); 
    struct sockaddr_in Cadd; 
    int CaddLen= sizeof ( Cadd); 
    while ( TRUE ) 
    { 
        SOCKET c= accept( s,( sockaddr*)& Cadd,& CaddLen); 
        if ( c== INVALID_SOCKET) 
        { 
            printf( "accept() Failed,Error=【%d】/n" , WSAGetLastError()); 
            return 1 ;
        } 
        else //**************开始发送、接收********************
        { 
            printf( "客户已来，已创建用于本次连接的套接字是：【%d】/n" , c); 
            printf( "客户端IP地址：【%s】,端口号：【%d】/n" , inet_ntoa( Cadd.sin_addr), ntohs( Cadd.sin_port)); 
            while ( 1 )
            { 
                //-------接受-----
                char Rbuf[ 256 ]; 
                memset( Rbuf, 0 ,sizeof ( Rbuf)); 
                int SRecv= recv( c, Rbuf, 256 ,0 ); 
                if ( SRecv== SOCKET_ERROR) 
                { 
                    printf( "recv() Failed,Error=【%d】或客户端非法关闭连接/n" , WSAGetLastError()); 
                    break ; 
                } 
                else if ( SRecv== 0 )
                { 
                    printf( "没接收到任何来自客户端的数据，或者客户端已关闭本次连接！！/n" ); 
                    break ; 
                } 
                else //------正确接收---
                { 
                    printf( "接收到数据：【%s】/n" , Rbuf); 
                    char Sbuf[]= "Hello! I am a server" ; 
                    int isend= send( c, Sbuf, sizeof ( Sbuf), 0 ); 
                    if ( isend== SOCKET_ERROR) 
                    { 
                        printf( "send() Failed,Error=【%d】/n" , WSAGetLastError()); 
                        break ; 
                    } 
                    else if ( isend== 0 )
                    { 
                        printf( "消息发送失败/n" ); 
                        closesocket( c); 
                        break ; 
                    } 
                    else 
                        printf( "给客户信息【%s】已发送/n" , Sbuf); 
                } //end 正确接收
            } //end while2
        } //end 开始接收
        closesocket( c); 
        printf( "关闭本次用于连接的套接字【%d】,和【%s】连接完毕/n/n" , c, inet_ntoa( Cadd.sin_addr)); 
    } //end while 1
    //---------------⑥关闭、释放--------------------
    closesocket( s); 
    WSACleanup(); 
    return 0 ;
}

1号客户端程序：

#include < WinSock2.h> 
#pragma comment( lib, "ws2_32" ) 
#include < stdio.h> 
int main() 
{ 
    printf( "1号客户端程序/n" ); 
    //-----------①加载----------------
    WSADATA wsaData; 
    WORD wVersionRequested= MAKEWORD( 2 ,2 ); 
    if ( WSAStartup( wVersionRequested,& wsaData)!= 0 )
    { 
        printf( "WSAStartup Failed,Error=【%d】/n" , WSAGetLastError()); 
        return 1 ;
    } 
    else 
        printf( "①加载成功/n" ); 
    //-------------②创建流式套接字-----------------
    SOCKET c1= socket( AF_INET, SOCK_STREAM, 0 ); 
    if ( c1== INVALID_SOCKET) 
    { 
        printf( "socket() Failed,Error=【%d】/n" , WSAGetLastError()); 
        return 1 ;
    } 
    else 
        printf( "②已创建连接套接字:【%d】/n" , c1); 
    //-------------绑定地址---------------------
    struct sockaddr_in C1add; 
    C1add.sin_family= AF_INET; 
    C1add.sin_port= htons( 2222 ); 
    C1add.sin_addr.s_addr= inet_addr( "192.168.31.2" ); 
    if ( bind( c1,( sockaddr*)& C1add, sizeof ( C1add))== SOCKET_ERROR) 
    { 
        printf( "bind() Failed,Error=【%d】/n" , WSAGetLastError()); 
        return 1 ;
    } 
    else 
        printf( "绑定成功，本地IP地址：【%s】,端口号：【%d】/n" , inet_ntoa( C1add.sin_addr), ntohs( C1add.sin_port)); 
    //------------③连接请求---------------
    struct sockaddr_in Sadd; 
    Sadd.sin_family= AF_INET; 
    Sadd.sin_port= htons( 1111 ); 
    Sadd.sin_addr.s_addr= inet_addr( "192.168.31.1" ); 
    if ( connect( c1,( sockaddr*)& Sadd, sizeof ( Sadd))==- 1 )
    { 
        printf( "Failed connect(),Error=【%d】/n" , WSAGetLastError()); 
        return 1 ;
    } 
    else //*********连接成功，可以开始发送、接收************
    { 
        printf( "③连接成功，服务器IP地址:【%s】,端口号：【%d】/n" , inet_ntoa( Sadd.sin_addr), ntohs( Sadd.sin_port)); 
        int a; 
        printf( "希望发送数据吗？(键入“1”发送，键入其他值则退出)" ); 
        scanf( "%d" ,& a); 
        while ( a== 1 )
        { 
            //---发送-----
            char S_buf[]= "Hello!I am a client 1" ; 
            int isend= send( c1, S_buf, strlen( S_buf), 0 ); 
            if ( isend== SOCKET_ERROR) 
            { 
                printf( "Failed send(),Error=【%d】,或者服务器意外关闭/n" , WSAGetLastError()); 
                return 1 ;
            } 
            else if ( isend!= 0 )
                printf( "信息【%s】已发送/n" , S_buf); 
            else 
                printf( "信息无法发送给客户端/n" ); 
            //---接收----
            char R_buf[ 256 ]; 
            int RRecv; 
            memset( R_buf, 0 ,sizeof ( R_buf)); 
            RRecv= recv( c1, R_buf, 256 ,0 ); 
            if ( RRecv== SOCKET_ERROR) 
            { 
                printf( "Failed recv(),Error=【%d】/n" , WSAGetLastError()); 
                return 1 ;
            } 
            else if ( RRecv== 0 )
                printf( "无法收到来自服务器的任何数据，或者服务器意外关闭/n" ); 
            else 
            { 
                printf( "接收到来自服务器的数据：【%s】/n" , R_buf); 
                printf( "希望继续发送数据吗？（键入”1“继续发送，键入其他值则退出)" ); 
                scanf( "%d" ,& a); 
                if ( a!= 1 )
                    break ; 
            } 
        } //-------end 结束
        printf( "已选择退出连接/n" ); 
    } //------end 结束
    //-------------------④关闭、释放------------
    closesocket( c1); 
    WSACleanup(); 
    printf( "④与服务器连接完毕/n" ); 
    return 0 ;
}

2号客户端程序与1号的相差无几，主要是提示文字变成“2号客户端”，绑定的IP地址也不一样。
先启动服务器端，再启动1号客户端，接着启动2号客户端，就会看到如图所示：

服务器端只有当1号客户端退出，才能收到2号客户端的通信。