include "libIXWebSocket/libIXWebSocket.h"
ix::WebSocketServer server(9000);
server.setOnClientMessageCallback(
[](std::shared_ptr<ix::ConnectionState> connectionState,
ix::WebSocket& webSocket,
const ix::WebSocketMessagePtr& msg)
{
if (msg->type == ix::WebSocketMessageType::Message)
{
std::cout << msg->str << std::endl;
std::cout << connectionState->getRemotePort() << std::endl;
webSocket.send("echo: " + msg->str + ",port:" + std::to_string(connectionState->getRemotePort()));
}
});
auto res = server.listen();
if (!res.first)
{
std::cout << res.second << std::endl;
return 1;
}
server.start();
while (true)
{
Sleep(1000);
}