helloworld

Documentation

Index

• Constants
• type RabbitMQ
  • func NewRabbitMQ(queueName string, exchange string, key string) *RabbitMQ
  • func NewRabbitMQInstance(queueName string) *RabbitMQ
  • func (r *RabbitMQ) Close()
  • func (r *RabbitMQ) Consume()
  • func (r *RabbitMQ) Publish(message string)

Constants

const MQURL = "amqp://lzr:123qwe@127.0.0.1:5672/hello_world"

MQURL 连接信息amqp://lzr:123qwe@127.0.0.1:5672/hello_world 这个信息是固定不变的amqp://事固定参数后面两个是用户名密码ip地址端口号Virtual Host

Types

type RabbitMQ

type RabbitMQ struct {

	//队列名称
	QueueName string
	//交换机名称
	Exchange string
	//bind Key 名称
	Key string
	//连接信息
	MqURL string
	// contains filtered or unexported fields
}

RabbitMQ rabbitMQ结构体

func NewRabbitMQ

func NewRabbitMQ(queueName string, exchange string, key string) *RabbitMQ

func NewRabbitMQInstance

func NewRabbitMQInstance(queueName string) *RabbitMQ

func (*RabbitMQ) Close

func (r *RabbitMQ) Close()

Close 关闭mq

func (*RabbitMQ) Consume

func (r *RabbitMQ) Consume()

Consume 消费消息

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish(message string)

Publish 生产消息