SRQ >>= Stupid Redis message Queue
It is a so stupid message queue based on redis that I think it is Simple
Install
go get -u -v github.com/Lispre/srq
Feature
- It supports multi producer push message at the same time, and the same message enqueue Only once.
- It supports multi consumer fetch message from queue at the same time, and it make sure that every consumer get the different message every time from each other.
- It supports the priority configuration of message with waitWeight parameter
API
- Create a redis connection
func NewConnection(network string // tcp, udp ...
address string // "127.0.0.1:6379
options options ...redis.DialOption) (redis.Conn, error)
- Create a queue
func NewQueue(queueName string, conn redis.Conn) *Queue
- Push message to queue
func (queue *Queue) Push(message string, waitWeight int64 // This parameter set more large will wait longer time to consumered by consumer) (bool, error)
- Pop message from queue
func (queue *Queue) Pop() (string, error)
Example
producer
package main
import (
"fmt"
"github.com/Lispre/srq"
)
func main() {
conn, err := srq.NewConnection("tcp", "127.0.0.1:6379")
if err != nil {
fmt.Printf("connect redis error\n")
return
}
defer conn.Close()
queue := srq.NewQueue("test_queue", conn)
status, err := queue.Push("message1", 11)
if err != nil {
fmt.Printf("push message error\n")
}
if status {
fmt.Printf("push message success\n")
}
status, err = queue.Push("message2", 22)
if err != nil {
fmt.Printf("push message error\n")
}
if status {
fmt.Printf("push message success\n")
}
status, err = queue.Push("message3", 33)
if err != nil {
fmt.Printf("push message error\n")
}
if status {
fmt.Printf("push message success\n")
}
}
consumer
package main
import (
"fmt"
"github.com/Lispre/srq"
)
func main() {
conn, err := srq.NewConnection("tcp", "127.0.0.1:6379")
if err != nil {
fmt.Printf("connect redis error\n")
return
}
defer conn.Close()
queue := srq.NewQueue("test_queue", conn)
msg1, err := queue.Pop()
if err != nil {
fmt.Printf("received message error\n")
}
if msg1 == "" {
fmt.Printf("No message in queue\n")
return
}
fmt.Printf("message is: %v\n", msg1)
msg2, err := queue.Pop()
if err != nil {
fmt.Printf("received message error\n")
}
if msg1 == "" {
fmt.Printf("No message in queue")
}
fmt.Printf("message is: %v\n", msg2)
msg3, err := queue.Pop()
if err != nil {
fmt.Printf("received message error\n")
}
if msg1 == "" {
fmt.Printf("No message in queue")
}
fmt.Printf("message is: %v\n", msg3)
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent