Attaches socket.io to koa and allows koa-style middleware for sockets
Middleware for Koa2 to get/set session use with custom stores such as Redis or mongodb
Use native ES6(async/await) by Nodejs v7.6, use --harmony option.
Or you can use the old versions:
koa-socket.io now requires node v7.6.0 or higher although koa-socket.io simply attaches to the server instance so will be compatible with a koa v1 powered app.
If you need use koa-socket.io on lower version that requires node v4.0.0 or higher, plase use koa-socket.io v1.0.3
npm i -S koa-socket.ioThere is a simple example/test project in test dir. You can launch it by run: (The example code not in the published module, please fetch it at: koa-socket.io@github)
git clone https://github.com/LnsooXD/koa-socket.io.git koa-socket.io
cd koa-socket.io
export NODE_ENV=development
npm install
npm run exampleSome simple example code:
const Koa = require( 'koa' )
const IO = require( 'koa-socket.io' )
const http = require('http');
const app = new Koa()
const io = new IO({
namespace: '/'
})
app.use( ... )
let options = {
/* socket.io options */
}
var server = http.createServer(app.callback());
io.start( server, options/*, port, host */ )
io.on('join', function* () {
console.log('join event receiverd, new user: ', this.data)
// use global io send borad cast
io.emit('msg', '[All]: ' + this.data + ' joind');
// use current socket send a broadcast
this.socket.broadcast('msg', '[All]: Hello guys, I\'m ' + this.data + '.');
// just send to current user
this.socket.emit('msg', '[' + this.data + ']' + " Welcome to koa-socket.io !");
})
server.listen( process.env.PORT || 3000 )- Attach socket.io to existing koa projects
- Attach koa-style middleware to socket.io events
Middleware can be added in much the same way as it can be added to any regular koa instance.
io.use(function* (next){
let start = new Date()
yield next;
console.log( `response time: ${ new Date() - start }ms` )
})this = {
event: listener.event,
data: data,
socket: Socket,
acknowledge: cb
}
io.use( function* (next ) {
this.process = process.pid
yield next;
})
io.use( function *(next ) => {
// ctx is passed along so ctx.process is now available
console.log( this.process )
})
io.on( 'event', function*(next) => {
// ctx is passed all the way through to the end point
console.log( this.process )
})Namespaces can be defined simply by instantiating a new instance of koaSocket and passing the namespace id in the constructor. All other functionality works the same, it’ll just be constrained to the single namespace.
const app = new Koa()
const chat = new IO({
namespace: 'chat'
})
chat.start( app.server )
chat.on( 'message', function*(next) {
console.log( this.data )
chat.broadcast( 'response', ... )
})Namespaces also attach themselves to the app instance, throwing an error if the property name already exists.
const app = new Koa()
const chat = new IO({
namespace: 'chat'
})
chat.start( app.server )
chat.use( ... )
chat.on( ... )
chat.broadcast( ... )Attaches to a http/https server
io.start( server )
server.listen( process.env.PORT )Applies middleware to the stack.
Middleware are executed each time an event is reacted to and before the callback is triggered for an event.
Middleware must be generator
Middleware functions are called with this and next like koa 1.x.
io.use( function* (next ) {
console.log( 'Upstream' )
yield next;
console.log( 'Downstream' )
})io.on( 'join', function *( next) => {
console.log( this.data )
console.log( this.event)
})Removes a callback from an event.
If the event is omitted then it will remove all listeners from the instance.
If the callback is omitted then all callbacks for the supplied event will be removed.
io.off( 'join', onJoin )
io.off( 'join' )
io.off()Sends a message to all connections.