postor/sse-notify-server repository overview

import { Publisher } from 'sse-notify-suite'

let publisher = new Publisher('http://localhost:3000')

publisher.publish('hello', 'world')
// will send { event: 'hello', data: 'world' }

curl -d "event=hello&data=world" -X POST http://localhost:3000

import { Subscriber } from 'sse-notify-suite'

let subscriber = new Subscriber('http://localhost:3000')

subscriber.on('hello',(data)=>console.log(data))
//'world'

var es = new EventSource('/stream') 
es.addEventListener('hello', function (data) {
  console.log(data)
  //MessageEvent ....
})

npm i sse-notify-suite -g

# default port 3000
sse-notify-server

# or specify port through env
PORT=3001 sse-notify-server

docker run -p 3000:3000 -it --rm postor/sse-notify-server

let subscriber = new Subscriber('http://localhost:3000')

subscriber.on(event,callback)

// unregister callback | 取消一个 callback 的注册
subscriber.off(event,callback)

// unregister all callback for event | 取消 event 的注册
subscriber.off(event)

// unregister all | 取消所有注册
subscriber.off()

// unsubscribe | 停止订阅
subscriber.unsubscribe()

import express from 'express'
import router from 'sse-notify-suite/router'

const app = express()

app.use('/', router)

git clone https://github.com/postor/sse-notify-suite
cd sse-notify-suite/examples/nextjs-docker
docker-compose up -d