boost 相关问题

Boost是一系列旨在用于C ++的高质量库。 Boost是免费的，通常被认为是“第二标准库”。

如何使用 add_vertex() 将自定义 vertex_descriptor 设置为自己的值 - Boost Graph Library

我正在学习 Boost Graph Library (BGL) 的工作原理，并使用以下示例来尝试根据文本文件中的某些数据创建图形。数据从文本文件中读入...

c++ graph boost boost-graph

回答 1 投票 0

如何修复“无法打开包含文件‘boost/config.hpp’：没有这样的文件或目录（包含目录覆盖：C:\Program Files oost oost_1_67_0）

我正在使用 MS VS 2017 Community，想要运行 Quantlib 和 Boost，请将 C:\Program Files oost oost_1_67_0 放入“In Include Directory”，将 C:\Program Files oost oost_1_67_0\libs 放入“Library Direct”。 ..

c++ boost

回答 2 投票 0

有人尝试过构建Boost.Json静态库吗？

我正在尝试构建 boost json 来获取 libboost_json.a 。尝试使用 --with-json 选项，但它永远不会生成 . 我的配置显示其正在构建，但我没有看到该库生成，输入我...

boost boost-build boost-json

回答 3 投票 0

如何将成员函数连接到 boost 信号

有没有办法避免使用 boost::bind 将成员函数附加到 boost::signal slot ？我可以让它工作的唯一方法是使用像这样的绑定： mysignal.connect(boost::bind(&m...

c++ boost boost-bind boost-signals2

回答 1 投票 0

返回包含 boost::multi_array 的自定义结构的函数

我有这个看似简单的代码，但 boost 抱怨尺寸不匹配： #包括 #包括 #include“boost/multi_array.hpp” 结构体 t_struct {

c++ boost boost-multi-array

回答 1 投票 0

通过 PCL 使用全局描述符（形状函数集合）进行 3D 对象识别

我正在开发一个使用点云库进行 3D 对象识别的系统。我想将 ESF 描述符应用于我本地存储的数据集。我将包含数据的文件夹提供给...

c++ boost point-cloud-library point-clouds

回答 1 投票 0

使用boost::push_relabel_max_flow

我在使用 boost::push_relabel_max_flow 计算给定图的最大流量时遇到问题。我编写了以下代码： std::map edge2rescap; 嘘...

c++ graph boost max-flow push-relabel

回答 1 投票 0

Boost.Test 检查指针是否为空

我有以下测试： BOOST_CHECK_NE(指针, nullptr); 编译失败的原因是 /xxx/include/boost/test/tools/detail/print_helper.hpp:50:14: 错误: ‘operato...

c++ c++11 boost boost.test

回答 3 投票 0

如何使用boost multi precision的gmp_int类型？

我正在尝试在 C++ 中使用 boost 多精度库，并且遇到了 gmp_int 类型的问题。我获得 boost 库的全部目的是用任意的值进行算术......

c++ boost

回答 1 投票 0

通过 MacPorts 在 MacOS 上使用 boost

我正在尝试在MacOS上构建一些使用boost（特别是boost_system）的软件。一切似乎都配置和构建正常，但是当它链接时出现错误： ld：库“boost_sy...

boost macports automake

回答 1 投票 0

我的服务器中 boost::asio async_connect 的问题是什么？

#包括 #包括 #包括 #包括 #包括 #包括 #include <iostream> #include <string> #include <boost/asio.hpp> #include <boost/asio/thread_pool.hpp> #include <boost/algorithm/string.hpp> #include <boost/bind.hpp> #include "http_server.hh" using namespace boost::asio; using ip::tcp; std::string desired_IP_address = "172.16.0.2"; // For example purposes class Session : public std::enable_shared_from_this<Session> { public: Session(ip::tcp::resolver& resolver,tcp::socket socket, tcp::socket client_socket) : socket_(std::move(socket)), resolver_(resolver), client_socket_(std::move(client_socket)) {} void start() { do_read(); } private: void do_read() { auto self(shared_from_this()); socket_.async_read_some( boost::asio::buffer(data_), [this, self](boost::system::error_code ec, std::size_t length) { if (!ec) { std::string request(data_.data(), length); path_ = extract_path(request); resolver_.async_resolve( ip::tcp::resolver::query("172.16.0.4", "5000"), [this,self](const boost::system::error_code& ec, ip::tcp::resolver::iterator it) { if (ec) { std::cout << "Error resolving " << "localhost" << ": " << ec.message()<< std::endl; return; } // For simplicity, we'll assume the first endpoint will always // be available. //std::cout << "localhost" << ": resolved to " << it->endpoint() // << std::endl; do_connect(it->endpoint()); }); //handle_request_async(path); } }); } void do_connect(const ip::tcp::endpoint& dest) { // Remember that the Asio library will make copies of parameters passed // by const reference, so it's ok to let the endpoint go out of scope // when this method returns. auto self(shared_from_this()); boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string("172.16.0.4"), 5000); client_socket_.async_connect(a endpoint, [this, self](const boost::system::error_code& ec) { if (ec) { std::cout << "Error connecting to " << "localhost"<< ": " << ec.message()<< std::endl; return; } //std::cout << "localhost" << ": connected to " // << client_socket_.remote_endpoint() << std::endl; do_send_http_get(); }); } void do_send_http_get() { auto self(shared_from_this()); // At minimum, the remote server needs to know the path being fetched // and the host serving that path. The latter is required because a // single server often hosts multiple domains. request_ = std::string("GET /") + " HTTP/1.1\r\nHost: " + "example.com" + "\r\n\r\n"; async_write( client_socket_, buffer(request_), [this,self](const boost::system::error_code& ec, std::size_t size) { if (ec) { std::cout << "Error sending GET " << ec<< std::endl; return; } //std::cout << "localhost" << ": sent " << size << " bytes"<< std::endl; do_recv_http_get_header(); }); } void do_recv_http_get_header() { // Since HTTP/1.1 is a text based protocol, most of it is human readable // by design. Notice how the "double end of line" character sequence // ("\r\n\r\n") is used to delimit message sections. auto self(shared_from_this()); async_read_until( client_socket_, response_, "\r\n\r\n", [this, self](const boost::system::error_code& ec, std::size_t size) { if (ec) { std::cout << "Error receiving GET header " << ec; return; } //std::cout << "localhost:5000" << ": received " << size << ", streambuf " // << response_.size(); // The asio::streambuf class can use multiple buffers // internally, so we need to use a special iterator to copy out // the header. std::string header( buffers_begin(response_.data()), buffers_begin(response_.data()) + size); response_.consume(size); //std::cout << "----------" << std::endl << "localhost:5000" // << ": header length " << header.size() << std::endl // << header << std::endl; // First we'll check for the explicit "Content-Length" length // field. This provides the exact body length in bytes. size_t pos = header.find("Content-Length: "); if (pos != std::string::npos) { size_t len = std::strtoul( header.c_str() + pos + sizeof("Content-Length: ") - 1, nullptr, 10); do_receive_http_get_body(len - response_.size()); return; } // The other alternative is a chunked transfer. There is a quick // way to determine the remaining length in this case. pos = header.find("Transfer-Encoding: chunked"); if (pos != std::string::npos) { do_receive_http_get_chunked_body(); return; } std::cout << "Unknown body length"; }); } void do_receive_http_get_body(size_t len) { // For "Content-Length" we know exactly how many bytes are left to // receive. auto self(shared_from_this()); async_read( client_socket_, response_, transfer_exactly(len), [this,self] (const boost::system::error_code& ec, std::size_t size) { handle_http_get_body(ec, size); }); } void do_receive_http_get_chunked_body() { // For chunked transfers the final body chunk will be terminated by // another "double end of line" delimiter. auto self(shared_from_this()); async_read_until( client_socket_, response_, "\r\n\r\n", [this,self] (const boost::system::error_code& ec, std::size_t size) { handle_http_get_body(ec, size); }); } void handle_http_get_body(const boost::system::error_code& ec, std::size_t size) { if (ec) { std::cout << "Error receiving GET body " << ec; return; } //std::cout << "localhost:5000" << ": received " << size << ", streambuf " // << response_.size(); // We can finally consume the body and print it out if desired. const auto& data = response_.data(); std::string response_body(buffers_begin(data), buffers_end(data)); response_.consume(size); //std::cout << "----------" << std::endl << "localhost:5000" << ": body length " // << response_body.size() << std::endl; //std::cout << response_body << std::endl; handle_request_async(); } void handle_request_async() { auto self(shared_from_this()); async_response([this,self](const std::string& response) { // std::cout << "path " << path_ << std::endl; // std::cout << response << std::endl; async_write(socket_, boost::asio::buffer(response), [this,self](boost::system::error_code ec, std::size_t /*length*/) { if (!ec) { //std::cout << "response" << std::endl; boost::system::error_code ignored_ec; socket_.shutdown(tcp::socket::shutdown_both, ignored_ec); } }); }); } void async_response(std::function<void(const std::string&)> callback) { // Assuming handle_request returns HTTP_Response asynchronously HTTP_Response* htmlResponse = handle_request(path_); //std::cout << "path: " << path << std::endl; std::string response = htmlResponse->body; //std::cout << "content: " << response << std::endl; callback(response); delete htmlResponse; } // Function to extract path from the HTTP request std::string extract_path(const std::string& request) { // Logic to extract path from the request string // Example logic: extracting the path after the GET method std::string path; //std::cout << request << std::endl; // Implement your path extraction logic here // Find the end of the request line (the first line of the HTTP request) std::size_t requestLineEnd = request.find("\r\n"); if (requestLineEnd != std::string::npos) { std::string requestLine = request.substr(0, requestLineEnd); // Split the request line into parts (method, path, protocol) std::vector<std::string> parts; boost::split(parts, requestLine, boost::is_any_of(" ")); // The second part typically contains the path (e.g., "GET /path HTTP/1.1") if (parts.size() >= 2) { path = parts[1]; // Extract the path from the request line } } return path; } tcp::socket socket_; tcp::socket client_socket_; std::array<char, 8192> data_; std::string path_; std::string request_; boost::asio::streambuf response_; ip::tcp::resolver& resolver_; }; class Server { public: Server(boost::asio::io_context& io_context, short port) : acceptor_(io_context, tcp::endpoint(boost::asio::ip::make_address(desired_IP_address), port)), //acceptor_(io_context, tcp::endpoint(tcp::v4(), port)), socket_(io_context), resolver_(io_context), client_socket_(io_context) { do_accept(); } private: void do_accept() { acceptor_.async_accept( socket_, [this] (boost::system::error_code ec) { if (!ec) { std::make_shared<Session>(resolver_, std::move(socket_), std::move(client_socket_))->start(); } do_accept(); }); } tcp::acceptor acceptor_; tcp::socket socket_; tcp::socket client_socket_; ip::tcp::resolver resolver_; }; int main() { try { boost::asio::io_context io_context; Server server(io_context, 8080); boost::asio::thread_pool pool(40); for (std::size_t i = 0; i < 40; ++i) boost::asio::post(pool, [&io_context]() { io_context.run(); }); pool.join(); } catch (std::exception& e) { std::cerr << "Exception: " << e.what() << std::endl; } return 0; } 我收到错误 “连接到本地主机时出错：无法分配请求的地址” 这是 async_connect 调用时的错误。当服务器固定到一个核心且该核心的 cpu_utilization 为 100% 时，我会收到此错误。还观察到吞吐量周期性下降。注意：此服务器与其尝试连接的服务器位于不同的 Linux 网络命名空间中还有一件事此问题仅在存在网络间命名空间通信时才会发生，而在同一 Linux 网络命名空间或本地主机上运行服务器时不会发生。 io_context.run() 已阻塞。您将其发布到同样多的服务线程 40 次，具有讽刺意味的是，确保零线程能够取得进一步的进展。看来您将 asio::threadpool 误认为是 boost::thread_group 之类的东西。相比之下，asio::threadpool已经is-aexecution_context，并且根据定义，所有线程都已经附加到池run服务。总而言之，更简单的 main 看起来像： int main() try { asio::thread_pool pool; Server server(pool.get_executor(), 8080); pool.join(); } catch (std::exception const& e) { std::cerr << "Exception: " << e.what() << std::endl; } 恐怕代码的其余部分有一些危险信号： async_response 需要 std::function，这有击败 Asio 执行者的风险你有很多线程。这本身就是一种反模式，但特别是因为没有任何操作使用链您正在运行定制的 HTTP 消息“解析”。更喜欢使用库（例如 Boost Beast）。具体来说，您的代码看起来不会处理 HTTP 1.1 功能每个接受动作都来自同一个client_socket_。那是...充其量没用确实没有任何理由“假设第一个端点有效”。只需使用asio::async_connect 当推送到了紧要关头时，我不清楚您是否只是简单地实现一个中继 HTTP 代理（它看起来很像）还是......一个通用的 HTTP 服务器。现在看起来很像您收到了一个请求，您将其转发到上游。但是，根据给定的代码，来自上游服务器的响应...被视为请求？！？然后将其输入 handle_request。看起来那段代码放错了地方。无论如何，这是我长时间研究这段代码并提出大量您可能会使用的改进的结果。我用替换了丢失的标题 http_server.hh using Request = http::request<http::string_body>; using Response = http::response<http::string_body>; http::message_generator handle_request(fs::path path) { std::cout << "path " << path << std::endl; path = fs::current_path() / path; // emulate virtual root, NOTE: not secure! if (exists(path) && fs::is_regular_file(path)) { http::response<http::file_body> res(http::status::ok, 11); error_code ec; res.body().open(path.c_str(), boost::beast::file_mode::scan, ec); std::cout << res.base() << std::endl; return res; } else { http::response<http::string_body> res(http::status::ok, 11); res.body() = "TODO:" + path.native(); std::cout << res << std::endl; return res; } } 这将通过发送该文件来响应与服务器工作目录中现有文件相对应的路径，否则带有请求路径的 TODO: 正文。住在Coliru #include <boost/asio.hpp> #include <boost/beast.hpp> #include <filesystem> #include <iostream> namespace asio = boost::asio; namespace http = boost::beast::http; namespace fs = std::filesystem; using asio::ip::tcp; using boost::system::error_code; // #include "http_server.hh" using Request = http::request<http::string_body>; using Response = http::response<http::string_body>; http::message_generator handle_request(fs::path path) { std::cout << "path " << path << std::endl; path = fs::current_path() / path; // emulate virtual root, NOTE: not secure! if (exists(path) && fs::is_regular_file(path)) { http::response<http::file_body> res(http::status::ok, 11); error_code ec; res.body().open(path.c_str(), boost::beast::file_mode::scan, ec); std::cout << res.base() << std::endl; return res; } else { http::response<http::string_body> res(http::status::ok, 11); res.body() = "TODO:" + path.native(); std::cout << res << std::endl; return res; } } struct Session : std::enable_shared_from_this<Session> { Session(tcp::socket socket) : downstream_{std::move(socket)} , upstream_{downstream_.get_executor()} , resolver_{downstream_.get_executor()} {} ~Session() { std::cerr << "Session closed" << std::endl; } void start() { std::cerr << "Accepted from " << downstream_.remote_endpoint() << std::endl; do_read(); } private: void do_read() { http::async_read( downstream_, downbuf_, request_, [this, self = shared_from_this()](error_code ec, size_t /*length*/) { std::cout << "Received " << ec.message() << ": " << request_.base() << std::endl; if (ec) return; path_ = request_.target(); auto host = request_.at(http::field::host); auto port = "http"; // TODO parse port from host? resolver_.async_resolve(host, port, [this, self](error_code ec, auto eps) { std::cout << "Resolved upstream: " << ec.message() << std::endl; if (ec) return; for (auto&& ep : eps) std::cout << " - candidate: " << ep.endpoint() << std::endl; asio::async_connect(upstream_, eps, [this, self](error_code ec, tcp::endpoint) { std::cout << "Connect upstream: " << ec.message() << std::endl; if (!ec) { std::cout << "upstream: " << upstream_.remote_endpoint() << std::endl; do_relay(); } }); }); }); } void do_relay() { #if true // keep the request as received from downstream_ #else // At minimum, server needs the path & host header request_ = Request{http::verb::get, "/", 11}; request_.set(http::field::host, "example.com"); #endif async_write(upstream_, request_, [this, self = shared_from_this()](error_code ec, size_t size) { std::cout << "Relayed upstream: " << ec.message() << std::endl; if (!ec) { std::cout << "sent to upstream: " << size << " bytes" << std::endl; do_recv_response(); } }); } void do_recv_response() { response_.clear(); http::async_read( upstream_, upbuf_, response_, [this, self = shared_from_this()](error_code ec, size_t /*size*/) { if (ec) { std::cout << "Error receiving GET header " << ec.message(); return; } std::cout << "-- Response headers -- " << response_.base() << std::endl; if (response_.has_content_length()) { std::cout << "-- Content-Length header = " << response_.at(http::field::content_length) << std::endl; } if (response_.chunked()) std::cout << "-- Received using chunked encoding" << std::endl; std::cout << "-- Actual Body Length: " << response_.body().length() << std::endl; std::cout << "-- Body: " << response_.body() << std::endl; // this looks REALY out of place boost::beast::async_write( // downstream_, handle_request(path_), [this, self = shared_from_this()](error_code ec, size_t /*length*/) { if (!ec) { // std::cout << "response" << std::endl; error_code ignored_ec; downstream_.shutdown(tcp::socket::shutdown_both, ignored_ec); } }); }); } tcp::socket downstream_; asio::streambuf downbuf_; tcp::socket upstream_; asio::streambuf upbuf_; Request request_; Response response_; std::string path_; tcp::resolver resolver_; }; struct Server { Server(asio::any_io_executor ex, uint16_t port, std::string bind_address = "172.16.0.2") : acceptor_(ex, tcp::endpoint(asio::ip::make_address(bind_address), port)) { do_accept(); } private: void do_accept() { acceptor_.async_accept(make_strand(acceptor_.get_executor()), [this](error_code ec, tcp::socket s) { if (!ec) std::make_shared<Session>(std::move(s))->start(); do_accept(); }); } tcp::acceptor acceptor_; }; int main() try { asio::thread_pool pool; Server server(pool.get_executor(), 8080, "0.0.0.0"); pool.join(); } catch (std::exception const& e) { std::cerr << "Exception: " << e.what() << std::endl; } 带有本地互动演示：

c++ boost boost-asio

回答 1 投票 0

用于在本地主机上运行 boost asio 服务器的网络设置

我写了一个客户端client.cpp和一个服务器server.cpp，它们编译得很好。但我不知道如何将 client.cpp 连接到 localhost 中的 server.cpp 我用 Boost.Asio 编写了代码，它们编译...

c++ sockets boost boost-asio asio

回答 1 投票 0

/usr/bin/ld：找不到-lboost_python3

我已经安装了 libboost_python3 并尝试将其链接到我的程序，但出现此错误： /usr/bin/ld：找不到-lboost_python3 谁能帮我链接到lboost_python3？谢谢

python-3.x boost caffe pycaffe

回答 2 投票 0

对`boost::re_detail

我是catkin_make VINS-MONO，错误：对 `boost::re_detail` 的未定义引用对 `boost::filesystem::detail::directory_iterator 的未定义引用出来了，为什么？当我编译 VINS-...