Wormhole JS 介绍
Wormhole 是一个基于 Node.js
的流消息队列系统。其特点是高性能。和Kafka以及Databus类似，Wormhole是个高度可扩展的发布/订阅系统。在Facebook内部，Wormhole每天处理多达1T的消息，高峰时每秒超过1千万条消息。
Wormhole总体架构如下图
示例代码：
var Wormhole = require('wormhole');
net.createServer(function (client) {
Wormhole(client, 'chat', function (msg) {
// All messages received from client over chat channel, such as
// {hello: 'World'}
});
Wormhole(client, 'auth', function (msg) {
// All messages received from client, such as
// {hello: 'World'}
if (msg.user == 'foo' && msg.pass == 'bar') {
client.write('auth', {auth: 'Thank you for logging in'});
}
});
// client.write Now overloaded to encode data.
client.write('auth', {auth: 'Please login!'});
client.write('chat', {greet: 'Welcome to our server!'});
}).listen(2122);
var client = net.createConnection(2122, function() {
Wormhole(client, 'chat', function (err, msg) {
// Messages received from server, such as
// {greet: 'Welcome to our server!'}
});
Wormhole(client, 'auth', function (err, msg) {
// Messages received from server on auth channel, such as
// {auth: 'Please login!'}
// {auth: 'Thank you for logging in!'}
});
client.write('auth', {user: 'foo', pass: 'bar'});
client.write('chat', {hello: 'World'});
});
Wormhole JS 官网
http://aikar.co/projects/wormhole/
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
