【RabbitMQ】RabbitMQ安装与使用详解以及Spring集成

本文介绍: RabbitMQ 是一个由Erlang语言开发的 AMQP 的开源实现。 AMQP ：Advanced Message Queue，高级消息队列协议。它是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受产品、开发语言等条件的限制。 RabbitMQ 最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。1.可靠性（Reliability）。

请添加图片描述

RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现。 AMQP ：Advanced Message Queue，高级消息队列协议。它是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受产品、开发语言等条件的限制。 RabbitMQ 最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。

具体特点包括：

1.可靠性（Reliability）

RabbitMQ 使用一些机制来保证可靠性，如持久化、传输确认、发布确认。

docker pull rabbitmq:management

docker run -d 
--name my-rabbitmq 
-p 5672:5672  -p 15672:15672 
--hostname my-rabbitmq-host 
-e RABBITMQ_DEFAULT_VHOST=my_vhost 
-e RABBITMQ_DEFAULT_USER=admin 
-e RABBITMQ_DEFAULT_PASS=admin 
--restart=always 
rabbitmq:management

firewall-cmd --zone=public --add-port=5672/tcp --add-port=15672/tcp --permanent

firewall-cmd --reload

 <parent>
        <groupId>org.example</groupId>
        <artifactId>Rabbit</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>

   <!--定义子项目-->
    <modules>
        <module>produce</module>
    </modules>

server:
    port: 9999
spring:
    application:
        name: consume
rabbitmq:
    host: localhost
    username: weiwei
    password: 123456
    port: 5672
    virtual-host: my_vhost

package org.example.produce.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@SuppressWarnings("all")
public class RabbitConfig {
    @Bean
    public Queue firstQueue() {
        return new Queue("firstQueue");
    }
}

package org.example.produce.controller;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;

@RestController
public class Sender {
    @Autowired
    private AmqpTemplate rabbitTemplate;

    @RequestMapping("send01")
    public void send01() {
        rabbitTemplate.convertAndSend("firstQueue", "Hello World");
    }
}

package org.example.produce.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@SuppressWarnings("all")
@Slf4j
@RabbitListener(queues = "firstQueue")
public class Receiver {
    @RabbitHandler
    public void process(String msg) {
        log.warn("接收到:" + msg);
    }
}