示例調(diào)用v0.12.0版本的node-coap，目前只能在server端通過res.end()觸發(fā)finish事件，client端目前還沒實現(xiàn)響應API。但火狐copper插件取消訂閱時，server端可以觸發(fā)finish事件。發(fā)現(xiàn)client取消訂閱API的讀者若能與我交流分享，不甚感激。

node-coap示例中observe的示例只簡單介紹了observe請求的創(chuàng)建，本文重點介紹如何處理server端每次發(fā)來的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)

//結束觀察模式后觸發(fā)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

})

//統(tǒng)計觸發(fā)response事件的次數(shù)

var resp_count = 0

req.on('response', function(res) {

//輸出響應結果

res.pipe(process.stdout)

resp_count++

console.log('觸發(fā)resp：' + resp_count)

//統(tǒng)計觸發(fā)data事件的次數(shù)

var data_count = 0

//每次收到服務器發(fā)來的observe響應時觸發(fā)data事件

res.on('data',function(data){

data_count++

console.log('觸發(fā)data：' + data_count + '\n-------\n')

//data事件次數(shù)達到3時關閉監(jiān)聽

if(data_count === 3)

res.close()

})

})

req.end()

啟動server

$ node observe_server

server start

啟動client

$ node observe_client

觸發(fā)resp：1

2015-10-17T05:26:53.773Z

觸發(fā)data：1

-------

2015-10-17T05:26:54.787Z

觸發(fā)data：2

-------

2015-10-17T05:26:55.797Z

觸發(fā)data：3

-------

此時，啟動server的終端：

$ node observe_server

server started

finsh

從命令行的輸出我們可以知道，client進入observe模式時，只有第一次觸發(fā)response事件，每次都觸發(fā)data事件。

總結

以上是生活随笔為你收集整理的coap python3_node-coap入门（三）——Observe的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。