routing

package

v0.0.0-...-b9ba31e Latest Latest Go to latest Published: Jan 3, 2022 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/llzzrrr1997/rabbitmq-go-example

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type RabbitMQ
- func NewRabbitMQ(queueName string, exchange string, key string) *RabbitMQ
- func NewRabbitMQInstance(exchangeName string, routingKey string) *RabbitMQ

Constants ¶

View Source

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

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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(exchangeName string, routingKey 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 生产消息

Source Files ¶

View all Source files

rabbitmq.go

Directories ¶

Path	Synopsis
consumer
publisher

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL