. . . . . . . . . . . . . . . . . . . . . . . .
\n. . . . . . . . . . . . . . . . . . . . . . . .
\n. . . . . . . . . . . . . . . . . . . . . . . .<\/p>\n
docker run --detach -p 10001:8080 jmalloc\/echo-server<\/code><\/pre>\nclient<\/h2>\n#include <websocketpp\/config\/asio_no_tls_client.hpp>\n\n#include <websocketpp\/client.hpp>\n\n#include <iostream>\n\ntypedef websocketpp::client<websocketpp::config::asio_client> client;\n\nusing websocketpp::lib::placeholders::_1;\nusing websocketpp::lib::placeholders::_2;\nusing websocketpp::lib::bind;\n\n\/\/ pull out the type of messages sent by our config\ntypedef websocketpp::config::asio_client::message_type::ptr message_ptr;\n\n\/\/ Handlers\nvoid on_open(client* c, websocketpp::connection_hdl hdl) {\n std::string msg = "Hello";\n c->send(hdl,msg,websocketpp::frame::opcode::text);\n c->get_alog().write(websocketpp::log::alevel::app, "Sent Message: "+msg);\n}\n\nvoid on_fail(client* c, websocketpp::connection_hdl hdl) {\n c->get_alog().write(websocketpp::log::alevel::app, "Connection Failed");\n}\n\nvoid on_message(client* c, websocketpp::connection_hdl hdl, message_ptr msg) {\n c->get_alog().write(websocketpp::log::alevel::app, "Received Reply: "+msg->get_payload());\n c->close(hdl,websocketpp::close::status::normal,"");\n}\n\nvoid on_close(client* c, websocketpp::connection_hdl hdl) {\n c->get_alog().write(websocketpp::log::alevel::app, "Connection Closed");\n}\n\nint main(int argc, char* argv[]) {\n client c;\n\n std::string uri = "ws:\/\/localhost:9002";\n\n if (argc == 2) {\n uri = argv[1];\n }\n\n try {\n \/\/ set logging policy if needed\n c.clear_access_channels(websocketpp::log::alevel::frame_header);\n c.clear_access_channels(websocketpp::log::alevel::frame_payload);\n \/\/c.set_error_channels(websocketpp::log::elevel::none);\n\n \/\/ Initialize ASIO\n c.init_asio();\n\n \/\/ Register our handlers\n c.set_open_handler(bind(&on_open,&c,::_1));\n c.set_fail_handler(bind(&on_fail,&c,::_1));\n c.set_message_handler(bind(&on_message,&c,::_1,::_2));\n c.set_close_handler(bind(&on_close,&c,::_1));\n\n \/\/ Create a connection to the given URI and queue it for connection once\n \/\/ the event loop starts\n websocketpp::lib::error_code ec;\n client::connection_ptr con = c.get_connection(uri, ec);\n c.connect(con);\n\n \/\/ Start the ASIO io_service run loop\n c.run();\n } catch (const std::exception & e) {\n std::cout << e.what() << std::endl;\n } catch (websocketpp::lib::error_code e) {\n std::cout << e.message() << std::endl;\n } catch (...) {\n std::cout << "other exception" << std::endl;\n }\n}<\/code><\/pre>\nsudo apt install libwebsocketpp-dev\n\ng++ basic_client.cpp -lpthread\n.\/a.out http:\/\/localhost:10001\/.ws<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"