導航:首頁 > 編程語言 > nodejs定時

nodejs定時

發布時間:2023-01-26 12:32:19

Ⅰ 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

閱讀全文

與nodejs定時相關的資料

熱點內容
微信清除緩存圖片恢復 瀏覽:305
安卓app會閃退怎麼解決 瀏覽:429
哪些app背單詞是免費的 瀏覽:889
cf擊殺圖標放哪個文件夾 瀏覽:208
為什麼我的爐石不能查看完整數據 瀏覽:179
蘋果7音量按鍵不回彈 瀏覽:296
u盤兩個系統可以放一個文件夾嗎 瀏覽:538
linuxshell變數累加 瀏覽:386
win10控制面板怎麼看 瀏覽:574
如何編程換裝游戲程序 瀏覽:269
怎麼登錄沭陽縣民政局網站 瀏覽:451
iphone6降級ios7 瀏覽:92
怎麼隱藏三星應用程序圖標不見了 瀏覽:203
可以兼職的app 瀏覽:493
iphone圓角圖標製作 瀏覽:659
建設銀行app怎麼申請 瀏覽:163
系統備份文件夾在哪 瀏覽:998
qq分組exo韓文 瀏覽:849
華碩裝裝win7系統教程視頻 瀏覽:407
什麼是數據直連 瀏覽:210

友情鏈接