[2017.11.01] 65. Firebase - Notification 사용[Node.js]

도입

이번 포스팅에서는 Node.js를 활용해 Firebase의 Notification을 실습할 예정이다.

Firebase - Notification 사용[Node.js]의 데이터의 흐름

Step1. Android Client1가 [전달 받을 디바이스, 특정 메시지]를 Nodejs 서버에 전달한다.

Step2. Nodejs는 [전달 받을 디바이스, 특정 메시지]를 Firebase 서버에 전달한다.

Step3. Firebase Server는 특정 메시지를 해당 디바이스에 전달한다. 

실습

Node.JS Server 

var http = require("http");
var httpUrlConnection = require("request");
 
// Google Firebase 서버
const fcmServerUrl = "https://fcm.googleapis.com/fcm/send";
 
// 나의 Firebase 서버의 키
const serverKey = "Your key";
 
// Firebase로 전송될 객체의 틀, 정해져 있는 것이어서 변경할 수 없다.
// 참조: https://firebase.google.com/docs/cloud-messaging/concept-options?authuser=1
var msg = {
    to : "",
    notification : {
        body : ""
    }
}
 
var server = http.createServer(function(request, response) {
    // Step1. Node.JS Server가 Android Client1으로부터
    //        post 메시지 수신
    if (request.url == "/sendNotification") {
 
        var postdata = "";
        request.on("data", function(fragment) {
            postdata += fragment;
        });
 
        request.on("end", function() {
            // Step1. 수신한 메시지를 JSON 객체화
            var postObj = JSON.parse(postdata);
            
            msg.to = postObj.to;
            msg.notification.body = postObj.msg;
 
            // Step2. Node.JS Server에서 Firebase Server로 데이터 전달
            httpUrlConnection (
            {
                url : fcmServerUrl,
                method : "POST",
                headers : {
                    "Content-Type"  : "application/json",
                    "Authorization" : "key=" + serverKey
                },
                // JSON 객체를 전달할 수 있는 string으로 변경
                body : JSON.stringify(msg)
            },
                // Step2 종료 후 실행되는 Callback 메소드 설정
                function(error, answer, body) {
                    var result = {
                        code : answer.statusCode,
                        msg : body
                    };
                    // Client1에서 반환되는 메시지
                    response.writeHead(200, {"Content-Type":"plain/text"});
                    response.end(JSON.stringify(result));
                }
            )
        });
    } else {
        response.end("404 page not found!");
    }
});
 
server.listen(8090, function() {
    console.log("Server running ... ");
});

Android Client 1

public class StorageActivity extends AppCompatActivity 
                             implements ShowTokenRecyclerAdapter.Callback {
    // ...
    // Step1. NodeJS 서버에 메시지 날리기
    public void send(View view) {
        String token = selectToken.getText().toString();
        String msg = editContent.getText().toString();
 
        if (token == null || "".equals(token)) {
            return;
        }
        if (msg == null || "".equals(msg)) {
            return;
        }
        // 전송할 데이터 선언
        String json = "{\"to\":\"" + token + "\", \"msg\":\"" + msg + "\"}";
 
        RequestBody body = RequestBody.create(MediaType.parse("plain/text"), json);
        
        // 레트로핏 선언
        // Local Server Url 설정
        Retrofit retrofit = new Retrofit.Builder()
                                        .baseUrl("http://192.168.1.76:8090/")
                                        .build();
 
        // 인터페이스와 결합
        IRetro service = retrofit.create(IRetro.class);
 
        // 서비스로 서버 연결 준비
        Call<ResponseBody> remote = service.sendNotification(body);
 
        // 실제 연결 후 데이터 처리
        remote.enqueue(new Callback<ResponseBody>() {
            @Override
            public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
                if (response.isSuccessful()) {
                    ResponseBody data = response.body();
                    try {
                        Toast.makeText(StorageActivity.this, 
                                       data.string()+"", 
                                       Toast.LENGTH_SHORT).show();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
 
            @Override
            public void onFailure(Call<ResponseBody> call, Throwable t) {
                Log.e("Retro", t.getMessage());
            }
        });
    }
}

스크린 샷

#firebase Notification 설정 #firebase Notification #파이어베이스 Notification