监控阮1峰老师的blog

原创: 2016-06-13 12:29:03 857浏览

监控阮一峰老师的blog

引言

阮一峰大家基本都认识，很厉害的一个人，经济学博士，文章写得很棒，知识面很广泛，计算机、算法、英语、文采，这是能想到的他的一些标签，他的博客应该算是最受欢迎的博客之一了。
我经常回去看他的博客，但有时候时间长了，再次去看，发现他已经有好几篇新文章了，我就在想，能不能自己写个程序，监控的他博客，当他有新文章的时候，第一时间推送给我。

思路

他的博客中有一个feed，是一个返回xml格式文档的接口，这个接口是最新的文章列表，总共15篇，可以通过监控这个接口中前几篇文章列表的变化来间接的检测他的文章更新，如果有新的文章马上给我的邮箱发送邮件，这样我就可以尽可能早的get到阮老师的最新文章了。
这是设计思路图：
系统流程图

首先就是rss解析了，这个使用php的原生函数simplexml_load_string得到一个解析之后的SimpleXMLElement对象，通过该对象可以很轻松的获取到阮老师更新的前几篇文章。然后和redis中的已发送文章列表集合作对比，如果有新的更新，将更新的信息发送给UDPserver，让UDPserver去发送邮件给用户列表。检测程序循环执行，每10分钟跑一次。

开始编码

有了思路编码就很快了（这里其实优化了好几次，刚开始的时候思路也没有这么明了，边做边改，当然了，还是要慢慢锻炼，开始之前尽可能多的完善思路）。
使用PHP依赖管理利器——Composer，经常使用PHP的开发者对这个工具应该很熟悉，不熟悉的同学可以点击前面的链接进行脑补，文档是中文的，很好懂。这个小系统将会使用到三个类库：
phpmailer，predis，workerman。第一个是一个发送邮件的类库，可以点击这里查看他的相关信息，第二个类库是php对redis接口的封装，这里是他的源码地址，第三个是一个创建UDPserver的类库，这里是他的官方网站。

安装依赖的类库

首先新建一个项目目录，然后进入项目目录安装依赖

mkdir blog-observercd blog-observercomposer require phpmailer/phpmailercomposer require predis/prediscomposer require workerman/workerman

执行完上面的命令之后，会在项目目录blog-observer目录下面看到下面几个文件composer.json，composer.lock和文件夹vender，composer.json中的内容如下，至此依赖的类库安装好了。

{    "require": {        "phpmailer/phpmailer": "^5.2",        "predis/predis": "^1.0",        "workerman/workerman": "^3.3"    }}

监控博客更新&推送更新消息给UDP

下面是主要代码，由于是服务端程序，所以这里设置为daemon进程，我这里UDPserver为udp://127.0.0.1:1234

daemonize();while(1){       //获取最新的几篇文章，看看是否需要推送    $c = file_get_contents(XML_URL);    $parse = @simplexml_load_string($c);    if($parse)    {           $count  = count($parse->entry);        $count  = $count > RECENT_NUM ? RECENT_NUM : $count;        $maynew = [];          for($i = 0; $i $count; $i++)        {               $maynew[$parse->entry[$i]->link->attributes()->href->__toString()]   = $parse->entry[$i]->title->__toString();        }        $body   = "";        //是否推送        foreach($maynew as $url => $title)        {               if($client->sadd(SENDED_SET_KEY, $url))            {                   //send EMAIL                $body   .= ".$url."'>".$title."
";            }        }        if($body)        {               $msg                = [];            $msg['type']        = 1;            $msg['mailbody']    = $body;            $start              = 0;            while($mailaddrs = $client->lrange(EMAIL_LIST_KEY ,$start, ($start + EVERY_SEND_NUM -1 )))            {                $msg['mailaddrs']   = $mailaddrs;                $send_msg           = json_encode($msg);                socket_sendto($sock, $send_msg, strlen($send_msg), 0, '127.0.0.1', 1234);                $start              += EVERY_SEND_NUM;            }        }    }    sleep(GAP_SECONDS);}

UDPserver程序

有了workerman，可以很方便的实现UDPserver，比自己写来的快得多。

$udp_worker         = new Workerman\Worker("udp://0.0.0.0:".MAIL_UDP_PORT);$udp_worker->count  = 2;$udp_worker->onMessage = function($connection, $data) use ($mail){    $arr    = json_decode($data, true);    switch($arr['type'])    {        //发送邮件        case '1':        {            $mailaddrs  = $arr['mailaddrs'];            if(!empty($mailaddrs) && $arr['mailbody'])            {                foreach($mailaddrs as $to)                {                    $mail->clearAddresses();                    $mail->AddAddress($to);                    $mail->Body = $arr['mailbody'];                    if(!$mail->Send())                    {                        echo "发送邮件失败：\n"."address：".$to."\n";                    }                }            }            break;        }        default:            break;    }};Workerman\Worker::runAll();