1.Node.js 的 TCP可以使用以下來取得目前連線中的連接
server.getConnections((err, count) => {
console.log(count)
})
2.net.createServer((socket) => ....)
雖然TCP連線後會繼續保持,但其中的socket callback會是最後一個連線到server的client,所以需要自行把先前連線的socket保存著
const net = require('net');
const server = net.createServer((c) => {
// 'connection' listener
console.log('client connected');
c.on('end', () => {
console.log('client disconnected');
});
c.on('error', (err) => {
console.log(err)
})
c.on('data', (data) => {
console.log(data)
})
c.write('hello\r\n');
//c.pipe(c); 用來echo任何client送出的message給client
});
server.on('error', (err) => {
throw err;
});
server.listen(8120, () => {
console.log('server bound');
});
// 監聽ctrl + c 並且disconnect 來避免TCP server產生ECONNRESET ERROR
process.on('SIGINT', function() {
console.log("Caught interrupt signal");
client.end();
});
const net = require('net');
const client = net.createConnection({ port: 8120 }, () => {
//'connect' listener
console.log('connected to server!');
client.write('world123!\r\n');
});
client.on('data', (data) => {
console.log(data.toString());
//client.end();
});
client.on('end', () => {
console.log('disconnected from server');
process.exit();
});
// 監聽ctrl + c 並且disconnect 來避免TCP server產生ECONNRESET ERROR
process.on('SIGINT', function() {
console.log("Caught interrupt signal");
client.end();
});
const net = require('net');
const server = net.createServer((c) => {
// 'connection' listener
console.log('client connected');
c.on('end', () => {
console.log('client disconnected');
});
c.write('hello\r\n');
c.pipe(c);
});
server.on('error', (err) => {
throw err;
});
server.listen(8121, () => {
console.log('server bound');
});
const client = net.createConnection({ port: 8120 }, () => {
//'connect' listener
console.log('connected to server!');
client.write('world123!\r\n');
});
client.on('data', (data) => {
console.log(data.toString());
//client.end();
});
client.on('end', () => {
console.log('disconnected from server');
process.exit();
});
// 監聽ctrl + c 並且disconnect 來避免TCP server產生ECONNRESET ERROR
process.on('SIGINT', function() {
console.log("Caught interrupt signal");
client.end();
});
每個tcp建立連線後可以把socket物件記住,之後連線其他的節點後可以再次存取原先socket即可再次傳送訊息。
1. server.maxConnections
2.設定Linux中的tcp_max_syn_backlog 與 somaxconn
3.設定listen參數中的backlog