///////////////////////////////////////////////////////////////////////// // StringClient.cpp - Demonstrates simple one-way string messaging // // // // Jim Fawcett, CSE687 - Object Oriented Design, Spring 2016 // // Application: OOD Project #4 // // Platform: Visual Studio 2017, Dell XPS 8920, Windows 10 pro // ///////////////////////////////////////////////////////////////////////// /* * This package implements a client that sends string messages * to a server that simply displays them. * * It's purpose is to provide a very simple illustration of how to use * the Socket Package provided for Project #4. * * Required Files: * --------------- * StringClient.cpp, StringServer.cpp * Sockets.h, Sockets.cpp * Logger.h, Logger.cpp, Cpp11-BlockingQueue.h * StringUtilities.h, StringUtilities.cpp * * Maintenance History: * -------------------- * ver 1.1 : 19 Mar 2018 * - updated to use Sockets, ver 5.3 * ver 1.0 : 04 Apr 2016 * - first release */ #include "../Sockets/Sockets.h" #include "../Logger/Logger.h" #include "../Utilities/StringUtilities/StringUtilities.h" #include "../Utilities/CodeUtilities/CodeUtilities.h" #include #include #include using Show = StaticLogger<1>; using namespace Utilities; using namespace Sockets; ///////////////////////////////////////////////////////////////////// // ClientCounter creates a sequential number for each client // class ClientCounter { public: ClientCounter() { ++clientCount; } size_t count() { return clientCount; } private: static size_t clientCount; }; size_t ClientCounter::clientCount = 0; ///////////////////////////////////////////////////////////////////// // StringClient class // - was created as a class so more than one instance could be // run on child thread // class StringClient { public: void execute(const size_t TimeBetweenMessages, const size_t NumMessages); }; void StringClient::execute(const size_t TimeBetweenMessages, const size_t NumMessages) { ClientCounter counter; size_t myCount = counter.count(); std::string myCountString = Utilities::Converter::toString(myCount); Show::attach(&std::cout); Show::start(); Show::title( "Starting String client" + myCountString + " on thread " + Utilities::Converter::toString(std::this_thread::get_id()) ); try { SocketSystem ss; SocketConnecter si; while (!si.connect("localhost", 8080)) { Show::write("\n client waiting to connect"); ::Sleep(100); } std::string msg; for (size_t i = 0; i < NumMessages; ++i) { msg = "message #" + Converter::toString(i + 1) + " from client" + myCountString; si.sendString(msg); Show::write("\n client" + myCountString + " sent \"" + msg + "\""); ::Sleep(TimeBetweenMessages); } msg = "quit"; si.sendString(msg); Show::write("\n client sent \"" + msg + "\""); Show::write("\n"); Show::write("\n All done folks"); } catch (std::exception& exc) { Show::write("\n Exeception caught: "); std::string exMsg = "\n " + std::string(exc.what()) + "\n\n"; Show::write(exMsg); } } int main() { Show::title("Demonstrating two String Clients each running on a child thread"); StringClient c1; std::thread t1( [&]() { c1.execute(100, 50); } // 50 messages 100 millisec apart ); StringClient c2; std::thread t2( [&]() { c2.execute(120, 50); } // 50 messages 120 millisec apart ); t1.join(); t2.join(); }
