redis

Documentation

Index

• Variables
• func NewMQ() mq.IReactMQ
• type RedisMQ
  • func (this *RedisMQ) Close()
  • func (this *RedisMQ) Connect(mode mq.Mode, strURL string) (err error)
  • func (this *RedisMQ) Consume(strBindingKey, strQueueName string, handler mq.ReactHandler) (err error)
  • func (this *RedisMQ) Debug(enable bool)
  • func (this *RedisMQ) GetAdapter() (adapter mq.Adapter)
  • func (this *RedisMQ) IsClosed() bool
  • func (this *RedisMQ) Publish(strBindingKey, strQueueName, key string, value string) (err error)
  • func (this *RedisMQ) Reconnect() (err error)

Variables

var REDIS_CMD_AUTH = "AUTH"

var REDIS_CMD_BRPOP = "BRPOP"

var REDIS_CMD_DEL = "DEL"

var REDIS_CMD_EVAL = "EVAL"

var REDIS_CMD_EXPIRE = "EXPIRE"

var REDIS_CMD_GET = "GET"

var REDIS_CMD_LPUSH = "LPUSH"

var REDIS_CMD_PING = "PING"

var REDIS_CMD_PSUBSCRIBE = "PSUBSCRIBE" //模式订阅(使用*作为通配符)

var REDIS_CMD_PUBLISH = "PUBLISH"

var REDIS_CMD_SET = "SET"

var REDIS_CMD_SUBSCRIBE = "SUBSCRIBE"

var REDIS_RESP_OK = "OK"

var REDIS_SET_EX = "EX"

var REDIS_SET_NX = "NX"

var REDIS_SET_WITH_EXPIRE_TIME = "PX"

Functions

func NewMQ

func NewMQ() mq.IReactMQ

Types

type RedisMQ

type RedisMQ struct {
	// contains filtered or unexported fields
}

func (*RedisMQ) Close

func (this *RedisMQ) Close()

func (*RedisMQ) Connect

func (this *RedisMQ) Connect(mode mq.Mode, strURL string) (err error)

Redis连接URL 有密码 "redis://123456@192.168.1.10:6379"

没有密码则是 "redis://192.168.1.10:6379"

func (*RedisMQ) Consume

func (this *RedisMQ) Consume(strBindingKey, strQueueName string, handler mq.ReactHandler) (err error)

* @brief 消息消费接口定义 * @param strBindingKey 队列绑定Key * @param strQueueName 队列名称 * @param handler 消费回调处理对象 * @return err 成功返回nil，失败返回返回具体错误信息 * @remark 服务器异常或重启时内部会自动重连服务器

func (*RedisMQ) Debug

func (this *RedisMQ) Debug(enable bool)

* @brief 开启或关闭调式模式 * @param enable true开启/false关闭

func (*RedisMQ) GetAdapter

func (this *RedisMQ) GetAdapter() (adapter mq.Adapter)

* @brief 获取当前MQ类型 * @param adapter MQ类型

func (*RedisMQ) IsClosed

func (this *RedisMQ) IsClosed() bool

func (*RedisMQ) Publish

func (this *RedisMQ) Publish(strBindingKey, strQueueName, key string, value string) (err error)

* @brief 消息发布接口定义(仅支持字符串类型消息) * @param strBindingKey 队列绑定Key(topic) * @param strQueueName 队列名称(group) * @param key 消息KEY(仅kafka必填，其他MQ类型默认填PRODUCER_KEY_NULL) * @param value 消息数据 * @return err 发布失败返回具体错误信息

func (*RedisMQ) Reconnect

func (this *RedisMQ) Reconnect() (err error)