5. PC 서버와 라즈베리파이 통신

라즈베리파이의 ip주소와 공유기가 변동될 예정이다.

(시연할 때 다른 곳에서 하기 때문)

따라서 외부 서버(IFTTT, Google API 등)와 데이터를 주고 받기위해 PC에 서버를 하나 개설하고

PC서버와 라즈베리파이가 통신을 하도록 개발한다.

후에 시연장소가 공개되면 해당 장소에서 라즈베리파이에 와이파이를 연결하고

고정ip 할당, 포트포워딩 할 수도 있음.

이렇게 할 경우 외부 서버 필요x

하지만 혹시 모르니 일단은 PC서버와 라즈베리파이가 통신하는 방법으로 구현한다.

 예상 구조도는 위와 같다.

라즈베리파이의 외부 접근이 가능할 경우 PC서버를 제거하고 PC서버의 역할을 라즈베리파이가 직접할 수 있다.

이벤트가 발생하면 외부 서버에서 PC로 웹 요청을 보낸다.

PC에서는 웹 요청을 분석하여 정보를 저장하고 이벤트 여부를 기록한다.

라즈베리파이에서 서버로 1초에 한번씩 신호를 보낸다.

PC에서는 이벤트가 있을 경우 이벤트의 정보를 라즈베리파이에 응답으로 보낸다.

1. 모듈 설치

라즈베리파이의 Smartlamp_pi2 디렉토리로 이동하여 진행한다.

다음의 명령어로 웹 요청을 보내기 위한 모듈인 request를 설치한다.

$ sudo npm install request --save

2. 라즈베리파이 코드 수정

다음과 같이 index.js 파일을 수정한다.

$ sudo vi index.js

var express = require("express");
var request = require('request');

var app = express();
var port = 5000;

var optionsSmartLamp = {
   uri : "http://PC서버ip주소:포트번호/smartLamp",
   method : "GET",
   headers : { "Content-Type" : "application/x-www-form-urlencoded"}
};

app.get('/', function(req,res) {
   console.log('smart void lamp');
   res.send('Smart Voice Lamp');
});

app.listen(port,function() {
   console.log("create Server");

   //1초마다 smartLamp 함수 호출
   setInterval(smartLamp,1000);
});

function smartLamp() {
   //GET 요청 전송
   request(optionsSmartLamp, function(error, response, body) {
      if(body == "empty" ) {
         console.log("no data");
      }
      else {
         console.log(body);
      }
   });
}

optionsSmartLamp 변수에 웹 요청을 보내기 위한 옵션을 저장한다.

GET 요청을 http://PC서버ip주소:포트번호/smartLamp로 보내는 옵션을 설정하였다.

app.listen() 메소드에서 setInterval 함수로 smarLamp를 1초마다 호출한다.

smartLamp()에서는 request모듈을 이용하여 PC서버로 GET 요청을 보낸다.

응답의 body를 검사하여 body가 empty일 경우 no data를 콘솔에 출력하고,

그렇지 않을 경우 body의 내용을 콘솔에 출력한다.

3. PC 서버 코드 수정

PC의 index.js 파일을 다음과 같이 수정한다.

var express = require("express");
var bodyParser = require("body-parser");

var app = express();
var port = 3000;

var isData = false;
var empty = "empty";
var longtext = "";

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

app.get('/', function (req,res) {
    console.log('app.get "/" ');
    res.send("Smart Lamp Server");
});

//파이로부터 1초마다 호출됨
app.get('/smartLamp', function(req,res) {
    if(isData) {
        isData = false;     //한번 데이터 출력한 후 초기화
        res.send(longtext);
    }
    else {
        res.send(empty);
    }
});

app.post('/facebook', function(req,res) {
    var from = req.body.from;
    var myMessage = req.body.myMessage;
    var updateAt = req.body.updateAt;

    longtext = "페이스북에" + req.body.from + "님이" + req.body.myMessage + "라고 게시했습니다.";
    console.log(longtext);

    isData = true;
    res.send("Success");
});

app.listen(port, function () {
    console.log('Smart Lamp Server app listening on port ' + port);
});

app.get('/smartLamp' ..... 부분이 파이로부터 1초마다 호출되는 함수이다.

호출되면 새로운 데이터가 있는지 확인하여 있을경우 데이터를 보내고, 없을경우 empty라는 메시지를 보낸다.

app.post('/facebook',...... 의 함수 내부도 수정되었다.

IFTTT로부터 받은 내용을 longtext라는 변수에 저장하고, 이를 출력한다.

isData변수를 true로 만들어 새로운 데이터가 있다는 것을 기록한다.

4. 실행 & 테스트

PC서버와 라즈베리파이 서버를 실행하고

페이스북에 게시글을 작성하면 아래와 같이 pc서버와 라즈베리파이에 출력되는것을 볼 수 있다.