Socket库助力C++实现P2P通信

在C++中，使用Socket库可以实现P2P（点对点）通信

1. 首先，确保已经安装了Boost库。Boost库是一个广泛使用的C++库，提供了许多实用的功能，包括网络编程。你可以从这里下载Boost库：https://www.boost.org/users/download/

2. 创建一个C++项目，并将Boost库添加到项目中。具体操作方法取决于你使用的IDE（如Visual Studio、GCC等）。

3. 在项目中包含Boost库的头文件。例如，使用Boost.Asio库，你需要在源文件中包含以下头文件：

#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>

4. 定义一个简单的P2P通信类，如下所示：

class Peer {
public:
    Peer(boost::asio::io_service& io_service, const std::string& ip, unsigned short port)
        : io_service_(io_service), socket_(io_service) {
        boost::asio::ip::tcp::resolver resolver(io_service_);
        boost::asio::ip::tcp::resolver::query query(ip, std::to_string(port));
        boost::asio::ip::tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);

        boost::asio::connect(socket_, endpoint_iterator);
    }

    void send_message(const std::string& message) {
        boost::asio::write(socket_, boost::asio::buffer(message));
    }

    std::string receive_message() {
        char buffer[1024];
        size_t length = socket_.read_some(boost::asio::buffer(buffer), boost::asio::error::eof);
        return std::string(buffer, length);
    }

private:
    boost::asio::io_service& io_service_;
    boost::asio::ip::tcp::socket socket_;
};

5. 在主函数中创建两个Peer对象，分别表示两个P2P通信端，并进行消息传递：

int main() {
    try {
        boost::asio::io_service io_service;

        Peer peer1(io_service, "127.0.0.1", 12345);
        Peer peer2(io_service, "127.0.0.1", 12346);

        peer1.send_message("Hello from Peer 1!");
        std::string message = peer2.receive_message();
        std::cout << "Received message: " << message << std::endl;

        peer2.send_message("Hello from Peer 2!");
        message = peer1.receive_message();
        std::cout << "Received message: " << message << std::endl;

    } catch (std::exception& e) {
        std::cerr << "Exception: " << e.what() << std::endl;
    }

    return 0;
}

这个简单的示例展示了如何使用Boost.Asio库创建一个P2P通信应用。你可以根据需要扩展这个示例，例如添加更多的错误处理、协议解析等功能。