1小时快速上手RabbitMQ(简介及安装过程)
作者:半旧518 发布时间:2022-04-26 15:49:40
前 言
🍉 作者简介:半旧518,长跑型选手,立志坚持写10年博客,专注于java后端
☕专栏简介:深入、全面、系统的介绍消息中间件
🌰 文章简介:本文将介绍RabbitMQ,一小时快速上手RabbitMQ
1.MQ的介绍
1.1 MQ的基本概念
1.2 MQ的优缺点
下面是MQ的优缺点
1.2.1 优点1:应用解耦
考虑由订单系统与库存系统、支付系统、物流系统直接通过远程调用方式通信,模块耦合度较高的情况。
会存在问题:
(1)容错性较低。
一个库存系统出问题,通信链路断了,订单下单就失败了。
(2)可维护性低
增加x系统,需要修改订单系统的代码。再加再改,撤回也改。
引入消息中间件MQ后。订单系统作为消息生产者生产订单消息生产消息到MQ,库存、支付、物流作为消息消费者消费消息。即使库存系统出现问题,也可以在恢复以后再从MQ中消费消息,而不会导致订单失败。
扩展新的x系统,只需要x系统把MQ中的消息再消费一次即可,订单系统无需改代码。
1.2.2 优点2:异步提速
引入中间件之前,需要同步完成订单系统对其它模块的调用,即调用库存返回后调用支付,调用支付返回后调用物流。
引入中间件之后,25ms返回请求。
1.2.3 优点3:削峰填谷
引入消息中间件前,假如A系统来个秒杀活动,会寄。
引入之后,MQ就像一个大仓库,5000个请求,对MQ小意思。A系统慢慢从仓库里运货吧。
1.2.4 缺点
1.3常见的消息中间件
2.RabbitMQ的介绍与安装
2.1 RabbitMQ简介
2.2 JMS概念
2.3 RabbitMQ安装
官网地址:https://www.rabbitmq.com/
往下翻一翻,下载软件和文档。
由于只是方便学习,本文基于windows安装rabbitmq,如果使用linux推荐使用docker进行部署。
2.3.1 安装依赖环境
由于rabbitmq是基于erlang语言开发的,因此需要有erlang语言环境。
先看看官方文档中,对于erlang的版本要求说明。
https://www.rabbitmq.com/which-erlang.html
可以看到,不同版本的rabbitmq需要的erlang版本不同。这里我们使用3.11.5版的rabbitmq。因此需要的erlang版本是25.0-25.2
通过下列网址可以下载erlang25.2:https://www.erlang.org/patches/otp-25.2
选择下图中的windows installer,下载exe安装包。
点击exe文件安装即可。
配置环境变量。
cmd键入erl -version判断是否配置成功
C:\Users\24724>erl -version
Erlang (SMP,ASYNC_THREADS) (BEAM) emulator version 13.1.3
2.3.2 安装rabbitmq
下载exe安装包。
https://www.rabbitmq.com/install-windows.html
版本选用:3.11.5
双击安装。从安装目录打开cmd,
使用如下命令安装管理页面的插件
rabbitmq-plugins enable rabbitmq_management
双击bat脚本启动
这时,打开浏览器输入http://localhost:15672,账号密码默认是:guest/guest
大功告成咯!
2.4 rabbitmq管控台的使用
rabbitmq的管控台还是比较友好的,可以随便点点。这里带大家简单熟悉下。
添加用户。
添加虚拟机。
点击添加的虚拟机ittest,进入详情页面为其授权。
授权成功。
其它的您自己点点点吧,很简单。
3.RabbitMQ快速入门
3.1 需求描述
RabbitMQ有六种工作模式,先来介绍最简单的一种,实现一个helloworld。
需求如下:
图示如下。
3.2 准备工作
idea新建项目rabbitqmdemo,maven模块rabbitmq-producer,rabbitmq-consumer
在两个模块中引入依赖。
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.1.7.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
<version>2.1.8.RELEASE</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.1.7.RELEASE</version>
</dependency>
</dependencies>
3.3 生产者实现
producer下新建Producer_HelloWorld.java
。
其要实现的代码逻辑其实看着下图就会了。
代码如下。
/**
*
* 发送消息
*/
public class Producer_HelloWorld {
public static void main(String[] args) throws IOException, TimeoutException {
//1.创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
//2. 设置参数
factory.setHost("localhost");//ip 默认值 localhost
factory.setPort(5672); //端口 默认值 5672
factory.setVirtualHost("/ittest");//虚拟机 默认值/
factory.setUsername("guest");//用户名 默认 guest
factory.setPassword("guest");//密码 默认值 guest
//3. 创建连接 Connection
Connection connection = factory.newConnection();
//4. 创建Channel
Channel channel = connection.createChannel();
//5. 创建队列Queue
/*
queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
参数:
1. queue:队列名称
2. durable:是否持久化,当mq重启之后,还在
3. exclusive:
* 是否独占。只能有一个消费者监听这队列
* 当Connection关闭时,是否删除队列
*
4. autoDelete:是否自动删除。当没有Consumer时,自动删除掉
5. arguments:参数。
*/
//如果没有一个名字叫hello_world的队列,则会创建该队列,如果有则不会创建
channel.queueDeclare("hello_world",true,false,false,null);
/*
basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body)
参数:
1. exchange:交换机名称。简单模式下交换机会使用默认的 ""
2. routingKey:路由名称
3. props:配置信息
4. body:发送消息数据
*/
String body = "hello rabbitmq~~~";
//6. 发送消息
channel.basicPublish("","hello_world",null,body.getBytes());
//7.释放资源
channel.close();
connection.close();
}
}
代码运行前,guest用户的管控台是这样的,没有queue
管控台变成了这个样子
3.4 消费者实现
consumer模块新建Consumer_HelloWorld.java
。
public class Consumer_HelloWorld {
public static void main(String[] args) throws IOException, TimeoutException {
//1.创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
//2. 设置参数
factory.setHost("localhost");//ip 默认值 localhost
factory.setPort(5672); //端口 默认值 5672
factory.setVirtualHost("/ittest");//虚拟机 默认值/
factory.setUsername("guest");//用户名 默认 guest
factory.setPassword("guest");//密码 默认值 guest
//3. 创建连接 Connection
Connection connection = factory.newConnection();
//4. 创建Channel
Channel channel = connection.createChannel();
//5. 创建队列Queue
/*
queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
参数:
1. queue:队列名称
2. durable:是否持久化,当mq重启之后,还在
3. exclusive:
* 是否独占。只能有一个消费者监听这队列
* 当Connection关闭时,是否删除队列
*
4. autoDelete:是否自动删除。当没有Consumer时,自动删除掉
5. arguments:参数。
*/
//如果没有一个名字叫hello_world的队列,则会创建该队列,如果有则不会创建
channel.queueDeclare("hello_world",true,false,false,null);
/*
basicConsume(String queue, boolean autoAck, Consumer callback)
参数:
1. queue:队列名称
2. autoAck:是否自动确认
3. callback:回调对象
*/
// 接收消息
Consumer consumer = new DefaultConsumer(channel){
/*
回调方法,当收到消息后,会自动执行该方法
1. consumerTag:标识
2. envelope:获取一些信息,交换机,路由key...
3. properties:配置信息
4. body:数据
*/
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
System.out.println("consumerTag:"+consumerTag);
System.out.println("Exchange:"+envelope.getExchange());
System.out.println("RoutingKey:"+envelope.getRoutingKey());
System.out.println("properties:"+properties);
System.out.println("body:"+new String(body));
}
};
channel.basicConsume("hello_world",true,consumer);
//关闭资源?不要,因为要一直监听消息
}
}
执行结果如下,消费者成功的拿到了消息。
来源:https://blog.csdn.net/qq_41708993/article/details/128518641
猜你喜欢
- Java中有四种权限修饰符publicprotected(default)private同一个类yesyesyesyes同一个包yesyes
- 爱java 爱dota,突发奇想想用java开发dota操作最华丽的英雄之一的卡尔的技能,因为本人系小白,代码不足的地方还请包涵,有同样爱好
- 最近过年发红包拜年成为一种新的潮流,作为程序猿对算法的好奇远远要大于对红包的好奇,这里介绍一种自己想到的一种随机红包分配策略,还请大家多多指
- 一、CORS概述跨源资源共享标准通过新增一系列 HTTP 头,让服务器能声明那些来源可以通过浏览器访问该服务器上的各类资源(包括CSS、图片
- Elastic Search是一个开源的,分布式,实时搜索和分析引擎。Spring Boot为Elasticsearch及Spring Da
- 使用 DateFormat 格式化日期、时间DateFormat 也是一个抽象类,它也提供了如下几个类方法用于获取 DateFormat 对
- 写在前面关于数据结构,Java官方其实已经帮我们写好并封装起来了,在真正需要使用的时候直接调用即可,但为了更好的理解数据结构,我会按照源码的
- 前言大家好,我是bigsai,在数据结构与算法中,二叉树无论是考研、笔试都是非常高频的考点内容,在二叉树中,二叉树的遍历又是非常重要的知识点
- 写在前面注:本文章使用的 SpringBoot 版本为 2.2.4.RELEASE,其 Spring 版本为 5.2.3.RELEASE前言
- 如下所示://view重绘时回调view.getViewTreeObserver().addOnDrawListener(new OnDra
- 一、Spring-boot配置mybatis的mapper-locations解决什么问题?mapper-locations顾名思义是一个定
- 本文实例为大家分享了Java操作qq邮箱发送邮件的具体代码,供大家参考,具体内容如下今天尝试了使用QQ邮箱的POP3/IMAP/SMTP/E
- 前言为什么用动静态库我们在实际开发中,经常要使用别人已经实现好的功能,这是为了开发效率和鲁棒性(健壮性);因为那些功能都是顶尖的工程师已经写
- 本文实例为大家分享了Android实现登录注册功能的具体代码,供大家参考,具体内容如下运行环境 Android Studio总体效果图一、
- 如下所示:# ===============================================================
- 之前做过用java读取word文档,获取word文本内容。但发现docx的支持,doc就异常了。后来找了很多资料发现是解析方法不一样。首先要
- 一,网络编程中两个主要的问题一个是如何准确的定位网络上一台或多台主机,另一个就是找到主机后如何可靠高效的进行数据传输。在TCP/IP协议中I
- 相比于直线检测,直线拟合的最大特点是将所有数据只拟合出一条直线void fitLine( InputArray points, Output
- 1.初始化顺序当Java创建一个对象时,系统先为该对象的所有实例属性分配内存(前提是该类已经被加载过了),接着程序开始对这些实例属性执行初始
- 使用Mybatis的开发者,大多数都会遇到一个问题,就是要写大量的SQL在xml文件中,除了特殊的业务逻辑SQL之外,还有大量结构类似的增删