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

(0)

相关推荐

  • 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

  • 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 rabb

  • docker一键安装wordpress的方法步骤

    安装环境: centos 7 准备工作: 安装docker和docker-compose 最近想把闲置的域名使用起来, 于是想搭建个人博客,也为简书的博客留个副本,本来想通过hexo在GitHub托管静态博客, 后来发现静态博客的局限性很大,但 最终还是选择了wordpress wordpress是一套很成熟的建站工具, 有完善的后台, 丰富的扩展, 而且有手机app供你随时发布文章, 几年前, 我在树莓派搭建过wordpress的网站, 当时花了整整一天才把wordpress完全搞定 但现在毕

  • Docker安装FastDFS的方法步骤

    拉取镜像 docker pull season/fastdfs:1.2 启动Tracker docker run -ti -d --name trakcer -v /opt/fastdfs/tracker_data:/fastdfs/tracker/data --net=host season/fastdfs:1.2 tracker 启动Storage 注意替换{ipaddress} docker run -ti -d --name storage -v /opt/fastdfs/storage

  • docker搭建fastdfs环境的方法步骤

    fastdfs是一个开源的分布式文件系统,在实际使用中,通过源码编译安装过程非常复杂,但是通过docker快速构建却非常容易.下面介绍通过docker安装fastdfs的方法. docker镜像的选择也挺重要的,我最开始选择season/fastdfs,发现有些麻烦,有的版本好像带nginx比如1.2,有的版本又不带nginx比如latest.我使用season/fastdfs镜像安装没有成功过,但是使用delron/fastdfs镜像就成功了,而且只需要启动两个容器,一个tracker,一个s

  • docker启动Java程序的方法步骤

    创建一个简单的Spring boot web项目 idea工具创建Spring boot web项目,因为是测试,一直next就行. 写一个test API,用来访问,服务端口号可以不用改,我本地改成8701. 程序启动,发现程序不是默认的8080端口了,访问:http://localhost:8701/v1/hello 以上一个简单web项目建好了,下面我们通过docker来运行这个demo项目 第一步,你需要安装docker(这里不做详细步骤). 第二步,我们需要一个有java环境docke

  • Gogs+Jenkins+Docker 自动化部署.NetCore的方法步骤

    环境说明 腾讯云轻量服务器, 配置 1c 2g 6mb ,系统是 ubuntu 20.14,Docker 和 Jenkins 都在这台服务器上面, 群晖218+一台,Gogs 在这台服务器上. Docker安装 卸载旧的 Docker sudo apt-get remove docker docker-engine docker.io containerd runc 更新 apt 包索引并安装包以允许 apt 通过 HTTPS 使用存储库 sudo apt-get update sudo apt

  • 使用Docker构建开发环境的方法步骤( Windows和mac)

    目录 1. 使用 Docker 的好处 2. 安装 Docker 1) Linux 安装 Docker 2) Windows 10 3) macOS 3. Docker 换源 1) Linux 换源 2) Windows 和 Mac 换源 4. 编写 Dockerfile 5. 编写 docker-compose.yml 6. 启动容器 7. 总结 我们在开发中都会遇到这样的问题:在本地开发好功能后,部署到服务器,或者其他人拉到本地接着开发时,会出现功能无法使用的情况. 这些异常情况,大多数时候

  • Linux环境下使用Docker搭建Jenkins容器的方法步骤

    目录 需要提前准备的条件 Step1:安装Jenkins镜像 Step2:docker启动Jenkins容器 Step3:访问Jenkins Step4:安装Jenkins插件 需要提前准备的条件 Maven环境 Docker环境 JDK环境(Centos8 自带JDK环境去除,重装的JDK) Step1:安装Jenkins镜像 用docker查询jenkins镜像 docker search jenkins 我们选择下载第二个,jenkins/jenkins,下载命令 docker pull

  • CentOS 7下用yum快速安装MongoDB的方法教程

    前言 MongoDB 是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的.MongoDB是深受广大开源爱好者支持和研究的NoSQL数据库之一,它基于灵活的JSON文档方式,非常适合敏捷开发,其高可用功能强大,支持水平扩展等众多关键特性.一如其简约而不简单的MySQL一样,安装起来也非常方便,支持源码编译安装,rpm安装以及yum安装等众多方式.本文主要讲述在CentOS 7下用yum方式快速安装MongoDB的方法,下面来一起看看吧. 一.安装环境及配置

  • Python3安装Scrapy的方法步骤

    本文介绍了Python3安装Scrapy的方法步骤,分享给大家,具体如下: 运行平台:Windows Python版本:Python3.x IDE:Sublime text3 一.Scrapy简介 Scrapy是一个为了爬取网站数据提取结构性数据而编写的应用框架,可以应用于数据挖掘,信息处理或存储历史数据等一些列的程序中.Scrapy最初就是为了网络爬取而设计的.现在,Scrapy已经推出了曾承诺过的Python3.x版本. 为什么学习Scrapy呢?它能我们更好的完成爬虫任务,自己写Pytho

随机推荐