时间:2021-05-19
一、获取镜像
#指定版本,该版本包含了web控制页面docker pull rabbitmq:management二、运行镜像
#方式一:默认guest 用户,密码也是 guestdocker run -d --hostname my-rabbit --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq:management#方式二:设置用户名和密码docker run -d --hostname my-rabbit --name rabbit -e RABBITMQ_DEFAULT_USER=user -e RABBITMQ_DEFAULT_PASS=password -p 15672:15672 -p 5672:5672 rabbitmq:management三、访问ui页面
http://localhost:15672/
四、golang案例
#producer生产者代码package mainimport ( "fmt" "log" "github.com/streadway/amqp")const ( //AMQP URI uri = "amqp://guest:guest@10.0.0.11:5672/" // 10.0.0.11为主机ip //Durable AMQP exchange name exchangeName = "" //Durable AMQP queue name queueName = "test-queues" //Body of message bodyMsg string = "hello angel")//如果存在错误,则输出func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) panic(fmt.Sprintf("%s: %s", msg, err)) }}func main() { //调用发布消息函数 publish(uri, exchangeName, queueName, bodyMsg) log.Printf("published %dB OK", len(bodyMsg))}//发布者的方法//@amqpURI, amqp的地址//@exchange, exchange的名称//@queue, queue的名称//@body, 主体内容func publish(amqpURI string, exchange string, queue string, body string) { //建立连接 log.Printf("dialing %q", amqpURI) connection, err := amqp.Dial(amqpURI) failOnError(err, "Failed to connect to RabbitMQ") defer connection.Close() //创建一个Channel log.Printf("got Connection, getting Channel") channel, err := connection.Channel() failOnError(err, "Failed to open a channel") defer channel.Close() log.Printf("got queue, declaring %q", queue) //创建一个queue q, err := channel.QueueDeclare( queueName, // name false, // durable false, // delete when unused false, // exclusive false, // no-wait nil, // arguments ) failOnError(err, "Failed to declare a queue") log.Printf("declared queue, publishing %dB body (%q)", len(body), body) // Producer只能发送到exchange,它是不能直接发送到queue的 // 现在我们使用默认的exchange(名字是空字符)这个默认的exchange允许我们发送给指定的queue // routing_key就是指定的queue名字 err = channel.Publish( exchange, // exchange q.Name, // routing key false, // mandatory false, // immediate amqp.Publishing{ Headers: amqp.Table{}, ContentType: "text/plain", ContentEncoding: "", Body: []byte(body), }) failOnError(err, "Failed to publish a message")}五、拥有消息确认的代码
#producerpackage mainimport ( "fmt" "github.com/streadway/amqp" "log" "os" "strings")const ( //AMQP URI uri = "amqp://guest:guest@10.0.0.11:5672/" //Durable AMQP exchange name exchangeName = "" //Durable AMQP queue name queueName = "test-queues-acknowledgments")//如果存在错误,则输出func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) panic(fmt.Sprintf("%s: %s", msg, err)) }}func main() { bodyMsg := bodyFrom(os.Args) //调用发布消息函数 publish(uri, exchangeName, queueName, bodyMsg) log.Printf("published %dB OK", len(bodyMsg))}func bodyFrom(args []string) string { var s string if (len(args) < 2) || os.Args[1] == "" { s = "hello angel" } else { s = strings.Join(args[1:], " ") } return s}//发布者的方法//@amqpURI, amqp的地址//@exchange, exchange的名称//@queue, queue的名称//@body, 主体内容func publish(amqpURI string, exchange string, queue string, body string) { //建立连接 log.Printf("dialing %q", amqpURI) connection, err := amqp.Dial(amqpURI) failOnError(err, "Failed to connect to RabbitMQ") defer connection.Close() //创建一个Channel log.Printf("got Connection, getting Channel") channel, err := connection.Channel() failOnError(err, "Failed to open a channel") defer channel.Close() log.Printf("got queue, declaring %q", queue) //创建一个queue q, err := channel.QueueDeclare( queueName, // name false, // durable false, // delete when unused false, // exclusive false, // no-wait nil, // arguments ) failOnError(err, "Failed to declare a queue") log.Printf("declared queue, publishing %dB body (%q)", len(body), body) // Producer只能发送到exchange,它是不能直接发送到queue的。 // 现在我们使用默认的exchange(名字是空字符)。这个默认的exchange允许我们发送给指定的queue。 // routing_key就是指定的queue名字。 err = channel.Publish( exchange, // exchange q.Name, // routing key false, // mandatory false, // immediate amqp.Publishing{ Headers: amqp.Table{}, ContentType: "text/plain", ContentEncoding: "", Body: []byte(body), }) failOnError(err, "Failed to publish a message")}到此这篇关于docker快速安装rabbitmq的方法步骤的文章就介绍到这了,更多相关docker安装rabbitmq内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
快速回顾一下RabbitMQ服务器的安装:sudoapt-getinstallrabbitmq-serverPython使用RabbitMQ需要Pika库:su
题记安装系列一篇,最近闲暇来折腾折腾Docker和springboot。记录步骤,简要说明,目的是能够快速安装使用,方便查阅,这就是写安装文章的作用,我个人不喜
rabbitMq是一种应用程序对应用程序的通信方法,可以在AMQP基础上完整的,可复用的企业消息系统。一起来看看centos7rabbitmq安装的方法吧。安装
rabbitmq安装之前需要安装socat,否则直接安装rabbitmq可能会报错如果没有找到,则先安装epel源 yum-yinstallepel-rele
本文实例讲述了使用PHP访问RabbitMQ消息队列的方法。分享给大家供大家参考,具体如下:扩展安装PHP访问RabbitMQ实际使用的是AMQP协议,所以我们