Gque is a message queue protocol written in Golang that internally uses a NoSQL database to store broadcast queues and messages. Gque is designed to handle high-throughput message processing with a focus on scalability and reliability.
- Message Queuing: Efficiently queues incoming messages for processing.
- NoSQL Integration: Stores and retrieves messages and queues from a NoSQL database.
- Channel-Based Processing: Uses Golang channels for asynchronous message handling.
- Event-Driven Architecture: Supports the creation of events that can be broadcast to multiple consumers.
- Integration with Gnosql: Utilize Gnosql for high-performance in-memory data storage.
-
Receiving Messages:
- Requests from Gque clients are received by the handler.
- A new event is created and pushed into the incoming message channel.
-
Processing Incoming Messages:
- The incoming message worker consumes messages from the incoming message channel.
- The message data is stored in a GnoSQL database.
- The message is then passed to the message producer channel.
-
Producing Messages:
- The message producer worker consumes the message from the producer channel.
- Necessary events are generated.
- Events are pushed into the appropriate consumer channels.
- Run the following command to pull gque image:
go run cmd/main.go