/* * main.c * * Created on: 2019��3��13�� * Author: root */ #include "../Sers/Mq/SocketMq/ClientMq.h" #include #include "../Sers/Core/Module/Api/ApiClient.hpp" #include "../Sers/Core/Module/Log/Logger.hpp" #include "../Sers/Core/Util/Common/CommonHelp.hpp" #include "../Sers/Core/Util/ConfigurationManager/JsonFile.hpp" ////////////////////////////////////////////////////////////////// // Logger test using namespace Sers::Core::Util::ConfigurationManager; using namespace Sers::Core::Module::Log; void LoggerTest(){ //(x.1) Logger Logger::Info("start"); Logger::Error("throws exception"); Sers::Core::Module::Log::Logger::Error("fail"); //(x.2)ConfigurationManager string t3=JsonFile::ConfigurationManager.GetStringByPath("Sers.test"); //(x.3)JsonFile Sers::Core::Util::ConfigurationManager::JsonFile json("appsettings.json"); string t2=json.GetStringByPath("Sers.test"); } // Logger test ////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////// // Mq test using namespace std; using namespace Sers::Core::Data; void OnReceiveRequest(Sers::Mq::SocketMq::MqConnect & mq,const ArraySegment & requestData,ByteData & replyData ) { replyData.InsertData(requestData); } Sers::Core::Util::Threading::AutoResetEvent mEvent; void OnDisConnected() { printf("mq stoped"); mEvent.Set(); } void MqTest(){ Sers::Mq::SocketMq::ClientMq mq; //mq.config.host="192.168.10.100"; mq.config.host="127.0.0.1"; mq.config.port=4501; mq.config.secretKey="SersSocketMq"; mq.OnDisConnected_Set(&OnDisConnected); mq.OnReceiveRequest_Set(OnReceiveRequest); if(!mq.Connect()) { printf("���ӷ����� fail. exit"); return ; } printf("mq connect succeed! "); mEvent.WaitOne(); printf("main stoped"); } // Mq test //////////////////////////////////////////////////////////////////