207. (NodeJs) [Mac Os] [rxjs] : RxJs 모듈 사용해 interval 주기적 반복 데이터 발행 실시

---

[개발 환경 설정]

​

개발 툴 : VS CODE

개발 언어 :NodeJs

 

---

[사전) NodeJS 모듈 추가 방법]

​

https://blog.naver.com/kkh0977/223351347351

205. (NodeJs) [Mac Os] [rxjs] : 리액티브 (Reactive) 모듈 설치 방법

 

---

[사전) NodeJS 프로젝트 설정 방법]

​

 

---

[app.js : 소스 코드]

 

// ----------------------------------------------------------------------------------------------

// ---------------------------------------
// [모듈 추가]
// ---------------------------------------
const express = require('express')
const app = express()



// ---------------------------------------
// [모듈 추가]
// ---------------------------------------
app.set('view engine', 'ejs') // [Page] : [Render]
app.set('views', './views') // [Page] : [Render]



// ---------------------------------------
// [모듈 추가]
// ---------------------------------------
var bodyParser = require('body-parser'); // [body-parser 사용]

app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());



// ---------------------------------------
// [모듈 추가]
// ---------------------------------------
var nocache = require('nocache'); // [nocache 사용]
app.use(nocache());


// ---------------------------------------
// [모듈 추가]
// ---------------------------------------
const Rx = require('rxjs'); // [rxjs 모듈]

// ----------------------------------------------------------------------------------------------

// [Get] : Path = [/rxjs] : http://localhost:3000/rxjs
app.get('/rxjs', function (req, res) {
    console.log("")
    console.log("==============================================================================")
    console.log("[Server] :: [App] :: [Path = /rxjs] :: [Start]")
    console.log("==============================================================================")
    console.log("")


    try {

        // [Observable 선언]
        const observable = Rx.interval(1000);


        // [subscribe 구독해 데이터 소비]
        let subscribe = observable.subscribe(
            function (value) { 
                console.log("")
                console.log("==============================================================================")
                console.log("[Server] :: [App] :: [Path = /rxjs] :: [onNext]")
                console.log("--------------------------------------------------------------------------")
                console.log("value : " + value)
                console.log("==============================================================================")
                console.log("")

                // [카운트 종료를 위해 구독 해제]
                if (value == 2){
                    
                    subscribe.unsubscribe();

                    // [http 리턴]
                    res.status(200).send(JSON.stringify({"result" : "success"})); // [http 반환]
                }
            },
            function (error) { 
                console.log("")
                console.log("==============================================================================")
                console.log("[Server] :: [App] :: [Path = /rxjs] :: [onError]")
                console.log("--------------------------------------------------------------------------")
                console.log("error : " + error)
                console.log("==============================================================================")
                console.log("")
            },
            function () { 
                console.log("")
                console.log("==============================================================================")
                console.log("[Server] :: [App] :: [Path = /rxjs] :: [onCompleted]")
                console.log("==============================================================================")
                console.log("")
            }
        );
        
    }
    catch (err) {
        res.status(500).send(JSON.stringify({"result" : 'error'})); // [http 반환]
    }
    
})

// ----------------------------------------------------------------------------------------------

// [Server] : [Start]
//*
app.listen(3000, function () {
    console.log("")
    console.log("==============================================================================")
    console.log("[Server] :: [Port = 3000] :: [Start]")
    console.log("==============================================================================")
    console.log("")
})
// */

// ----------------------------------------------------------------------------------------------

 

---

[결과 출력]

​

---