Ramqp是对Go版本amqp的简单封装，提供了简洁明了的调用方式，并且支持断线重连。理论上支持所有实现了amqp协议的消息中间件，比如著名的RabbitMQ。
go get -u -v github.com/ijkbytes/ramqp
下面的例子展示了如何使用Ramqp：
...
msg := make(chan string)
mq := ramqp.New("amqp://test:[email protected]:5672/test")
receiver := &ramqp.Receiver{
ExchangeName: "exchange_name",
ExchangeType: "topic",
QueueName: "test_queue",
RouteKey: "test_queue",
OnReceive: func(msg *amqp.Delivery) bool {
msg <- string(msg.Body)
return true
},
}
publisher = &rabbitmq.Publisher{}
// register receiver and enable auto ack
mq.RegisterReceiver(&ReceiverA{}, ramqp.WithConsumeAutoAck())
// register publisher
mq.RegisterPubliser(publisher)
if err := mq.Start(); err != nil {
panic(err)
}
publisher.Publish("exchange_name", "test_queue", amqp.Publishing{
Body: []byte("this is a test."),
})
fmt.Println("receive msg: ", <-msg)
...- TCP断线自动重连
- 多通道共用一条TCP连接
- 通道异常重连
- 队列被删除自动重建
- 实现消费者
- 实现生产者