一、獲取鏡像

#指定版本，該版本包含了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內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！