dispatch_communicator.h 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. //
  2. // Created by zx on 2020/7/21.
  3. //
  4. #ifndef NNXX_TESTS_DISPATCH_COMMUNICATOR_H
  5. #define NNXX_TESTS_DISPATCH_COMMUNICATOR_H
  6. #include "communication_socket_base.h"
  7. #include "singleton.h"
  8. #include "dispatch_message.pb.h"
  9. #include "error_code.h"
  10. #include "thread_safe_map.h"
  11. #include "message_compare.h"
  12. RegistoryCompare(message,message::Dispatch_request_msg)
  13. class Dispatch_communicator :public Singleton<Dispatch_communicator>, public Communication_socket_base
  14. {
  15. friend Singleton<Dispatch_communicator>;
  16. public:
  17. virtual ~Dispatch_communicator();
  18. Error_manager dispatch_request(message::Dispatch_request_msg& request,message::Dispatch_response_msg& result);
  19. /*
  20. * 提前取消请求
  21. */
  22. Error_manager cancel_request(message::Dispatch_request_msg& request);
  23. Error_manager check_statu();
  24. protected:
  25. Dispatch_communicator();
  26. virtual Error_manager encapsulate_msg(Communication_message* message);
  27. virtual Error_manager execute_msg(Communication_message* p_msg);
  28. /*
  29. * 检测消息是否可被处理
  30. */
  31. virtual Error_manager check_msg(Communication_message* p_msg);
  32. /*
  33. * 心跳发送函数,重载
  34. */
  35. virtual Error_manager encapsulate_send_data();
  36. //检查消息是否可以被解析, 需要重载
  37. virtual Error_manager check_executer(Communication_message* p_msg);
  38. /*
  39. * 根据接收到的response,生成对应的 request
  40. */
  41. message::Dispatch_request_msg create_request_by_response(message::Dispatch_response_msg& msg);
  42. private:
  43. thread_safe_map<message::Dispatch_request_msg,message::Dispatch_response_msg> m_response_table;
  44. };
  45. #endif //NNXX_TESTS_DISPATCH_COMMUNICATOR_H