go-redis-mq:!!!

时间:2024-06-02 13:07:26
【文件属性】:

文件名称:go-redis-mq:!!!

文件大小:10KB

文件格式:ZIP

更新时间:2024-06-02 13:07:26

Go

基于go 和 redis 的消息服务框架 1.原理 基于redis的list的rpush和blpop的队列,消费者和服务提供者各有一条消息队列,消费者在服务者的消息队列push一条服务请求,服务提供者得到请求处理后放入消费者消息队列,消费者获得消息并处理。 2.优点 1 节点由redis控制,消费者和服务者无需关心消息的来源和去向 2 缓存机制 3 重试机制 3.例子 服务提供者 server: package main import ( "./godis" ) func main (){ server, _:=godis.NewServer("4","127.0.0.1:6379") h := func(v godis.ProtoType) (int64, godis.ProtoType, error) { dd := make(godis.ProtoType) dd["r


【文件预览】:
go-redis-mq-master
----server.go(317B)
----godis()
--------server.go(2KB)
--------keyName.go(1KB)
--------connect.go(774B)
--------monitor.go(1012B)
--------client.go(4KB)
--------protocol.go(3KB)
--------common.go(560B)
----LICENSE(1KB)
----monitor.go(109B)
----README.md(2KB)
----client.go(801B)

网友评论