Go语言使用RabbitMQ-CFANZ编程社区

基本概念

什么是消息队列

消息队列是一种应用（进程）间的通信方式。

生产者只需把消息发布到MQ，消费者只需重MQ中取出，可靠传递由消息队列中的消息系统来确保。

消息队列有什么用

消息队列是一种异步协作机制，最根本的用处在于将一些不需要即时生效的操作拆分出来异步执行，从而达到可靠传递、流量削峰等目的。

常用的消息队列

常用的MQ大概有ActiveMQ、RabbitMQ、RocketMQ、Kafka

ActiveMQ，基于Java

优点：对Java的JMS支持最好；多线程并发；

缺点：历史悠久，版本更新慢。现在慢慢用的少了；

RabbitMQ，基于Erlang

优点：生态丰富，是现在主流的MQ；支持多种客户端、支持AJAX；

缺点：对想深入源码的Java选手不太友好；

RocketMQ，基于Java

优点：为海量数据打造；主张拉模式；天然集群、HA、负载均衡；

缺点：生态较小

Kafka，基于Scala

优点：分布式高可拓展；高性能；容错强

缺点：消息重复；乱序；维护成本高

什么是RabbitMQ

RabbitMQ是一个erlang开发的AMQP实现

生产者将消息发送到Exchange上，通过Exchange从而Binding到Queues上。

Exchange有三种具体类型：

direct：如果消息中的RoutingKey和Binding中的BindingKey一致就转发
fanout：消息被分发到所有队列中
topic：将RoutingKey和队列的模式进行匹配

应用场景

异步

可以理解为将遇到非必须的业务时，立即响应客户端，不关系业务何时完成

解耦

考虑两个系统间存在消息传递，一个系统的故障会影响到整个业务的正常运转。可以用消息队列来保证消息可靠传递

削峰

考虑短时间的大量请求，可能会带来内存溢出、大面积连接超时等情况，使得服务器崩溃。引入消息队列后，可以控制请求到业务处理系统的流量，从而防止崩溃现象的出现。

Go语言使用RabbitMQ

docker安装RabbitMQ

sudo docker pull rabbitmq
sudo docker images
sudo docker run --name rabbitmq -d -p 5672:5672
sudo docker ps

go安装rabbitmq客户端

go get github.com/streadway/amqp

HelloRabbitMQ

send.go

func main() {
	conn, _ := amqp.Dial("amqp://guest:guest@localhost:5672/")
	defer conn.Close()
	ch, _ := conn.Channel()
	defer ch.Close()
	q, _ := ch.QueueDeclare(
		"hello", // name
		false,   // durable
		false,   // delete when unused
		false,   // exclusive
		false,   // no-wait
		nil,     // arguments
	)
	body := "Hello World!"
	_ = ch.Publish(
		"",     // exchange
		q.Name, // routing key
		false,  // mandatory
		false,  // immediate
		amqp.Publishing{
			ContentType: "text/plain",
			Body:        []byte(body),
		})
}

recv.go

func main() {
	conn, _ := amqp.Dial("amqp://guest:guest@localhost:5672/")
	defer conn.Close()
	ch, _ := conn.Channel()
	defer ch.Close()
	q, _ := ch.QueueDeclare(
		"hello", // name
		false,   // durable
		false,   // delete when unused
		false,   // exclusive
		false,   // no-wait
		nil,     // arguments
	)
	msgs, _ := ch.Consume(
		q.Name, // queue
		"",     // consumer
		true,   // auto-ack
		false,  // exclusive
		false,  // no-local
		false,  // no-wait
		nil,    // args
	)
	forever := make(chan bool)
	go func() {
		for d := range msgs {
			log.Printf("Received a message: %s", d.Body)
		}
	}()
	<-forever
}