A simple message bus built in Go — producer, broker, consumer.
This is a learning project. The goal was to understand how message queues work by building one from scratch, keeping things as simple as possible.
- Episode 1 — project setup, message structure, producer
- Episode 2 — broker, topic queues
- Episode 3 — consumer, putting it all together
make
Start the broker:
./build/broker
Send a message:
./build/producer -topic orders -message "hello"
Read messages:
./build/consumer -topic orders
broker: -phost, -pport (default 9990) for producers — -chost, -cport (default 9991) for consumers
producer: -host, -port (default 9990), -topic, -message
consumer: -host, -port (default 9991), -topic