Ⅰ nodejs——定时器
javaScript中可以实现定时器功能的有两个函数——setTimeout和setInterval,二者的不同是setTimeout只执行一次,而setInterval是以指定的时间间隔重复执行。setTimeout可以使用clearTimeout取消,setInterval可以使用clearInterval取消。
有时,我们会用setTimeout(callback,0)将任务推迟一段很短的时间,但是其实通过process.nextTick(callback)来实现会更好,因为Node中的事件循环在一个处理事件队列的循环里运行,每循环一次称为一个“tick”。使用process.nextTick(callback)回调函数会在事件队列内所有事件处理完毕后,会在下次事件循环之前被调用,即进入下个event loop前执行;而setTimeout(callback,0)把回调延迟到后面的某个event loop执行,具体由设置的延时时间和event loop的执行时间决定。
这样可以保证my_async_function函数是顺序执行。
Ⅱ Nodejs 定时器 later 怎么运行自己创建的 schele
在实际开发项目中,会遇到很多定时任务的工作。比如:定时导出某些数据、定时专发送消息或邮件给用户、定属时备份什么类型的文件等等
一般可以写个定时器,来完成相应的需求,在node.js中自已实现也非常容易,接下来要介绍的是node-schele来完成定时任务!
Ⅲ 关于nodejs的web server如何设置开机启动,定时重启和自动备份数据
方法有很多,一一介绍下面这种:
开始-运行-shutdown.exe -s -t 3600,执行以后,系统默认关机时间为1个小时;
上面命令win7系统有时候会不执行关机,可以加个-f,强制关机:shutdown.exe -f -s -t 3600,这样1小时以后会强制关机;
控制面版-管理工具-计划任务程序也可以设置自动关机的任务;
现在好多软件也可以设置自动关机,比如qq音乐,在设置面版里面就可以设置多久关机;
P.S取消上面1.2的关机命令:shutdown.exe -a 就可以取消设置的1小时以后关机的命令了;
-s 关闭此计算机
-r 关闭并且重新启动改计算机
-a 放弃关闭计算机任务
-t xx 为设置关机的时间,XX单位为秒
-f 强制运行的应用程序关闭而没有警告
Ⅳ 如何给nodejs redis session 定时
这里所说的定时任务可以说是计时器任务,比如说用户触发了某个动作,那么从这个点开始过二十四小时要对这个动作做点什么。那么如果有 1000 个用户触发了这个动作,就会有 1000 个定时任务。于是这就不是 Cron 范畴里面的内容了。
举个最简单的例子,一个用户推荐了另一个用户,定一个二十四小时之后的任务,看看被推荐的用户有没有来注册,如果没注册就给他搞一条短信过去。Σ>―(〃°ω°〃)♡→
最初的设想
一开始是想把这个计时器做在内存里面直接调用的。
考虑到 Node.js 的定时并不是那么准确(无论是setTimeout还是setInterval),所以本来打算自己维护这个定时器队列。
又考虑到 Node.js 原生对象比较耗内存。之前用JSON对象存了一本字典,约十二万多的词条,原文件大概也就五六兆,用 Node.js 的原生对象一存居然有五六百兆的内存占用——所以打算这个定时器队列用 C++ 来写 addon。
考虑到任何时候插入的任务都有可能在已有的任务之前或者之后,所以本来想用 C++ 来写一个 小根堆 。每次用户来一个任务的时候就将这个任务插入到堆中。
如果按照上述方法的话,再加上对时间要求掐得也不是那么紧,于是就是一个不断的process.nextTick()的过程。
在process.nextTick()当中执行这么一个函数:
从小根堆中不断获取堆顶的任务并处理,一直处理到堆顶任务的执行时间大于当前时间为止。
继续process.nextTick()来让下一个 tick 执行步骤 1 中的流程。
所以最后就是一边往小根堆插入任务,另一边通过不断process.nextTick()消费任务的这么一个过程。
最后,为了考虑到程序重启的时候内存数据会丢失,还应该做一个持久化的事情——在每次插入任务的时候顺便往持久化中间件中插一条副本,比如 MySQL、MongoDB、Redis、Riak 等等任何三方依赖。消费任务的时候顺便把中间件中的这条任务数据给删除。
也就是说中间件中永远存的就是当前尚未完成的任务。每当程序重启的时候都先从中间件中把所有任务读取进来重建一下堆,然后就能继续工作了。
如果当时没有发现 Redis 的这个妙用的话,上述的流程将会是实现定时任务的流程了。
Redis 妙用
在 Redis 的 2.8.0 版本之后,其推出了一个新的特性——键空间消息( Redis Keyspace Notifications ),它配合 2.0.0 版本之后的SUBSCRIBE就能完成这个定时任务的操作了, 不过定时的单位是秒 。
Publish / Subscribe
Redis 在 2.0.0 之后推出了 Pub / Sub 的指令,大致就是说一边给 Redis 的特定频道发送消息,另一边从 Redis 的特定频道取值——形成了一个简易的消息队列
比如可以往foo频道推一个消息bar,那么就可以直接:
PUBLISH foo bar
javascript
var Redis = require("ioredis");
var sub = new Redis(/** 连接信息 */);
sub.once("connect", function() {
// 假设需要选择 redis 的 db,因为实际上们不会去污染默认的 db 0
sub.select(DB_NUMBER, function(err) {
if(err) process.exit(4);
sub.subscribe("foo", function() {
//... 订阅频道成功
});
});
});
// 监听从 `foo` 来的消息
sub.on("message", function(channel, msg) {
console.log(channel, msg);
});
Redis Keyspace Notifications
在 Redis 里面有一些事件,比如键到期、键被删除等。然后可以通过配置一些东西来让 Redis 一旦触发这些事件的时候就往特定的 Channel 推一条消息。
本文所涉及到的需求的话所需要关心的事件是EXPIRE即过期事件。
大致的流程就是给 Redis 的某一个 db 设置过期事件,使其键一旦过期就会往特定频道推消息,在自己的客户端这边就一直消费这个频道就好了。
以后一来一条定时任务,就把这个任务状态压缩成一个键,并且过期时间为距这个任务执行的时间差。那么当键一旦到期,就到了任务该执行的时间,Redis 自然会把过期消息推去,的客户端就能接收到了。这样一来就起到了定时任务的作用。
消息类型
当达到一定条件后,有两种类型的这种消息会被触发,用哪个需要自己选了。举个例子,删除了在 db 0 中一个叫foo的键,那么系统会往两个频道推消息,一个是del事件频道推foo消息,另一个是foo频道推del消息,它们小俩口被系统推送的指令分别等价于:
PUBLISH __keyspace@0__:foo del PUBLISH __keyevent@0__:del foo
其中往foo推送del的频道名为__keyspace@0__:foo,即是"__keyspace@" + DB_NUMBER + "__:" + KEY_NAME;而del的频道名为"__keyevent@" + DB_NUMBER + "__:" + EVENT_NAME。
配置
即使你的 Redis 版本达标了,但是 Redis 默认是关闭这个功能的,你需要修改配置文件来打开它,或者直接在 CLI 里面通过指令修改。这里就说说配置文件的修改吧。。
首先打开 Redis 的配置文件,在不同的系统和安装方式下文件位置可能不同,比如通过brew安装的 MacOS 下可能是在/usr/local/etc/redis.conf下面,通过apt-get安装的 Ubuntu 下可能是在/etc/redis/redis.conf下,总之找到配置文件。或者自己写一个配置文件,启动的时候指定配置文件地址就好。
然后找到一项叫notify-keyspace-events的地方,如果找不到则自行添加,其值可以是Ex、Klg等等。这些字母的具体含义如下所示:
K ,表示keyspace事件,有这个字母表示会往__keyspace@<db>__频道推消息。
E ,表示keyevent事件,有这个字母表示会往__keyevent@<db>__频道推消息。
g ,表示一些通用指令事件支持,如DEL、EXPIRE、RENAME等等。
$ ,表示字符串(String)相关指令的事件支持。
l ,表示列表(List)相关指令事件支持。
s ,表示集合(Set)相关指令事件支持。
h ,哈希(Hash)相关指令事件支持。
z ,有序集(Sorted Set)相关指令事件支持。
x ,过期事件,与 g 中的EXPIRE不同的是, g 的EXPIRE是指执行EXPIRE key ttl这条指令的时候顺便触发的事件,而这里是指那个key刚好过期的这个时间点触发的事件。
e ,驱逐事件,一个key由于内存上限而被驱逐的时候会触发的事件。
A ,g$lshzxe的别名。也就是说AKE的意思就代表了所有的事件。
结合上述列表就能拼凑出自己所需要的事件支持字符串了,在需求中只需要Ex就可以满足了,所以配置项就是这样的:
notify-keyspace-events Ex
然后保存配置文件,启动 Redis 就启用了过期事件的支持了。
实践
先说任务的创造者吧。由于这里 Redis 的事件只会传键名,并不会传键值,而过期事件触发的时候那个键已经没了,你也无法获取键值,加上主系统和任务系统是分布式的,所以就把所有需要的信息往键名塞。
一个最简单的键名设计就是任务类型 + ":" + JSON.stringify 化后的参数数组;更有甚者可以直接把任务类型替换成所需的函数路径,比如需要执行这个任务的函数在task/foo/bar文件下面的baz函数,参数arguments数组为[ 1, 2 ],那么键名的设计可以是task/foo/bar.baz:[1,2],反正只需要触发这个键,用不着去查询这个键。等到真正过期了任务系统接收到这个键名的时候再一一解析,得到需要执行task/foo/bar.baz这个消息,并且网函数里面传入[1,2]这个arguments。
所以当接收到一个定时任务的时候,得到消息、函数名、过期时间参数,这个函数
/** 假设 redis 是一个 ioredis 的对象 */
var sampleTaskMaker = function(message, func, timeout) {
message = JSON.stringify(message);
console.log("Received a new task:", func, message, "after " + timeout + ".");
// 这里的 uuid 是 npm 一个包
// 生成一个唯一 uuid 的目的是为了防止两个任务用了相同的函数和参数,那么
// 键名可能会重复并覆盖的情况
// uuid 的文档为 https://www.npmjs.com/package/node-uuid
//
// 这里的 ❤️ 是一个分隔符,冒号是分割 uuid 和后面内容的,而 ❤️ 是分割函数名
// 和消息的
var key = uuid.v1().replace(/-/g, "") +
":❤️" + func + "❤️" + message;
var content = "";
redis.multi()
.set(key, content)
.expire(key, timeout)
.exec(function(err) {
if(err) {
console.error("Failed to publish EXPIRE EVENT for " + content);
console.error(err);
return;
}
});
};
// assign 是 sugarjs 里面的函数
// 把 db 塞到字符串里面的 {db} 里去
var subscribeKey = "__keyevent@{db}__:expired".assign({ db: 1 });
// 假设 sub 是 ioredis 的对象
sub.once("connect", function() {
// 假设需要选择 redis 的 db,因为实际上不会去污染默认的 db 0
sub.select(1, function(err) {
if(err) process.exit(4);
sub.subscribe("foo", function() {
//... 订阅频道成功
});
});
});
// 监听从 `foo` 来的消息
sub.on("message", sampleOnExpired);
注意:这里选择 db 1 是因为一旦开启过期事件监听,那么这个 db 的所有过期事件都会被发送。为了不跟正常使用的 redis 过期键混淆,为这个事情专门用一个新的 db。比如在自己正常使用的 db 0 里面监听了,那么不是任务触发的过期事件也会传过来,这个时候解析的键名就不对了。
最后就是sampleOnExpired函数了。
var sampleOnExpired = function(channel, key) {
// UUID:❤️func❤️params
var body = key.split("❤️");
if(body.length < 3) return;
// 取出 body 第一位为 func
var func = body[1];
// 推出前两位,后面剩下的有可能是参数里面自带 ❤️ 而被分割,所以要拼回去
body.shift(); body.shift();
var params = body.join("❤️");
// 然后把 params 传入 func 去执行
// func:
// path1/path2.func
func = func.split(".");
if(func.length !== 2) {
console.error("Bad params for task:", func.join("."), "-", params);
return;
}
var path = func[0];
func = func[1];
var mod;
try {
mod = require("./tasks/" + path);
} catch(e) {
console.error("Failed to load mole", path);
console.error(e.stack);
return;
}
process.nextTick(function() {
try {
mod[func].apply(null, JSON.parse(params));
} catch(e) {
console.error("Failed to call function", path, "-", func, "-", params);
console.error(e.stack);
}
});
};
这个简易的架子搭好后,只需要去写一堆任务执行函数,然后在生成任务的时候把相应参数传给sampleTaskMaker就好了。Redis 会自动过期并且触发事件给sampleOnExpired函数,然后就会去执行相应的任务处理函数了
Ⅳ NodeJs多线程、多进程、定时任务
JS是单线程语言,减少了线程间切换的开销,且不用考虑锁的问题,因此适合IO密集型项目。
JS的单线程,其实指的是js主引擎线程的。除此之外还有定时器线程、异步http线程(ajax)等,最终通过Event Loop协调执行。
为了充分利用多核CPU,可以使用 worker_threads 实现多线程, child_process 或 cluster 实现多进程(master-worker模式)。
不同于浏览器中的 web worker ,nodejs中通过 worker_threads 实现多线程。通常在计算密集型场景中,才需要使用NodeJs多线程,因此使用场景较少。
electron中即经常使用该模块。
cluster 封装了 child_process.fork ,并内置了负载均衡,可有效实现多进程。
Ⅵ NodeJs的一次实用(定时抓取数据)
想定时抓取某个接口的数据,然后解析数据,通过邮件通知给我。
1、 https 用来发送网络请求
2、 node-schele 用来实现定时任务
3、 nodemailer 用来发送邮件
介绍一下简单用法
我这里使用的QQ邮箱,使用第三方发送邮件需要打开授权,我这里开启的是 POP3/IMAP ,然后用授权码登录。 授权方法->
哈哈,还是比较成功的,达到了我预期的目标。
邮件接收的延迟比较大,大概3分钟左右,耐心等候,另外我在QQ邮箱的发件箱里没看到已发送的邮件,可能不会显示。
demo就不发了,比较简单,这几个模块组装起来就可以运行了。
Ⅶ nodejs如何实现定时任务
1.使用node-schele在指定时间执行方法
var schele = require('node-schele');
var date = new Date(2017, 11, 16, 16, 43, 0);
var j = schele.scheleJob(date, function(){
console.log('现在时间:',new Date());
});
2.指定时间间隔执行方法 (扩展-->每秒执行就是rule.second =[0,1,2,3......59])
var rule = new schele.RecurrenceRule();
rule.second = 10;
var j = schele.scheleJob(rule, function(){
console.log('现在时间:',new Date());
});
3.每小时的固定时间
(每小时的40分钟执行)
var rule = new schele.RecurrenceRule();
rule.minute = 40;
var j = schele.scheleJob(rule, function(){
console.log("执行任务");
});
Ⅷ nodeJS实现企业微信机器人每天定时发消息实例 定时任务
由于企业微信办公需要,“每天定时推送某消息用来提醒群里面所有人或者部分人”,于是决定用企业微信自带的机器人来实现此功能,来代替人为的每天发送同样的消息,具体方法我来一一讲述。
需要用到企业微信群、企业微信机器人、一台服务器(或者一台不关机的电脑)、nodeJS、node-schele、request等;
具体见官网说明: https://work.weixin.qq.com/help?person_id=1&doc_id=13376
GitHub地址: https://github.com/chenwenbo236/timedTasks.git
关于 node-schele request 的详细教程,可自行网络。
如有什么问题,可以指出,谢谢!
Ⅸ Nodejs中读取中文文件编码问题、发送邮件和定时任务实例
关于nodejs读取中文文件真是折腾了不少时间,网上各种方案,最后没有一个适用我,好在解决了。
下面的三个知识点都是从项目中抽出的,要单独运行脚本的话需要用全局模式来安装模块,比如安装中文转换模块(后续其它的也需要这么做):
复制代码
代码如下:
npm
install
-g
iconv-lite
npm
install
-g
nodemailer
npm
install
-g
node-schele