php实现读取内存顺序号

这篇文章主要介绍了php实现读取内存顺序号,十分的简单实用，需要的朋友可以参考下

只是做记录，osc本站应该有重复的

semWrapper.class.php

1. /* 
2. * 信号量(Semaphore)。 
3. * 这是一个包装类，用于解决不同平台下对“信号量”的不同实现方式。 
4. * 目前这个类只是象征性的，在 Windows 平台下实际是空跑（并没有真的实现互斥）。 
5. */ 
6. class SemWrapper 
7. { 
8. private $hasSemSupport; 
9. private $sem; 
10. const SEM_KEY = 1; 
11.  
12. public function __construct() 
13. { 
14. $this->hasSemSupport = function_exists( 'sem_get' ); 
15. if ( $this->hasSemSupport ) { 
16. $this->sem = sem_get( self::SEM_KEY ); 
17. } 
18. } 
19.  
20. public function acquire() { 
21. if ( $this->hasSemSupport ) { 
22. return sem_acquire( $this->sem ); 
23. } 
24. return true; 
25. } 
26.  
27. public function release() { 
28. if ( $this->hasSemSupport ) { 
29. return sem_release( $this->sem ); 
30. } 
31. return true; 
32. } 
33. } 

SeqGenerator.class.php

1. /* 
2. * 顺序号发生器。 
3. */ 
4. class SeqGenerator 
5. { 
6. const SHM_KEY = 1; 
7.  
8. /** 
9. * 对顺序号发生器进行初始化。 
10. * 仅在服务器启动后的第一次调用有效，此后再调用此方法没有实际作用。 
11. * @param int $start 产生顺序号的起始值。 
12. * @return boolean 返回 true 表示成功。 
13. */ 
14. static public function init( $start = 1 ) 
15. { 
16. // 通过信号量实现互斥，避免对共享内存的访问冲突 
17. $sw = new SemWrapper; 
18. if ( ! $sw->acquire() ) { 
19. return false; 
20. } 
21.  
22. // 打开共享内存 
23. $shm_id = shmop_open( self::SHM_KEY, 'n', 0644, 4 ); 
24. if ( emptyempty($shm_id) ) { 
25. // 因使用了 'n' 模式，如果无法打开共享内存，可以认为该共享内存已经创建，无需再次初始化 
26. $sw->release(); 
27. return true; 
28. } 
29.  
30. // 在共享内存中写入初始值 
31. $size = shmop_write( $shm_id, pack( 'L', $start ), 0 ); 
32. if ( $size != 4 ) { 
33. shmop_close( $shm_id ); 
34. $sw->release(); 
35. return false; 
36. } 
37.  
38. // 关闭共享内存，释放信号量 
39. shmop_close( $shm_id ); 
40. $sw->release(); 
41. return true; 
42. } 
43.  
44. /** 
45. * 产生下一个顺序号。 
46. * @return int 产生的顺序号 
47. */ 
48. static public function next() 
49. { 
50. // 通过信号量实现互斥，避免对共享内存的访问冲突 
51. $sw = new SemWrapper; 
52. if ( ! $sw->acquire() ) { 
53. return 0; 
54. } 
55.  
56. // 打开共享内存 
57. $shm_id = shmop_open( self::SHM_KEY, 'w', 0, 0 ); 
58. if ( emptyempty($shm_id) ) { 
59. $sw->release(); 
60. return 0; 
61. } 
62.  
63. // 从共享内存中读出顺序号 
64. $data = shmop_read( $shm_id, 0, 4 ); 
65. if ( emptyempty($data) ) { 
66. $sw->release(); 
67. return 0; 
68. } 
69.  
70. $arr = unpack( 'L', $data ); 
71. $seq = $arr[1]; 
72.  
73. // 把下一个顺序号写入共享内存 
74. $size = shmop_write( $shm_id, pack( 'L', $seq + 1 ), 0 ); 
75. if ( $size != 4 ) { 
76. $sw->release(); 
77. return 0; 
78. } 
79.  
80. // 关闭共享内存，释放信号量 
81. shmop_close( $shm_id ); 
82. $sw->release(); 
83. return $seq; 
84. } 
85. } 

page.php

1. //使用方法 
2.  
3. $seq = SeqGenerator::next(); 
4.  
5. var_dump($seq); 

以上所述就是本文的全部内容了，希望大家能够喜欢。