3

私は優れたwebsocketppライブラリを使用して、C++ アプリケーションで Websocket (および HTTP) サーバーを提供しています。REST API に接続するには、同じアプリに HTTP クライアントも必要です。私は websocketpp でもこれを試みてきましたが、これまでのところほとんど成功していません。次の予備試行により、次のログ出力が得られます。

[2015-03-06 18:01:18] [connect] Successful connection
[2015-03-06 18:01:18] [error] Server handshake response error: websocketpp.processor:20 (Invalid HTTP status.)
[2015-03-06 18:01:18] [disconnect] Failed: Invalid HTTP status.

これは、http_ハンドラー メソッドにさらに何かが必要な可能性があることを示唆しています。アドバイスをいただければ幸いです。websocketpp のドキュメントと例には、単純な HTTP クライアントが含まれていないようです。

#define _WEBSOCKETPP_CPP11_STL_
#include <websocketpp/config/asio_client.hpp>
#include <websocketpp/client.hpp>
#include <websocketpp/common/thread.hpp>

namespace {

using namespace websocketpp;
typedef client<websocketpp::config::asio_client> client;

class Client {
public:

    Client(void){
        client_.init_asio();
        client_.set_http_handler(bind(&Client::http_,this,_1));
    }

    std::string get(const std::string& url) {
        websocketpp::lib::error_code error;
        client::connection_ptr con = client_.get_connection(url,error);
        if(error) std::runtime_error("Unable to connnect.\n  url: "+url+"\n  message: "+error.message());
        client_.connect(con);
        websocketpp::lib::thread asio_thread(&client::run, &client_);
        asio_thread.join();
        return data_;
    }

private:

    void http_(connection_hdl hdl){
        std::cout<<"Connected\n";
        data_ = "http payload";
    }

    client client_;
    std::string data_;
};

}

int main(void){
    Client client;
    client.get("http://google.com/");
}
4

3 に答える 3

6

WebSocket++ の HTTP 処理機能は、WebSocket サーバーが限られた容量で HTTP 応答を提供できるように設計された便利な機能です。WebSocket++ は、一般的な HTTP ライブラリとして使用することを意図しておらず、(WebSocket 以外の) HTTP クライアントの役割を果たす機能は含まれていません。

HTTP クライアント機能に別のライブラリ (cpp-netlib など) を使用することは、適切なソリューションです。

于 2015-04-02T14:14:42.837 に答える
2

C++ で WebSocket と HTTP の両方を実行しようとしている場合は、これらの両方を備えた Beast という優れたライブラリがあります。そのオープン ソースと Boost.Asio のビルド: https://github.com/vinniefalco/Beast/

コード例を次に示します。

HTTP を使用して Web サイトからルート ページを要求し、応答を出力します。

#include <beast/http.hpp>
#include <boost/asio.hpp>
#include <iostream>
#include <string>

int main()
{
    // Normal boost::asio setup
    std::string const host = "boost.org";
    boost::asio::io_service ios;
    boost::asio::ip::tcp::resolver r(ios);
    boost::asio::ip::tcp::socket sock(ios);
    boost::asio::connect(sock,
        r.resolve(boost::asio::ip::tcp::resolver::query{host, "http"}));

    // Send HTTP request using beast
    beast::http::request_v1<beast::http::empty_body> req;
    req.method = "GET";
    req.url = "/";
    req.version = 11;
    req.headers.replace("Host", host + ":" + std::to_string(sock.remote_endpoint().port()));
    req.headers.replace("User-Agent", "Beast");
    beast::http::prepare(req);
    beast::http::write(sock, req);

    // Receive and print HTTP response using beast
    beast::streambuf sb;
    beast::http::response_v1<beast::http::streambuf_body> resp;
    beast::http::read(sock, sb, resp);
    std::cout << resp;
}

WebSocket 接続を確立し、メッセージを送信して応答を受信します。

#include <beast/to_string.hpp>
#include <beast/websocket.hpp>
#include <boost/asio.hpp>
#include <iostream>
#include <string>

int main()
{
    // Normal boost::asio setup
    std::string const host = "echo.websocket.org";
    boost::asio::io_service ios;
    boost::asio::ip::tcp::resolver r(ios);
    boost::asio::ip::tcp::socket sock(ios);
    boost::asio::connect(sock,
        r.resolve(boost::asio::ip::tcp::resolver::query{host, "80"}));

    // WebSocket connect and send message using beast
    beast::websocket::stream<boost::asio::ip::tcp::socket&> ws(sock);
    ws.handshake(host, "/");
    ws.write(boost::asio::buffer("Hello, world!"));

    // Receive WebSocket message, print and close using beast
    beast::streambuf sb;
    beast::websocket::opcode op;
    ws.read(op, sb);
    ws.close(beast::websocket::close_code::normal);
    std::cout << to_string(sb.data()) << "\n";
}
于 2016-06-04T12:00:31.207 に答える
-2

websocketppクライアントが を要求しないようにする方法がわからなかったので、代わりに HTTP クライアントにcpp-netlibUpgrade: connectionを使用することになりました。

于 2015-03-15T19:59:48.877 に答える