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