node-msgpack-rpc is an implementation of the Msgpack-RPC protocol specification for node.js.
Switch branches/tags
Nothing to show
Failed to load latest commit information.
examples version control Sep 10, 2010
lib version control Sep 10, 2010
test version control Sep 10, 2010 version control Sep 10, 2010
package.json Tweaks to package.json to work with latest version of npm Nov 30, 2010


node-msgpack-rpc is an implementation of the Msgpack-RPC protocol specification for node.js. Msgpack-RPC is built ontop of the very fast MessagePack serialization format. This implementation supports tcp and unix socket transports (it may one day support UDP).

Simple Usage

The easiest way to create a server is with a handler object. All incoming calls will be invoked on the handler object:

var handler = {
  'add' : function(a, b, response) {
     response.result( a + b );

var rpc = require('msgpack-rpc');

a corresponding client might look like:

var c = rpc.createClient(8000, '', function() {
  c.invoke('add', 5, 4, function(err, response) {
    assert.equal(9, response);

Without a handler

rpc.createServer(function(rpc_stream) {
  rpc_stream.on('request', function(method, params, response) {
    if(method == 'add') {
      response.result( params[0] + params[1] );
    } else {
      response.error("unknown method!");

  rpc_stream.on('notify', function(method, params) {
    console.log("recieved notification: " + method);

Session Pool

This module also provides a session pool which allows you to re-use client connections:

var sp = new SesssionPool();
sp.getClient(8000, '').invoke('hello','world', function(err, response) { ... });;
sp.getClient(8001, '').invoke('hello','world', function(err, response) { ... });;

// Uses same tcp connection as above
sp.getClient(8000, '').invoke('goodbye','world', function(err, response) { ... });;



First you will need to install the node-msgpack add-on

To install node-msgpack-rpc with npm:

git clone
cd node-msgpack-rpc
npm link .

RPC Stream API

Clients and the streams passed to servers for incoming connections are both instances of MsgpackRPCStream.


c.createClient(port, [hostname], [ready_cb]);
c.invoke(method, [param1, param2, ...], cb);
c.notify(method, [param1, param2, ...]);
c.setTimeout(milliseconds);  // Setting this will cause requests to fail with err "timeout" if they don't recieve a response for the specified period
c.close(); // Close the socket for this client // underlying net.Stream object


'ready' // emitted when we've connected to the server
'request' // recieved request
'notify' // recieved notification


  • UDP Support?