hans00 / fastws Goto Github PK

    const fastWS = require('fast-ws/server');

    const options = {};
    const app = new fastWS(options)

    app.ws('/db', ws => {
      console.log(`Connected ${ws.remoteAddress}`)

      ws.on('message', ({ data }) => {
        console.log(`Received: ${data}`);
        ws.sendMessage(data)
      })

      ws.on('echo', ({ reply, data }) => {
        reply(data)
      })
    });

    const [host, port] = ['127.0.0.1', 8080];
    app.listen(host, port, () => {
      console.log(`Listen on ${host}:${port}`)
    })

  const Client = require('fast-ws/client')

  const options = {
    // Ping Interval (not less then server `idleTimeout`)
    pingInterval: 30000, // Default (ms)
    // Reply Timeout (Event reply)
    replyTimeout: 5000, // Default (ms)
    // parser options (same as server)
    parserOptions: {},
    // Others options for package 'ws'
  };
  
  const ws = new Client('ws://127.0.0.1:8080/db', options)