互联网分布式应用之RabbitMQ

发布时间：2024年01月04日

RabbitMQ

Java 是第一大编程语言和开发平台。它有助于企业降低成本、缩短开发周期、推动创新以及改善应用服务。如今全球有数百万开发人员运行着超过 51 亿个 Java 虚拟机，Java 仍是企业和开发人员的首选开发平台。
??

课程内容的介绍

1. RabbitMQ介绍安装
2. RabbitMQ交换器
3. RabbitMQ高级
??

一、RabbitMQ介绍安装

1. AMQP 简介
AMQP (Advanced Message Queuing Protocol ，高级消息队列协议）是 个线路层的协议规范，而不是 API 规范（例如 JMS ）。由于AMQP 是一个线路层协议规范，因此它天然就是跨平台的，就像 SMTP HTTP 等协议 样，只要开发者按照规范的格式发送数据，任何平台都可以通过 AMQP进行消息交互。像目前流行的 StormMQ RabbitMQ 等都实现了 AMQP。
? ?
2. RabbitMQ简介
RabbitMQ 一个实现了 AMQP 的开源消息中间件，使用高性能的 Erlang 编写。 RabbitMQ有可靠性、支持多种协议、高可用、支持消息集群以及多语言客户端等特点，在分布式系统中存储转发消息，具有不错的性能表现。
??
为什么要使用 RabbitMQ？他解决了什么问题？
现在的市面上有很多MQ可以选择，比如ActiveMQ、ZeroMQ、Appche Qpid，那问题来了为什么要选择RabbitMQ？
除了Qpid，RabbitMQ是唯一一个实现了AMQP标准的消息服务器；
可靠性，RabbitMQ的持久化支持，保证了消息的稳定性；
高并发，RabbitMQ使用了Erlang开发语言，Erlang是为电话交换机开发的语言，天生自带高并发光环，和高可用特性；
集群部署简单，正是应为Erlang使得RabbitMQ集群部署变的超级简单；
社区活跃度高，根据网上资料来看，RabbitMQ也是首选；

??

??

??

? ??

? ??
3. 消息队列基础知识
3.1 Provider
消息生产者，就是投递消息的程序。
??
3.2 Consumer
消息消费者，就是接受消息的程序。
?
3.3 非消息队列

??
3.4 使用消息队列

??
3.5 什么是队列？
队列就像存放了商品的仓库或者商店，是生产商品的工厂和购买商品的用户之间的中转站。
? ?
3.6 队列里存储了什么？
在 rabbitMQ 中，信息流从你的应用程序出发，来到 Rabbitmq 的队列，所有信息可以只存储在一个队列中。队列可以存储很多信息，因为它基本上是一个无限制的缓冲区，前提是你的机器有足够的存储空间。
??
3.7 队列和应用程序的关系？
多个生产者可以将消息发送到同一个队列中，多个消息者也可以只从同一个队列接收数据。
??
4. RabbitMQ安装
因为在Linux上面直接安装RabbitMQ比较复杂，而且容易出错，所以我们通过Docker来快速的安装我们的RabbitMQ。
?
4.1 查找镜像
docker search rabbitmq:management
??

??
4.2 拉取镜像
docker pull macintoshplus/rabbitmq-management
? ?

??
4.3 查看镜像 
docker images
??

??
4.4 创建容器
docker run -d --hostname bobo01 --name rabbitmq -e RABBITMQ_DEFAULT_USER=guest -e RABBITMQ_DEFAULT_PASS=guest -p 15672:15672 -p 5672:5672 c20
??

??
4.5 查看容器
docker ps -a
??
4.6 访问测试
http://192.168.100.120:15672/

??

??
这就表示RabbitMQ安装成功并且访问成功了！
??
5.入门案例
5.1 创建项目
创建一个SpringBoot项目，并引入相关的依赖即可。 
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
    </dependencies>
??
5.2 配置文件
我们需要在application.properties中添加RabbitMQ的相关的配置信息。 
spring.application.name=rabbitmq-demo01
spring.rabbitmq.host=192.168.100.120
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

# 自定义一个属性 设置 队列的名称
mq.queue.name=hello-queue
?
5.3 队列配置文件 
package com.bobo.config;

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

@Configuration
public class QueueConfig {

    @Value("${mq.queue.name}")
    private String queueName;

    @Bean
    public Queue createQueue(){
        return new Queue(queueName);
    }
}
? ?
5.4 消费者
package com.bobo.consumer;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 消费者
 */
@Component
public class Receiver {

    /**
     * 接收消息，然后处理消息
     */
    @RabbitListener(queues = {"${mq.queue.name}"})
    public void process(String msg){
        // 处理消息
        System.out.println("recevier: " + msg);
    }
}
??
5.5 生产者 
package com.bobo.provider;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * 消息的提供者
 *
 */
@Component
public class Sender {

    @Autowired
    private AmqpTemplate template;

    @Value("${mq.queue.name}")
    private String queueName;

    /**
     * 发送消息的方法
     */
    public void send(String msg){
        // 队列名称  消息内容
        template.convertAndSend(queueName,msg);
    }

}
??
文章来源:https://blog.csdn.net/m0_52514893/article/details/135375480
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
最新文章