SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

沙海
沙海
沙海
1016
文章
2
评论
2021年4月28日12:00:29
评论
2 3211字阅读10分42秒
摘要

SpringBoot项目开发(十一):RabbitMQ消息队列

SpringBoot项目开发(十一):RabbitMQ消息队列

SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

闪耀的瞬间
2018-08-09 11:40:54
SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客
2194

SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

收藏

1

分类专栏:
spring boot
java
SpringBoot 项目开发
文章标签:
rabbitmq

版权

SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客
1.为什么使用消息队列?

  • 系统解耦:在分布式环境中,可能有A、B、C、D…等多个系统,A直接调用B提供的服务接口,当A系统修改时,可能需要B也跟着修改,这样耦合性比较强。MQ可以解耦这样的场景
  • 流量销峰:在电商抢购活动中,商品可能几秒钟就被抢购完,但是系统或数据库无法在几秒内处理所有请求,大量请求或许会让数据库直接崩溃,把请求压到队列中,消费者有序的处理队列中的请求
  • 稳定性:队列有确认机制,当消费者进程异常时,也就是该消息还没有被确认消费,那么其他消费进程可再次处理该消息

2.RabbitMQ 特点

  • 可靠性:RabbitMQ 使用一些机制来保证可靠性,如持久化、传输确认、发布确认
  • 消息集群:多个 RabbitMQ 服务器可以组成一个集群,形成一个逻辑 Broker
  • 高可用:队列可以在集群中的机器上进行镜像,使得在部分节点出问题的情况下队列仍然可用。
  • 多语言客户端:RabbitMQ 几乎支持所有常用语言,比如 Java、.NET、Ruby 等
  • 管理界面:RabbitMQ 提供了一个易用的用户界面,使得用户可以监控和管理消息 Broker 的许多方面

消息默认存储在磁盘上,磁盘的处理能力是有限,对于大流量、高并发场景,RabbitMQ有内存模式,内存可以高速处理消息,但是需要磁盘模式配合,防止消息丢失,关于RabbitMQ集群方面的,请参考 RabbitMQ + Haproxy 高可用队列集群

3.RabbitMQ 中的概念模型

生产者(producer)创建消息,然后发布到队列(queue)中,消费者(consumer)订阅某个队列,最后将消息发送到监听的消费者,可以有多个消费者,消息会被平均分摊给多个消费者进行处理 SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

RabbitMQ有 4 个重要概念,分别为:虚拟主机,交换机,队列,和绑定。

  • Broker:rabbitmq队列服务器,里面可以有多个 虚拟主机 Virtual Host
  • Virtual Host:为什么需要多个虚拟主机呢?很简单,RabbitMQ当中,用户只能在虚拟主机的粒度进行权限控制。 因此,如果需要禁止A组访问B组的交换机/队列/绑定,必须为A和B分别创建一个虚拟主机。每一个RabbitMQ服务器都有一个默认的虚拟主机“/”。
  • Exchange:交换机用于转发消息,但是它不会做存储 ,如果没有 Queue bind 到 Exchange 的话,它会直接丢弃掉 Producer 发送过来的消息。

    这里有一个比较重要的概念:路由键 。消息到交换机的时候,交互机会转发到对应的队列中,那么究竟转发到哪个队列,就要根据该路由键。

  • Binding:交换机需要和绑定队列,这其中如上图所示,是多对多的关系。
  • Quene:队列
  • Connection:连接,建立一个tcp连接,使用多路复用方式提升性能,节约资源
  • Channel:信道,一个连接可以多路复用打开多个信道,获取队列中的消息

SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

RabbitMQ常用的交换机Exchange Type有四种:direct、fanout、topic、headers。

  direct:点对点模式,一对一关系,把消息投递到那些binding key与routing key完全匹配的队列中。
  fanout:广播模式,一对多关系,转发消息到所有绑定队列。
  topic:发布订阅模式,一对多关系,按规则转发消息,将消息路由到binding key与routing key模式匹配的队列中。
  headers:设置header attribute参数类型的交换机,很少用
1234

4.SrpingBoot集成 RabbitMQ

1).添加引用依赖

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
1234

2).添加配置,rabbitmq的安装地址、端口以及账户信息,没有rabbitmq环境的可以参考 RabbitMQ安装教程

spring.rabbitmq.host=192.168.68.128
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=admin
spring.rabbitmq.virtual-host=zy_host

#下面的参数待测试
#prefetch每次一次性从broker里面取的待消费的消息的个数
spring.rabbitmq.listener.simple.prefetch=5
#创建消费者的个数(并发消费)
spring.rabbitmq.listener.simple.concurrency=5
spring.rabbitmq.listener.simple.max-concurrency=10
123456789101112

3).队列配置

@Configuration
public class RabbitConfig {
    //定义一个名称为hello的队列
    @Bean
    public Queue HelloQueue(){
        return new Queue("hello");
    }
}
12345678

4).生产者,AmqpTemplate是springboot 提供的默认实现

@Component
public class HelloSender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send(String queueName, String message){
        rabbitTemplate.convertAndSend(queueName,message);
    }
}
12345678910

5).消费者,监听队列,处理消息

@Component
@RabbitListener(queues = "hello")
public class HelloReceiver {

    @RabbitHandler
    public void process(String context){
        System.out.println("Receiver : " + context);
    }
}
123456789

6).测试,生产者与消费者的queue name必须一致,不然无法接收

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitMQTest {
    @Autowired
    private HelloSender helloSender;

    @Test
    public void sendMessage(){
        helloSender.send("hello","你好,我要向队列发送消息1...");
    }
}
1234567891011

运行测试方法时,可以在rabbitmq管理后台看到,hello队列会自动创建

SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

还可以测试一对多,多对多关系,看队列是怎么消费的 多个生成者

@Test
public void sendManyMessage(){
	for (int i=0;i<5;i++){
		helloSender.send("hello","你好,我要向队列发送消息1..."+i);
		helloSender.send("hello","你好,我要向队列发送消息2..."+i);
	}
}
1234567

多个消费者,监听 hello 队列 SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

运行,查看结果:多个消费者均匀的消费多个消息 SpringBoot项目开发(十一):RabbitMQ消息队列_zhuyu19911016520-CSDN博客

本篇是抛砖引玉,介绍了一些概念和简单使用,它的高级使用,请参考下面: centos7下RabbitMQ安装教程 RabbitMQ + Haproxy 高可用队列集群 RabbitMQ 延迟队列的实现

下篇 发送邮件

继续阅读
weinxin
资源分享QQ群
本站是一个IT技术分享社区, 会经常分享资源和教程; 分享的时代, 请别再沉默!
沙海
匿名

发表评论

匿名网友 填写信息

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: