鲁西愚公-贺万会的个人博客

贺万会,一个PHP菜鸟的日常工作记录和总结

分类 "PHP" 下的文章

PHP 订单延时处理:延迟队列 (转载收藏)

延迟队列,顾名思义它是一种带有延迟功能的消息队列。 那么,是在什么场景下我才需要这样的队列呢?
一、背景

先看看一下业务场景:

1.会员过期前3天发送召回通知

2.订单支付成功后,5分钟后检测下游环节是否都正常,比如用户购买会员后,各种会员状态是否都设置成功

3.如何定期检查处于退款状态的订单是否已经退款成功?

4.实现通知失败,1,3,5,7分钟重复通知,直到对方回复?

通常解决以上问题,最简单直接的办法就是定时去扫表。

扫表存在的问题是:

1.扫表与数据库长时间连接,在数量量大的情况容易出现连接异常中断,需要更多的异常处理,对程序健壮性要求高

2.在数据量大的情况下延时较高,规定内处理不完,影响业务,虽然可以启动多个进程来处理,这样会带来额外的维护成本,不能从根本上解决。

3.每个业务都要维护一个自己的扫表逻辑。 当业务越来越多时,发现扫表部分的逻辑会重复开发,但是非常类似

延时队列能对于上述需求能很好的解决
二、调研

调研了市场上一些开源的方案,以下:

1.有赞科技:只有原理,没有开源代码

2.github个人的:https://github.com/ouqiang/delay-queu ,感觉也不太适合我们团队,主要基于如下几点考虑

    1.基于redis实现,redis只能配置一个,如果redis挂了整个服务不可用,可用性差点

    2.消费端实现的是拉模式,接入成本大,每个项目都得去实现一遍接入代码

    3.在star使用的人数不多,放在生产环境,存在风险,加之对go语言不了解,出了问题难以维护

3.SchedulerX-阿里开源的: 功能很强大,但是运维复杂,依赖组件多,不够轻量

4.RabbitMQ-延时任务: 本身没有延时功能,需要借助一特性自己实现,而且公司没有部署这个队列,去单独部署一个这个来做延时队列成本有点高,而且还需要专门的运维来维护,目前团队不支持

基本以上原因打算自己写一个,平常使用php多,项目基本redis的zset结构作为存储,用php语言实现 ,实现原理参考了有赞团队:https://tech.youzan.com/queuing_delay/

整个延迟队列主要由4个部分

JobPool用来存放所有Job的元信息。

DelayBucket是一组以时间为维度的有序队列,用来存放所有需要延迟的Job(这里只存放Job Id)。

Timer负责实时扫描各个Bucket,并将delay时间大于等于当前时间的Job放入到对应的Ready Queue。

ReadyQueue存放处于Ready状态的Job(这里只存放JobId),以供消费程序消费。

消息结构 每个Job必须包含一下几个属性:

topic:Job类型。可以理解成具体的业务名称。

id:Job的唯一标识。用来检索和删除指定的Job信息。

delayTime:jod延迟执行的时间,13位时间戳

ttr(time-to-run):Job执行超时时间。

body:Job的内容,供消费者做具体的业务处理,以json格式存储。

对于同一类的topic delaytime,ttr一般是固定,job可以在精简一下属性

1.topic:Job类型。可以理解成具体的业务名称

2.id:Job的唯一标识。用来检索和删除指定的Job信息。

3.body:Job的内容,供消费者做具体的业务处理,以json格式存储。

delaytime,ttr在topicadmin后台配置
三、目标

轻量级:有较少的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

五、模块时序图

消息写入:

timer查找到期消息:

consumer消费流程:

六、部署

环境依赖: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:网络抖动在所难免,通知接口如果涉及到核心的服务,一定要保证幂等!!

redis宕机通知:


十、线上情况

线上部署了两个实例每个机房部一个,4个redis共16G内存作存储,服务稳定运行数月,各项指标均符合预期

主要接入业务:

订单10分钟召回通知

调用接口超时或者失败时做补偿

会员过期前3天召回通知

十一、参考

https://www.cnblogs.com/peachyy/p/7398430.html

https://tech.youzan.com/queuing_delay/

http://www.runoob.com/bootstrap/bootstrap-tutorial.html

【本文作者】

爱的奇迹:前百度高级工程师,现供职于微博,一直做 PHP 相关的开发工作。

Nginx 反向代理、负载均衡、页面缓存、URL重写及读写分离详解(转载)

(1).正向代理的概念
正向代理,也就是传说中的代理,他的工作原理就像一个跳板,简单的说,我是一个用户,我访问不了某网站,但是我能访问一个代理服务器,这个代理服务器呢,他能访问那个我不能访问的网站,于是我先连上代理服务器,告诉他我需要那个无法访问网站的内容,代理服务器去取回来,然后返回给我。从网站的角度,只在代理服务器来取内容的时候有一次记录,有时候并不知道是用户的请求,也隐藏了用户的资料,这取决于代理告不告诉网站。

   结论就是,正向代理 是一个位于客户端和原始服务器(origin server)之间的服务器,为了从原始服务器取得内容,客户端向代理发送一个请求并指定目标(原始服务器),然后代理向原始服务器转交请求并将获得的内容返回给客户端。客户端必须要进行一些特别的设置才能使用正向代理。

(2).反向代理的概念

继续举例:
例用户访问 http://www.test.com/readme,但www.test.com上并不存在readme页面,他是偷偷从另外一台服务器上取回来,然后作为自己的内容返回用户,但用户并不知情。这里所提到的 www.test.com 这个域名对应的服务器就设置了反向代理功能。

   结论就是,反向代理正好相反,对于客户端而言它就像是原始服务器,并且客户端不需要进行任何特别的设置。客户端向反向代理的命名空间(name-space)中的内容发送普通请求,接着反向代理将判断向何处(原始服务器)转交请求,并将获得的内容返回给客户端,就像这些内容原本就是它自己的一样。

(3).两者区别

从用途上来讲:

   正向代理的典型用途是为在防火墙内的局域网客户端提供访问Internet的途径。正向代理还可以使用缓冲特性减少网络使用率。反向代理的典型用途是将防火墙后面的服务器提供给Internet用户访问。反向代理还可以为后端的多台服务器提供负载平衡,或为后端较慢的服务器提供缓冲服务。另外,反向代理还可以启用高级URL策略和管理技术,从而使处于不同web服务器系统的web页面同时存在于同一个URL空间下。

从安全性来讲:

   正向代理允许客户端通过它访问任意网站并且隐藏客户端自身,因此你必须采取安全措施以确保仅为经过授权的客户端提供服务。反向代理对外都是透明的,访问者并不知道自己访问的是一个代理。

五、Nginx之负载均衡

注,大家可以看到,由于我们网站是发展初期,nginx只代理了后端一台服务器,但由于我们网站名气大涨访问的人越来越多一台服务器实在是顶不住,于是我们加了多台服务器,那么多台服务器又怎么配置代理呢,我们这里以两台服务器为案例,为大家做演示。

1.upstream 负载均衡模块说明

案例:

下面设定负载均衡的服务器列表。

upstream test.net{
ip_hash;
server 192.168.10.13:80;
server 192.168.10.14:80 down;
server 192.168.10.15:8009 max_fails=3 fail_timeout=20s;
server 192.168.10.16:8080;
}
server {
location / {
proxy_pass http://test.net;
}
}

   upstream是Nginx的HTTP Upstream模块,这个模块通过一个简单的调度算法来实现客户端IP到后端服务器的负载均衡。在上面的设定中,通过upstream指令指定了一个负载均衡器的名称test.net。这个名称可以任意指定,在后面需要用到的地方直接调用即可。

2.upstream 支持的负载均衡算法

Nginx的负载均衡模块目前支持4种调度算法,下面进行分别介绍,其中后两项属于第三方调度算法。

轮询(默认)。每个请求按时间顺序逐一分配到不同的后端服务器,如果后端某台服务器宕机,故障系统被自动剔除,使用户访问不受影响。Weight 指定轮询权值,Weight值越大,分配到的访问机率越高,主要用于后端每个服务器性能不均的情况下。

ip_hash。每个请求按访问IP的hash结果分配,这样来自同一个IP的访客固定访问一个后端服务器,有效解决了动态网页存在的session共享问题。

fair。这是比上面两个更加智能的负载均衡算法。此种算法可以依据页面大小和加载时间长短智能地进行负载均衡,也就是根据后端服务器的响应时间来分配请求,响应时间短的优先分配。Nginx本身是不支持fair的,如果需要使用这种调度算法,必须下载Nginx的upstream_fair模块。

url_hash。此方法按访问url的hash结果来分配请求,使每个url定向到同一个后端服务器,可以进一步提高后端缓存服务器的效率。Nginx本身是不支持url_hash的,如果需要使用这种调度算法,必须安装Nginx 的hash软件包。

3.upstream 支持的状态参数

在HTTP Upstream模块中,可以通过server指令指定后端服务器的IP地址和端口,同时还可以设定每个后端服务器在负载均衡调度中的状态。常用的状态有:

down,表示当前的server暂时不参与负载均衡。

backup,预留的备份机器。当其他所有的非backup机器出现故障或者忙的时候,才会请求backup机器,因此这台机器的压力最轻。

max_fails,允许请求失败的次数,默认为1。当超过最大次数时,返回proxy_next_upstream 模块定义的错误。

fail_timeout,在经历了max_fails次失败后,暂停服务的时间。max_fails可以和fail_timeout一起使用。

注,当负载调度算法为ip_hash时,后端服务器在负载均衡调度中的状态不能是weight和backup。

5.配置nginx负载均衡
[root@nginx ~]# vim /etc/nginx/nginx.conf
upstream webservers {
server 192.168.18.201 weight=1;
server 192.168.18.202 weight=1;
}
server {
listen 80;
server_name localhost;
#charset koi8-r;
#access_log logs/host.access.log main;
location / {
proxy_pass http://webservers;
proxy_set_header X-Real-IP $remote_addr;
}
}

注,upstream是定义在server{ }之外的,不能定义在server{ }内部。定义好upstream之后,用proxy_pass引用一下即可。

需求分析,前端一台nginx做负载均衡反向代理,后面两台httpd服务器。整个架构是提供BBS(论坛)服务,有一需求得实现读写分离,就是上传附件的功能,我们上传的附件只能上传到Web1,然后在Web1上利用rsync+inotify实现附件同步,大家都知道rsync+inotify只能是主向从同步,不能双向同步。所以Web1可进行写操作,而Web2只能进行读操作,这就带来读写分离的需求,下面我们就来说一下,读写分离怎么实现。

2.WebDAV功能说明

   WebDAV (Web-based Distributed Authoring and Versioning) 一种基于 HTTP 1.1协议的通信协议。它扩展了HTTP 1.1,在GET、POST、HEAD等几个HTTP标准方法以外添加了一些新的方法,使应用程序可直接对Web Server直接读写,并支持写文件锁定(Locking)及解锁(Unlock),还可以支持文件的版本控制。这样我们就能配置读写分离功能了,下面我们来具体配置一下。

3.修改配置文件

[root@nginx nginx]# vim /etc/nginx/nginx.conf
server {
listen 80;
server_name localhost;
#charset koi8-r;
#access_log logs/host.access.log main;
location / {
proxy_pass http://192.168.18.202;
if ($request_method = "PUT"){
proxy_pass http://192.168.18.201;
}
}
}

4.重新加载一下配置文件

[root@nginx ~]# service nginx reload
nginx: the configuration file /etc/nginx/nginx.conf syntax is ok
nginx: configuration file /etc/nginx/nginx.conf test is successful
重新载入 nginx: [确定]

5.配置httpd的WebDAV功能
[root@web1 ~]# vim /etc/httpd/conf/httpd.conf

注,在下启用就行。

6.重新启动一下httpd

[root@web1 ~]# service httpd restart
停止 httpd: [确定]
正在启动 httpd: [确定]

7.测试一下

[root@nginx ~]# curl http://192.168.18.201

web1.test.com

[root@nginx ~]# curl http://192.168.18.202

web2.test.com

注,web1与web2访问都没问题。

[root@nginx ~]# curl -T /etc/issue http://192.168.18.202
<!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">
<html><head>
<title>405 Method Not Allowed</title>
</head><body>

Method Not Allowed

The requested method PUT is not allowed for the URL /issue.


Apache/2.2.15 (CentOS) Server at 192.168.18.202 Port 80

</body></html>

注,我们上传文件到,web2上时,因为web2只人读功能,所以没有开户WebDAV功能,所以显示是405 Method Not Allowed。

[root@nginx ~]# curl -T /etc/issue http://192.168.18.201
<!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">
<html><head>
<title>403 Forbidden</title>
</head><body>

Forbidden

You don't have permission to access /issue
on this server.


Apache/2.2.15 (CentOS) Server at 192.168.18.201 Port 80

</body></html>

注,我们在Web1开启了WebDAV功能,但我们目录是root目录是不允许apache用户上传的,所以显示的是403 Forbidden。下面我们给apache授权,允许上传。
1

[root@web1 ~]# setfacl -m u:apache:rwx /var/www/html/

下面我们再来测试一下,

[root@nginx ~]# curl -T /etc/issue http://192.168.18.201
<!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">
<html><head>
<title>201 Created</title>
</head><body>

Created

Resource /issue has been created.


Apache/2.2.15 (CentOS) Server at 192.168.18.201 Port 80

</body></html>

注,大家可以看到我们成功的上传了文件,说明nginx读写分离功能配置完成。最后,我们来查看一下上传的文件。
[root@web1 ~]# cd /var/www/html/
[root@web1 html]# ll
总用量 12
drwxr-xr-x 2 root root 4096 9月 4 13:16 forum
-rw-r--r-- 1 root root 23 9月 3 23:37 index.html
-rw-r--r-- 1 apache apache 47 9月 4 14:06 issue

[root@web1 ~]# cd /var/www/html/
[root@web1 html]# ll
总用量 12
drwxr-xr-x 2 root root 4096 9月 4 13:16 forum
-rw-r--r-- 1 root root 23 9月 3 23:37 index.html
-rw-r--r-- 1 apache apache 47 9月 4 14:06 issue

本文出自 “Share your knowledge …” 博客,请务必保留此出处http://freeloda.blog.51cto.com/2033581/1288553

win10下安装mysql5.7问题记录

原来一直用的是win7系统,公司新电脑装的是win10系统,于是开始在64位win10下搭建php环境,(win10+Apache2.4.18+Mysql5.7.11+Php7.0.3)。php和apache都是从官网上下的,安装过程也没出现什么问题,只是要注意自己的版本和运行库的版本

1.下载zip格式的免安装包

下载后解压安装包到mysql的安装目录。如 D:/WAMP/MYSQL57

2.编写配置文件

新建一个my.ini文件,然后用记事本打开输入mysql的基本配置:


[mysql]

default-character-set=utf8

[mysqld]

port = 3306 

basedir=D:\wamp\Mysql57

datadir=D:\wamp\Mysql57\data

max_connections=200

character-set-server=utf8

default-storage-engine=INNODB 

11.png

3.安装服务

以管理员身份运行cmd窗口后,进入mysql的bin目录。输入mysqld install回车运行。

33.png
注意一定要以管理员身份运行cmd

4.初始化data目录

命令行下运行 mysqld --initialize

5.启动服务

命令行下运行 net start mysql

mysql5.7之前的安装,root用户是不需要密码的,但是自mysql5.7开始就不可以了,登录时会报错

登录方式:mysql -u root -p 报错如下


ERROR 1045 (28000): Access denied for user'root'@'localhost'(using password: NO)

44.png

接下来我会记录一下我是怎么解决的