Spring 与AMQP

电玩女神 2024-04-17 15:29 74阅读 0赞

#### `一、Spring 与AMQP` ####

1.1 配置Spring支持AMQP消息

> 使用Spring AMQP前需要配置AMQP的RabbitMQ连接工厂。RabbitMQ是一个流行的开源消息代理，它实现了AMQP。Spring AMQP为RabbitMQ提供了支持，包括RabbitMQ连接工厂、模板以及Spring配置命名空间。  
>   
> 在使用它发送和接收消息之前，你需要预先安装RabbitMQ。我们可以在www.rabbitmq.com/download.html上找到安装指南。根据你所运行的OS不同，这会有所差别，所以根据环境的不同，遵循相应指南进行安装。

**配置RabbitMQ连接工厂**

> 配置RabbitMQ连接工厂最简单的方式就是使用Spring AMQP所提供的rabbit配置命名空间。为了使用这项功能，需要确保在Spring配置文件中已经声明了该模式。  
> ![在这里插入图片描述][20190828000107647.png]

**声明队列、Exchange以及binding**

<table> 
 <thead> 
  <tr> 
   <th align="left">元素</th> 
   <th align="left">作用</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">&lt;queue&gt;</td> 
   <td align="left">创建一个队列</td> 
  </tr> 
  <tr> 
   <td align="left">&lt;fanout-exchange&gt;</td> 
   <td align="left">创建一个fanout类型的Exchange</td> 
  </tr> 
  <tr> 
   <td align="left">&lt;header-exchange&gt;</td> 
   <td align="left">创建一个header类型的Exchange</td> 
  </tr> 
  <tr> 
   <td align="left">&lt;topic-exchange&gt;</td> 
   <td align="left">创建一个topic类型的Exchange</td> 
  </tr> 
  <tr> 
   <td align="left">&lt;direct-exchange&gt;</td> 
   <td align="left">创建一个direct类型的Exchange</td> 
  </tr> 
  <tr> 
   <td align="left">&lt;bindings&gt;<br>&lt;/bindings&gt;</td> 
   <td align="left">元素定义一个或多个元素的集合。元素创建Exchange和队列之间的binding</td> 
  </tr> 
 </tbody> 
</table>

> 这些配置元素要与<admin>元素一起使用。<admin>元素会创建一个RabbitMQ管理组件（administrative component），它会自动创建（如果它们在RabbitMQ代理中尚未存在的话）上述这些元素所声明的队列、Exchange以及binding。

> 例如，如果你希望声明名为spittle.alert.queue的队列，只需要在Spring配置中添加如下的两个元素即可：  
> ![在这里插入图片描述][20190828000521599.png]

1.2 使用RabbitTemplate发送消息

> 配置RabbitTemplate的最简单方式是使用rabbit命名空间的<template>元素，如下所示：  
> ![在这里插入图片描述][20190828000759594.png]

**使用RabbitTemplate来发送消息**

> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3ODcwNDIx_size_16_color_FFFFFF_t_70]

1.3 接收AMQP消息

**使用RabbitTemplate来接收消息**

> RabbitTemplate提供了多个接收信息的方法。最简单就是receive()方法，它位于消息的消费者端，对应于RabbitTemplate的send()方法。借助receive()方法，我们可以从队列中获取一个Message对象：  
> ![在这里插入图片描述][20190828001206782.png]  
> 或者，如果愿意的话，你还可以配置获取消息的默认队列，这是通过在配置模板的时候，设置queue属性实现的：  
> ![在这里插入图片描述][20190828001218753.png]  
> 这样的话，我们在调用receive()方法的时候，不需要设置任何参数就能从默认队列中获取消息了：  
> ![在这里插入图片描述][20190828001242994.png]  
> 在获取到Message对象之后，我们可能需要将它body属性中的字节数组转换为想要的对象。就像在发送的时候将领域对象转换为Message一样，将接收到的Message转换为领域对象同样非常繁琐。因此，我们可以考虑使用RabbitTemplate的receiveAndConvert()方法作为替代方案：  
> ![在这里插入图片描述][20190828001317967.png]  
> 我们还可以省略调用参数中的队列名称，这样它就会使用模板的默认队列名称：  
> ![在这里插入图片描述][20190828001329108.png]  
> receiveAndConvert()方法会使用与sendAndConvert()方法相同的消息转换器，将Message对象转换为原始的类型。  
> 调用receive()和receiveAndConvert()方法都会立即返回，如果队列中没有等待的消息时，将会得到null。这就需要我们来管理轮询（polling）以及必要的线程，实现队列的监控。

**定义消息驱动的AMQP POJO**

> 如果你想在消息驱动POJO中异步地消费使用Spittle对象，首先要解决的问题就是这个POJO本身。如下的SpittleAlertHandler扮演了这个角色：  
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3ODcwNDIx_size_16_color_FFFFFF_t_70 1]  
> 我们还需要在Spring应用上下文中将SpittleAlertHandler声明为一个bean：  
> ![在这里插入图片描述][2019082800144653.png]  
> 还需要声明一个监听器容器和监听器，当消息到达的时候，能够调用SpittleAlertHandler。  
> ![在这里插入图片描述][20190828001516856.png]

[20190828000107647.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/5d532960381e4f72bb31d1705bdc6e96.png
[20190828000521599.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/f5266949f9cf4c9ea7fa2bf1dfe53ca7.png
[20190828000759594.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/73b8a6fa2cb448f0a67066512f3dd7b8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3ODcwNDIx_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/0ca73695ed39459885f15afe46277a81.png
[20190828001206782.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/8ccd8572a18f48b28221dcf3bd722556.png
[20190828001218753.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/e25d80dab25c4d00b93cc9ddad5ba5af.png
[20190828001242994.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/f3879fa6d4cf4472bd21beb410c6210f.png
[20190828001317967.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/20b104f3bc6e44afbe0992838e398c10.png
[20190828001329108.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/09bfebf8883745b6b062c2e75bfe411f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3ODcwNDIx_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/5320855b3d504ead8dc31f265588c49f.png
[2019082800144653.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/6bf12e3b7b8e48119d9972bceb7f864e.png
[20190828001516856.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/4de58a9dc1284f328a7d30df50532ad2.png