updates

bin.shen

2016-12-03 58e2b4de6747acefbec06e549b30083267b53f87

updates

 queue.js

New file
@@ -0,0 +1,20 @@
/**
 * Created by bin.shen on 03/12/2016.
 */

var amqp = require('amqplib/callback_api');
var moment = require('moment');

var uri = 'amqp://guest:guest@121.40.92.176';
var ex = 'ex_data_dev1';

module.exports.publishMessage = function(data) {
    amqp.connect(uri, function(err, conn) {
        conn.createChannel(function(err, ch) {
            ch.assertExchange(ex, 'fanout', { durable: false });
            var message = '{"data": "' + data + '", "time":"' + moment().format('YYYY-MM-DD HH:mm:ss') + '"}';
            ch.publish(ex, '', new Buffer(message));
        });
        setTimeout(function() { conn.close(); process.exit(0) }, 500);
    });
};

 server.js

@@ -7,6 +7,7 @@
var mongoClient = require('mongodb').MongoClient;
var config = require('./config');
var method = require('./method');
var queue = require('./queue');

var map = {
    "5a0000010001": 32,
@@ -101,6 +102,9 @@
    if(length > 0) {
        var value = data.slice(0, length);
        console.log(moment().format('YYYY-MM-DD HH:mm:ss') + " => " + value);

        queue.publishMessage(value);

        handleData(db, socket, value);

        doWork(db, socket, data.slice(length));