VB.net 2010 视频教程 VB.net 2010 视频教程 python基础视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > PHP >
  • php缓存Memcache的Queue的用法

分享一篇关于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);//取出一定数量的数据
  9.  



出处:http://www.phpfensi.com/php/20140911/5330.html


相关教程