Home Explore Help
Sign In
wk
/
Project
1
0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Branch: dispatch_2
Branches Tags
Project
/
plc调度节点
/
system
/
system_communication.h

system_communication.h 2.5 KB
Permalink History Raw

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 
  1. //
    2. 

  2. // Created by huli on 2020/6/28.
    3. 

  3. //
    4. 

  4. 

  5. #ifndef NNXX_TESTS_SYSTEM_COMMUNICATION_H
    6. 

  6. #define NNXX_TESTS_SYSTEM_COMMUNICATION_H
    7. 

  7. 

  8. #include "../tool/singleton.h"
    9. 

  9. //#include "../communication/communication_socket_base.h"
    10. 

  10. #include "../rabbitmq/rabbitmq_base.h"
    11. 

  11. 

  12. #define RABBITMQ_PARAMETER_PATH_A "rabbitmq_a.prototxt"
    13. 

  13. #define RABBITMQ_PARAMETER_PATH_B "rabbitmq_b.prototxt"
    14. 

  14. #define RABBITMQ_PARAMETER_PATH_C "rabbitmq_c.prototxt"
    15. 

  15. #define RABBITMQ_PARAMETER_PATH_A1	"rabbitmq_a1.prototxt"
    16. 

  16. #define RABBITMQ_PARAMETER_PATH_A2	"rabbitmq_a2.prototxt"
    17. 

  17. #define RABBITMQ_PARAMETER_PATH_A3	"rabbitmq_a3.prototxt"
    18. 

  18. #define RABBITMQ_PARAMETER_PATH_A4	"rabbitmq_a4.prototxt"
    19. 

  19. #define RABBITMQ_PARAMETER_PATH_B1	"rabbitmq_b1.prototxt"
    20. 

  20. #define RABBITMQ_PARAMETER_PATH_B2	"rabbitmq_b2.prototxt"
    21. 

  21. #define RABBITMQ_PARAMETER_PATH_B3	"rabbitmq_b3.prototxt"
    22. 

  22. #define RABBITMQ_PARAMETER_PATH_B4	"rabbitmq_b4.prototxt"
    23. 

  23. #define RABBITMQ_PARAMETER_PATH_B5	"rabbitmq_b5.prototxt"
    24. 

  24. #define RABBITMQ_PARAMETER_PATH_C1	"rabbitmq_c1.prototxt"
    25. 

  25. #define RABBITMQ_PARAMETER_PATH_C2	"rabbitmq_c2.prototxt"
    26. 

  26. 

  27. 

  28. class System_communication:public Singleton<System_communication>, public Rabbitmq_base
    29. 

  29. {
    30. 

  30. 

  31. // 子类必须把父类设定为友元函数，这样父类才能使用子类的私有构造函数。
    32. 

  32.    friend class Singleton<System_communication>;
    33. 

  33. private:
    34. 

  34.  // 父类的构造函数必须保护，子类的构造函数必须私有。
    35. 

  35.    System_communication();
    36. 

  36. public:
    37. 

  37.     //必须关闭拷贝构造和赋值构造，只能通过 get_instance 函数来进行操作唯一的实例。
    38. 

  38.     System_communication(const System_communication& other) = delete;
    39. 

  39.     System_communication& operator =(const System_communication& other) = delete;
    40. 

  40.     ~System_communication();
    41. 

  41. public://API functions
    42. 

  42. 	//初始化 通信 模块。如下三选一
    43. 

  43. 	virtual Error_manager communication_init();
    44. 

  44. 	virtual Error_manager communication_init(int dispatch_id);
    45. 

  45. 	//检查消息是否有效, 主要检查消息类型和接受者, 判断这条消息是不是给我的.
    46. 

  46. 	virtual Error_manager check_msg(Rabbitmq_message* p_msg);
    47. 

  47. 	//检查执行者的状态, 判断能否处理这条消息, 需要子类重载
    48. 

  48. 	virtual Error_manager check_executer(Rabbitmq_message* p_msg);
    49. 

  49. 	//处理消息, 需要子类重载
    50. 

  50. 	virtual Error_manager execute_msg(Rabbitmq_message* p_msg);
    51. 

  51. 

  52. 	//定时封装发送消息, 一般为心跳和状态信息, 需要子类重载
    53. 

  53. 	virtual Error_manager auto_encapsulate_status();
    54. 

  54. 

  55. public://get or set member variable
    56. 

  56. 

  57.     
    58. 

  58. protected://member variable 
    59. 

  59. 

  60.     
    61. 

  61. private:
    62. 

  62.     
    63. 

  63. };
    64. 

  64. 

  65. 

  66. #endif //NNXX_TESTS_SYSTEM_COMMUNICATION_H
    67.