极简操作RabbitMQ的Go客户端

基于https://github.com/streadway/amqp封装了一个RabbitMQ Go客户端，使用起来更方便。

安装

go get github.com/itbsl/rabbitmq

使用

使用起来，rabbitmq只包含5个创建不同类型的RabbitMQ实例的方法，和一个关闭连接的方法，以及发送消息和获取消息的的两个方法，共八个方法
方法如下：

//创建普通类型的rabbitmq实例，消息没有持久化
rabbitmq.NewSimpleRabbitMQ()
//创建工作队列模式的RabbitMQ实例：消息持久化，需要手动应答
rabbitmq.NewWorkQueueRabbitMQ()
//创建发布/订阅模式的RabbitMQ实例：消息持久化，自动应答
rabbitmq.NewPubSubRabbitMQ()
//创建路由模式的RabbitMQ实例：消息持久化，手动应答
rabbitmq.NewRouteRabbitMQ()
//创建话题模式的RabbitMQ实例：消息持久化，手动应答
rabbitmq.NewTopicRabbitMQ()

示例：

生产者客户端
1.创建RabbitMQ实例
2.发送消息

package main

import (
	"github.com/itbsl/rabbitmq"
	"log"
)

func main() {
	//连接RabbitMQ
	url := "amqp://root:root@127.0.0.1:5672/"
	mq, err := rabbitmq.NewWorkQueueRabbitMQ(url, "hello")
	if err != nil {
		log.Fatalf("连接RabbitMQ出错，错误为：%v
", err)
	}
	defer mq.Close()

	//发送消息
	err = mq.Send("hello world!")
	if err != nil {
		log.Fatalf("发送消息失败，错误为：%v
", err)
	}
}

消费者客户端
1.创建所需类型的RabbitMQ实例
2.消费消息，业务代码写在回调函数里

package main

import (
	"github.com/itbsl/rabbitmq"
	"log"
)

func main() {
	//连接RabbitMQ
	url := "amqp://root:root@127.0.0.1:5672/"
	mq, err := rabbitmq.NewWorkQueueRabbitMQ(url, "hello")
	if err != nil {
		log.Fatalf("连接RabbitMQ出错，错误为：%v
", err)
	}
	defer mq.Close()

	//消费消息
	err = mq.Consume(func(msg string) bool {
		//这里写业务处理代码，业务处理成功，返回true用于手动应答，失败返回false,消息会被重新放入队列
		return true
	})
	if err != nil {
		log.Fatalf("消费失败，错误为：%v
", err)
	}
}