HashSaver.php 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. <?php
  2. namespace loyalsoft;
  3. /**
  4. * 对象字段将以hash表结构存入Redis中.
  5. * 以达到拆分读写各个子节点的目标, 最终能够节省(带宽、内存、运算)消耗,提升性能.
  6. * @author gwang
  7. * @version
  8. * 1.0.1 增加了一个stVer 记录存储次数. --gwang 2022.2.22
  9. * 1.0.0 创建. 2年以前就跟高健讨论过的理念,我一直没有落到实处(高健已经使用了). --gwang 2020.4.24
  10. */
  11. class HashSaver extends Object_ext {
  12. private static $save_tag = array();
  13. /**
  14. * 添加回存记录
  15. * @param type $name
  16. */
  17. protected static function save_tag($name) {
  18. self::$save_tag[] = $name;
  19. }
  20. /**
  21. * storeage version 存储版本(每写入一次+1)
  22. * @var int
  23. */
  24. public $stVer = 0;
  25. //
  26. // <editor-fold defaultstate="collapsed">
  27. /**
  28. * 自定义的数据加载方式
  29. * @param type $mem_key
  30. */
  31. function readDataFromMem($mem_key) {
  32. $ret = gMem()->hgetall($mem_key); # 已JSON解析
  33. if (null == $ret) {
  34. return $ret;
  35. }
  36. // my_Assert(null != $ret, ErrCode::err_mem); # 未找到数据
  37. $this->LoadFrom($ret);
  38. return $this;
  39. }
  40. /**
  41. * 存储数据到redis
  42. * @return boolean 是否成功
  43. */
  44. function updateDataFull($mem_key) {
  45. $this->stVer++;
  46. return gMem()->hmset_Cas($mem_key, $this);
  47. // return true;
  48. // return gMem()->hmset($mem_key, $this);
  49. }
  50. function dic() {
  51. $newdic = ArrayInit();
  52. foreach ($this as $k => $v) {
  53. $newdic[$k] = msgpack_pack($v);
  54. }
  55. return $newdic;
  56. }
  57. /**
  58. * 存储数据到redis(这个设计目的是只保存改变的部分)
  59. */
  60. function updateDataByTag($mem_key) {
  61. $data = array();
  62. foreach (self::$save_tag as $k) {
  63. $data[$k] = $this->$k;
  64. }
  65. $this->stVer++;
  66. $data['stVer'] = $this->stVer;
  67. return gMem()->hmset($mem_key, $data);
  68. }
  69. // </editor-fold>
  70. }