Rabbitmq---消息队列
一 . mq:message queue
消息队列的作用: 1 通信解耦 2 高峰限流
原理分析:
一开始,认证系统是强耦合的,a系统传递认证系统消息接收计算结果的过程中
1 传给认证系统
2 认证系统计算
3 返回计算结果
4 读取a系统逻辑
只要当前计算没有完成,对于认证系统来讲消耗线程资源.并存在强耦合现象
有了消息队列,每一次连接不管是生成消息还是消费消息,都有各自的逻辑与其他逻辑无关--通信解耦
通信强耦合的情况下高峰访问拒绝,达到了高峰限流的效果
二 . rabbitmq
1 rabbitmq的结构(组件)
外部: 生产者和消费者
生产者:对于消息来讲,生成消息客户端是生产者
消费者:消费消息执行消费后的逻辑的客户端是消费者
客户端可以使用各种其他技术或者语言 都不是rabbitmq自身的技术
2 rabbitmq内部组件
connection:基于底层通信逻辑的长连接
channel:基于长连接创建的;可以在一次长连接的基础上多次频繁的创建和销毁,占用资源非常少
交换机exchange 优点:并发能力高 并发稳定
客户端连接发送消息,多种情况都需要并发的发送,如果从客户端执行并发的发送逻辑,rabbitmq的并发能力就限制在了客户端
exchange基于erlang语言开发的(并发,可控制线程)
queue:rabbitmq中的队列,根据不同的情况队列可以完成不同的工作
使用场景:在项目中，将一些无需即时返回且耗时的操作提取出来，进行了异步处理，而这种异步处理的方式大大的节省了服务器的请求响应时间，从而提高了系统的吞吐量。
三 . rabbitmq的五种工作模式
1 简单模式
1 )一个生产者将消息交给默认的交换机(amqp default)
2 )交换机获取消息后交给绑定的这个生产者的队列(其中关系是通过队列名称完成的)
3 )监听当前队列的消费者获取消息,执行消费逻辑
应用场景:短信聊天
2 工作模式(资源争抢)
1 )生产者将消息交给交换机
2 )交换机交给绑定的队列
3 )队列由多个消费者同时监听,只有其中一个能获取者一条消息,形成了资源的争抢,谁的资源空闲大,争抢到的可能越大
3 发布订阅(publish/fanout)
1 )生产者扔给交换机消息
2 )交换机根据自身的类型(fanout)将会把所有消息复制同步到所有与其绑定的队列
3 )每个队列可以有一个消费者,接收消息进行消费逻辑
4 路由模式(routing/dircet)
1 )生产者还是将消息发送给交换机,消息携带具体的路由key(routingkey)
2 )交换机类型direct,将接受到消息中的routingkey与之绑定队列的routingkey比对
3 )消费者监听一个队列,获取消息,执行消费逻辑.
5 topic主题模式
1 )生产端发送消息,消息携带具体的路由key
2 )交换机的类型topic
3 )队列绑定交换机不在使用具体的路由key而是一个范围值
与路由模式的区别:路由模式中的queue绑定携带的具体的key值,路由细化划分,topic主题模式queue携带的key是一个范围的匹配,某一类消息的获取
四 . rabbitmq的安装及虚拟机和用户名的创建
https://www.cnblogs.com/nanlinghan/p/9960361.html
五 . springboot整合rabbitmq
整合思路:1 )配置信息 2 )配置类 (明确初始化对象,初始化一个工厂,就从工厂获取连接;生产端逻辑实现简单;) 3 )二次封装
springboot
自动配置:扫描同名,下级包
根据依赖的文件自动配置需要的内容(一旦依赖了jdbc,不配置datasource就报错)
springboot就会根据依赖的amqp自动创建连接消息队列的内部connection,封装一个对外调用的对象rabbittemplate模板对象;做生产逻辑
利用底层连接,实现异步非阻塞监听,只需要在方法上使用注解,就可以将监听内容传递给方法的参数;
1 添加依赖
<starter-amqp>简化依赖
groupid在maven库是一个具有结构的文件夹
artifactid是一整个文件夹
version是一个文件夹
org\springframework\boot\spring-boot-starter-amqp
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-amqp</artifactid>
</dependency>
2 配置文件(application.properties)
spring.rabbitmq.host=10.9.100.26
spring.rabbitmq.port=5672
spring.rabbitmq.username=easymall
spring.rabbitmq.password=123456
spring.rabbitmq.virtualhost=/easymall
3 配置文件中声明对象
内部完成各种连接channel等的封装
声明需要的队列和交换机
配置类中完成这种声明,并且交换机,队列的对象由框架维护,何时调用由业务逻辑决定;
1 package com.jt.config;
2 import org.springframework.amqp.core.binding;
3 import org.springframework.amqp.core.bindingbuilder;
4 import org.springframework.amqp.core.directexchange;
5 import org.springframework.amqp.core.queue;
6 import org.springframework.context.annotation.bean;
7 import org.springframework.context.annotation.configuration;
8 @configuration
9 public class rabbitmqconfig {
10 //路由模式做案例
11 //准备2个queue,1个路由交换机
12 //声明2个队列
13 @bean
14 public queue queue01(){
15 //org.springframework.amqp.core.
16 return new queue("springboot-q1", false);
17 }
18 @bean
19 public queue queue02(){
20 //org.springframework.amqp.core.
21 return new queue("springboot-q2", false);
22 }
23 @bean//声明交换机
24 public directexchange ex(){
25 return new directexchange("springboot-ex");
26 }
27 //声明绑定关系
28 @bean
29 public binding bind01(){
30 return bindingbuilder.
31 bind(queue01()).to(ex()).with("item.add");
32 }
33 @bean
34 public binding bind02(){
35 return bindingbuilder.
36 bind(queue02()).to(ex()).with("item.update");}}
4 编写生成者代码
编写到一个controller中,接收访问的参数,利用参数作为消息发送到交换机携带路由key
1 package com.jt.controller;
2
3 import org.springframework.amqp.rabbit.core.rabbittemplate;
4 import org.springframework.beans.factory.annotation.autowired;
5 import org.springframework.stereotype.controller;
6 import org.springframework.web.bind.annotation.requestmapping;
7 import org.springframework.web.bind.annotation.responsebody;
8
9 @controller
10 public class msgcontroller {
11 @autowired
12 private rabbittemplate rabbit;
13 /*
14 * 接收消息msg
15 */
16 @requestmapping("msg")
17 @responsebody
18 public string sendmsg(string msg,string routingkey){
19 //注入自动配置的rabbittemplate对象发送消息
20 rabbit.convertandsend("springboot-ex", routingkey, msg);
21 return "success";
22 }
23 }
5 消费端
2个消费者,监听2个队列,发送的不同路由key会在不同的消费端完成消费逻辑
1 package com.jt.component;
2
3 import org.springframework.amqp.rabbit.annotation.rabbitlistener;
4 import org.springframework.stereotype.component;
5 @component
6 public class consumercon {
7 //实现消费逻辑,需要完成异步监听
8 //监听注解会绑定队列的消费者和当前的方法,一旦消费者获取消息,会把消息内容传递给
9 //自定义的方法参数msg
10 @rabbitlistener(queues="springboot-q1")
11 public void process01(string msg){
12 system.out.println("消费者1接收商品新增:"+msg);
13 }
14
15 @rabbitlistener(queues="springboot-q2")
16 public void process02(string msg){
17 system.out.println("消费者2接收到商品更新:"+msg);
18 }
19 }