Libraries that implement messaging systems.

Newest releases

c16a Hermes Hermes is a tiny MQTT compatible broker written in Go. The goals of the project are as below Easy to compile, and run Tiny footprint Extensible

queer 신경 신경 /ɕʰinɡjʌ̹ŋ/ • sin-gyeong (try it with IPA Reader) nerve Nerve /nərv/ • noun (in the body) a whitish fiber or bundle of fibers that transmits imp

hoorayman a distributed chat system which can be used as chat rooms or state synchronization

dominikbraun buneary, pronounced bun-ear-y, is an easy-to-use RabbitMQ command line client for managing exchanges, managing queues and publishing messages to exchanges.

mostafa This is a k6 extension using the xk6 system.

mattermost It's written in Golang and React and runs as a single Linux binary with MySQL or PostgreSQL.

batchcorp RabbitMQ wrapper for steadway/amqp that supports auto-reconnects

vmihailenco[Go] MessagePack encoding for Golang

mkocikowski Package libkafka is a low level library for producing to and consuming from Kafka 2.3+. It has no external dependencies. It is not modeled on the Java client. All API calls are synchronous and all code executes in the calling goro

mkocikowski This is a high-level kafka client based on the low level libkafka library. It is meant as an alternative to Sarama for producing high volumes of messages.

nats-io NATS is a simple, secure and performant communications system for digital systems, services and devices. NATS is part of the Cloud Native Computing Foundation (CNCF). NATS has over 30 client language implementation

mustafaturan 🔊 Bus Bus is a minimalist event/message bus implementation for internal communication. It is heavily inspired from my event_bus package for Elixir language. Installation Via go packages: go get

joncrlsn dque - a fast embedded durable queue for Go dque is: persistent -- survives program restarts scalable -- not limited by your RAM, but by your disk space FIFO -- First In First Out embedded -- compiled into

Clivern Beaver A Real Time Messaging Server. Beaver is a real-time messaging server. With beaver you can easily build scalable in-app notifications, realtime graphs, multiplayer games, chat applications, geotrackin

nsqio Source: Issues: Mailing List: [email protected] IRC: #nsq on freenode Docs: Twitter: @nsqio NSQ is a realt

Jeffail Benthos is a high performance and resilient message streaming service, able to connect various sources and sinks and perform arbitrary actions, transformations and filters on payloads. It is easy to deploy and monitor, and r

vgoio Vgo Rebuild the way of instant messaging, connecting server-side,app-user,web-user by pub/sub. Homepage: ###Project status Under refactoring Features Pub/Sub Multiple clients can su

alash3al Websocketify (wsify) v2.0 Just a tiny, simple and realtime pub/sub messaging service Why I wanted to create a tiny solution that can replace pusher and similar services and learning more about the

goiiot libmqtt Feature rich modern MQTT library in pure Go, for Go, C/C++, Java Table of contents Features Usage Topic Routing Session Persist Benchmark Extensions LICENSE Features

sandglass Sandglass is a distributed, horizontally scalable, persistent, time ordered message queue. It was developed to support asynchronous tasks and message scheduling which makes it suitable for usage as a task queue.

vgoio Vgo Rebuild the way of instant messaging, connecting server-side,app-user,web-user by pub/sub. Homepage: ###Project status Under refactoring Features Pub/Sub Multiple clients can su

rgamba Postman Postman is a HTTP to AMQP reverse proxy that combines the ease of implementing an HTTP API with the benefits of async inter-service communication. Most of the HTTP services use a reverse proxy (nginx, Apache, e

siadat System V message queue IPC functions Wrapper functions for System V Message Queue IPC. Example package main import ( "log" "syscall" "" ) func main() { key, err := ipc.Ftok("

MasslessParticle GoQ Package Goq provides a lightweight, extensible, in-memory message broker. go get Running tests: go get go get go install

ridwanmsharif mqueue (Go) In-memory message broker in Go over an HTTP API using a concurrent, thread-safe publisher/subscriber architecture with multiple topics. Installation $ go get $ c

meitu go-consumergroup Go-consumergroup is a kafka consumer library written in golang with rebalance and chroot supports. Chinese Doc Requirements Apache Kafka 0.8.x, 0.9.x, 0.10.x, 0.11.x, 1.0.x

asim MQ MQ is a simple in-memory message broker It is used mainly for testing. Purely a toy project. Features In-memory message queue Optionally persist to file Client side clustering Proxying MQ cluste

jakewins 4FQ (Four Fast Queues) This repository contains four fast queues for Go: Multi-Producer/Multi-Consumer Multi-Producer/Single-Consumer Single-Producer/Multi-Consumer Single-Producer/Single-Consumer For some

lirm aeron-go Implementation of Aeron messaging client in Go. Architecture, design, and protocol of Aeron can be found here Usage Example subscriber can be found here. Example publication can be found here.

travisjeffery Jocko Kafka/distributed commit log service in Go. Goals of this project: Implement Kafka in Go Protocol compatible with Kafka so Kafka clients and services work with Jocko Make operating simpler

xuri Overview aurora is a web-based Beanstalkd queue server console written in Go and works on macOS, Linux, and Windows machines. The main idea behind using Go for backend development is to utilize the ability of

ninibe NetLog A lightweight, HTTP-centric, log-based (Kafka-style) message queue. Alpha software This is still early software and potentially buggy. To peek at the internals start with BigLog. Roadmap

uniqush Homepage Download Blog/News @uniqush Introduction Uniqush (\ˈyü-nə-ku̇sh\ "uni" pronounced as in "unified", and "qush" pronounced as in "cushion") is a free and open source software system which provides a u