hi,你好!欢迎访问本站!登录
本站由简数采集腾讯云宝塔系统阿里云强势驱动
当前位置:首页 - PHP问题 - 正文 请牢记本站网址www.sosophp.cn

php耽误行列是怎样完成的【php题目】

2019-11-26PHP问题搜搜PHP网56°c
A+ A-

耽误行列,望文生义它是一种带有耽误功用的音讯行列。 那末,是在什么场景下我才须要如许的行列呢?

一、背景

先看看一下营业场景:

1.会员逾期前3天发送召回关照

2.定单付出胜利后,5分钟后检测下流环节是不是都平常,比方用户购置会员后,种种会员状况是不是都设置胜利

3.怎样按期搜检处于退款状况的定单是不是已退款胜利?

4.完成关照失利,1,3,5,7分钟反复关照,直到对方复兴?

平常处置惩罚以上题目,最简朴直接的方法就是定时去扫表。

扫表存在的题目是:

1.扫表与数据库长时刻衔接,在数量量大的状况轻易涌现衔接异常中断,须要更多的异常处置惩罚,对顺序硬朗性要求高

2.在数据量大的状况下延时较高,划定内处置惩罚不完,影响营业,虽然能够启动多个历程来处置惩罚,如许会带来分外的保护本钱,不能从 根本上处置惩罚。

3.每一个营业都要保护一个自身的扫表逻辑。 当营业愈来愈多时,发明扫表部份的逻辑会反复开辟,然则异常相似

延时行列能关于上述需求能很好的处置惩罚

二、调研

调研了市场上一些开源的计划,以下:

·有赞科技:只需道理,没有开源代码

·github个人的:https://github.com/ouqiang/delay-queue

1.基于redis完成,redis只能设置一个,假如redis挂了全部效劳不可用,可用性差点

2.消耗端完成的是拉形式,接入本钱大,每一个项目都得去完成一遍接入代码

3.在star运用的人数不多,放在生产环境,存在风险,加上对go言语不相识,出了题目难以保护

·SchedulerX-阿里开源的: 功用很壮大,然则运维庞杂,依靠组件多,不够轻量

·RabbitMQ-延时使命: 自身没有延时功用,须要借助一特征自身完成,而且公司没有布置这个行列,去零丁布置一个这个来做延时行列本钱有点高,而且还须要特地的运维来保护,现在团队不支撑

基础以上缘由盘算自身写一个,寻常运用php多,项目基础redis的zset构造作为存储,用php言语完成 ,完成道理参考了有赞团队:https://tech.youzan.com/queuing_delay/

相干引荐:《php教程》

三、目的

·轻量级:有较少的php的拓展就可以直接运转,不须要引入收集框架,比方swoole,workman之类的

·稳固性:采纳master-work架构,master不做营业处置惩罚,只担任治理子历程,子历程异常退出时自动拉起

·可用性:

1.支撑多实例布置,每一个实例无状况,一个实例挂掉不影响效劳

2.支撑设置多个redis,一个redis挂了只影响部份音讯

3.营业方接入轻易,在背景只需填写相干音讯范例和回掉接口

·拓展性: 当消耗历程存在瓶颈时,能够设置加大消耗历程数,当写入存在瓶颈时,可增加实例数写入机能可线性进步

·及时性:许可存在肯定的时刻误差。

·支撑音讯删除:营业运用方,能够随时删除指定音讯。

·音讯传输可靠性:音讯进入到耽误行列后,保证至少被消耗一次。

·写入机能:qps>1000+

四、架构设想与申明

整体架构

在这里插进去图片形貌

采纳master-work架构形式,重要包含6个模块:

1.dq-mster: 主历程,担任治理子历程的建立,烧毁,接纳以及信号关照

2.dq-server: 担任音讯写入,读取,删除功用以及保护redis衔接池

3.dq-timer-N: 担任从redis的zset构造中扫描到期的音讯,并担任写入ready 行列,个数可设置,平常2个就好了,由于音讯在zset构造是按时刻有序的

4.dq-consume-N: 担任从ready行列中读取音讯并关照给对应回掉接口,个数可设置

5.dq-redis-checker: 担任搜检redis的效劳状况,假如redis宕机,发送告警邮件

6.dq-http-server: 供应web背景界面,用于注册topic

五、布置

环境依靠:PHP 5.4+ 装置sockets,redis,pcntl,pdo_mysql 拓展

step1:装置数据库用于存储一些topic以及告警信息

create database dq;
#寄存告警信息
CREATE TABLE `dq_alert` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `host` varchar(255) NOT NULL DEFAULT '',
  `port` int(11) NOT NULL DEFAULT '0',
  `user` varchar(255) NOT NULL DEFAULT '',
  `pwd` varchar(255) NOT NULL DEFAULT '',
  `ext` varchar(2048) NOT NULL DEFAULT '',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
#寄存redis信息
CREATE TABLE `dq_redis` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `t_name` varchar(200) NOT NULL DEFAULT '',
  `t_content` varchar(2048) NOT NULL DEFAULT '',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=14 DEFAULT CHARSET=utf8;
#存储注册信息
CREATE TABLE `dq_topic` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `t_name` varchar(1024) NOT NULL DEFAULT '',
  `delay` int(11) NOT NULL DEFAULT '0',
  `callback` varchar(1024) NOT NULL DEFAULT '',
  `timeout` int(11) NOT NULL DEFAULT '3000',
  `email` varchar(1024) NOT NULL DEFAULT '',
  `topic` varchar(255) NOT NULL DEFAULT '',
  `createor` varchar(1024) NOT NULL DEFAULT '',
  `status` tinyint(4) NOT NULL DEFAULT '1',
  `method` varchar(32) NOT NULL DEFAULT 'GET',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;

step2:在DqConfg.文件中设置数据库信息: DqConf::$db

step3:启动http效劳

在DqConf.php文件中修正php了途径 $logPath

敕令:

php DqHttpServer.php --port 8088

接见:http://127.0.0.1:8088,涌现设置界面

在这里插进去图片形貌

redis信息花样:host:post:auth 比方 127.0.0.1:6379:12345

stop4:启动效劳历程

php DqInit.php --port 6789

看到以下信息申明启动胜利

在这里插进去图片形貌

stop5:设置告警信息(比方redis宕机)

在这里插进去图片形貌

stop6:注册topic

在这里插进去图片形貌

在这里插进去图片形貌

step7:写入数据,在项目根目次下新建test.php文件写入

<?php
include_once 'DqLoader.php';
date_default_timezone_set("PRC");
//可设置多个
$server=array(
    '127.0.0.1:6789',
);
$dqClient = new DqClient();
$dqClient->addServer($server);
 
$topic ='order_openvip_checker'; //topic在背景注册
$id = uniqid();
$data=array(
    'id'=>$id,
    'body'=>array(
        'a'=>1,
        'b'=>2,
        'c'=>3,
        'ext'=>str_repeat('a',64),
    ),
    //可选,设置后以这个关照时刻为准,默许延时时刻在注册topic的时刻指定
    'fix_time'=>date('Y-m-d 23:50:50'),
);
 
//增加
$boolRet = $dqClient->add($topic, $data);
echo 'add耗时:'.(msectime() - $time)."ms\n";
//查询
$time = msectime();
$result = $dqClient->get($topic, $id);
echo 'get耗时:'.(msectime() - $time)."ms\n";
 
//删除
$time = msectime();
$boolRet = $dqClient->del($topic,$id);
echo 'del耗时:'.(msectime() - $time)."ms\n";

实行php test.php

step8:检察日记

默许日记目次在项目目次的logs目次下,在DqConf.php修正$logPath

1.要求日记:request_ymd.txt

2.关照日记:notify_ymd.txt

3.毛病日记:err_ymd.txt

step9:假如设置文件有修改

1.体系会自动检测设置文件新,假如有修改,会自动退出(没有找到较好的热更新的计划),须要重启,能够在crontab内里建个使命,1分钟实行一次,顺序有check_self的推断

2.文雅退出敕令: master检测侦听了USR2信号,收到信号后会关照一切子历程,子历程完成当前使命后会自动退出

ps -ef | grep dq-master| grep -v grep | head -n 1 | awk '{print $2}' | xargs kill -USR2

六、机能测试

须要装置pthreads拓展:

测试道理:运用多线程模仿并发,在1s内能胜利返回要求胜利的个数

php DqBench  concurrency  requests
concurrency:并发数
requests: 每一个并发发生的要求数
测试环境:内存 8G ,8核cpu,2个redis和1个dq-server 布置在一个机械上,数据包64字节
qps:2400

七、值得一提的机能优化点:

1.redis multi敕令:将多个对redis的操纵打包成一个削减收集开支。

2.计数的操纵异步处置惩罚,在异步逻辑内里用函数的static变量来保留,当写入redis胜利后开释static变量,能够在redis涌现异常时计数仍能保持一致,除非历程退出。

3.内存泄漏检测有必要: 一切的内存分配在底层都是挪用了brk或许mmap,只需顺序只需大批brk或许mmap的体系挪用,内存泄漏能够性异常高 ,检测敕令: strace -c -p pid | grep 'mmap| brk'。

4.检测顺序的体系挪用状况:strace -c -p pid ,发明某个体系函数挪用是其他的数倍,能够大几率顺序存在题目。

八、异常处置惩罚

假如挪用关照接口在超时时刻内,没有收到复兴以为关照失利,体系会从新把数据放入行列,从新关照,体系默许最大关照10次(能够在Dqconf.php文件中修正$notify_exp_nums)关照距离为2n+1,比方第一次1分钟,关照失利,第二次3分钟后,直到收到复兴,超越最大关照次数后体系自动抛弃,同时发邮件关照。

ps:收集发抖在所难免,关照接口假如涉及到中心的效劳,肯定要保证幂等!!

九、线上状况

线上布置了两个实例每一个机房部一个,4个redis作存储,效劳稳固运转数月,各项目标均相符预期。

重要接入营业:

·定单10分钟召回关照

·接口超时或许失利赔偿

项目地点: https://github.com/chenlinzhong/php-delayqueue

以上就是php耽误行列是怎样完成的的细致内容,更多请关注ki4网别的相干文章!

  选择打赏方式
微信赞助

打赏

QQ钱包

打赏

支付宝赞助

打赏

  选择分享方式
  移步手机端
php耽误行列是怎样完成的【php题目】

1、打开你手机的二维码扫描APP
2、扫描左则的二维码
3、点击扫描获得的网址
4、可以在手机端阅读此文章
推荐阅读