node.js - SSE(服务器发送事件)，在 Node.js 服务器中监听事件并将其 POST 到其他服务器

Question

我有由 SSE(服务器发送事件)触发的事件监听器，我如何将数据发布到其他服务器。

NODE JS

    //including Event Source
    var EventSource = require('eventsource');       

    var es  = new EventSource('http://api.xyz.com:8100/update/');

    //Listening URL Event Sourse 
    es.addEventListener('message', function (e) { 

        //Extract Json
        var extractData =  JSON.parse(e.data); 

        if(extractData.type == 'CALL' )
        {  
           console.log(extractData);
           //POST DATA
        }
    });

我需要将数据发布到其他服务器另一端是PHP

Answer 1

您可以尝试使用请求库，相关问题:how to make an http post request in node js你可以引用这个。

//including Event Source
var EventSource = require('eventsource');

var request     = require('request');  /*****ADDED******/   

var es  = new EventSource('http://api.xyz.com:8100/update/');

//Listening URL Event Sourse 
es.addEventListener('message', function (e) { 

    //Extract Json
    var extractData =  JSON.parse(e.data); 

    if(extractData.type == 'CALL' )
    {  
       console.log(extractData);

        //you can call a function 
        postDataToServer(extractData); 

    }
});

//Post Details to other server
function postDataToServer(SendingDetails)
{ 
    var ServerURL = 'OTHER_SERVAL_URL';

    request({
        url    : ServerURL,
        method : "POST",
        json   : true,
        body   : SendingDetails
    }, function (error, response, body){
        console.log(body);       
    });
}