寫(xiě)文章

首頁(yè) 手記 C++11服務(wù)器入門(mén)：新手必備指南

C++11服務(wù)器入門(mén)：新手必備指南

標(biāo)簽：

Linux C++

概述

本文介绍了使用C++11进行服务器编程的基础知识和实践方法，涵盖了网络编程、线程池和异步I/O等关键技术。通过示例代码展示了如何构建一个简单的TCP服务器，并提供了调试和优化服务器性能的技巧。文章还通过构建一个小型聊天室服务器，进一步说明了如何应用这些技术。此文章适合希望了解C++11服务器入门的读者。

C++11简介

C++11新特性概览

C++11是C++编程语言的一个重要版本，发布于2011年。它引入了许多新特性，使语言的可读性和开发效率得到提升。以下是一些重要的新特性：

智能指针：std::shared_ptr和std::unique_ptr提供了更安全的内存管理方式。
范围for循环：简化了容器的遍历操作。
右值引用：支持移动语义，允许对象资源的高效转移。
类型推断：auto关键字可以在编译时自动推断类型。
Lambda函数：允许在代码中直接定义临时函数对象。
初始化列表：可以初始化类成员变量时使用统一的语法。
多线程支持：引入了std::thread和std::mutex等多线程库。
正则表达式支持：增强了文本处理能力。
变长参数列表：支持函数的变长参数列表，类似于C语言的va_list。
属性和反射：虽然受限，但提供了基本的元编程功能。

为什么选择C++11进行服务器编程

C++11提供了许多现代编程语言的功能，使其成为服务器编程的理想选择。以下是一些主要原因：

性能：C++11的特性提高了代码的执行效率，特别是在服务器端应用中，这对性能要求高的场景尤为重要。
内存管理：智能指针等特性简化了内存管理，减少了内存泄漏的风险。
并发支持：C++11中的多线程支持使得编写高性能的并发服务器变得更为容易。
稳定性：C++11的语法更加严格，减少了潜在的错误，提高了程序的稳定性。
持续维护：C++11是C++标准委员会近年来发布的重要版本，得到了广泛的社区支持和持续的维护更新。

服务器编程基础

网络编程基础

网络编程是服务器编程的基础。在C++11中，我们可以使用标准库中的网络库来实现TCP或UDP通信。网络编程的关键概念包括：

套接字：套接字是网络通信的基本单位，代表了网络上的一个端点。
地址与端口：每个套接字都有一个唯一的地址和端口号，用于标识网络上的一个具体位置。
连接与监听：服务器端程序需要监听一个或多个端口，并为每个连接请求创建新的套接字。
数据传输：客户端和服务器之间可以发送和接收数据流。

以下是一个简单的TCP服务器的示例：

#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <cstring>
#include <vector>

// 简单的TCP服务器
int main() {
    int server_fd, new_socket, valread;
    struct sockaddr_in address;
    int opt = 1;
    int addrlen = sizeof(address);
    char buffer[1024] = {0};
    std::string message = "Hello from server";

    server_fd = socket(AF_INET, SOCK_STREAM, 0);
    if (server_fd == 0) {
        std::cerr << "Socket failed\n";
        return 1;
    }

    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons(8080);

    if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
        std::cerr << "Setsockopt failed\n";
        return 1;
    }

    if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        std::cerr << "Bind failed\n";
        return 1;
    }

    if (listen(server_fd, 3) < 0) {
        std::cerr << "Listen failed\n";
        return 1;
    }

    while (true) {
        new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen);
        if (new_socket < 0) {
            std::cerr << "Accept failed\n";
            continue;
        }

        std::thread client_thread([new_socket, &message]() {
            valread = read(new_socket, buffer, 1024);
            std::string client_message(buffer);
            std::cout << "Client message: " << client_message << std::endl;

            send(new_socket, message.c_str(), message.length(), 0);
            close(new_socket);
        });
        client_thread.detach();
    }

    return 0;
}

基本的服务器架构

服务器架构的设计决定了服务器的可扩展性、性能和稳定性。一个典型的服务器架构包括以下几个部分：

监听器：负责监听客户端连接请求。
连接管理：管理客户端连接的状态和生命周期。
请求处理：解析客户端请求并返回响应。
资源管理：包括内存管理、线程池管理等。
错误处理与日志：记录错误信息和服务器运行日志。

以下是一个基本的服务器架构的示例代码：

#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <cstring>
#include <vector>

std::mutex server_mutex;

class Server {
public:
    void start() {
        int server_fd, new_socket, valread;
        struct sockaddr_in address;
        int opt = 1;
        int addrlen = sizeof(address);
        char buffer[1024] = {0};
        std::string message = "Hello from server";

        server_fd = socket(AF_INET, SOCK_STREAM, 0);
        if (server_fd == 0) {
            std::cerr << "Socket failed\n";
            return;
        }

        address.sin_family = AF_INET;
        address.sin_addr.s_addr = INADDR_ANY;
        address.sin_port = htons(8080);

        if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
            std::cerr << "Setsockopt failed\n";
            return;
        }

        if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
            std::cerr << "Bind failed\n";
            return;
        }

        if (listen(server_fd, 3) < 0) {
            std::cerr << "Listen failed\n";
            return;
        }

        while (true) {
            new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen);
            if (new_socket < 0) {
                std::cerr << "Accept failed\n";
                continue;
            }

            std::thread client_thread([new_socket, &message]() {
                valread = read(new_socket, buffer, 1024);
                std::string client_message(buffer);
                std::cout << "Client message: " << client_message << std::endl;

                send(new_socket, message.c_str(), message.length(), 0);
                close(new_socket);
            });
            client_thread.detach();
        }
    }
};

int main() {
    Server server;
    server.start();
    return 0;
}

使用C++11创建简单服务器

安装和配置开发环境

要使用C++11进行编程，你需要安装一个支持C++11标准的编译器。下面是如何在Linux和Windows上设置开发环境的步骤：

Linux

安装GCC或Clang编译器：

sudo apt-get update
sudo apt-get install g++-9

检查GCC版本：
```
g++-9 --version
```
使用g++命令编译C++11代码：
```
g++ -std=c++11 -o server server.cpp
```

Windows

安装MinGW或Visual Studio：
- MinGW可以从官方网站下载并安装。
- Visual Studio可以从微软网站下载并安装。
打开命令提示符或PowerShell，设置环境变量：
```
set PATH=C:\path\to\mingw\bin;%PATH%
```
编译C++11代码：
```
g++ -std=c++11 -o server server.cpp
```

编写一个简单的TCP服务器

以下是一个简单的TCP服务器，它监听一个端口并处理客户端的连接请求。

#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <cstring>
#include <vector>

std::mutex server_mutex;

class Server {
public:
    void start() {
        int server_fd, new_socket, valread;
        struct sockaddr_in address;
        int opt = 1;
        int addrlen = sizeof(address);
        char buffer[1024] = {0};
        std::string message = "Hello from server";

        server_fd = socket(AF_INET, SOCK_STREAM, 0);
        if (server_fd == 0) {
            std::cerr << "Socket failed\n";
            return;
        }

        address.sin_family = AF_INET;
        address.sin_addr.s_addr = INADDR_ANY;
        address.sin_port = htons(8080);

        if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
            std::cerr << "Setsockopt failed\n";
            return;
        }

        if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
            std::cerr << "Bind failed\n";
            return;
        }

        if (listen(server_fd, 3) < 0) {
            std::cerr << "Listen failed\n";
            return;
        }

        while (true) {
            new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen);
            if (new_socket < 0) {
                std::cerr << "Accept failed\n";
                continue;
            }

            std::thread client_thread([new_socket, &message]() {
                valread = read(new_socket, buffer, 1024);
                std::string client_message(buffer);
                std::cout << "Client message: " << client_message << std::endl;

                send(new_socket, message.c_str(), message.length(), 0);
                close(new_socket);
            });
            client_thread.detach();
        }
    }
};

int main() {
    Server server;
    server.start();
    return 0;
}

处理并发连接

使用线程池提高性能

线程池是一种优化并发处理的方法，它预先创建一组线程，并在需要时复用这些线程来处理任务。这样可以避免频繁创建和销毁线程的开销，提高服务器的性能。

以下是一个简单的线程池实现：

#include <iostream>
#include <vector>
#include <thread>
#include <queue>
#include <functional>
#include <mutex>
#include <condition_variable>
#include <future>

class ThreadPool {
public:
    ThreadPool(size_t numThreads) {
        for(size_t i = 0; i < numThreads; ++i)
            workers.emplace_back([this] {
                while (true) {
                    std::function<void()> task;
                    {
                        std::unique_lock<std::mutex> lock(this->queue_mutex);
                        this->condition_var.wait(lock,
                        [this] { return !this->tasks.empty() || this->stop; });
                        if (this->stop && this->tasks.empty())
                            return;
                        task = std::move(this->tasks.front());
                        this->tasks.pop();
                    }
                    task();
                }
            });
    }

    template<class F, class... Args>
    auto submit(F&& f, Args... args) -> std::future<decltype(f(args...))> {
        using return_type = decltype(f(args...));
        auto task = std::make_shared<std::packaged_task<return_type()>>(std::bind(std::forward<F>(f), std::forward<Args>(args)...));
        std::future<return_type> res = task->get_future();
        {
            std::unique_lock<std::mutex> lock(queue_mutex);
            if(stop) throw std::runtime_error("enqueue on stopped ThreadPool");
            tasks.emplace([task](){ (*task)(); });
        }
        condition_var.notify_one();
        return res;
    }

    ~ThreadPool() {
        {
            std::unique_lock<std::mutex> lock(queue_mutex);
            stop = true;
        }
        condition_var.notify_all();
        for(std::thread &worker: workers)
            worker.join();
    }

private:
    std::vector<std::thread> workers;
    std::queue<std::function<void()>> tasks;
    std::mutex queue_mutex;
    std::condition_variable condition_var;
    bool stop = false;
};

int main() {
    ThreadPool pool(4);
    std::vector<std::future<int>> futures;
    for(int i = 0; i < 10; ++i) {
        futures.push_back(pool.submit([](int i) {
            std::cout << "Task " << i << " is running" << std::endl;
            std::this_thread::sleep_for(std::chrono::milliseconds(1000));
            return i;
        }, i));
    }
    for(auto& future: futures) {
        std::cout << "Task result: " << future.get() << std::endl;
    }
    return 0;
}

基于异步I/O的服务器设计

异步I/O是一种无需阻塞等待I/O操作完成即可进行其他操作的技术。C++11提供了std::async和std::future等工具来简化异步编程。

以下是一个基于异步I/O的服务器示例：

#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <cstring>
#include <vector>
#include <future>

std::mutex server_mutex;

class AsyncServer {
public:
    void start() {
        int server_fd, new_socket, valread;
        struct sockaddr_in address;
        int opt = 1;
        int addrlen = sizeof(address);
        char buffer[1024] = {0};
        std::string message = "Hello from server";

        server_fd = socket(AF_INET, SOCK_STREAM, 0);
        if (server_fd == 0) {
            std::cerr << "Socket failed\n";
            return;
        }

        address.sin_family = AF_INET;
        address.sin_addr.s_addr = INADDR_ANY;
        address.sin_port = htons(8080);

        if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
            std::cerr << "Setsockopt failed\n";
            return;
        }

        if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
            std::cerr << "Bind failed\n";
            return;
        }

        if (listen(server_fd, 3) < 0) {
            std::cerr << "Listen failed\n";
            return;
        }

        while (true) {
            new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen);
            if (new_socket < 0) {
                std::cerr << "Accept failed\n";
                continue;
            }

            std::future<void> future = std::async(std::launch::async, [new_socket, &message]() {
                valread = read(new_socket, buffer, 1024);
                std::string client_message(buffer);
                std::cout << "Client message: " << client_message << std::endl;

                send(new_socket, message.c_str(), message.length(), 0);
                close(new_socket);
            });
        }
    }
};

int main() {
    AsyncServer server;
    server.start();
    return 0;
}

错误处理与调试技巧

常见错误及其解决方法

在服务器编程中，常见的错误包括：

内存泄漏：可以通过使用智能指针如std::shared_ptr和std::unique_ptr来避免内存泄漏。
死锁：使用适当的锁策略，并确保锁的顺序一致。
资源限制：检查系统资源限制，如文件描述符数量。
网络错误：确保网络配置正确，如防火墙设置、IP地址和端口。

使用调试工具进行调试

调试是程序开发中不可或缺的一部分。C++11支持多种调试工具，包括GDB、Visual Studio Debugger等。

以下是一个使用GDB进行调试的基本步骤：

编译代码时添加调试信息：
```
g++ -std=c++11 -g -o server server.cpp
```
启动GDB：
```
gdb ./server
```
设置断点：
```
(gdb) break Server::start
```
运行程序：
```
(gdb) run
```
单步执行：
```
(gdb) step
```
打印变量：
```
(gdb) print server_fd
```

实战：构建一个完整的服务器应用

设计一个小型聊天室服务器

设计一个简单的聊天室服务器，它可以接收多个客户端连接，并转发消息到所有其他客户端。

服务器端代码

#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <cstring>
#include <vector>
#include <map>

std::mutex server_mutex;
std::map<int, std::string> client_addresses;

class Server {
public:
    void start() {
        int server_fd, new_socket, valread;
        struct sockaddr_in address, client_address;
        int opt = 1;
        int addrlen = sizeof(address);
        char buffer[1024] = {0};

        server_fd = socket(AF_INET, SOCK_STREAM, 0);
        if (server_fd == 0) {
            std::cerr << "Socket failed\n";
            return;
        }

        address.sin_family = AF_INET;
        address.sin_addr.s_addr = INADDR_ANY;
        address.sin_port = htons(8080);

        if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
            std::cerr << "Setsockopt failed\n";
            return;
        }

        if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
            std::cerr << "Bind failed\n";
            return;
        }

        if (listen(server_fd, 3) < 0) {
            std::cerr << "Listen failed\n";
            return;
        }

        while (true) {
            new_socket = accept(server_fd, (struct sockaddr *)&client_address, (socklen_t*)&addrlen);
            if (new_socket < 0) {
                std::cerr << "Accept failed\n";
                continue;
            }

            std::string client_address_str = inet_ntoa(client_address.sin_addr);
            client_addresses[new_socket] = client_address_str;

            std::thread client_thread([new_socket, this]() {
                char buffer[1024] = {0};
                std::string message;
                std::string client_address_str = client_addresses[new_socket];

                while (true) {
                    valread = read(new_socket, buffer, 1024);
                    if (valread <= 0) {
                        std::cout << "Client " << client_address_str << " disconnected\n";
                        break;
                    }

                    message = buffer;
                    std::cout << "Client " << client_address_str << " sent: " << message << std::endl;

                    for (auto& [socket, address] : client_addresses) {
                        if (socket != new_socket) {
                            send(socket, buffer, valread, 0);
                        }
                    }
                }

                close(new_socket);
                client_addresses.erase(new_socket);
            });
            client_thread.detach();
        }
    }
};

int main() {
    Server server;
    server.start();
    return 0;
}

客户端代码

#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <cstring>
#include <vector>

std::mutex client_mutex;

void send_message(int socket) {
    std::string message;
    while (true) {
        std::cin >> message;
        send(socket, message.c_str(), message.length(), 0);
    }
}

int main() {
    int client_socket;
    struct sockaddr_in server_address;
    int opt = 1;

    client_socket = socket(AF_INET, SOCK_STREAM, 0);
    if (client_socket == 0) {
        std::cerr << "Socket failed\n";
        return 1;
    }

    server_address.sin_family = AF_INET;
    server_address.sin_addr.s_addr = INADDR_ANY;
    server_address.sin_port = htons(8080);

    if (connect(client_socket, (struct sockaddr *)&server_address, sizeof(server_address)) < 0) {
        std::cerr << "Connect failed\n";
        return 1;
    }

    std::thread send_thread(send_message, client_socket);
    send_thread.detach();

    char buffer[1024] = {0};
    while (true) {
        int valread = read(client_socket, buffer, 1024);
        std::cout << "Received: " << buffer << std::endl;
    }

    close(client_socket);
    return 0;
}

测试和优化服务器性能

测试

多客户端连接：使用多个客户端同时连接到服务器，测试服务器的并发处理能力。
消息传递延迟：测试在高负载下消息传递的延迟。
资源利用率：监控服务器的CPU和内存使用情况。

优化

优化线程池：通过调整线程池的大小来平衡并发处理能力和资源消耗。
减少锁竞争：使用更细粒度的锁或无锁数据结构来减少锁竞争。
异步I/O：使用异步I/O技术减少阻塞，提高响应速度。
消息队列：使用消息队列减少直接的网络通信，提高服务器的稳定性和性能。

點(diǎn)擊查看更多內(nèi)容

為 TA 點(diǎn)贊

若覺(jué)得本文不錯(cuò)，就分享一下吧！

評(píng)論

評(píng)論

共同學(xué)習(xí)，寫(xiě)下你的評(píng)論

評(píng)論加載中...

展開(kāi)查看更多評(píng)論

作者其他優(yōu)質(zhì)文章

正在加載中

POPMUISE

手記
篇

粉絲

80

獲贊與收藏

426

關(guān)注作者，訂閱最新文章

閱讀免費(fèi)教程

Linux 入門(mén)教程

50個(gè)小節(jié) 102888 1465

Android Studio 編輯器教程

40個(gè)小節(jié) 12081 251

后端通用面試教程

41個(gè)小節(jié) 32040 357

推薦

評(píng)論

收藏

共同學(xué)習(xí)，寫(xiě)下你的評(píng)論



感謝您的支持，我會(huì)繼續(xù)努力的～

掃碼打賞，你說(shuō)多少就多少

贊賞金額會(huì)直接到老師賬戶

支付方式

打開(kāi)微信掃一掃，即可進(jìn)行掃碼打賞哦

今天注冊(cè)有機(jī)會(huì)得

100積分直接送

付費(fèi)專欄免費(fèi)學(xué)

大額優(yōu)惠券免費(fèi)領(lǐng)

立即參與放棄機(jī)會(huì)

點(diǎn)擊
抽獎(jiǎng)

慕課手記新用戶專享福利

恭喜你，你的運(yùn)氣太好了，居然抽中了 100個(gè)積分！

恭喜你，抽中了價(jià)值元的專欄！

太棒了，直接落到你賬戶里！

積分商城里的羅技鼠標(biāo)、機(jī)械鍵盤(pán)、
Kindle 閱讀器、小米平衡車(chē)
Apple iPad （10.2英寸）、大額優(yōu)惠券
在等著你去兌換了噢

作者：

免費(fèi)贈(zèng)送

兌換碼：1111222211 復(fù)制

優(yōu)惠券可用于購(gòu)買(mǎi)實(shí)戰(zhàn)課、體系課
無(wú)門(mén)檻使用

先去看看，有什么好東西馬上兌換


第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

熱搜

最近搜索清空