【中间件】RabbitMQ入门

  

       📝个人主页：五敷有你      

 🔥系列专栏：中间件

⛺️稳中求进，晒太阳

MQ的优劣：

优势

1. 应用解耦：提升了系统容错性和可维护性
2. 异步提速：提升用户体验和系统吞吐量
3. 消峰填谷：提升系统稳定性

劣势

1. 系统可用性降低
   1. 系统引入的外部依赖越多，系统稳定性越差，一旦MQ宕机，就会对业务造成影响，如何保证MQ的高可用
2. 系统复杂度提高
   1. MQ的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是拖过MQ进行异步调用，如何保证消息没有被重复消费？怎么处理消息丢失情况？怎么保证消息传递的顺序性？
3. 一致性问题
   1. A系统处理完业务，通过MQ给B、C、D系统发送数据，如果B系统，C系统处理成功，D系统处理失败，如何保证消息数据处理的一致性。

既然MQ有优势也有劣势，那么怎么使用MQ需要满足什么条件呢？

1. 生产者不需要从消费者处获得反馈，引入消息队列之前直接调用，其接口的返回值应该为空，这才让明明下层的动作还没做，上层却当成动作做完了，继续往后走，即所谓异步成了可能
2. 容许短暂的不一致性
3. 确实是用了有效果，即解耦、提速、晓峰方面的收益，超过了加入MQ，管理MQ的成本

常见的MQ产品

RabbitMQ简介

AMQP

AMQP,即Advanced Message Queuing Protocol ,是一个网络协议，是应用层协议的一个开发标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。

RabbitMQ的基础架构

相关概念

• Broker：接收和分发消息的应用，RabbitMQ Server就是Message Broker
• Virtual host：出于多租户和安全因素的考虑，把AMQP 的基本组件划分到一个虚拟的分组中，类似于网络中的namespace概念。当多个不同的用户使用同一个RabbitMQ server提供的服务时，可以划分出多个vhost,每个用户在自己的vhost创建exchange/queue等。
• Connection：publisher/consumer和broker之间的TCP连接
• Channel：如果每一次访问RabbitMQ都建立一个Connection，在消息量大的时候建立TCP Connection的开销将是巨大的，效率也较低，Channel是在connection内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的channel进行通讯，AMQP method包含了channel id帮助客户端和message broker识别channel ,所以channel之间是完全隔离的，Channel作为轻量级的Connection极大减少了操作系统建立TCP connection的开销
• Exchange：message到达broker的第一站，根据分发规则，匹配查询表中的routing key,分发消息到queue中去，常用的类型有：direct,topic,
• Queue：消息最终被送到这里等待consumer被取走
• Binding：exchange 和 queue 之间的虚拟连接，binding中可以包含routing key 。Binding信息被保存到exchange中的查询表中，用于message的分发依据

RabbitMQ的6中工作模式

JMS

• JMS,即Java消息服务(JavaMessage Service) 应用程序接口，是一个Java平台中关于面向中间件的API
• JMS是JavaEE规范的一种，类似JDBC
• 很多中间件都实现类JMS规范.

快速入门

这个直接通过队列进行通信的

1. 引入spring-boot-starter-amqp
2. 配置rabbitmq服务端信息

spring:rabbitmq:host: ipport: 5672virtual-host: /username: MeetRyspassword: 123456

1. 利用RabbitTemplate发送消息

@Autowired
private RabbitTemplate rabbitTemplate;@Test
void testSendMessage2Queue() {String queueName1 = "MeetRys01";String queueName2 = "MeetRys02";String msg = "hello word";rabbitTemplate.convertAndSend(queueName1, msg);rabbitTemplate.convertAndSend(queueName1,msg);}

        2.利用@RabbitListener注解声明要监听的队列

@Slf4j
@Component
public class MqListener {@RabbitListener(queues = "MeetRys01")public void listenSimpleQueue(String msg){System.out.println("消费者1收到了MeetRys01的消息：【" + msg +"】");}}