coap python3_node-coap入门(三)——Observe
示例調用v0.12.0版本的node-coap,目前只能在server端通過res.end()觸發finish事件,client端目前還沒實現響應API。但火狐copper插件取消訂閱時,server端可以觸發finish事件。發現client取消訂閱API的讀者若能與我交流分享,不甚感激。
node-coap示例中observe的示例只簡單介紹了observe請求的創建,本文重點介紹如何處理server端每次發來的observe響應。
observe_server
const coap = require('coap')
, server = coap.createServer()
server.on('request', function(req, res) {
//判斷是否是Observe請求
if (req.headers['Observe'] !== 0)
return res.end(new Date().toISOString() + '\n')
//定時將日期寫入ObserveWriteStream
var count = 0
var interval = setInterval(function() {
count++
res.write(new Date().toISOString() + '\n')
if (count === 3) {
clearInterval(interval)
//結束觀察模式
res.end()
}
}, 1000)
//結束觀察模式后觸發finish事件
res.on('finish', function(err) {
console.log('finsh')
})
})
server.listen(function() {
console.log('server started')
})
observe_client
var coap = require('coap')
, req = coap.request({
observe: true
})
//統計觸發response事件的次數
var resp_count = 0
req.on('response', function(res) {
//輸出響應結果
res.pipe(process.stdout)
resp_count++
console.log('觸發resp:' + resp_count)
//統計觸發data事件的次數
var data_count = 0
//每次收到服務器發來的observe響應時觸發data事件
res.on('data',function(data){
data_count++
console.log('觸發data:' + data_count + '\n-------\n')
//data事件次數達到3時關閉監聽
if(data_count === 3)
res.close()
})
})
req.end()
啟動server
$ node observe_server
server start
啟動client
$ node observe_client
觸發resp:1
2015-10-17T05:26:53.773Z
觸發data:1
-------
2015-10-17T05:26:54.787Z
觸發data:2
-------
2015-10-17T05:26:55.797Z
觸發data:3
-------
此時,啟動server的終端:
$ node observe_server
server started
finsh
從命令行的輸出我們可以知道,client進入observe模式時,只有第一次觸發response事件,每次都觸發data事件。
總結
以上是生活随笔為你收集整理的coap python3_node-coap入门(三)——Observe的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: memcached的java客户端_Me
- 下一篇: python framework thr