安装说明

<span  class="pln">mkdir php_httpsqs_client? cd php_httpsqs_client? <br >unzip php_httpsqs_0</span><span  class="pun">.</span><span  class="lit">1.zip</span><span  class="pln">? </span><span  class="pun">/</span><span  class="pln">usr</span><span  class="pun">/</span><span  class="kwd">local</span><span  class="pun">/</span><span  class="pln">php</span><span  class="pun">/</span><span  class="pln">bin</span><span  class="pun">/</span><span  class="pln">phpize? </span><span  class="pun">./</span><span  class="pln">configure </span><span  class="pun">--</span><span  class="pln">enable</span><span  class="pun">-</span><span  class="pln">httpsqs <br ></span><span  class="pun">--</span><span  class="kwd">with</span><span  class="pun">-</span><span  class="pln">php</span><span  class="pun">-</span><span  class="pln">config</span><span  class="pun">=</span><span  class="str">/usr/</span><span  class="kwd">local</span><span  class="pun">/</span><span  class="pln">php</span><span  class="pun">/</span><span  class="pln">bin</span><span  class="pun">/</span><span  class="pln">php</span><span  class="pun">-</span><span  class="pln">config? make </span><span  class="pun">&&</span><span  class="pln"> make install? </span><span  class="com"><br >#接着在php.ini中添加一行</span><span  class="pln">? extension</span><span  class="pun">=</span><span  class="pln">httpsqs</span><span  class="pun">.</span><span  class="pln">so</span><span  class="pun">;</span>

函数说明

<span  class="com">/**? ?* 创建httpsqs连接? ?* @param string $host 服务器地址，可以为空，默认为127.0.0.1? ?* @param int ? ?$port 服务器端口，可以为空，默认为1218? ?* @return resource? ?*/</span><span  class="pln">? $hr </span><span  class="pun">=</span><span  class="pln"> httpsqs_connect</span><span  class="pun">(</span><span  class="str">"127.0.0.1"</span><span  class="pun">,</span><span  class="pln"> </span><span  class="lit">1218</span><span  class="pun">);</span>

<span  class="com">/**? ?* 写入队列数据? ?* @param resource $hr ? ? ?服务器连接句柄? ?* @param string ? $queue ? 队列名称? ?* @param string ? $data ? ?写入数据? ?* @param string ? $charset 字符集，可以为空，默认为utf-8? ?* @return boolean? ?*/</span><span  class="pln">? <br >$putRes </span><span  class="pun">=</span><span  class="pln"> httpsqs_put</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"testQueue"</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"This is a test Data"</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"UTF-8"</span><span  class="pun">);</span>

<span  class="com">/** ? ?* 获取队列最后一条数据? ?* @param resource $hr? ?* @param string ? $queue? ?* @param boolean ?$return_array 是否返回数组，可以为空，默认为false? ? ? ? ? ? 返回数组格式：array('pos'=>'队列插入点', 'data'=>'数据值')? ?* @param string ? $charset 可以为空? ?* @return mixed? ?*/</span><span  class="pln">? $content </span><span  class="pun">=</span><span  class="pln"> httpsqs_get</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"testQueue"</span><span  class="pun">,</span><span  class="pln"> </span><span  class="kwd">true</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"UTF-8"</span><span  class="pun">);</span>

<span  class="com">/**? ?* 获取队列状态? ?* @param resource $hr? ?* @param string ? $queue? ?* @param boolean ?$return_json 是否返回状态的json格式，可以为空，默认为false? ?* @return string? ?*/</span><span  class="pln">? $status </span><span  class="pun">=</span><span  class="pln"> httpsqs_status</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"testQueue"</span><span  class="pun">,</span><span  class="pln"> </span><span  class="kwd">true</span><span  class="pun">);</span>

<span  class="com">/**? ?* 获取队列某个点数据? ?* @param resource $hr? ?* @param string ? $queue? ?* @param int ? ? ?$pos 要获取的某条数据的位置? ?* @param string ? $charset 可以为空? ?* @return string? ?*/</span><span  class="pln">? $posData </span><span  class="pun">=</span><span  class="pln"> httpsqs_view</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"testQueue"</span><span  class="pun">,</span><span  class="pln"> </span><span  class="lit">10</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"UTF-8"</span><span  class="pun">);</span>

<span  class="com">/**? ?* 队列重置? ?* @param resource $hr? ?* @param string ? $queue? ?* @return boolean? ?*/</span><span  class="pln">? $resetRes </span><span  class="pun">=</span><span  class="pln"> httpsqs_reset</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"testQueue"</span><span  class="pun">);</span>

<span  class="com">/**? ?* 设置队列最大数据条数? ?* @param resource $hr? ?* @param string ? $queue? ?* @param int ? ? ?$maxqueue 队列最大数据条数? ?* @return boolean? ?*/</span><span  class="pln">? $maxqueueRes </span><span  class="pun">=</span><span  class="pln"> httpsqs_maxqueue</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"testQueue"</span><span  class="pun">,</span><span  class="pln"> </span><span  class="lit">10000</span><span  class="pun">);</span>

<span  class="com">/**? ?* 修改定时刷新内存缓冲区内容到磁盘的间隔时间? ?* @param resource $hr? ?* @param string ? $queue? ?* @param int ? ? ?$synctime 间隔时间? ?* @return boolean? ?*/</span><span  class="pln">? $synctimeRes </span><span  class="pun">=</span><span  class="pln"> httpsqs_synctime</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> </span><span  class="str">"testQueue"</span><span  class="pun">,</span><span  class="pln"> </span><span  class="lit">10</span><span  class="pun">);</span>

对象调用

<span  class="com">// 参数与httpsqs_connect对应</span><span  class="pln">? $hr </span><span  class="pun">=</span><span  class="pln"> </span><span  class="kwd">new</span><span  class="pln"> </span><span  class="typ">HttpSQS</span><span  class="pun">(</span><span  class="pln">$host</span><span  class="pun">,</span><span  class="pln"> $port</span><span  class="pun">);</span><span  class="pln">? ? </span><span  class="com">// 参数与httpsqs_get对应</span><span  class="pln">? $hr</span><span  class="pun">-></span><span  class="kwd">get</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">,</span><span  class="pln"> $return_array</span><span  class="pun">,</span><span  class="pln"> $charset</span><span  class="pun">);</span><span  class="pln">? ? </span><span  class="com">// 参数与httpsqs_put对应</span><span  class="pln">? $hr</span><span  class="pun">-></span><span  class="pln">put</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">,</span><span  class="pln"> $data</span><span  class="pun">,</span><span  class="pln"> $charset</span><span  class="pun">);</span><span  class="pln">? ? </span><span  class="com">// 参数与httpsqs_status对应</span><span  class="pln">? $hr</span><span  class="pun">-></span><span  class="pln">status</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">,</span><span  class="pln"> $return_json</span><span  class="pun">);</span><span  class="pln">? ? </span><span  class="com">// 参数与httpsqs_view对应</span><span  class="pln">? $hr</span><span  class="pun">-></span><span  class="pln">view</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">,</span><span  class="pln"> $pos</span><span  class="pun">);</span><span  class="pln">? ? </span><span  class="com">// 参数与httpsqs_reset对应</span><span  class="pln">? $hr</span><span  class="pun">-></span><span  class="pln">reset</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">);</span><span  class="pln">? ? </span><span  class="com">// 参数与httpsqs_maxqueue对应</span><span  class="pln">? $hr</span><span  class="pun">-></span><span  class="pln">maxqueue</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">);</span><span  class="pln">? ? </span><span  class="com">// 参数与httpsqs_synctime对应</span><span  class="pln">? $hr</span><span  class="pun">-></span><span  class="pln">synctime</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">);</span>

示例

<span  class="com">// 取数据Daemon</span><span  class="pln">? $hr </span><span  class="pun">=</span><span  class="pln"> httpsqs_connect</span><span  class="pun">(</span><span  class="pln">$host</span><span  class="pun">,</span><span  class="pln"> $port</span><span  class="pun">);</span><span  class="pln">? </span><span  class="kwd">while</span><span  class="pln"> </span><span  class="pun">(</span><span  class="lit">1</span><span  class="pun">)</span><span  class="pln"> </span><span  class="pun">{</span><span  class="pln">? ? ? <br >$data </span><span  class="pun">=</span><span  class="pln"> httpsqs_get</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> $queuename</span><span  class="pun">,</span><span  class="pln"> $charset</span><span  class="pun">);</span><span  class="pln">? ? ? </span><span  class="kwd"><br >if</span><span  class="pln"> </span><span  class="pun">(</span><span  class="pln">$data </span><span  class="pun">===</span><span  class="pln"> </span><span  class="kwd">false</span><span  class="pun">)</span><span  class="pln"> </span><span  class="pun">{</span><span  class="pln">? ? ? ? ?sleep</span><span  class="pun">(</span><span  class="lit">1</span><span  class="pun">);</span><span  class="pln">? ? ? </span><span  class="pun">}</span><span  class="pln"> </span><span  class="kwd">else</span><span  class="pln"> </span><span  class="pun">{</span><span  class="pln">? ? ? ? </span><span  class="com">// do something...</span><span  class="pln">? ? ? </span><span  class="pun">}</span><span  class="pln">? </span><span  class="pun">}</span><span  class="pln">? ?<br >?</span><span  class="com">// 或者</span><span  class="pln">? $hr </span><span  class="pun">=</span><span  class="pln"> </span><span  class="kwd">new</span><span  class="pln"> </span><span  class="typ">HttpSQS</span><span  class="pun">(</span><span  class="pln">$host</span><span  class="pun">,</span><span  class="pln"> $port</span><span  class="pun">);</span><span  class="pln">? </span><span  class="kwd">while</span><span  class="pln"> </span><span  class="pun">(</span><span  class="lit">1</span><span  class="pun">)</span><span  class="pln"> </span><span  class="pun">{</span><span  class="pln">? ? ? $data </span><span  class="pun">=</span><span  class="pln"> $hr</span><span  class="pun">-></span><span  class="kwd">get</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">,</span><span  class="pln"> $charset</span><span  class="pun">);</span><span  class="pln">? ? ?<br >?</span><span  class="kwd">if</span><span  class="pln"> </span><span  class="pun">(</span><span  class="pln">$data </span><span  class="pun">===</span><span  class="pln"> </span><span  class="kwd">false</span><span  class="pun">)</span><span  class="pln"> </span><span  class="pun">{</span><span  class="pln">? ? ? ? ? sleep</span><span  class="pun">(</span><span  class="lit">1</span><span  class="pun">);</span><span  class="pln">? ? ? </span><span  class="pun">}</span><span  class="pln"> </span><span  class="kwd">else</span><span  class="pln"> </span><span  class="pun">{</span><span  class="pln">? ? ? ? </span><span  class="com">// do something...</span><span  class="pln">? ? ? </span><span  class="pun">}</span><span  class="pln">? </span><span  class="pun">}</span><span  class="pln">? ?<br >?</span><span  class="com">// 写数据</span><span  class="pln">? $hr </span><span  class="pun">=</span><span  class="pln"> httpsqs_connect</span><span  class="pun">(</span><span  class="pln">$hort</span><span  class="pun">,</span><span  class="pln"> $port</span><span  class="pun">);</span><span  class="pln">? httpsqs_put</span><span  class="pun">(</span><span  class="pln">$hr</span><span  class="pun">,</span><span  class="pln"> $queuename</span><span  class="pun">,</span><span  class="pln"> $data</span><span  class="pun">,</span><span  class="pln"> $charset</span><span  class="pun">);</span><span  class="pln">? ?<br >?</span><span  class="com">// 或者</span><span  class="pln">? $hr </span><span  class="pun">=</span><span  class="pln"> </span><span  class="kwd">new</span><span  class="pln"> </span><span  class="typ">HttpSQS</span><span  class="pun">(</span><span  class="pln">$hort</span><span  class="pun">,</span><span  class="pln"> $port</span><span  class="pun">);</span><span  class="pln">? $hr</span><span  class="pun">-></span><span  class="pln">put</span><span  class="pun">(</span><span  class="pln">$queuename</span><span  class="pun">,</span><span  class="pln"> $data</span><span  class="pun">,</span><span  class="pln"> $charset</span><span  class="pun">);</span>

声明

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

您如何防止与会议有关的跨站点脚本（XSS）攻击？Apr 23, 2025 am 12:16 AM

要保护应用免受与会话相关的XSS攻击，需采取以下措施：1.设置HttpOnly和Secure标志保护会话cookie。2.对所有用户输入进行输出编码。3.实施内容安全策略(CSP)限制脚本来源。通过这些策略，可以有效防护会话相关的XSS攻击，确保用户数据安全。

您如何优化PHP会话性能？Apr 23, 2025 am 12:13 AM

优化PHP会话性能的方法包括：1.延迟会话启动，2.使用数据库存储会话，3.压缩会话数据，4.管理会话生命周期，5.实现会话共享。这些策略能显着提升应用在高并发环境下的效率。

什么是session.gc_maxlifetime配置设置？Apr 23, 2025 am 12:10 AM

thesession.gc_maxlifetimesettinginphpdeterminesthelifespanofsessiondata，setInSeconds.1）它'sconfiguredinphp.iniorviaini_set（）.2）abalanceIsiseededeedeedeedeedeedeedto to to avoidperformance andununununununexpectedLogOgouts.3）

您如何在PHP中配置会话名？Apr 23, 2025 am 12:08 AM

在PHP中，可以使用session_name()函数配置会话名称。具体步骤如下：1.使用session_name()函数设置会话名称，例如session_name("my_session")。2.在设置会话名称后，调用session_start()启动会话。配置会话名称可以避免多应用间的会话数据冲突，并增强安全性，但需注意会话名称的唯一性、安全性、长度和设置时机。

您应该多久再生一次会话ID？Apr 23, 2025 am 12:03 AM

会话ID应在登录时、敏感操作前和每30分钟定期重新生成。1.登录时重新生成会话ID可防会话固定攻击。2.敏感操作前重新生成提高安全性。3.定期重新生成降低长期利用风险，但需权衡用户体验。

如何在PHP中设置会话cookie参数？Apr 22, 2025 pm 05:33 PM

在PHP中设置会话cookie参数可以通过session_set_cookie_params()函数实现。1)使用该函数设置参数，如过期时间、路径、域名、安全标志等；2)调用session_start()使参数生效；3)根据需求动态调整参数，如用户登录状态；4)注意设置secure和httponly标志以提升安全性。