A. 在php中如何使用消息列隊
在寫入隊列的時候可以規定相應的規則如:
{'處理腳本':'test','data':{'test':'test'},'分組':『1','處理結果':'0'}
這樣就可以通過一個消息隊列來處理整個項目的所以消息任務
把data發送給相遇的腳本返回處理結果,而這個分組可以實現分組多進程並發處理來解決效率問題。
效率問題的結局還可以在守護進程上進行增加,守護進程跟進當前的任務量發起適當的處理進程,處理進程再分發給具體的業務處理腳本!
B. php有什麼數據結構可以實現雙向索引查詢
數組就是典型的數據結構了,使用數組操作函數,就可以實現單向和多向隊列了。 操作函數有: array_shift array_unshift array_push array_pop
C. PHP FPM源代碼反芻品味之四:事件處理
FPM master 進程啟動後,會進入函數fpm_event_loop,無限循環.
處理事件.
master 進程所做的的事,總的來說就是兩類:
簡稱timer事件,需按時運行,主要有3個:
簡稱fd事件,需從文件句柄(file descriptor)讀取到指令後,依指令運行.
重復一下,unix 下一切IO, 皆文件,socket ,socketpair,pipe 都返迴文件句柄(fd) 用於通信.
主要的fd有:
對於timer事件,多個事件在事件軸上是依次排列的,只需反復檢查,到時運行.
對於fd事件,需監聽多個fd,需用到我們第二篇講的IO多路復用技術.
如果滿足事件條件,則處理事件內容.
FPM設計上,兩類事件使用同一個結構,並且事件觸發條件和事件處理邏輯放到同一個事件對象里(C語言對象就是結構體).
舉個例子, 打鈴下課,打鈴是觸發條件,下課是事件內容,兩個同時放到一個事件對象 ,這是一個很好的設計.
fd值: -1
flags值:FPM_EV_PERSIST
which值: FPM_EV_TIMEOUT
fd值: 獲取觸發指令的文件fd
flags值: FPM_EV_EDGE(fd事件底層的邊緣觸發標志,需系統支持)
which值: FPM_EV_READ
兩類事件分別放在兩個事件隊列
static struct fpm_event_queue_s *fpm_event_queue_timer = NULL;
static struct fpm_event_queue_s *fpm_event_queue_fd = NULL;
事件隊列的結構很常見,雙向隊列:
typedef struct fpm_event_queue_s {
struct fpm_event_queue_s *prev;
struct fpm_event_queue_s *next;
struct fpm_event_s *ev;
} fpm_event_queue;
4移除事件 (fpm_event_del -> fpm_event_queue_del)
簡單的出列操作:
static int fpm_event_queue_del(struct fpm_event_queue_s **queue, struct fpm_event_s *ev)
對於fd事件,需在底層事件輪詢機制里移除(如:epoll)
5,運行事件回調函數:
6, 底層事件輪詢模塊結構
不同的操作系統,支持不同的IO事件機制,linux 支持epoll,
windows支持select, freebsd 支持kqueue,這個結構統一操作介面
在函數fpm_event_init_main里 調用mole->init初始化
fpm 里對應的配置
master進程在fpm_event_loop函數里無限循環,處理定時任務和fd事件.
期間會在mole->wait阻塞片刻,對於epoll機制,就是epoll_wait.
D. 如何使用php實現一個雙向隊列的數據結構有幾種方式
不建議直接用php來做隊列,php的array操作雖然勉強能做偽隊列,但問題也來了,如果是大量的數據呢?php會不會內存問題直接掛了?
建議:測試的話用用還湊合,但真正去用的話雙向隊列,用redis的list類型吧,可以滿足你的需求,同時數量級上也不是問題,單向隊列
httpsqs,rabbitmq等
再看看別人怎麼說的。
E. 用PHP寫的這個雙向隊列應該怎麼使用
<?php
class Deque{
private $queue = array();
public function addFirst($item){
return array_unshift($this->queue, $item);
}
public function addLast($item){
return array_push($this->queue, $item);
}
public function removeFirst(){
return array_shift($this->queue);
}
public function removeLast(){
return array_pop($this->queue);
}
}
F. php消息隊列怎麼做
PHP的消息隊列一般使用redis結合去做,要不就只能使用文件和資料庫了,php本身不能常駐內存,不能做消息隊列
G. php怎麼把各種任務做成多個任務隊列,每3秒任務執行程序輪一次,分別按順序從各隊列里提取一個任務來執行
可以使用數組模擬隊列,給定多個數組,然後將任務放入各個數組中,每次循環遍歷數組,從數組中獲取任務,然後調度執行。
對於每3秒執行一次,可以使用定時器。或者寫一個死循環,循環裡面執行一次程序,然後睡眠3秒,這樣就可以簡單實現每隔3秒的任務循環調度。
H. 如何使用php實現一個雙向隊列的數據結構有幾種方式
數組就是典型的數據結構了,使用數組操作函數,就可以實現單向和多向隊列了。
操作函數有:
array_shift
array_unshift
array_push
array_pop