开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 金融证券系统 > 查看源码
response.h
资源名称：stkdataengine.rar　[点击查看]
上传用户：egreat
上传日期：2007-07-13
资源大小：29k
文件大小：2k
源码类别：

金融证券系统

开发平台：

Visual C++

response.h：源码内容
  2. #ifndef _RESPONSE_H
  3. #define _RESPONSE_H
  5. #include <set>
  6. #include <map>
  7. #include <boost/thread/thread.hpp>
  8. #include <boost/thread/recursive_mutex.hpp>
  9. #include <loki/singleton.h>
  10. #include <loki/Factory.h>
  12. namespace StockMarket
  13. {
  14. using namespace std;
  15. using namespace boost;
  16. using namespace Loki;
  18. extern recursive_mutex res_fact_mutex;
  20. typedef set<string> StringSet;
  21. typedef map <int, StringSet> IntStringSetMap; // 股票板块列表
  23. class StockRes
  24. {
  25. public:
  26. StockRes();
  27. StockRes(uchar* pData, ulong data_len);
  28. virtual ~StockRes();
  29. uint read(const uchar* pData, ulong data_len);
  30. ulong buff_left();
  31. bool end();
  32. void reset();
  33. virtual void operator()() = 0;
  34. ushort get_packet_len();
  35. static ushort get_packet_len(const uchar*);
  36. uint get_seq_id();
  37. static uint get_seq_id(const uchar*);
  38. ushort get_cmd_id();
  39. static ushort get_cmd_id(const uchar*);
  40. protected:
  41. void skip_byte(ulong count);
  42. void skip_data(ulong count);
  43. char get_char();
  44. uchar get_uchar();
  45. short get_short();
  46. ushort get_ushort();
  47. int  get_int();
  48. uint  get_uint();
  49. float get_float();
  50. int parse_data();
  51. int parse_data2();
  52. protected:
  53. const uchar* raw_data; // the raw data passed in 
  54. ulong raw_len; // the raw data len
  55. const uchar* data; // payload data, 
  56. ulong len; // payload len
  57. const uchar* current; // pointer to parse
  58. ulong left; // len left unparsed
  59. private:
  60. void umcompress_if();
  61. bool  dataNew;
  63. };
  65. class StockHeartBeatRes: public StockRes
  66. {
  67. public:
  68. void operator()();
  69. };
  71. class StockListRes: public StockRes
  72. {
  73. public:
  74. StockListRes();
  75. StockListRes(uchar* pData, ulong data_len);
  76. void operator()();
  77. };
  79. class StockHoldChgRes: public StockRes
  80. {
  81. public:
  82. StockHoldChgRes();
  83. StockHoldChgRes(uchar* pData, ulong data_len);
  84. void operator()();
  85. private:
  86. };
  88. typedef Factory< StockRes, int > RespFct_t;
  89. typedef SingletonHolder<RespFct_t> ResponseFactory;
  91. struct StockResWrongData : public std::exception
  92. {
  93. StockResWrongData(int i = 0);
  94. virtual const char *what( ) const throw();
  95. int n_;
  96. };
  98. extern  void ProcessResponsePacket(const uchar * pData , size_t len, bool test);
  100. extern StockRes* CreateStockListRes();
  101. extern StockRes* CreateStockHoldChgRes();
  102. extern StockRes* CreateStockHeartBeatRes();
  105. }
  106. #endif