如何从套接字读取接收自定义数据类型？

Question

我想接收数据（自定义类型如 CMYType） 我有以下代码；

using namespace boost::asio;

streambuf receivedStreamBuffer;
streambuf::mutable_buffers_type bufs;
bufs = receivedStreamBuffer.prepare( sizeof(CMYType) );
std::size_t length = read( *m_pReciver->ConSocket(), 
                           buffer(bufs, sizeof(CMYType)),  
                           transfer_all(),
                           ec);

知道如何将 receivedStreamBuffer 转换为 CMYType 类型的对象吗？！

Answer 1

您的代码“可能”确实有效。但是，正如Christophe 所指出的，您需要考虑许多问题。

TCP/IP 编程

在您的评论中，您提到您是 TCP/IP 编程的新手。我建议你通读"Beej's guide to network programming"。这是一个简短的（大约 20 页）和体面的介绍，几乎涵盖了网络编程的所有方面，包括以下内容。值得花时间，而且是免费的。

字节序

这是网络通信的一般基本问题。如果您无法控制软件运行的机器，您绝对需要处理它。或者，如果您想要可移植的代码。 只有在您绝对确定通信的两台（所有）机器都具有相同架构时，您才可以跳过此步骤。

如果您需要了解更多问题，thesethreewebsites 是很好的起点。

序列化

序列化既是对问题的概括，也是可以解决上述问题的“灵丹妙药”（如果应用正确的话）。基本思想是将您的数据类型（结构）转换为“串行流”，可以通过任何通道（网络）传输并转换回您的类型。 Boost 有一个serialization library 可用于此目的。

Answer 2

请记住其他人提到的可移植性和 ABI 警告。

如果，正如您在评论中所说，您确定您的客户端和服务器在这些方面兼容：

对于 POD 数据

只要你的类型满足 POD 要求，你可以使用buffer_cast:

事实上，你可以使用buffer 函数将其隐式化：

Live On Coliru

#include <boost/asio.hpp>
#include <iostream>
#include <vector>
#include <boost/thread.hpp>

struct CMYType {
    float a,b,c;
};

static_assert(std::is_pod<CMYType>::value, "Not bitwise serializable");

static std::ostream& operator<<(std::ostream& os, CMYType const& cmy) {
    return os << "[" << cmy.a << "," << cmy.b << "," << cmy.c << "]";
}

static boost::mutex mx;

void server() {
    boost::system::error_code ec;
    using namespace boost::asio;

    io_service svc;
    ip::tcp::acceptor acc(svc, ip::tcp::endpoint{ {}, 6767 });

    {
        ip::tcp::socket sock(svc);
        acc.accept(sock, ec);

        CMYType data;
        std::size_t length = read(sock, buffer(&data, sizeof(data)), ec);
        boost::lock_guard<boost::mutex> lk(mx);
        std::cout << "length:" << length << " data: " << data << "\n";
    }

    {
        ip::tcp::socket sock(svc);
        acc.accept(sock, ec);

        std::vector<CMYType> data(10);
        std::size_t length = read(sock, buffer(data), ec);

        boost::lock_guard<boost::mutex> lk(mx);
        std::cout << "length:" << length << " data: { ";

        for(auto& cmy : data)
            std::cout << cmy << ", ";

        std::cout << " }\n";
    }
}

void client() {
    boost::system::error_code ec;
    using namespace boost::asio;

    io_service svc;

    {
        ip::tcp::socket sock(svc);
        sock.connect({ {}, 6767 }, ec);

        CMYType data { 1, 2, 3 };

        std::size_t length = write(sock, buffer(&data, sizeof(data)), ec);
        boost::lock_guard<boost::mutex> lk(mx);
        std::cout << "sent: " << length << " bytes\n";
    }

    {
        ip::tcp::socket sock(svc);
        sock.connect({ {}, 6767 }, ec);

        std::vector<CMYType> data { 
            { 1,  2,  3  }, { 4,  5,  6  }, { 7,  8,  9  }, { 10, 11, 12 }, { 13, 14, 15 },
            { 16, 17, 18 }, { 19, 20, 21 }, { 22, 23, 24 }, { 25, 26, 27 }, { 28, 29, 30 },
        };
        std::size_t length = write(sock, buffer(data), ec);

        boost::lock_guard<boost::mutex> lk(mx);
        std::cout << "sent: " << length << " bytes\n";
    }

}

int main() {
    boost::thread_group tg;
    tg.create_thread(server);
    tg.create_thread(client);

    tg.join_all();
}

打印

sent: 12 bytes
length:12 data: [1,2,3]
sent: 120 bytes
length:120 data: { [1,2,3], [4,5,6], [7,8,9], [10,11,12], [13,14,15], [16,17,18], [19,20,21], [22,23,24], [25,26,27], [28,29,30],  }

对于非 POD 数据

您可以使用例如Boost Serialization 对数据进行序列化