node package manager

socket-pool

Build Status

socket-pool

Node socket pool for persistent TCP/IPC connections

Install

$ npm install socket-pool --save

Usage

import Pool from 'socket-pool'
 
const pool = new Pool({
  connect: {
    host: 'localhost',
    port: 2181
  },
 
  pool: {
    // the options of generic-pool 
    max: 100,
    min: 10
  }
 
  // other options of net.Socket 
})
 
pool.acquire()
.then(socket => {
  socket.on('data', chunk => {
    // concat chunks 
 
    // To re-use TCP connections, it is better NOT to end or destroy a socket 
    // after data received. 
    // Some mechanism could be used to tell the client if there is no more 
    // chunks, such as: 
    // - design a protocol to define the content-length of the incoming chunks. 
    if (dataFinished) {
      // Release the socket resource, 
      // then it can be required again. 
      socket.release()
    }
  })
})
 
// And then, the usage of `socket` is nearly the same as `new net.Socket` 

new Pool({connect, pool, ...socketOptions})

  • pool Object the options of generic-pool, and the value is simply passed
  • socketOptions Object the options of new net.Socket(options) of the vanilla node.js. The only difference is that the option socketOptions.allowHalfOpen defaults to true. If half-opened TCP connections are not allowed, allowHalfOpen should be explicit set to false. But setting this to false is kind of silly, since that's the whole purpose of this lib.

connect Object

If connect.path is specified, then other socket options will be ignored, and it is only for IPC connections.

  • path String the same argument of socket.connect(path) of the vanilla node.js

Otherwise, it is for TCP connections, available options are:

  • port
  • host
  • localAddress
  • localPort
  • family
  • hints
  • lookup

pool.acquire()

Returns Promise.

const socket = await pool.acquire()
 
// do something with socket 

The acquired socket is a wrapped net.Socket instance which will be destroyed when 'end' event occurs, and some additional methods are available:

socket.release()

The socket-pool-specified method to release the socket to the pool

socket.destroy()

Destroy the socket instance.

License

MIT