Supported features

Installation

npm install @socket.io/postgres-adapter

Usage

Standalone

import{Server}from"socket.io";import{createAdapter}from"@socket.io/postgres-adapter";importpgfrom"pg";constio=newServer();constpool=newpg.Pool({user:"postgres",host:"localhost",database:"postgres",password:"changeit",port:5432,});pool.query(`  CREATE TABLE IF NOT EXISTS socket_io_attachments (      id          bigserial UNIQUE,      created_at  timestamptz DEFAULT NOW(),      payload     bytea  );`);pool.on("error",(err)=>{console.error("Postgres error",err);});io.adapter(createAdapter(pool));io.listen(3000);

With Node.js cluster

importclusterfrom"node:cluster";import{createServer}from"node:http";import{availableParallelism}from"node:os";import{Server}from"socket.io";import{setupPrimary}from"@socket.io/postgres-adapter"import{createAdapter}from"@socket.io/cluster-adapter";importpgfrom"pg";if(cluster.isPrimary){constpool=newpg.Pool({user:"postgres",password:"changeit",});awaitpool.query(`    CREATE TABLE IF NOT EXISTS socket_io_attachments (        id          bigserial UNIQUE,        created_at  timestamptz DEFAULT NOW(),        payload     bytea    );  `);setupPrimary(pool);for(leti=0;i<availableParallelism();i++){cluster.fork();}}else{constio=newServer({adapter:createAdapter(),});io.on("connection",(socket)=>{/* ... */});io.listen(3000);}

Options

License