当前位置: 首页 > wzjs >正文

成人高考和函授有什么区别网站优化排名首页

成人高考和函授有什么区别,网站优化排名首页,用wordpress建的网站,成都网站优化平台目录 SpringAMQP是什么 为什么采用SpringAMQP SpringAMQP应用 准备springBoot工程 实现消息发送 SpringAMQP是什么 Spring AMQP是Spring框架下用于简化AMQP(高级消息队列协议)应用开发的一套工具集,主要针对RabbitMQ等消息中间件的集成…

目录

SpringAMQP是什么

为什么采用SpringAMQP

SpringAMQP应用

准备springBoot工程

实现消息发送


SpringAMQP是什么

Spring AMQP是Spring框架下用于简化AMQP(高级消息队列协议)应用开发的一套工具集,主要针对RabbitMQ等消息中间件的集成。它提供了基于模板的消息发送和接收方法(如AmqpTemplate),以及用于配置和管理交换机、队列及其绑定关系的机制。通过Spring AMQP,开发者可以方便地将消息队列功能整合到Spring项目中。

为什么采用SpringAMQP

将来我们开发业务功能的时候,肯定不会在控制台收发消息,而是应该基于编程的方式。RabbitMQ官方提供的Java客户端编码相对复杂,一般生产环境下我们更多会结合Spring来使用。而Spring的官方刚好基于RabbitMQ提供了这样一套消息收发的模板工具:SpringAMQP。并且还基于SpringBoot对其实现了自动装配,使用起来非常方便。

SpringAMQP提供了三个功能:

1.自动声明队列、交换机及其绑定关系

2.基于注解的监听器模式,异步接收消息

3.封装了RabbitTemplate工具,用于发送消息

SpringAMQP应用

准备springBoot工程

新建一个springboot工程,包括三部分:

  • mq-demo:父工程,管理项目依赖

  • publisher:消息的发送者

  • consumer:消息的消费者

工程目录如图所示:

pom.xml文件导入依赖:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>cn.itcast.demo</groupId><artifactId>mq-demo</artifactId><version>1.0-SNAPSHOT</version><modules><module>publisher</module><module>consumer</module></modules><packaging>pom</packaging><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.12</version><relativePath/></parent><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target></properties><dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><!--AMQP依赖,包含RabbitMQ--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><!--单元测试--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId></dependency></dependencies>
</project>

如此,子工程中就可以直接使用SpringAMQP。

实现消息发送

首先配置MQ地址,在publisher服务的application.yml和consumer服务的application.yml中添加配置:

spring:rabbitmq:host: 192.168.12.101 # 你的虚拟机IPport: 5672 # 端口virtual-host: /user # 你的虚拟主机username: user # 用户名password: 123 # 密码

然后在publisher服务中编写测试类SpringAmqpTest,并利用RabbitTemplate实现消息发送:

@SpringBootTest
class SpringAmqpTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testSimpleQueue() {// 队列名称String queueName = "hello.queue";// 消息String message = "hello rabbitmq";// 发送消息rabbitTemplate.convertAndSend(queueName, message);}
}

运行后,打开控制台,可以看到消息已经发送到队列中:

当然,我们可以在consumer服务的consumer.listener包中新建一个类SpringRabbitListener来接收,代码如下:

@Component
@Slf4j
public class SpringRabbitListener {@RabbitListener(queues = "hello.queue")public void listenSimpleQueue(String msg) {log.info("消费者收到消息:{}", msg);}
}

启动ConsumerApplication,控制台显示如下:

解读:实现SpringAMQP对RabbitMQ的消息收发的测试。

http://www.dtcms.com/wzjs/516508.html

相关文章:

  • 做app推广上哪些网站吗专业seo公司
  • 手机wap网站多少钱外链seo招聘
  • 网站推广策划公司网上教育培训机构
  • 商城网站建设流程郑州专业网站建设公司
  • 台式服务器怎么做网站推广资源seo
  • 如何在电脑上做网站谷歌google浏览器官方下载
  • 旅游景点网站设计百度网盘官方
  • 广州培训做网站网站网络优化外包
  • 公司网站建设费入账外贸谷歌推广
  • wordpress qq聊天seo外链工具软件
  • 网站建设专员工作总结seo在线诊断工具
  • 朔州做网站的公司谷歌浏览器在线入口
  • 新型网络平台代理加盟抖音搜索seo
  • 动态网站开发工具长沙百家号seo
  • 高端定制网站公司哪家好如何提高网站的自然排名
  • 教新手做网站难吗手机百度2020最新版
  • 东莞专业做淘宝网站建设关键词优化的发展趋势
  • 《网站建设验收报告》游戏推广赚佣金的平台
  • 东网站建设酒店推广渠道有哪些
  • 河南宝盈建设工程有限公司网站世界球队最新排名
  • 个人博客网站制作流程网上营销
  • 网站建设一般需要什么软件企业网站推广外包
  • 网站建设建网站年轻的母亲岳阳网站建设推广
  • 嘉禾专业网站建设外包公司
  • 校园网站推广方案怎么做整合营销经典案例
  • asp政府单位网站源码程序针对大学生推广引流
  • 电影网站怎么做的推广赚钱一个2元
  • 网站维护中 页面网站一般需要怎么推广
  • 介绍自己的做的网站吗公司全网推广
  • 做网站找不到客户网站建设技术外包