www.adminn.cn
站长正能量分享网!

php缓存Memcache的Queue的用法

AD:阿里云服务器企业会员更优惠 腾讯云香港,韩国免备案服务器1.8折优惠

分享一篇关于php中缓存Memcache的Queue的用法,Memcache是一种缓存技术,可以提升程序的性能减轻服务器的压力,代码如下:

  1. <?php  
  2. class MQ{  
  3. public static $client;  
  4. private static $m_real;  
  5. private static $m_front;  
  6. private static $m_data = array();  
  7. const QUEUE_MAX_NUM = 100000000;  
  8. const QUEUE_FRONT_KEY = '_queue_item_front';  
  9. const QUEUE_REAL_KEY = '_queue_item_real';  
  10. public static function setupMq($conf) {  
  11. self::$client = memcache_pconnect($conf);  
  12. self::$m_real = memcache_get(self::$client, self::QUEUE_REAL_KEY);  
  13. self::$m_front = memcache_get(self::$client, self::QUEUE_FRONT_KEY);  
  14. if (!isset(self::$m_real) || emptyempty(self::$m_real)) {  
  15. self::$real= 0;  
  16. }  
  17. if (!isset(self::$m_front) || emptyempty(self::$m_front)) {  
  18. self::$m_front = 0;  
  19. }  
  20. return self::$client;  
  21. }  
  22. public static function add($queue$data) {  
  23. $result = false;  
  24. if (self::$m_real < self::QUEUE_MAX_NUM) {  
  25. if (memcache_add(self::$client$queue.self::$m_real$data)) {  
  26. self::mqRealChange();  
  27. $result = true;  
  28. }  
  29. }  
  30. return $result;  
  31. }  
  32. public static function get($key$count) {  
  33. $num = 0;  
  34. for ($i=self::$m_front;$i<self::$m_front + $count;$i++) {  
  35. if ($dataTmp = memcache_get(self::$client$key.$i)) {  
  36. self::$m_data[] = $dataTmp;  
  37. memcache_delete(self::$client$key.$i);  
  38. $num++;  
  39. }  
  40. }  
  41. if ($num>0) {  
  42. self::mqFrontChange($num);  
  43. }  
  44. return self::$m_data;  
  45. }  
  46. private static function mqRealChange() {  
  47. memcache_add(self::$client, self::QUEUE_REAL_KEY, 0);  
  48. self::$m_real = memcache_increment(self::$client, self::QUEUE_REAL_KEY, 1);  
  49. }  
  50. private static function mqFrontChange($num) {  
  51. memcache_add(self::$client, self::QUEUE_FRONT_KEY, 0);  
  52. self::$m_front = memcache_increment(self::$client, self::QUEUE_FRONT_KEY, $num);  
  53. }  
  54. public static function mflush($memcache_obj) {  
  55. memcache_flush($memcache_obj);  
  56. }  
  57. public static function Debug() {  
  58. echo 'real:'.self::$m_real."<br>/r/n";  
  59. echo 'front:'.self::$m_front."<br>/r/n";  
  60. echo 'wait for process data:'.intval(self::$m_real – self::$m_front);  
  61. echo "<br>/r/n";  
  62. echo '<pre>';  
  63. print_r(self::$m_data);  
  64. echo '<pre>';  
  65. }  
  66. }  
  67. define('FLUSH_MQ',0);//CLEAN ALL DATA  
  68. define('IS_ADD',0);//SET DATA  
  69. //开源代码phpfensi.com 
  70. $mobj = MQ::setupMq('127.0.0.1','11211');  
  71. if (FLUSH_MQ) {  
  72. MQ::mflush($mobj);  
  73. else {  
  74. if (IS_ADD) {  
  75. MQ::add('user_sync''1test');  
  76. MQ::add('user_sync''2test');  
  77. MQ::add('user_sync''3test');  
  78. MQ::add('user_sync''4test');  
  79. MQ::add('user_sync''5test');  
  80. MQ::add('user_sync''6test');  
  81. else {  
  82. MQ::get('user_sync', 10);  
  83. }  
  84. }  
  85. MQ::Debug();  
  86. ?> 

好了下面来看看用法,代码如下:

  1. MQ::setupMq('127.0.0.1','11211');//连接  
  2. MQ::add($key$value);//添加数据到队列  
  3. MQ::add($key$value);//添加数据到队列  
  4. MQ::add($key$value);//添加数据到队列  
  5. MQ::add($key$value);//添加数据到队列  
  6. MQ::add($key$value);//添加数据到队列  
  7. MQ::add($key$value);//添加数据到队列  
  8. MQ:get($key, 10);//取出一定数量的数据

模板优惠价: (点击购买)
版权声明:本文采用知识共享 署名4.0国际许可协议 [BY-NC-SA] 进行授权
文章名称:《php缓存Memcache的Queue的用法》
文章链接:https://www.adminn.cn/news/8454.html
本站资源模板仅供个人学习交流,请于下载后24小时内删除,不允许用于商业用途,否则法律问题自行承担。2021.5月起,网站调整,暂不再分享免费模板。谢谢理解

扫码支付后请联系右侧QQ发送下载地址!!

源码请勿用于任何涉灰站点!净化网络,站长更有责!

支付宝扫一扫打赏