简单的客户端-服务器模型

1、服务器端代码

#pragma comment(lib, "ws2_32.lib")

#include <WinSock2.h>
#include <iostream>

using namespace std;

bool LoadSockLib()
{
    WSADATA wsaData;
    if(SOCKET_ERROR == WSAStartup(MAKEWORD(2, 2), &wsaData))
    {
        DWORD dwError(0);
        dwError = GetLastError();
        cout << "加载套接字库失败，错误代码：" << dwError << endl;
        return false;
    }
    return true;
}

int main()
{
    if(!LoadSockLib())
    {
        exit(-1);
    }

    SOCKET sock = socket(AF_INET, SOCK_STREAM, 0);
    if(INVALID_SOCKET == sock)
    {
        DWORD dwError(0);
        dwError = GetLastError();
        cout << "获取套接字失败，错误代码：" << dwError << endl;
        exit(-2);
    }

    sockaddr_in addrBind;
    addrBind.sin_family = AF_INET;
    addrBind.sin_port = htons(3456);
    addrBind.sin_addr.S_un.S_addr = INADDR_ANY;

    sockaddr_in addrClient;

    int iRetVal = 0;
    if(iRetVal = bind(sock, (sockaddr*)&addrBind, sizeof(addrBind)))
    {
        DWORD dwError(0);
        dwError = GetLastError();
        cout << "绑定套接字失败，错误代码：" << dwError << endl;
        exit(-3);
    }

    listen(sock, 5);
    int len = sizeof(sockaddr);
    cout  << "服务器已经准备好，正在等待客户端的连接..." << endl;
    SOCKET sockClient = accept(sock, (sockaddr*)&addrClient, &len);
    cout << inet_ntoa(addrClient.sin_addr) << "已连接。" << endl;

    char szRecBuf[512] = {0};
    char szSendBuf[512] = {0};
    while(true)
    {
        cout << "请给客户端发送消息：" << endl;
        cin >> szSendBuf;
        send(sockClient, szSendBuf, strlen(szSendBuf), 0);
        cout << "消息已经发送给客户端，等待其回复..." << endl;

        iRetVal = recv(sockClient, szRecBuf, 512, 0);
        cout << "127.0.0.1 回复说：" << szRecBuf << endl;
        
        memset(szRecBuf, 0, 512);
        memset(szSendBuf, 0, 512);
    }

    return 0;
}

2、客户端代码

#pragma comment(lib, "ws2_32.lib")

#include <WinSock2.h>
#include <iostream>

using namespace std;

bool LoadSockLib()
{
    WSADATA wsaData;
    if(SOCKET_ERROR == WSAStartup(MAKEWORD(2, 2), &wsaData))
    {
        DWORD dwError(0);
        dwError = GetLastError();
        cout << "加载套接字库失败，错误代码：" << dwError << endl;
        return false;
    }
    return true;
}

int main()
{
    if(!LoadSockLib())
    {
        exit(-1);
    }

    SOCKET sock = socket(AF_INET, SOCK_STREAM, 0);
    if(INVALID_SOCKET == sock)
    {
        DWORD dwError(0);
        dwError = GetLastError();
        cout << "获取套接字失败，错误代码：" << dwError << endl;
        exit(-2);
    }

    SOCKADDR_IN addr;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3456);
    addr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");

    int iRetVal = 0;
    iRetVal = connect(sock, (SOCKADDR*)&addr, sizeof(addr));
    if(SOCKET_ERROR == iRetVal)
    {
        DWORD dwError(0);
        dwError = GetLastError();
        cout << "连接服务器失败，错误代码：" << dwError << endl;
        exit(-3);
    }

    char szRecBuf[512] = {0};
    char szSendBuf[512] = {0};
    while(true)
    {
        cout << "等待服务器发送消息..." << endl;
        iRetVal = recv(sock, szRecBuf, 512, 0);
        cout << "127.0.0.1 说：" << szRecBuf << endl;

        cout << "请回复服务器：" << endl;
        cin >> szSendBuf;
        send(sock, szSendBuf, strlen(szSendBuf), 0);

        memset(szRecBuf, 0, 512);
        memset(szSendBuf, 0, 512);
    }
    return 0;
}

执行结果：

服务器端

客户端

3、我的疑问

虽然程序是正确的执行的了，但是其中却还有存有许多的疑问。

1. 以前看书时，说的是，服务器端监听一个固定的端口，当收到连接请求时，用accept接受请求并返回一个新生成的套接字，该服务器套接字继续监听该固定端口。于是问题来，我运行该程序，当服务器端进行通信时，我用netstat查看了一下端口，发现监听的是3456（我指定的监听端口），其状态为listen，然而，通信的端口还是3456，也就是服务器和客户端通信使用的端口还是3456，因为我现在一个客户端，所以没问题，但是，将程序的监听功能放在一个单独的线程中执行的话，那么就可以同时和多个客户端通信，那难熬还是使用同一个端口么？下面是我查看端口的截图

未完待续。。。