监控阮1峰老师的blog
监控阮一峰老师的blog
引言
阮一峰大家基本都认识，很厉害的一个人，经济学博士，文章写得很棒，知识面很广泛，计算机、算法、英语、文采，这是能想到的他的一些标签，他的博客应该算是最受欢迎的博客之一了。
我经常回去看他的博客，但有时候时间长了，再次去看，发现他已经有好几篇新文章了，我就在想，能不能自己写个程序，监控的他博客，当他有新文章的时候，第一时间推送给我。
思路
他的博客中有一个feed，是一个返回xml格式文档的接口，这个接口是最新的文章列表，总共15篇，可以通过监控这个接口中前几篇文章列表的变化来间接的检测他的文章更新，如果有新的文章马上给我的邮箱发送邮件，这样我就可以尽可能早的get到阮老师的最新文章了。
这是设计思路图：
首先就是rss解析了，这个使用php的原生函数simplexml_load_string得到一个解析之后的SimpleXMLElement对象，通过该对象可以很轻松的获取到阮老师更新的前几篇文章。然后和redis中的已发送文章列表集合作对比，如果有新的更新，将更新的信息发送给UDPserver，让UDPserver去发送邮件给用户列表。检测程序循环执行，每10分钟跑一次。
开始编码
有了思路编码就很快了（这里其实优化了好几次，刚开始的时候思路也没有这么明了，边做边改，当然了，还是要慢慢锻炼，开始之前尽可能多的完善思路）。
使用PHP依赖管理利器——Composer，经常使用PHP的开发者对这个工具应该很熟悉，不熟悉的同学可以点击前面的链接进行脑补，文档是中文的，很好懂。这个小系统将会使用到三个类库：phpmailer，predis，workerman。第一个是一个发送邮件的类库，可以点击这里查看他的相关信息，第二个类库是php对redis接口的封装，这里是他的源码地址，第三个是一个创建UDPserver的类库，这里是他的官方网站。
安装依赖的类库
首先新建一个项目目录，然后进入项目目录安装依赖
<code>mkdir blog-observercd blog-observercomposer require phpmailer/phpmailercomposer require predis/prediscomposer require workerman/workerman</code>
执行完上面的命令之后，会在项目目录blog-observer目录下面看到下面几个文件composer.json，composer.lock和文件夹vender，composer.json中的内容如下，至此依赖的类库安装好了。
<code class="sourceCode json"><span class="fu">{</span> <span class="dt">"require"</span><span class="fu">:</span> <span class="fu">{</span> <span class="dt">"phpmailer/phpmailer"</span><span class="fu">:</span> <span class="st">"^5.2"</span><span class="fu">,</span> <span class="dt">"predis/predis"</span><span class="fu">:</span> <span class="st">"^1.0"</span><span class="fu">,</span> <span class="dt">"workerman/workerman"</span><span class="fu">:</span> <span class="st">"^3.3"</span> <span class="fu">}</span><span class="fu">}</span></code>监控博客更新&推送更新消息给UDP
下面是主要代码，由于是服务端程序，所以这里设置为daemon进程，我这里UDPserver为udp://127.0.0.1:1234
<code class="sourceCode php">daemonize<span class="ot">();</span><span class="kw">while</span><span class="ot">(</span><span class="dv">1</span><span class="ot">)</span>{ <span class="co">//获取最新的几篇文章，看看是否需要推送</span> <span class="kw">$c</span> = <span class="fu">file_get_contents</span><span class="ot">(</span><span class="kw">XML_URL</span><span class="ot">);</span> <span class="kw">$parse</span> = <span class="er">@</span><span class="fu">simplexml_load_string</span><span class="ot">(</span><span class="kw">$c</span><span class="ot">);</span> <span class="kw">if</span><span class="ot">(</span><span class="kw">$parse</span><span class="ot">)</span> { <span class="kw">$count</span> = <span class="fu">count</span><span class="ot">(</span><span class="kw">$parse</span>->entry<span class="ot">);</span> <span class="kw">$count</span> = <span class="kw">$count</span> > <span class="kw">RECENT_NUM</span> <span class="ot">?</span> <span class="kw">RECENT_NUM</span> <span class="ot">:</span> <span class="kw">$count</span><span class="ot">;</span> <span class="kw">$maynew</span> = <span class="ot">[];</span> <span class="kw">for</span><span class="ot">(</span><span class="kw">$i</span> = <span class="dv">0</span><span class="ot">;</span> <span class="kw">$i</span> < <span class="kw">$count</span><span class="ot">;</span> <span class="kw">$i</span>++<span class="ot">)</span> { <span class="kw">$maynew</span><span class="ot">[</span><span class="kw">$parse</span>->entry<span class="ot">[</span><span class="kw">$i</span><span class="ot">]</span>-><span class="fu">link</span>->attributes<span class="ot">()</span>->href-><span class="fu">__toString</span><span class="ot">()]</span> = <span class="kw">$parse</span>->entry<span class="ot">[</span><span class="kw">$i</span><span class="ot">]</span>->title-><span class="fu">__toString</span><span class="ot">();</span> } <span class="kw">$body</span> = <span class="st">""</span><span class="ot">;</span> <span class="co">//是否推送</span> <span class="kw">foreach</span><span class="ot">(</span><span class="kw">$maynew</span> <span class="kw">as</span> <span class="kw">$url</span> => <span class="kw">$title</span><span class="ot">)</span> { <span class="kw">if</span><span class="ot">(</span><span class="kw">$client</span>->sadd<span class="ot">(</span><span class="kw">SENDED_SET_KEY</span><span class="ot">,</span> <span class="kw">$url</span><span class="ot">))</span> { <span class="co">//send EMAIL</span> <span class="kw">$body</span> .= <span class="st">"<a href='"</span>.<span class="kw">$url</span>.<span class="st">"'>"</span>.<span class="kw">$title</span>.<span class="st">"</a><br>"</span><span class="ot">;</span> } } <span class="kw">if</span><span class="ot">(</span><span class="kw">$body</span><span class="ot">)</span> { <span class="kw">$msg</span> = <span class="ot">[];</span> <span class="kw">$msg</span><span class="ot">[</span><span class="st">'type'</span><span class="ot">]</span> = <span class="dv">1</span><span class="ot">;</span> <span class="kw">$msg</span><span class="ot">[</span><span class="st">'mailbody'</span><span class="ot">]</span> = <span class="kw">$body</span><span class="ot">;</span> <span class="kw">$start</span> = <span class="dv">0</span><span class="ot">;</span> <span class="kw">while</span><span class="ot">(</span><span class="kw">$mailaddrs</span> = <span class="kw">$client</span>->lrange<span class="ot">(</span><span class="kw">EMAIL_LIST_KEY</span> <span class="ot">,</span><span class="kw">$start</span><span class="ot">,</span> <span class="ot">(</span><span class="kw">$start</span> + <span class="kw">EVERY_SEND_NUM</span> -<span class="dv">1</span> <span class="ot">)))</span> { <span class="kw">$msg</span><span class="ot">[</span><span class="st">'mailaddrs'</span><span class="ot">]</span> = <span class="kw">$mailaddrs</span><span class="ot">;</span> <span class="kw">$send_msg</span> = <span class="fu">json_encode</span><span class="ot">(</span><span class="kw">$msg</span><span class="ot">);</span> <span class="fu">socket_sendto</span><span class="ot">(</span><span class="kw">$sock</span><span class="ot">,</span> <span class="kw">$send_msg</span><span class="ot">,</span> <span class="fu">strlen</span><span class="ot">(</span><span class="kw">$send_msg</span><span class="ot">),</span> <span class="dv">0</span><span class="ot">,</span> <span class="st">'127.0.0.1'</span><span class="ot">,</span> <span class="dv">1234</span><span class="ot">);</span> <span class="kw">$start</span> += <span class="kw">EVERY_SEND_NUM</span><span class="ot">;</span> } } } <span class="fu">sleep</span><span class="ot">(</span><span class="kw">GAP_SECONDS</span><span class="ot">);</span>}</code>UDPserver程序
有了workerman，可以很方便的实现UDPserver，比自己写来的快得多。
<code class="sourceCode php"><span class="kw">$udp_worker</span> = <span class="kw">new</span> Workerman\Worker<span class="ot">(</span><span class="st">"udp://0.0.0.0:"</span>.<span class="kw">MAIL_UDP_PORT</span><span class="ot">);</span><span class="kw">$udp_worker</span>-><span class="fu">count</span> = <span class="dv">2</span><span class="ot">;</span><span class="kw">$udp_worker</span>->onMessage = <span class="kw">function</span><span class="ot">(</span><span class="kw">$connection</span><span class="ot">,</span> <span class="kw">$data</span><span class="ot">)</span> <span class="kw">use</span> <span class="ot">(</span><span class="kw">$mail</span><span class="ot">)</span>{ <span class="kw">$arr</span> = <span class="fu">json_decode</span><span class="ot">(</span><span class="kw">$data</span><span class="ot">,</span> <span class="kw">true</span><span class="ot">);</span> <span class="kw">switch</span><span class="ot">(</span><span class="kw">$arr</span><span class="ot">[</span><span class="st">'type'</span><span class="ot">])</span> { <span class="co">//发送邮件</span> <span class="kw">case </span><span class="st">'1'</span><span class="ot">:</span> { <span class="kw">$mailaddrs</span> = <span class="kw">$arr</span><span class="ot">[</span><span class="st">'mailaddrs'</span><span class="ot">];</span> <span class="kw">if</span><span class="ot">(</span>!<span class="fu">empty</span><span class="ot">(</span><span class="kw">$mailaddrs</span><span class="ot">)</span> && <span class="kw">$arr</span><span class="ot">[</span><span class="st">'mailbody'</span><span class="ot">])</span> { <span class="kw">foreach</span><span class="ot">(</span><span class="kw">$mailaddrs</span> <span class="kw">as</span> <span class="kw">$to</span><span class="ot">)</span> { <span class="kw">$mail</span>->clearAddresses<span class="ot">();</span> <span class="kw">$mail</span>->AddAddress<span class="ot">(</span><span class="kw">$to</span><span class="ot">);</span> <span class="kw">$mail</span>->Body = <span class="kw">$arr</span><span class="ot">[</span><span class="st">'mailbody'</span><span class="ot">];</span> <span class="kw">if</span><span class="ot">(</span>!<span class="kw">$mail</span>->Send<span class="ot">())</span> { <span class="fu">echo</span> <span class="st">"发送邮件失败：</span><span class="kw">\n</span><span class="st">"</span>.<span class="st">"address："</span>.<span class="kw">$to</span>.<span class="st">"</span><span class="kw">\n</span><span class="st">"</span><span class="ot">;</span> } } } <span class="kw">break</span><span class="ot">;</span> } <span class="kw">default:</span> <span class="kw">break</span><span class="ot">;</span> }}<span class="ot">;</span>Workerman\Worker::runAll<span class="ot">();</span></code>启动监控程序
好了，至此所有的设计编码工作就完成了，现在启动程序，进程启动之后会议daemon的形式运行，不会随着终端的关闭而停止。
<code>php xmldup.php startphp xmlmail.php</code>
总结
这是一个小系统，当然了还有很多不规范的地方，比如daemon进程一般都会以字母d结尾，还有就是启动很不方便，要启动两次脚本，哈哈，当然了，这只是自己先来无事玩玩了，要真设计一个完成的系统估计会考虑很多很多的东西，加油吧，继续前进。
这里是github地址：blog-observer，自己试用的时候记得修改邮箱名称和密码。
如果谁也想第一时间获取到最新的阮老师的文章可以给我发邮件，我把你们的邮件地添加到邮件list中，但不保证会发送到，有时候关了电脑程序就停止了~
- 7楼飞凡123
- 时间间隔设定的是多少
- Re: 奔跑的Man
- @飞凡123，测试的时候是600s，这个时间不能太短，太短了没多大意义，还浪费阮老师的服务器资源
- 6楼Liez
- 马克
- 5楼白丸
- 真是好学生
- 4楼旭宝爱吃鱼
- 可以，赞
- Re: 奔跑的Man
- @旭宝爱吃鱼，THX
- 3楼wzx_xle
- 我用的foxmail的rss订阅功能
- Re: 奔跑的Man
- @wzx_xle，@星夜落尘，RSS订阅？行，你们可以啊，我又没说不可以，你要用RSS订阅我啥也不说了，我就喜欢DIV，得劲了吧~~
- 2楼永远的麦子
- 写得很好，也很喜欢阮老师的博客，上次了解到阮老师的博客是学习git的时候了解到阮老师的。
- Re: 奔跑的Man
- @永远的麦子，谢谢了。多像阮老师学习，哈哈，多涉猎技术之外的知识充实自己
- 1楼星夜落尘
- 不是有rss订阅吗。。。
핫 AI 도구
Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱
AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.
Undress AI Tool
무료로 이미지를 벗다
Clothoff.io
AI 옷 제거제
AI Hentai Generator
AI Hentai를 무료로 생성하십시오.
인기 기사
뜨거운 도구
메모장++7.3.1
사용하기 쉬운 무료 코드 편집기
SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.
스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경
드림위버 CS6
시각적 웹 개발 도구
SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)
뜨거운 주제
7569
15
1386
52
87
11
61
19
28
107
화웨이 GT3 Pro와 GT4의 차이점은 무엇입니까?
Dec 29, 2023 pm 02:27 PM
많은 사용자들이 스마트 시계를 선택할 때 Huawei 브랜드를 선택하게 됩니다. 그 중 Huawei GT3pro와 GT4가 가장 인기 있는 선택입니다. 두 제품의 차이점을 궁금해하는 사용자가 많습니다. Huawei GT3pro와 GT4의 차이점은 무엇입니까? 1. 외관 GT4: 46mm와 41mm, 재질은 유리 거울 + 스테인레스 스틸 본체 + 고해상도 섬유 후면 쉘입니다. GT3pro: 46.6mm 및 42.9mm, 재질은 사파이어 유리 + 티타늄 본체/세라믹 본체 + 세라믹 백 쉘입니다. 2. 건강한 GT4: 최신 Huawei Truseen5.5+ 알고리즘을 사용하면 결과가 더 정확해집니다. GT3pro: ECG 심전도, 혈관 및 안전성 추가
Workerman 문서에서 파일 업로드 및 다운로드 구현
Nov 08, 2023 pm 06:02 PM
Workerman 문서에서 파일 업로드 및 다운로드를 구현하려면 특정 코드 예제가 필요합니다. 소개: Workerman은 간단하고 효율적이며 사용하기 쉬운 고성능 PHP 비동기 네트워크 통신 프레임워크입니다. 실제 개발에서 파일 업로드 및 다운로드는 일반적인 기능 요구 사항입니다. 이 기사에서는 Workerman 프레임워크를 사용하여 파일 업로드 및 다운로드를 구현하는 방법을 소개하고 구체적인 코드 예제를 제공합니다. 1. 파일 업로드: 파일 업로드란 로컬 컴퓨터에 있는 파일을 서버로 전송하는 작업을 말합니다. 다음이 사용됩니다
Workerman 문서의 기본 사용법을 구현하는 방법
Nov 08, 2023 am 11:46 AM
Workerman 문서의 기본 사용법을 구현하는 방법 소개: Workerman은 개발자가 동시성이 높은 네트워크 애플리케이션을 쉽게 구축하는 데 도움이 되는 고성능 PHP 개발 프레임워크입니다. 이 기사에서는 설치 및 구성, 서비스 및 수신 포트 생성, 클라이언트 요청 처리 등 Workerman의 기본 사용법을 소개합니다. 그리고 해당 코드 예제를 제공하십시오. 1. Workerman을 설치하고 구성하려면 명령줄에 다음 명령을 입력합니다.
스울과 워커맨 중 어느 것이 더 낫나요?
Apr 09, 2024 pm 07:00 PM
Swoole과 Workerman은 모두 고성능 PHP 서버 프레임워크입니다. 비동기 처리, 우수한 성능 및 확장성으로 잘 알려진 Swoole은 많은 수의 동시 요청과 높은 처리량을 처리해야 하는 프로젝트에 적합합니다. Workerman은 사용 편의성과 낮은 동시성 볼륨을 처리하는 프로젝트에 더 적합한 직관적인 API를 통해 비동기식 및 동기식 모드의 유연성을 제공합니다.
워커맨 개발: UDP 프로토콜 기반 실시간 영상통화 구현 방법
Nov 08, 2023 am 08:03 AM
Workerman 개발: UDP 프로토콜 기반 실시간 영상통화 요약: 이 글에서는 Workerman 프레임워크를 사용하여 UDP 프로토콜 기반 실시간 영상통화 기능을 구현하는 방법을 소개합니다. UDP 프로토콜의 특성을 심층적으로 이해하고 코드 예제를 통해 간단하지만 완전한 실시간 화상 통화 애플리케이션을 구축하는 방법을 보여줍니다. 소개: 네트워크 통신에서 실시간 영상통화는 매우 중요한 기능입니다. 기존 TCP 프로토콜은 실시간 영상 통화 구현 시 전송 지연 등의 문제가 발생할 수 있습니다. 그리고 UDP
Workerman을 사용하여 고가용성 로드 밸런싱 시스템을 구축하는 방법
Nov 07, 2023 pm 01:16 PM
Workerman을 사용하여 고가용성 로드 밸런싱 시스템을 구축하려면 특정 코드 예제가 필요합니다. 현대 기술 분야에서는 인터넷의 급속한 발전으로 인해 점점 더 많은 웹사이트와 애플리케이션이 많은 수의 동시 요청을 처리해야 합니다. 고가용성과 고성능을 달성하기 위해 로드 밸런싱 시스템은 필수 구성 요소 중 하나가 되었습니다. 이 기사에서는 PHP 오픈 소스 프레임워크인 Workerman을 사용하여 고가용성 로드 밸런싱 시스템을 구축하는 방법을 소개하고 구체적인 코드 예제를 제공합니다. 1. WorkermanWorke 소개
Workerman 문서에서 역방향 프록시 기능을 구현하는 방법
Nov 08, 2023 pm 03:46 PM
Workerman 문서에서 역방향 프록시 기능을 구현하려면 구체적인 코드 예제가 필요합니다. 소개: Workerman은 풍부한 기능과 강력한 성능을 제공하는 고성능 PHP 다중 프로세스 네트워크 통신 프레임워크로 웹 실시간 통신 및 장기 통신에 널리 사용됩니다. 연결. 그 중 Workerman은 서버가 외부 서비스를 제공할 때 로드 밸런싱과 정적 리소스 캐싱을 실현할 수 있는 역방향 프록시 기능도 지원합니다. 이 글에서는 Workerman을 사용하여 역방향 프록시 기능을 구현하는 방법을 소개합니다.
Workerman 문서에서 타이머 기능을 구현하는 방법
Nov 08, 2023 pm 05:06 PM
Workerman 문서에서 타이머 기능을 구현하는 방법 Workerman은 타이머 기능을 포함한 다양한 기능을 제공하는 강력한 PHP 비동기 네트워크 통신 프레임워크입니다. 타이머를 사용하여 지정된 시간 간격 내에서 코드를 실행합니다. 이는 예약된 작업 및 폴링과 같은 애플리케이션 시나리오에 매우 적합합니다. 다음으로는 Workerman에서 타이머 기능을 구현하는 방법을 자세히 소개하고 구체적인 코드 예시를 제공하겠습니다. 1단계: Workerman 설치 먼저 Worker를 설치해야 합니다.
