zdpgo_rabbitmq

README

zdpgo_rabbitmq

简化Golang操作RabbitMQ的组件库

一、快速入门

1.1 发布和定义

1.1.1 生产者

package main

import (
	"github.com/zhangdapeng520/zdpgo_rabbitmq"
)

func main(){
	mq:=zdpgo_rabbitmq.NewDefaultRabbitMQ()
	mq.Send("msg", "你好，我是张大鹏！")
}

1.1.2 消费者

package main

import (
	"time"

	"github.com/zhangdapeng520/zdpgo_rabbitmq"
)

func main(){
	mq:=zdpgo_rabbitmq.NewDefaultRabbitMQ()
	mq.Receive("msg")
	time.Sleep(3*time.Second)
}

Documentation

Index

• type RabbitMQ
  • func NewDefaultRabbitMQ() *RabbitMQ
  • func (mq *RabbitMQ) Connect()
  • func (mq *RabbitMQ) CreateChannel() *amqp.Channel
  • func (mq *RabbitMQ) CreateQueue(channel *amqp.Channel, queueName string) amqp.Queue
  • func (mq *RabbitMQ) Pub(channel *amqp.Channel, queue amqp.Queue, msg string) error
  • func (mq *RabbitMQ) Receive(queueName string)
  • func (mq *RabbitMQ) Send(queueName, msg string)
  • func (mq *RabbitMQ) Sub(channel *amqp.Channel, queue amqp.Queue) <-chan amqp.Delivery

Types

type RabbitMQ

type RabbitMQ struct {
	Username string           // 用户名
	Password string           // 密码
	Ip       string           // IP
	Port     int              // 端口号
	Conn     *amqp.Connection // 连接
}

RabbitMQ结构体

func NewDefaultRabbitMQ

func NewDefaultRabbitMQ() *RabbitMQ

获取默认的结构体

func (*RabbitMQ) Connect

func (mq *RabbitMQ) Connect()

建立连接

func (*RabbitMQ) CreateChannel

func (mq *RabbitMQ) CreateChannel() *amqp.Channel

创建通道

func (*RabbitMQ) CreateQueue

func (mq *RabbitMQ) CreateQueue(channel *amqp.Channel, queueName string) amqp.Queue

创建队列

func (*RabbitMQ) Pub

func (mq *RabbitMQ) Pub(channel *amqp.Channel, queue amqp.Queue, msg string) error

发布消息

func (*RabbitMQ) Receive

func (mq *RabbitMQ) Receive(queueName string)

接收消息

func (*RabbitMQ) Send

func (mq *RabbitMQ) Send(queueName, msg string)

发送数据

func (*RabbitMQ) Sub

func (mq *RabbitMQ) Sub(channel *amqp.Channel, queue amqp.Queue) <-chan amqp.Delivery

订阅消息