A push notification micro server using Gin framework written in Go (Golang).

<ul>
<li>Support <a href="https://firebase.google.com/docs/cloud-messaging">Firebase Cloud Messaging</a> using <a href="https://github.com/appleboy/go-fcm">go-fcm</a> library for Android.</li>
<li>Support <a href="https://http2.github.io/">HTTP/2</a> Apple Push Notification Service using <a href="https://github.com/sideshow/apns2">apns2</a> library.</li>
<li>Support <a href="https://github.com/go-yaml/yaml">YAML</a> configuration.</li>
<li>Support command line to send single Android or iOS notification.</li>
<li>Support Web API to send push notification.</li>
<li>Support graceful restart &amp; zero downtime deploy using <a href="https://github.com/facebookgo/grace">facebook grace</a>.</li>
<li>Support <a href="https://http2.github.io/">HTTP/2</a> or HTTP/1.1 protocol.</li>
<li>Support notification queue and multiple workers.</li>
<li>Support <code>/api/stat/app</code> show notification success and failure counts.</li>
<li>Support <code>/api/config</code> show your <a href="https://en.wikipedia.org/wiki/YAML">YAML</a> config.</li>
<li>Support store app stat to memory, <a href="http://redis.io/">Redis</a>, <a href="https://github.com/boltdb/bolt">BoltDB</a>, <a href="https://github.com/tidwall/buntdb">BuntDB</a> or <a href="https://github.com/syndtr/goleveldb">LevelDB</a>.</li>
<li>Support <code>p12</code> or <code>pem</code> formtat of iOS certificate file.</li>
<li>Support <code>/sys/stats</code> show response time, status code count, etc.</li>
<li>Support for HTTP proxy to Google server (FCM).</li>
<li>Support retry send notification if server response is fail.</li>
<li>Support expose <a href="https://prometheus.io/">prometheus</a> metrics.</li>
<li>Support install TLS certificates from <a href="https://letsencrypt.org/">Let's Encrypt</a> automatically.</li>
<li>Support send notification through <a href="https://en.wikipedia.org/wiki/Remote_procedure_call">RPC</a> protocol, we use <a href="https://grpc.io/">gRPC</a> as default framework.</li>
</ul>

A push notification micro server using Gin framework written in Go (Golang).

gorush - A push notification server written in Go (Golang).

NATS Server is a simple, high performance open source messaging system for cloud native applications, IoT messaging, and microservices architectures. It implements a highly scalable and elegant publish-subscribe (pub/sub) distribution model. The performant nature of NATS make it an ideal base for building modern, reliable, scalable cloud native distributed systems.


gnatsd - High-Performance server for NATS, the cloud native messaging system.

Faye is a set of tools for simple publish-subscribe messaging between web clients. It ships with easy-to-use message routing servers for Node.js and Rack applications, and clients that can be used on the server and in the browser. It is based on the Bayeux protocol.

Faye - Simple pub/sub messaging for the web

The fastest, most reliable, Redis-based queue for Node. Carefully written for rock solid stability and atomicity. 
<ul>
<li> Minimal CPU usage due to a polling-free design.</li>
<li> Robust design based on Redis.</li>
<li> Delayed jobs.</li>
<li> Schedule and repeat jobs according to a cron specification.</li>
<li> Rate limiter for jobs.</li>
<li> Retries.</li>
<li> Priority.</li>
<li> Concurrency.</li>
<li> Pause/resume—globally or locally.</li>
<li> Multiple job types per queue.</li>
<li> Threaded (sandboxed) processing functions.</li>
<li> Automatic recovery from process crashes.</li>
</ul>

The fastest, most reliable, Redis-based queue for Node. Carefully written for rock solid stability and atomicity. 

Bull - Premium package for handling jobs and messages in NodeJS

Plumber is a CLI devtool for inspecting, piping, massaging and redirecting data in message systems like Kafka, RabbitMQ , GCP PubSub and many more. It helps to safely view the contents of your data streams, Decode protobuf/avro/thrift/JSON data in real-time, Route data from one place to another, Replay events into a message system on your local network and lot more.


Plumber - A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems

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.
 
<ul>
 <li>support distributed topologies with no SPOF</li>
 <li>horizontally scalable (no brokers, seamlessly add more nodes to the cluster)</li>
 <li>low-latency push based message delivery </li>
 <li>combination load-balanced and multicast style message routing</li>
 <li>excel at both streaming (high-throughput) and job oriented (low-throughput) workloads</li>
 <li>primarily in-memory (beyond a high-water mark messages are transparently kept on disk)</li>
 <li>runtime discovery service for consumers to find producers</li>
 <li>transport layer security (TLS)</li>
 <li>data format agnostic</li>
 <li>few dependencies (easy to deploy) and a sane, bounded, default configuration</li>
 <li>simple TCP protocol supporting client libraries in any language</li>
 <li>HTTP interface for stats, admin actions, and producers (no client library needed to publish)</li>
 <li>integrates with statsd for realtime instrumentation</li>
 <li>robust cluster administration interface</li>
</ul>

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.

NSQ - A realtime distributed messaging platform in Go

SHARQ is a flexible, open source, rate limited queuing system. Based on the Leaky Bucket Algorithm, SHARQ lets you create queues dynamically and update their rate limits in real time.
SHARQ consists of two components - the core component and the server component. The SHARQ core is built on Redis, using Python and Lua, and the SHARQ Server is built using Flask and Gevent and talks HTTP.

Sharq Server - A flexible rate limited queueing system

The nanomsg library is a simple high-performance implementation of several "scalability protocols". These scalability protocols are light-weight messaging protocols which can be used to solve a number of very common messaging patterns, such as request/reply, publish/subscribe, surveyor/respondent, and so forth. These protocols can run over a variety of transports such as TCP, UNIX sockets, and even WebSocket.  It aims to make the networking layer fast, scalable, and easy to use. 

nanomsg - High Performance Messaging Library

A simple, fast, robust job/task queue for Node.js, backed by Redis.Bee-Queue is meant to power a distributed worker pool and was built with short, real-time jobs in mind. A web server can enqueue a job, wait for a worker process to complete it, and return its results within an HTTP request. Scaling is as simple as running more workers.

Bee Queue - A simple, fast, robust job/task queue for Node.js, backed by Redis

Nakadi is a distributed event bus broker that implements a RESTful API abstraction on top of Kafka-like queues. It provides abstract event delivery via a secured RESTful API, Enable convenient development of event-driven applications and asynchronous microservices, Efficient low latency event delivery.

Nakadi - A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues

MBassador is a light-weight, high-performance event bus implementing the publish subscribe pattern. It is designed for ease of use and aims to be feature rich and extensible while preserving resource efficiency and performance. The core of MBassador is built around a custom data structure that provides non-blocking reads and minimized lock contention for writes such that performance degradation of concurrent read/write access is minimal.

MBassador - Light-weight, high-performance event bus implementing the publish subscribe pattern

pg-boss is a job queue built in Node.js on top of PostgreSQL in order to provide background processing and reliable asynchronous execution to Node.js applications. pg-boss relies on SKIP LOCKED, a feature introduced in PostgreSQL 9.5 written specifically for message queues, in order to resolve record locking challenges inherent with relational databases. This brings the safety of guaranteed atomic commits of a relational database to your asynchronous job processing.

pg-boss - Queueing jobs in Node.js using PostgreSQL like a boss 

CassieQ is a distributed queue built on cassandra. CassieQ leverages bucketing of messages to avoid queues modeled off deletes.

cassieq - A distributed queue built off cassandra

Discover open source projects across all platforms

Projects