简单介绍RabbitMQ与Spring的简单集成以及消息的发送和接收

1.因为是spring集成,第一要素在spring配置文件中新增命名空间,以及引入模式文档(就是xml里面头部那些内容)

Spring集成RabbitMQ

2.定义AMQP的连接工厂

Spring集成RabbitMQ

这里值我是写在属性配置文件中的,也可以在这里写死,不过一般写在一个 配置文件中。你怎么开心怎么来均可。

参数介绍:

id:bean的id值。

address:RabbitMQ服务器地址。默认值"localhost"。

virtual-host:虚拟主机,默认是"/"。

usernamepassword就是访问RabbitMQ服务的账户和密码了。

3.定义消息发送模板

Spring集成RabbitMQ

这个类是Spring为方便使用RabbitMQ服务,提供的一个操作模板类:org.springframework.amqp.rabbit.core.RabbitTemplate。此处配置后,在代码中即可使用该类进行消息发布,具体使用:引入该bean,注意id,是默认的类名,开头字母小写的形式

Spring集成RabbitMQ

4.定义队列和交换机(此处列出了多个类型的交换器,供参考)

Spring集成RabbitMQ

5.定义消息监听容器

Spring集成RabbitMQ

需要注意:ref="directManualListener",directManualListener这个bean类没有在配置文件中配置,而是在代码中通过注解注入

Spring集成RabbitMQ

类作为消息监听器,必须实现接口MessageListener或者是接口ChannelAwareMessageListener。

具体处理逻辑代码在onMessage中实现

public void onMessage(Message message) {}  

6.定义消息转换器,前面多出用到了这个属性。

Spring集成RabbitMQ

基本的配置到此结束!

相关文章:

  • 2022-12-23
  • 2021-07-23
  • 2022-12-23
  • 2021-08-31
  • 2021-05-12
  • 2022-01-22
  • 2021-08-23
猜你喜欢
  • 2021-04-25
  • 2021-04-23
  • 2021-08-24
  • 2022-12-23
  • 2022-12-23
相关资源
相似解决方案