mitt - 🥊 Tiny 200 byte functional event emitter / pubsub.

•    Javascript

---

Tiny 200b functional Event Emitter / pubsub.

mitt event-handlers pubsub tiny event event-bus event-listener eventemitter events

node_redis - redis client for node

•    Javascript

---

Redis client library

database redis transaction pipelining performance queue nodejs pubsub backpressure redis-client redis-driver redis-library

axon - message-oriented socket library for node.js heavily inspired by zeromq

•    Javascript

---

Axon is a message-oriented socket library for node.js heavily inspired by zeromq. For a light-weight UDP alternative you may be interested in punt.Backed by node-amp-message you may pass strings, objects, and buffers as arguments.

zmq zeromq pubsub socket emitter ipc rpc

primus - :zap: Primus, the creator god of the transformers & an abstraction layer for real-time to prevent module lock-in

•    Javascript

---

Primus, the creator god of transformers but now also known as universal wrapper for real-time frameworks. There are a lot of real-time frameworks available for Node.js and they all have different opinions on how real-time should be done. Primus provides a common low level interface to communicate in real-time using various real-time frameworks.If you deploy your application behind a reverse proxy (Nginx, HAProxy, etc.) you might need to add WebSocket specific settings to its configuration files. If you intend to use WebSockets, please ensure that these settings have been added. There are some example configuration files available in the observing/balancerbattle repository.

real-time websocket framework sockjs browserchannel polling http nodejs node abstraction engine.io comet streaming pubsub pub sub ajax xhr faye io primus prumus realtime socket socket.io sockets spark transformer transformers websockets ws uws

google-cloud-node - Google Cloud Client Library for Node.js

•    Javascript

---

Node.js idiomatic client for Google Cloud Platform services.If you need support for other Google APIs, check out the Google Node.js API Client library.

google-cloud nodejs bigquery bigtable compute datastore dns language logging prediction-api pubsub speech-recognition storage translate vision

Gizmo - A Microservice Toolkit from The New York Times

•    Go

---

Gizmo Microservice Toolkit toolkit provides packages to put together server and pubsub daemons with the following features like Standardized configuration and logging, Health check endpoints with configurable strategies, Configuration for managing pprof endpoints and log levels, Structured logging containing basic request information, Useful metrics for endpoints, Graceful shutdowns, Basic interfaces to define our expectations and vocabulary and lot more.

http-server pubsub google-pubsub sns sqs kafka gizmo web-framework go-web-framework framework

socketcluster - Highly scalable realtime framework

•    Javascript

---

SocketCluster is a fast, highly scalable HTTP + realtime server engine which lets you build multi-process realtime servers that make use of all CPU cores on a machine/instance. It removes the limitations of having to run your Node.js server as a single thread and makes your backend resilient by automatically recovering from worker crashes and aggregating errors into a central log on each host. SC can also auto-scale across multiple hosts on top of Kubernetes; see SCC guide: https://github.com/SocketCluster/socketcluster/blob/master/scc-guide.md.There are two ways to install SocketCluster.

realtime nodejs websocket pubsub scalable kubernetes docker framework websockets socketcluster server cluster

emqttd - EMQ - Erlang MQTT Broker

•    Erlang

---

EMQ (Erlang MQTT Broker) is a distributed, massively scalable, highly extensible MQTT message broker written in Erlang/OTP. EMQ is fully open source and licensed under the Apache Version 2.0. EMQ implements both MQTT V3.1 and V3.1.1 protocol specifications, and supports MQTT-SN, CoAP, WebSocket, STOMP and SockJS at the same time.

mqtt iot mqtt-broker erlang-mqtt-broker iot-middleware broker m2mqtt m2m pubsub messaging

vernemq - A distributed MQTT message broker based on Erlang/OTP

•    Erlang

---

VerneMQ is a high-performance, distributed MQTT message broker. It scales horizontally and vertically on commodity hardware to support a high number of concurrent publishers and consumers while maintaining low latency and fault tolerance. VerneMQ is the reliable message hub for your IoT platform or smart products. VerneMQ is an Apache2 licensed distributed MQTT broker, developed in Erlang.

mqtt m2m scalable broker distributed messaging pubsub vernemq iot-middleware iot

event-gateway - The Event Gateway combines both API Gateway and Pub/Sub functionality into a single event-driven experience

•    Go

---

Use the Event Gateway right now, by running the Event Gateway Example Application locally, with the Serverless Framework. The Event Gateway is a L7 proxy and realtime dataflow engine, intended for use with Functions-as-a-Service on AWS, Azure, Google & IBM.

event-driven dataflow pubsub functions-as-a-service serverless event-router

PubSubJS - Dependency free publish/subscribe for JavaScript

•    Javascript

---

PubSubJS is a topic-based publish/subscribe library written in JavaScript. PubSubJS has synchronisation decoupling, so topics are published asynchronously. This helps keep your program predictable as the originator of topics will not be blocked while consumers process them.

pub/sub pubsub publish/subscribe publish subscribe

emitter - High performance, distributed and low latency publish-subscribe platform.

•    Go

---

Emitter is a free open source real-time messaging service that connects all devices. This publish-subscribe messaging API is built for speed and security. Emitter is a real-time communication service for connecting online devices. Infrastructure and APIs for IoT, gaming, apps and real-time web. At its core, emitter.io is a distributed, scalable and fault-tolerant publish-subscribe messaging platform based on MQTT protocol and featuring message storage.

pubsub networking emitter mqtt mqtt-broker realtime high-performance low-latency

wisper - A micro library providing Ruby objects with Publish-Subscribe capabilities

•    Ruby

---

Note: Wisper was originally extracted from a Rails codebase but is not dependant on Rails. Please also see the Wiki for more additional information and articles.

events publish-subscribe pubsub

emqx - EMQ X Broker - Massively Scalable MQTT Messaging Broker

•    Erlang

---

EMQ X broker is a fully open source, highly scalable, highly available distributed MQTT messaging broker for IoT, M2M and Mobile applications that can handle tens of millions of concurrent clients. Starting from 3.0 release, EMQ X broker fully supports MQTT V5.0 protocol specifications and backward compatible with MQTT V3.1 and V3.1.1, as well as other communication protocols such as MQTT-SN, CoAP, LwM2M, WebSocket and STOMP. The 3.0 release of the EMQ X broker can scaled to 10+ million concurrent MQTT connections on one cluster.

mqtt iot mqtt-broker erlang-mqtt-broker iot-middleware broker m2mqtt m2m pubsub messaging coap coap-server lorawan lorawan-server mqttv5

autobahn-java - WebSocket & WAMP in Java for Android and Java 8

•    Java

---

Client library providing WAMP on Java 8 (Netty) and Android, plus (secure) WebSocket for Android. running on Android and Netty/Java8/JVM.

android java8 network websocket real-time wamp rpc pubsub autobahn

autobahn-js - WAMP in JavaScript for Browsers and NodeJS

•    Javascript

---

WAMP for Browsers and NodeJS. Autobahn|JS is a subproject of the Autobahn project and provides an open-source implementation of the Web Application Messaging Protocol V2 in JavaScript under the MIT license.

websocket real-time wamp rpc pubsub autobahn nodejs html5

autobahn-python - WebSocket and WAMP in Python for Twisted and asyncio

•    Python

---

WebSocket & WAMP for Python on Twisted and asyncio. for Python 2 and 3, and running on Twisted and asyncio.

websocket real-time wamp rpc pubsub autobahn

meq - A modern messaging platform for Message Push、IM、IoT etc, based on MQTT protocol

•    Go

---

A modern messaging platform for Message Push、IM、Group Chatting、IoT etc, based on MQTT protocol. MeQ is written in pure go and standard library,nearly no messy dependencies. so you can easily deploy a standalone binary in linux、unix、macos、windows. Our goal is to be the best messaging platform in the world.

message-push im mqtt push messaging networking iot pubsub

NSQ - A realtime distributed messaging platform in Go

•    Go

---

NSQ is a realtime distributed messaging platform designed to operate at scale, handling billions of messages per day. It promotes distributed and decentralized topologies without single points of failure, enabling fault tolerance and high availability coupled with a reliable message delivery guarantee. It scales horizontally, without any centralized brokers. Built-in discovery simplifies the addition of nodes to the cluster.

message-queue messaging distributed publish-subscribe pubsub queue

backbone.radio - Messaging patterns for Backbone applications.

•    Javascript

---

Messaging patterns for Backbone applications.

backbone marionette radio pub-sub decoupling messaging request events backbone-applications decoupled pubsub publish subscribe architecture spa