RabbitMQ is a messaging broker - an intermediary for messaging. It gives your applications a common platform to send and receive messages, and your messages a safe place to live until received. It features include reliability, high availability, Clustering and Federation. RabbitMQ ships with an easy-to use management UI that allows you to monitor and control every aspect of your message broker. There are RabbitMQ clients for almost any language you can think of. 

RabbitMQ - Robust messaging for applications

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).

RQ (Redis Queue) is a simple Python library for queueing jobs and processing them in the background with workers. It is backed by Redis and it is designed to have a low barrier to entry. It should be integrated in your web stack easily.RQ requires Redis >= 2.7.0.

rq - Simple job queues for Python

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.

MassTransit is a lightweight message bus for creating distributed applications using the .NET framework. MassTransit provides an extensive set of features on top existing message transports, resulting in a developer friendly way to asynchronously connect services using message-based conversation patterns. Message-based communication is a reliable and scalable way to implement a service oriented architecture.

MassTransit - Distributed Application Framework for .NET

Celery is an asynchronous task queue/job queue based on distributed message passing. It is focused on real-time operation, but supports scheduling as well. The execution units, called tasks, are executed concurrently on a single or more worker servers using multiprocessing, Eventlet, or gevent. Tasks can execute asynchronously (in the background) or synchronously (wait until ready).

Celery - Distributed Task Queue

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

go-socket.io is an implementation of socket.io in golang, which is a realtime application framework.It is compatible with latest implementation of socket.io in node.js, and supports room and namespace.

go-socket.io is an implementation of socket.io in golang, which is a realtime application framework. It is compatible with latest implementation of socket.io in node.js, and supports room and namespace.

go-socket.io - socket.io library for golang, a realtime application framework

Apache ActiveMQ is the most popular and powerful open source messaging and Integration Patterns provider. Apache ActiveMQ is fast, supports many Cross Language Clients and Protocols, comes with easy to use Enterprise Integration Patterns and many advanced features while fully supporting JMS 1.1 and J2EE 1.4. Its features include: 
 <UL>
	<LI>Supports a variety of Cross Language Clients and Protocols from Java, C, C++, C#, Ruby, Perl, Python, PHP
	<UL>
		<LI>OpenWire for high performance clients in Java, C, C++, C#</LI>
		<LI>Stomp support so that clients can be written easily in C, Ruby, Perl, Python, PHP, ActionScript/Flash, Smalltalk to talk to ActiveMQ as well as any other <A href="http://stomp.codehaus.org/StompConnect" rel="nofollow">popular Message Broker</A></LI>
	</UL>
	</LI>
	<LI>full support for the Enterprise Integration Patterns both in the JMS client and the Message Broker</LI>
	<LI>Supports many advanced features such as Message Groups, Virtual Destinations, Wildcards and Composite Destinations</LI>
	<LI>Fully supports JMS 1.1 and J2EE 1.4 with support for transient, persistent, transactional and XA messaging</LI>
	<LI>Spring Support so that ActiveMQ can be easily embedded into Spring applications and configured using Spring's XML configuration mechanism</LI>
	<LI>Tested inside popular J2EE servers such as Geronimo, JBoss 4, GlassFish and WebLogic
	<UL>
		<LI>Includes JCA 1.5 resource adaptors for inbound &amp; outbound messaging so that ActiveMQ should auto-deploy in any J2EE 1.4 compliant server</LI>
	</UL>
	</LI>
	<LI>Supports pluggable transport protocols such as in-VM, TCP, SSL, NIO, UDP, multicast, JGroups and JXTA transports</LI>
	<LI>Supports very fast persistence using JDBC along with a high performance journal</LI>
	<LI>Designed for high performance clustering, client-server, peer based communication</LI>
	<LI>REST API to provide technology agnostic and language neutral web based API to messaging</LI>
	<LI>Ajax to support web streaming support to web browsers using pure DHTML, allowing web browsers to be part of the messaging fabric</LI>
	<LI>CXF and Axis Support so that ActiveMQ can be easily dropped into either of these web service stacks to provide reliable messaging</LI>
	<LI>Can be used as an in memory JMS provider, ideal for unit testing JMS</LI>
</UL>

Apache ActiveMQ is the most popular and powerful open source messaging and Integration Patterns provider. Apache ActiveMQ is fast, supports many Cross Language Clients and Protocols, comes with easy to use Enterprise Integration Patterns and many advanced features while fully supporting JMS 1.1 and J2EE 1.4.

ActiveMQ

HornetQ is the new ultra high performance enterprise grade messaging system from JBoss community. It is a multi-protocol, embeddable, very high performance, clustered, asynchronous messaging system. It offers server replication and automatic client failover to eliminate lost or duplicated messages in case of server failure. It also provides a comprehensive management API to manage & monitor servers. HornetQ supports STOMP (simple text oriented messaging protocol), JMS bridge, Client side load balancing, Duplicate message detection, Message expiration, Scheduled messages and lot more.

HornetQ is the new ultra high performance enterprise grade messaging system from JBoss community. It is a multi-protocol, embeddable, very high performance, clustered, asynchronous messaging system. It offers server replication and automatic client failover to eliminate lost or duplicated messages in case of server failure. It also provides a comprehensive management API to manage & monitor servers.

Hornetq - Enterprise messaging

Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability.
 
Its features include: 
<ul>
<li>Pub/Sub messaging model</li>
<li>Scheduled message delivery</li>
<li>Message retroactivity by time or offset</li>
<li>Log hub for streaming</li>
<li>Big data integration</li>
<li>Reliable FIFO and strict ordered messaging in the same queue</li>
<li>Efficient pull&amp;push consumption model</li>
<li>Million-level message accumulation capacity in a single queue</li>
<li>Multiple messaging protocols like JMS and OpenMessaging</li>
<li>Flexible distributed scale-out deployment architecture</li>
<li>Lightning-fast batch message exchange system</li>
<li>Various message filter mechanics such as SQL and Tag</li>
<li>Docker images for isolated testing and cloud isolated clusters</li>
<li>Feature-rich administrative dashboard for configuration, metrics and monitoring</li>
</ul>

Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability.

RocketMQ - Distributed messaging and streaming data platform

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

dramatiq is a distributed task processing library for Python with a focus on simplicity, reliability and performance.

Dramatiq - Simple distributed task processing for Python 3.

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

Kombu is a Messaging Framework for Python. The aim of Kombu is to make messaging in Python as easy as possible by providing an idiomatic high-level interface for the AMQ protocol, and also provide proven and tested solutions to common messaging problems.  It allows application authors to support several message server solutions by using pluggable transports.

Kombu is a Messaging Framework for Python. The aim of Kombu is to make messaging in Python as easy as possible by providing an idiomatic high-level interface for the AMQ protocol, and also provide proven and tested solutions to common messaging problems. It allows application authors to support several message server solutions by using pluggable transports.

Kombu - Messaging Framework for Python

Discover open source projects across all platforms

Projects