gdax-orderbook-hpp/demo/dependencies/websocketpp-0.7.0/examples/echo_client/echo_client.cpp

   1 /*
   2  * Copyright (c) 2016, Peter Thorson. All rights reserved.
   3  *
   4  * Redistribution and use in source and binary forms, with or without
   5  * modification, are permitted provided that the following conditions are met:
   6  *     * Redistributions of source code must retain the above copyright
   7  *       notice, this list of conditions and the following disclaimer.
   8  *     * Redistributions in binary form must reproduce the above copyright
   9  *       notice, this list of conditions and the following disclaimer in the
  10  *       documentation and/or other materials provided with the distribution.
  11  *     * Neither the name of the WebSocket++ Project nor the
  12  *       names of its contributors may be used to endorse or promote products
  13  *       derived from this software without specific prior written permission.
  14  *
  15  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  16  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  17  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  18  * ARE DISCLAIMED. IN NO EVENT SHALL PETER THORSON BE LIABLE FOR ANY
  19  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
  20  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  21  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
  22  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  23  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
  24  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  25  *
  26  */
  27
  28 #include <websocketpp/config/asio_no_tls_client.hpp>
  29 #include <websocketpp/client.hpp>
  30
  31 #include <iostream>
  32
  33 typedef websocketpp::client<websocketpp::config::asio_client> client;
  34
  35 using websocketpp::lib::placeholders::_1;
  36 using websocketpp::lib::placeholders::_2;
  37 using websocketpp::lib::bind;
  38
  39 // pull out the type of messages sent by our config
  40 typedef websocketpp::config::asio_client::message_type::ptr message_ptr;
  41
  42 // This message handler will be invoked once for each incoming message. It
  43 // prints the message and then sends a copy of the message back to the server.
  44 void on_message(client* c, websocketpp::connection_hdl hdl, message_ptr msg) {
  45     std::cout << "on_message called with hdl: " << hdl.lock().get()
  46               << " and message: " << msg->get_payload()
  47               << std::endl;
  48
  49
  50     websocketpp::lib::error_code ec;
  51
  52     c->send(hdl, msg->get_payload(), msg->get_opcode(), ec);
  53     if (ec) {
  54         std::cout << "Echo failed because: " << ec.message() << std::endl;
  55     }
  56 }
  57
  58 int main(int argc, char* argv[]) {
  59     // Create a client endpoint
  60     client c;
  61
  62     std::string uri = "ws://localhost:9002";
  63
  64     if (argc == 2) {
  65         uri = argv[1];
  66     }
  67
  68     try {
  69         // Set logging to be pretty verbose (everything except message payloads)
  70         c.set_access_channels(websocketpp::log::alevel::all);
  71         c.clear_access_channels(websocketpp::log::alevel::frame_payload);
  72
  73         // Initialize ASIO
  74         c.init_asio();
  75
  76         // Register our message handler
  77         c.set_message_handler(bind(&on_message,&c,::_1,::_2));
  78
  79         websocketpp::lib::error_code ec;
  80         client::connection_ptr con = c.get_connection(uri, ec);
  81         if (ec) {
  82             std::cout << "could not create connection because: " << ec.message() << std::endl;
  83             return 0;
  84         }
  85
  86         // Note that connect here only requests a connection. No network messages are
  87         // exchanged until the event loop starts running in the next line.
  88         c.connect(con);
  89
  90         // Start the ASIO io_service run loop
  91         // this will cause a single connection to be made to the server. c.run()
  92         // will exit when this connection is closed.
  93         c.run();
  94     } catch (websocketpp::exception const & e) {
  95         std::cout << e.what() << std::endl;
  96     }
  97 }