php-httpsqs-client 的施用
php-httpsqs-client 的使用
安装说明
<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>
Hot AI Tools
Undresser.AI Undress
AI-powered app for creating realistic nude photos
AI Clothes Remover
Online AI tool for removing clothes from photos.
Undress AI Tool
Undress images for free
Clothoff.io
AI clothes remover
Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!
Hot Article
Hot Tools
Notepad++7.3.1
Easy-to-use and free code editor
SublimeText3 Chinese version
Chinese version, very easy to use
Zend Studio 13.0.1
Powerful PHP integrated development environment
Dreamweaver CS6
Visual web development tools
SublimeText3 Mac version
God-level code editing software (SublimeText3)
Hot Topics
Convert basic data types to strings using Java's String.valueOf() function
Jul 24, 2023 pm 07:55 PM
Convert basic data types to strings using Java's String.valueOf() function In Java development, when we need to convert basic data types to strings, a common method is to use the valueOf() function of the String class. This function can accept parameters of basic data types and return the corresponding string representation. In this article, we will explore how to use the String.valueOf() function for basic data type conversions and provide some code examples to
How to convert char array to string
Jun 09, 2023 am 10:04 AM
Method of converting char array to string: It can be achieved by assignment. Use {char a[]=" abc d\0efg ";string s=a;} syntax to let the char array directly assign a value to string, and execute the code to complete the conversion.
Detailed explanation of the usage of return in C language
Oct 07, 2023 am 10:58 AM
The usage of return in C language is: 1. For functions whose return value type is void, you can use the return statement to end the execution of the function early; 2. For functions whose return value type is not void, the function of the return statement is to end the execution of the function. The result is returned to the caller; 3. End the execution of the function early. Inside the function, we can use the return statement to end the execution of the function early, even if the function does not return a value.
Use Java's String.replace() function to replace characters (strings) in a string
Jul 25, 2023 pm 05:16 PM
Replace characters (strings) in a string using Java's String.replace() function In Java, strings are immutable objects, which means that once a string object is created, its value cannot be modified. However, you may encounter situations where you need to replace certain characters or strings in a string. At this time, we can use the replace() method in Java's String class to implement string replacement. The replace() method of String class has two types:
What is the execution order of return and finally statements in Java?
Apr 25, 2023 pm 07:55 PM
Source code: publicclassReturnFinallyDemo{publicstaticvoidmain(String[]args){System.out.println(case1());}publicstaticintcase1(){intx;try{x=1;returnx;}finally{x=3;}}}#Output The output of the above code can simply conclude: return is executed before finally. Let's take a look at what happens at the bytecode level. The following intercepts part of the bytecode of the case1 method, and compares the source code to annotate the meaning of each instruction in
2w words detailed explanation String, yyds
Aug 24, 2023 pm 03:56 PM
Hello everyone, today I will share with you the basic knowledge of Java: String. Needless to say the importance of the String class, it can be said to be the most used class in our back-end development, so it is necessary to talk about it.
Golang function byte, rune and string type conversion skills
May 17, 2023 am 08:21 AM
In Golang programming, byte, rune and string types are very basic and common data types. They play an important role in processing data operations such as strings and file streams. When performing these data operations, we usually need to convert them to each other, which requires mastering some conversion skills. This article will introduce the byte, rune and string type conversion techniques of Golang functions, aiming to help readers better understand these data types and be able to apply them skillfully in programming practice.
Use java's String.length() function to get the length of a string
Jul 25, 2023 am 09:09 AM
Use Java's String.length() function to get the length of a string. In Java programming, string is a very common data type. We often need to get the length of a string, that is, the number of characters in the string. In Java, we can use the length() function of the String class to get the length of a string. Here is a simple example code: publicclassStringLengthExample{publ
