SpringBoot中怎么使用RabbitMQ消息组件


这篇文章将为大家详细讲解有关SpringBoot中怎么使用RabbitMQ消息组件,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了 香港云主机解。1 在虚拟机中安装rabbitmq2 开启rabbitmq3 页面查看rabbitmq 3 rabbitmq相关知识点讲解 [1]MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表,一端往消息队列中不断写入消息,而另一端则可以读取队列中的消息。1、队列、生产者、消费者2、Exchange、Binding exchange:交换器,交换按照一定规则与对列绑定,消息才能到queue中 Binding用routing key3、Exchange Type有四种4 下面简单实现下图的结果1 创建direct类型的交换器2 创建 fanout类型的交换器 3 创建 topic类型的交换器4 创建的结果5 创建对列,以下图为例子队列创建完成6 绑定队列direct类型例子7 绑定fanout类型的例子8 绑定topic类型的例子9 测试direct类型的交换器测试结果 10 测试 fanout类型的交换器测试结果11 测试topic 类型的交换器5 在springBoot项目下使用RabbitMqpom.xml

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd">	4.0.0org.springframework.boot	spring-boot-starter-parent	2.1.6.RELEASE		com.maospring-01-amqp0.0.1-SNAPSHOTspring-01-amqpDemoprojectforSpringBoot1.8	org.springframework.boot		spring-boot-starter-amqp				org.springframework.boot		spring-boot-starter-web		org.springframework.boot		spring-boot-starter-test		test				org.springframework.boot			spring-boot-maven-plugin

applicaton.properties配置spring.rabbitmq.host=192.168.1.139spring.datasource.password=guestspring.datasource.username=guestbook实体public class book {}测试发送数据代码 @Test public void contextLoads() {下面这样就可以以json格式显示,与之前的一篇博客类似,配置自定义redis配置public class myamqpconfig { @Bean public MessageConverter messageConverter(){}使用下面的就可以收到消息@Servicepublic class BookService {关于SpringBoot中怎么使用RabbitMQ消息组件就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。

相关推荐: 使用webSocket与spring怎么实现一个应用

本篇文章给大家分享的是有关使用webSocket&…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

Like (0)
Donate 微信扫一扫 微信扫一扫
Previous 07/27 18:13
Next 07/27 18:14

相关推荐