文档章节

swoole+inotify实现异步实时文件监控

matyhtf
 matyhtf
发布于 2014/11/12 13:54
字数 641
阅读 5514
收藏 72
点赞 12
评论 3

inotify扩展介绍

inotify是Linux内核提供的一组系统调用,它可以监控文件系统操作,比如文件或者目录的创建、读取、写入、权限修改和删除等。

inotify使用也很简单,使用inotify_init创建一个句柄,然后通过inotify_add_watch/inotify_rm_watch增加/删除对文件和目录的监听。

PHP中提供了inotify扩展,支持了inotify系统调用。inotify本身也是一个文件描述符,可以加入到事件循环中,配合使用swoole扩展,就可以异步非阻塞地实时监听文件/目录变化。

安装inotify/swoole扩展

如果已经安装了inotify/swoole可以跳过此步骤。

pecl install swoole
pecl install inotify

操作成功后,修改php.ini,加入

extension=swoole.so
extension=inotify.so

查看扩展是否加载成功:

php -m | grep swoole
php -m | grep inotify

inotify的使用

首先在当前目录创建一个inotify.data文件,示例就用来监听此文件。

//创建一个inotify句柄
$fd = inotify_init();

//监听文件,仅监听修改操作,如果想要监听所有事件可以使用IN_ALL_EVENTS
$watch_descriptor = inotify_add_watch($fd, __DIR__.'/inotify.data', IN_MODIFY); 

while (true) {
    //阻塞地读取数据
    $events = inotify_read($fd);
    if ($events) {
        foreach ($events as $event) {
            echo "inotify Event :".var_export($event, 1)."\n";
        }
    }
}

//释放inotify句柄
inotify_rm_watch($fd, $watch_descriptor);
fclose($fd);

修改inotify.data,就可以看到程序输出了信息。

echo "hello world" > inotify.data

inotify Event :array (
  'wd' => 1,
  'mask' => 2,
  'cookie' => 0,
  'name' => '',
)

swoole+inotify异步非阻塞监听文件

//创建一个inotify句柄
$fd = inotify_init();

//监听文件,仅监听修改操作,如果想要监听所有事件可以使用IN_ALL_EVENTS
$watch_descriptor = inotify_add_watch($fd, __DIR__.'/inotify.data', IN_MODIFY);

//加入到swoole的事件循环中
swoole_event_add($fd, function ($fd) {
    $events = inotify_read($fd);
    if ($events) {
        foreach ($events as $event) {
            echo "inotify Event :" . var_export($event, 1) . "\n";
        }
    }
});

这里使用了swoole扩展提供swoole_event_add函数,将inotify句柄设置为非阻塞,并加入到epoll事件循环中。程序变成异步非阻塞模式。当有事件发生时才会执行inotify_read获取事件。没有事件发生时,程序可以执行其他的逻辑。

此程序与上一个同步阻塞例子的逻辑是相同的,向inotify写入内容时也会打印事件信息。区别在于swoole+inotify的程序是异步的。可以支持并发监听大量文件和目录,并且除了inotify操作之外还可以执行其他的IO操作。



© 著作权归作者所有

共有 人打赏支持
matyhtf

matyhtf

粉丝 390
博文 13
码字总数 7425
作品 8
深圳
程序员
加载中

评论(3)

小妖万岁
PHP Fatal error: swoole_event_add(): async-io must use in cli environment. 这个函数 不能用。。。。
徐长龙
徐长龙
补充,我照着做了下,手欠加了个while和sleep就挂了。。这个代码结尾不需要死循环和sleep~
prpr
prpr
与sersync比如何?
OSChina 技术周刊第九期 —— 每周技术精选,值得一看!

每周技术抢先看,总有你想要的! 移动开发 【翻译】介绍 Visual Studio 的 Android 模拟器 【博客】手机腾讯网mt框架之mtwebapp示例解析。 【博客】《Android深入透析》之常用设计模式经验谈...

OSC编辑部 ⋅ 2014/11/16 ⋅ 4

ischitry/LogMonitor

LogMonitor - Log日志Web在线同步监控 LogMonitor是一款简易的日志web在线监控工具,使用servlet3.0异步servlet技术,整个项目中的主要文件仅有4个,复杂度低,使用它,你可以很方便将他集成...

ischitry ⋅ 2016/09/28 ⋅ 0

大众点评开源分布式监控平台 CAT 深度剖析

一、CAT介绍 CAT系统原型和理念来源于eBay的CAL的系统,CAT系统第一代设计者吴其敏在eBay工作长达十几年,对CAL系统有深刻的理解。CAT不仅增强了CAL系统核心模型,还添加了更丰富的报表。自2...

王练 ⋅ 2016/10/31 ⋅ 11

深度剖析开源分布式监控系统CAT的设计思路

自2014年开源以来,除了美团点评之外,CAT还在携程、陆金所、猎聘网、找钢网等多家互联网公司生产环境应用,项目的开源地址是http://github.com/dianping/cat。 背景介绍 CAT整个产品研发是从...

满小茂 ⋅ 2016/11/10 ⋅ 0

bboss 大数据抽取工具 4.0.8 发布

bboss大数据抽取工具4.0.8发布 bboss大数据抽取工具功能特点如下: 实现db到hadoop hdfs数据导入功能,提供高效的分布式并行处理能力,可以采用数据库分区、按字段分区、分页方式并行批处理抽...

bboss ⋅ 2015/08/01 ⋅ 5

rsync+inotify实现文件实时同步

rsync+inotify实现文件实时同步 关于rsync,在我个人理解中,这个命令在使用时和scp很像,因为这两个命令在使用时的格式大体相同。所以在记忆的时候可以类比scp命令来记忆。 rsync最大的好处...

烟头网管 ⋅ 2015/01/28 ⋅ 0

bboss v4.0.9 发布,大数据抽取工具

bboss 大数据抽取工具 4.0.9 发布 相较上一版本(v4.0.8),v4.0.9增加了以下特性: 按照按日期字段切分任务,抽取db数据到hdfs,可以在第一次切分任务的基础上,将日期范围任务块进一步切分...

bboss ⋅ 2015/08/29 ⋅ 2

rsync+inotify实现数据实时同步备份

在实际生产环境当中,我们总会遇见需要把一些重要数据进行备份,且随着应用系统规模的增大,对数据的安全性、可靠性、时效性要求还是比较高的, 因此我自己有在用rsync+inotify来实现数据实时...

翘楚秦歌 ⋅ 2017/06/13 ⋅ 0

如何基于MYSQL做实时计算?

有时候我们会有这样的场景,在某个接口中,数据已经很规范地存入到一张的MYSQL表中,现在想对这样的数据做一些实时或准实时处理,比如数据多模式存储、异步准实时业务流程、业务实时监控等。...

阿里云云栖社区 ⋅ 2017/12/25 ⋅ 0

如何使用海康SDK实现网络摄像机(IPC)自动配置【源码】【监控】【录播】【NVR】

前言: 在上一篇博客:《如何使用海康SDK实现异步登录网络摄像机(IPC)》,我们实现了完全的IPC异步登录,今天我们要完成的是:实现IPC的自动配置,能够自动设定主码流和子码流,能获取通道的...

haoyitech ⋅ 03/15 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

apollo配置中心的学习笔记

公司现在配置文件太多了,导致配置文件修改起来还是非常麻烦的。在boss(业务运营支撑系统)中,配置文件是存放在jar包的,通过应用jar包来引用配置文件(区分不同环境)。这种方式虽然能够满足...

miaojiangmin ⋅ 3分钟前 ⋅ 0

Jena增删改查AP

插入、更新数据 public static void insert(){ String query = "PREFIX book: <http://www.book.com/jinyong/> \n" + " INSERT DATA \n" + ......

Vincent-Duan ⋅ 4分钟前 ⋅ 0

springMVC之与json数据交互方法

因为我也要返回json数据。所以需要这个注解@ResponseBody,把Java对象转换成json字符串 注意: 1、@RequestBody不能省,因为前台发过来的数据是json数据,得用这个注解去解析该怎么接收这些数...

颖伙虫 ⋅ 8分钟前 ⋅ 0

用实例域代替序号(31)

1、许多枚举天生就与一个单独的int 值相关联 ordinal 方法,返回枚举常量在类型中的数字位置 下述,枚举修改很不方便,不好维护 永远不要根据枚举的序数导出与他相关联的值 而是将他保存在一...

职业搬砖20年 ⋅ 10分钟前 ⋅ 0

并发编程---ConcurrentHashMap源码解析

ConcurrentHashMap是java中为了解决HashMap不能支持高并发而设计的新的实现。 ConcurrentHashMap的类结构 public class ConcurrentHashMap<K,V> extends AbstractMap<K,V> implements C......

千古一梦888 ⋅ 13分钟前 ⋅ 0

微服务 WildFly Swarm 简介

我们将看到的最后一个Java微服务框架是一个相对较新的场景,它利用了 JBoss WildFly 应用服务器中已试过且受信任的 JavaEE 功能。WildFly Swarm 是 WildFly 应用服务器的一个完整的拆下来的组...

woshixin ⋅ 18分钟前 ⋅ 0

android apk 瘦身

头条APK瘦身之路 随着版本迭代,功能增加安装包体积也会慢慢增大。 今日头条576版本APK达到了25M,通过一系列的优化,到目前的607版本为12M。本文主要是介绍头条APK瘦身中用到的一些方法。 ...

GoldenVein ⋅ 21分钟前 ⋅ 1

mac机器学习开发环境部署及helloworld

一、下载并安装Anaconda2.7 https://repo.anaconda.com/archive/Anaconda2-5.2.0-MacOSX-x86_64.pkg 路径:/Users/shijun/anaconda2 二、运行Anaconda Navigator -> Environments -> base(ro......

八戒八戒八戒 ⋅ 32分钟前 ⋅ 0

关于日常开发的经验总结(Java),持续更新中

常量尽量使用枚举来表示,这样表现力会很强,因为枚举比一个常量类要有更多的扩展性 方法的入参和出参尽量不要使用Map,因为Map会让调用者感到迷惑,他不知道你里面装的什么,面向对象的开发...

小99 ⋅ 33分钟前 ⋅ 0

IDEA创建SpringMVC+Mybatis+Maven项目

视频如下(加载有点慢请见谅,服务器不太好): 视频

影狼 ⋅ 33分钟前 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部