rabbitd

Documentation

Index

• type RabbitConsumerManager
  • func NewRabbitConsumer(ServerAddr string) *RabbitConsumerManager
  • func (mq *RabbitConsumerManager) Distory()
  • func (mq *RabbitConsumerManager) RegisterReceiver(receiver Receiver)
  • func (mq *RabbitConsumerManager) Start()
• type RabbitMQ
  • func (mq *RabbitMQ) Refresh() bool
• type RabbitProducerManager
  • func NewRabbitProducer(ServerAddr, exchangeName, exchangeType, routingKey, queueName string, ...) *RabbitProducerManager
  • func (p *RabbitProducerManager) Publish(msg string) error
• type Receiver

Types

type RabbitConsumerManager

type RabbitConsumerManager struct {
	RabbitMQ
	// contains filtered or unexported fields
}

RabbitConsumerManager consumer 管理

func NewRabbitConsumer

func NewRabbitConsumer(ServerAddr string) *RabbitConsumerManager

, exchangeName, exchangeType string, consumerMount int New 创建一个新的操作Rabbit Consumer的对象

func (*RabbitConsumerManager) Distory

func (mq *RabbitConsumerManager) Distory()

func (*RabbitConsumerManager) RegisterReceiver

func (mq *RabbitConsumerManager) RegisterReceiver(receiver Receiver)

RegisterReceiver 加入注册的消费者

func (*RabbitConsumerManager) Start

func (mq *RabbitConsumerManager) Start()

Start 启动Rabbitmq的客户端

type RabbitMQ

type RabbitMQ struct {
	Conn       *amqp.Connection
	ServerAddr string
	MaxRefresh int
	// contains filtered or unexported fields
}

RabbitMQ 用于管理和维护rabbit mq连接

func (*RabbitMQ) Refresh

func (mq *RabbitMQ) Refresh() bool

Refresh 初始和重试连接

type RabbitProducerManager

type RabbitProducerManager struct {
	RabbitMQ

	RoutingKey string
	Reliable   bool
	QueueName  string
	// contains filtered or unexported fields
}

RabbitProducerManager 消息生产者管理

func NewRabbitProducer

func NewRabbitProducer(ServerAddr, exchangeName, exchangeType, routingKey, queueName string, reliable bool, retry int) *RabbitProducerManager

New 创建一个新的操作Rabbit Producer的对象

func (*RabbitProducerManager) Publish

func (p *RabbitProducerManager) Publish(msg string) error

Publish 发送mq 消息

type Receiver

type Receiver interface {
	QueueName() string // 接收者监听队列
	RouterKey() string // 队列绑定的路由
	OnError(error)     // 错误处理
	OnReceive([]byte) bool
	ConsumerMount() int //开启接收者协程数量
	ExchangeName() string
	ExchangeType() string
}

Receiver 接口