kiteq is a distributed mq framework

Shortlink service (Microservice example) ⭐️ Star the repo if you like it!

💧Waterdrop is a high performance micro service framework. Waterdrop comes from (The Three Body Problem).

Golang MQTT Broker.

橘子 消息推送系统 是用golang( iris )开发的可消息配置管理、高可用的、多渠道发送的、可高并发(使用协程)发送的综合消息推送系统，集成了微信订阅消息、邮件发送、短信发送，支持批量发送，模板信息可配置，支持敏感词过滤，支持重试发送，消息自动匹配回复，支持数据入库。如果您需要一个消息服务专门用来给用户发消息，那这个橘子系统就很适合您。

小而美的业务基础框架，也是本项目的核心

基于 Rabbitmq 的 Http 异步消息调用服务

wmq admin

Pan is a high performance mq proxy,support kafka,rabbit-mq,rocketmq,nsq and other mq

基于Go整合Gossip+WebSocket的轻量级分布式消息队列。实现功能：订阅/发布推送、点对点推送、延时消息推送、消费失败自动重试、数据持久化、WAL预写日志、主从节点部署、集群负载均衡、ACK确认机制、内置网页端控制台

Queue based data collector, transmitter with store-and-forward. Useful for online/offline data collection, back pressure buffering or general queuing. REST / HTTP post.

a deadly simple thread-safe, zero-alloc event bus for Golang

Incubation Factory, include mq consumer,web/rpc and job service create

一个消息队列实践 -- A message queue through the channel connected sender and receiver

a message queue that can realize service decoupling

Pikaq makes writing your own high performance message-based services fun and type safe.

基于beego redis的简单消息队列（转发消息）

Simple Chat service using Hexagonal Architecture with Go

Kafka, Beanstalkd, Pulsar Pub/Sub framework. Reference: https://github.com/zeromicro/go-queue

a storage engine by FIFO QUEUE. you can make a distributed-message-queue based on qstore. you can also use it to implemente write-ahead-log