一、安装RabbitMQ

使用docker安装部署RabbitMQ server

拉取docekr镜像

    #注意：tag后缀为management的代表有web管理界面
    
    docker pull docker.io/rabbitmq:3.8.3-management

创建容器

    docker run -d --hostname my-rabbitmq \
     -p 15672:15672 -p 5672:5672 \
     -v /home/docker/rabbitmq/homedir:/var/lib/rabbitmq \
     -v /home/docker/rabbitmq/config/rabbitmq.config:/etc/rabbitmq/rabbitmq.config \
     -v /home/docker/rabbitmq/database:/var/lib/rabbitmq/mnesia/rabbit@my-rabbit \
     --name my-rabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin \
     docker.io/rabbitmq:rabbitmq:3.8.3-management
  • 注意:15672端口是RabitMQ的web管理页面访问端口，5672是AMQP协议连接端口

rabbitMQ容器启动后即可访问http://ip:15672 进入web管理页面

二、springboot整合RabbitMQ

添加pom依赖

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    
    <dependency>
        <groupId>org.springframework.amqp</groupId>
        <artifactId>spring-rabbit-test</artifactId>
        <scope>test</scope>
    </dependency>

配置application.yml

server:
  port: 8888
spring:
  #项目名
  application:
    name: rabbitmq-demo
  #rabbitMq 配置
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: admin
    password: admin
    virtual-host: /


order:
  fanout:
    exchange: order.fanout.exchange  #定义交换机
    queue: order.fanlout.queue   #定义队列

创建消息生产者

赞 赏