pomelo-globalchannel-plugin

pomelo-globalchannel-plugin is a plugin for pomelo, it can be used in pomelo(>=0.6).

In pomelo, channel is an abstract concept which can be understood as a collection of users. In pomelo you can add users into a named channel, and push message to all users in this channel. But it only can be used in the same server, which means it does not support distributed environment.

The global channel solve this problem. It uses persistent storage to do this thing. You can use it to store users in distributed environment and do same things as local channel does in pomelo.

Installation

npm install pomelo-globalchannel-plugin

Usage

var globalChannel = require('pomelo-globalchannel-plugin');

app.use(globalChannel, {globalChannel: {
  host: '127.0.0.1',
  port: 6379,
  db: '0'       // optinal, from 0 to 15 with default redis configure
}});

API

add(name, uid, sid, cb)

add a member into channel

Arguments

• name - channel name.
• uid - user id.
• sid - frontend server id
• cb - callback function

leave(name, uid, sid, cb)

remove user from channel

Arguments

• name - channel name.
• uid - user id.
• sid - frontend server id
• cb - callback function

getMemberBySid(name, sid, cb)

get members by frontend server id

Arguments

• name - channel name
• sid - frontend server id
• cb - callback function

getMembersByChannelName(stype, name, cb)

get members by channel name

Arguments

• stype - frontend server type string
• name - channel name
• cb callback function

pushMessage(stype, route, msg, name, opts, cb)

send message by global channel

Arguments

• stype - frontend server type string
• route - route string
• msg - message would be sent to clients
• name - channel name
• opts - optional parameters
• cb - callback function

destroyChannel(name, cb)

destroy a global channel

Arguments

• name - channel name
• cb - callback function

Notice

Global channel use redis as a default persistent storage, you can change it with your own implementation.

var globalChannel = require('pomelo-globalchannel-plugin');
var mysqlGlobalChannelManager = require('./mysqlGlobalChannelManager');

app.use(globalChannel, {globalChannel: {
  host: '127.0.0.1',
  port: 6379,
  channelManager: mysqlGlobalChannelManager
}});