2017-06-23 81 views
0

我有一個nodejs應用程序,它從redis讀取數據,我無法將它推入套接字。在c.write(消息)部分,如果我硬編碼(例如c.write('hello'),這些消息被放入套接字,但是當我把它作爲c.write(消息)時,什麼都不會。插座由於提前,Nodejs,Redis,套接字

var net = require('net'); 
var split = require('split'); 
var Redis = require('ioredis'); 
var redis = new Redis(); 


var server = net.createServer(function(c) { 

    console.log('client connected'); 
    c.on('end',() => { 
     console.log('client disconnected'); 
    }); 

    redis.subscribe('test-channel'); 

    redis.on('message', function(channel, message) { 
     console.log(message); 
     c.write(message); 
     c.pipe(c); 
    }); 
}); 

server.on('error', (err) => { 
    throw err; 
}); 
server.listen(3005, 'localhost',() => { 
    console.log('server bound'); 
}); 
+0

你想說什麼打印的console.log(消息)的時候? – ramasCoder

+0

發佈消息來自redis。@ professionallyme86 –

回答

1

我已經得到了答案

低於線只需添加到您的代碼:

var message_redis = message+'\r'+'\n'; 
c.write(message_redis);