docker快速安装rabbitmq的方法步骤

一、获取镜像

#指定版本,该版本包含了web控制页面
docker pull rabbitmq:management

二、运行镜像

#方式一:默认guest 用户,密码也是 guest
docker 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 main

import (
  "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")

}

五、拥有消息确认的代码

#producer
package main

import (
  "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内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

时间: 2020-07-12

docker安装并运行rabbitmq的实例代码

拉取镜像: [mall@VM_0_7_centos ~]$ sudo docker pull rabbitmq:3.7.15 [sudo] password for mall: 3.7.15: Pulling from library/rabbitmq 5b7339215d1d: Pull complete 14ca88e9f672: Pull complete a31c3b1caad4: Pull complete b054a26005b7: Pull complete eef17c6cb6c

yum下载docker安装包安装到离线机器的实例代码详解

1.在可联网机器上,使用默认centosyum源 [root@kole ~]# pwd /root [root@kole ~]# [root@kole ~]# cd docker/ [root@kole docker]# yum install --downloadonly --downloaddir=/root/docker docker [root@kole docker]# ll total 38800 -rw-r--r-- 1 root root 35780 Oct 2 00:52 at

java远程连接调用Rabbitmq的实例代码

本文介绍了java远程连接调用Rabbitmq,分享给大家,希望此文章对各位有所帮助. 打开IDEA创建一个maven工程(Java就可以了). pom.xml文件如下 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apac

java实现远程桌面的实例代码

java实现远程桌面的实例代码 控制端将鼠标事件传递到服务端 服务端拿到鼠标事件之后传输到客户端 客户端拿到鼠标事件之后,通过robot类即可完成,并且截屏将图片发给服务器,服务器再发给控制端 被我简化之后得到 //先介绍一下robot类的简单使用 import java.awt.AWTException; import java.awt.Robot; import java.awt.event.InputEvent; /** * 使用robot * @author 哑元 * */ public

使用Docker安装Jenkins的示例代码

在docker安装容器的时候容易遇到的两个问题 1.port is already allocated(端口被指派了) 解决办法:改端口 2.that container to be able to reuse that name 解决办法:查看(删除)之前的容器 docker ps -a | grep jenkins_im docker rm jenkins_im 启动docker服务 sudo systemctl start docker vi /home/jenkins/docker-co

matplotlib简介,安装和简单实例代码

官网介绍: Matplotlib is a Python 2D plotting library which produces publication quality figures in a variety of hardcopy formats and interactive environments across platforms. Matplotlib can be used in Python scripts, the Python and IPython shell, the ju

JS实现可直接显示网页代码运行效果的HTML代码预览功能实例

本文实例讲述了JS实现可直接显示网页代码运行效果的HTML代码预览功能.分享给大家供大家参考.具体如下: JavaScript实现HTML代码预览功能,直接在网页上显示代码运行的效果,就例如点击"运行代码"后的效果,使用时,你只需将需要运行的HTML代码拷贝到文本框内,点击对应的功能按钮即可. 运行效果如下图所示: 具体代码如下: <HTML> <HEAD> <TITLE>直接页面显示器</TITLE> <STYLE type=&q

Docker安装运行apache2服务器做图片服务器的方法

 1.安装 docker pull httpd 2.创建文件夹 mkdir -p /usr/docker_data/statics / /usr/docker_data/httpd/logs/ /usr/docker_data/httpd/conf/ 解释:statics文件夹映射图片文件存放路径  logs映射日志文件路径  conf映射配置文件路径 3.试运行httpd docker run -it --name test-httpd httpd bash 4.进入conf文件夹把httpd

docker 动态映射运行的container端口实例详解

docker动态映射运行的container端口,最近做项目,对于docker动态映射运行的container端口的资料有必要记录下,以便以后在用到, Docker自带了EXPOSE命令,可以通过编写dockerfile加-p参数方便的映射Container内部端口,但是对于已经运行的container,如果你想对外开放一个新的端口,只能编辑dockerfile然后重新build,有点不太方便. 其实docker本身使用了iptables来做端口映射的,所以我们可以通过一些简单的操作来实现动态映

消息队列 RabbitMQ 与 Spring 整合使用的实例代码

一.什么是 RabbitMQ RabbitMQ 是实现 AMQP(高级消息队列协议)的消息中间件的一种,最初起源于金融系统,用于在分布式系统中存储转发消息,在易用性.扩展性.高可用性等方面表现不俗.消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然. RabbitMQ 是由 Erlang 语言开发,安装 RabbitMQ 服务需要先安装 Erlang 语言包. 二.如何与 Spring 集成 1. 我们都需要哪些 Jar 包? 抛开单独使用 Spring 的包不说,