subscribe

Documentation

Index

• Constants
• type RedisSubscribe
  • func New() *RedisSubscribe
  • func (rs RedisSubscribe) Start()

Constants

const (
	EventCleanAppMemCache = "clean:app:memory:cache" // 清理各pod本地App相关内存缓存
)

定义redis pub-sub订阅消息事件常量<本质就是redis订阅推送过来的消息本身>

Types

type RedisSubscribe

type RedisSubscribe struct{}

RedisSubscribe redis 发布-订阅功能实现的多pod间触发执行一些同步逻辑

• 极端场景下redis pub-sub可靠性并不能百分百保障订阅者取得每一份消息
• <ugly-极端场景发生时业务已不可用订阅者是否还能收到消息还重要？>
• go-redis 本身已内部实现断线自动重连 https://redis.uptrace.dev/#pubsub

func New

func New() *RedisSubscribe

New 实例化redis订阅同步实例

func (RedisSubscribe) Start

func (rs RedisSubscribe) Start()

Start 启动redis发布-订阅监听<内部协程方式>