SpringBoot之RabbitMQ的使用方法

　　

　　

RabbitMQ是消息中间件的一种,消息中间件即分布式系统中完成消息的发送和接收的基础软件,消息中间件的工作过程可以用生产者消费者模型来表示,即生产者不断的向消息队列发送信息,而消费者从消息队列中消费信息。具体过程如下:

　　

　　

从上图可看的出,对于消息队列来说,生产者,消息队列,消费者是最重要的三个概念,生产者发消息到消息队列中去,消费者监听指定的消息队列,并且当消息队列收到消息之后,接收消息队列传来的消息,并且给予相应的处理。消息队列常用于分布式系统之间互相信息的传递。

　　

对于RabbitMQ来说,除了这三个基本模块以外,还添加了一个模块,即交换机(交流)。它使得生产者和消息队列之间产生了隔离,生产者将消息发送给交换机,而交换机则根据调度策略把相应的消息转发给对应的消息队列。

　　

交换机的主要作用是接收相应的消息并且绑定到指定的队列。交换机有四种类型,分别为直接、话题,头,分列。

　　

直接是RabbitMQ默认的交换机模式,也是最简单的模式,即创建消息队列的时候,指定一个BindingKey。当发送者发送消息的时候,指定对应的关键。当关键和消息队列的BindingKey一致的时候,消息将会被发送到该消息队列中。

　　

话题转发信息主要是依据通配符,队列和交换机的绑定主要是依据一种模式(通配符+字符串),而当发送消息的时候,只有指定的关键和该模式相匹配的时候,消息才会被发送到该消息队列中。

　　

头也是根据一个规则进行匹配,在消息队列和交换机绑定的时候会指定一组键值对规则,而发送消息的时候也会指定一组键值对规则,当两组键值对规则相匹配的时候,消息会被发送到匹配的消息队列中。

　　

扇出是路由广播的形式,将会把消息发给绑定它的全部队列,即便设置了钥匙,也会被忽略。

　　

　　

SpringBoot整合RabbitMQ非常简单,首先还是pom.xml引入依赖。

　　 　　 　　& lt; dependency> 　　& lt; groupId> org.springframework.boot 　　& lt; artifactId> spring-boot-starter-amqp 　　& lt;/dependency> 　　 　　

在application.properties中配置RabbitMQ相关的信息,并首先启动了RabbitMQ实例,并创建两个队列。

　　

　　 　　 　　spring.application.name=spirng-boot-rabbitmq 　　spring.rabbitmq.host=127.0.0.1 　　spring.rabbitmq.port=5672 　　spring.rabbitmq.username=admin 　　spring.rabbitmq.password=admin 　　 　　

配置队列(消息队列),由于采用的是直接模式,需要在配置队列的时候指定一个键,使其和交换机绑定。

　　 　　 　　@ configuration 　　公开课RabbitConfig { 　　 　　@ bean 　　公共org.springframework.amqp.core。队列的队列(){ 　　 　　返回新org.springframework.amqp.core.Queue (“hello”); 　　 　　} 　　} 　　 　　

接着就可以发送消息啦。在SpringBoot中,我们使用AmqpTemplate去发送消息。代码如下:

　　 　　 　　@ component 　　公开课HelloSender { 　　 　　@ autowired 　　私人AmqpTemplate rabbitTemplate; 　　 　　公共空间发送(int指数){ 　　 　　字符串内容=澳愫枚恿小?指数+新日期(); 　　system . out。println(“发件人:”+上下文); 　　this.rabbitTemplate。convertAndSend (“hello”、上下文); 　　} 　　} 　　 　　

生产者发送消息之后就需要消费者接收消息。这里定义了两个消息消费者,用来模拟生产者与消费者一对多的关系。

　　 　　 　　@ component 　　@RabbitListener(队列=澳愫谩? 　　公开课HelloReceiver { 　　 　　@RabbitHandler 　　公共空间过程(字符串你好){ 　　system . out。println (“Receiver1:“+你好); 　　} 　　} 　　@ component 　　@RabbitListener(队列=澳愫谩? 　　公开课HelloReceiver2 { 　　 　　@RabbitHandler 　　公共空间过程(字符串你好){ 　　system . out。println (“Receiver2:“+你好); 　　} 　　} 　　 　　

在单元测试中模拟发送消息,批量发送10条消息,两个接收者分别接收了5条消息。

　　 　　 　　@ autowired 　　私人HelloSender HelloSender; 　　@Test 　　公共空间hello()抛出异常{ 　　(int i=0; i

SpringBoot之RabbitMQ的使用方法