05、SpringBoot 集成 RocketMQ

目录

  • SpringBoot集成RocketMQ
    • 消息发送三种方式
      • 1、同步消息
        • producer-springboot
          • 创建项目
          • 添加依赖
          • 配置文件
          • 同步消息发送代码
          • 启动类
          • Test类
        • comsumer-springboot
          • 创建项目
          • 添加依赖
          • 配置文件
          • 同步消息消费代码
      • 2、异步消息
        • 生产者
        • 消费者
      • 3、一次性消息
        • 生产者
        • 消费者
    • 消息消费两种方式
      • 1、集群模式
        • 生产者:
        • 消费者:
      • 2、广播模式
        • 生产者
        • 消费者
    • 顺序消息
      • 生产者
        • 问题:
      • 消费者:
    • 延迟消息
      • 生产者:
      • 消费者:
    • 消息过滤
      • 1、Tag标签过滤
        • 生产者:
        • 消费者:
      • 2、SQL92过滤
        • 生产者:
        • 消费者:
    • 消费状态

SpringBoot集成RocketMQ

消息发送三种方式

1、同步消息

producer-springboot
创建项目

也是创建一个maven项目,添加对应的依赖就是boot项目了

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

添加依赖

在这里插入图片描述

    <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.14.RELEASE</version><relativePath/></parent><properties><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.4</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>
配置文件

application.properties

在这里插入图片描述

同步消息发送代码
启动类

在这里插入图片描述

Test类

因为没有用web来启动,所以我们来写个测试类就可以了

在这里插入图片描述

效果:已经成功发送消息到消息中间件

在这里插入图片描述
在这里插入图片描述

comsumer-springboot
创建项目

在这里插入图片描述

在这里插入图片描述

添加依赖

和生产者的依赖差不多

在这里插入图片描述

配置文件

只需要nameserver地址就可以,知道去哪里消费

在这里插入图片描述

同步消息消费代码

在这里插入图片描述

2、异步消息

生产者

在这里插入图片描述

消费者

消费者代码没变化,正常消费

在这里插入图片描述

3、一次性消息

生产者

就是调用方法而已,没有什么区别
在这里插入图片描述

消费者

都是同样的消费代码,不需要改变

在这里插入图片描述

消息消费两种方式

1、集群模式

开两个消费启动

在这里插入图片描述

在这里插入图片描述

生产者:

在这里插入图片描述

消费者:

集群模式的每个消费者,均衡分配消息进行消费

在这里插入图片描述
均衡分配

在这里插入图片描述

在这里插入图片描述

2、广播模式

每个消费者都能消费到同样的所有消息

生产者

在这里插入图片描述

消费者

在这里插入图片描述

顺序消息

加点基础数据

在这里插入图片描述

在这里插入图片描述

生产者

在这里插入图片描述

问题:

在这里插入图片描述

解答:

执行rocketMQTemplate.sendOneWayOrderly()这个发送消息的方法的时候,才会调用到这个rocketMQTemplate.setMessageQueueSelector()这个setxxx方法。

在这里插入图片描述

消费者:

注解上加个顺序消费的参数就可以了

在这里插入图片描述

多个结果都是按顺序消费的====创建–付款–完成–推送

在这里插入图片描述

延迟消息

生产者:

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

消费者:

在这里插入图片描述

如图:

第一次需要创建topic需要时间,所以假设延迟10秒,第一条消费的时间,因为要创建topic,所以会大于10秒,后面的其他消息就会稳定在10秒。

经自己测试,后面的其他延迟消息,会上下浮动1秒。

在这里插入图片描述

消息转string的其他方法,试下有没有用,没有用

在这里插入图片描述
在这里插入图片描述

消息过滤

1、Tag标签过滤

生产者:

在这里插入图片描述
在这里插入图片描述

消费者:

在这里插入图片描述

在这里插入图片描述

2、SQL92过滤

生产者:

在这里插入图片描述
在这里插入图片描述

消费者:

在这里插入图片描述

消费状态

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/108194.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

windows应用程序告警:帐户名与安全标识间无任何映射完成

目录 一、问题现象 二、问题解决 &#xff08;一&#xff09;官方方法 &#xff08;二&#xff09;问题定位 &#xff08;三&#xff09;问题处理 一、问题现象 今天巡检域控服务器时&#xff0c;发现告警如下&#xff1a; 安全策略已传播&#xff0c;但有警告信息。 0x534…

网络代理技术与安全防护

随着互联网的蓬勃发展&#xff0c;网络安全问题日益凸显&#xff0c;而网络代理技术作为一种重要的保障手段&#xff0c;正发挥着越来越关键的作用。本文将深入探讨Socks5代理、IP代理以及它们在网络安全防护、爬虫应用和HTTP传输中的实际应用。 Socks5代理与SK5代理&#xff…

LETCODE_2356_每位教师所教授的科目种类的数量

--2356. 每位教师所教授的科目种类的数量 --表: Teacher -- --------------------- --| Column Name | Type | --------------------- --| teacher_id | int | --| subject_id | int | --| dept_id | int | --------------------- --在 SQL 中&#xff0c;(subject_id…

21.Hadoop在Windows环境下的下载安装配置超详细版

Hadoop在Windows环境下的下载安装配置超详细版 本文章所需下载安装软件&#xff1a; 链接&#xff1a;https://pan.baidu.com/s/1jIQyy0VHuPvQZ8-n_Zq0pg?pwd1017 hadoop的Windows化安装步骤是非常麻烦的&#xff0c;如果有一步出错将导致得充头从来。 环境配置 前置依赖1&…

苏东坡在元丰五年

北宋神宗元丰二年&#xff08;1079年&#xff09;十二月二十八日&#xff0c;震惊朝野上下的“乌台诗案” 正式结案&#xff1a;“祠部员外郎、直史馆苏轼责授检校水部员外郎、黄州团练副使&#xff0c;本州安置、不得签书公事&#xff0c;令御史台差人转押前去。” 元丰三年&…

【排序】各类排序文章汇总

文章目录 C 库自带的排序 - qsort希尔排序 - shells sort C 库自带的排序 - qsort https://blog.csdn.net/yujianliam/article/details/122254586 希尔排序 - shell’s sort

外卖大数据案例

一、环境要求 HadoopHiveSparkHBase 开发环境。 二、数据描述 meituan_waimai_meishi.csv 是某外卖平台的部分外卖 SPU&#xff08;Standard Product Unit &#xff0c; 标准产品单元&#xff09;数据&#xff0c;包含了外卖平台某地区一时间的外卖信息。具体字段说明如下&am…

医院陪诊小程序:改善患者体验的技术创新

在数字化时代&#xff0c;医疗领域也迎来了革命性的变革。医院陪诊小程序作为这场变革的一部分&#xff0c;为患者和家属提供了前所未有的便捷和支持。这篇文章将探讨医院陪诊小程序的技术实现&#xff0c;以及如何使用代码来创建一个基本的医院陪诊小程序。 什么是医院陪诊小…

Archive Team: The Twitter Stream Grab

该集合不再更新&#xff0c;应被视为静态数据集。 从一般 Twitter 流中抓取的 JSON 的简单集合&#xff0c;用于研究、历史、测试和记忆的目的。这是“Spritzer”版本&#xff0c;最轻、最浅的 Twitter 抓取。不幸的是&#xff0c;我们目前无法访问流的洒水器或花园软管版本。 …

讲解嵌入式软件中超时机制设计

软件超时机制 1、背景 在嵌入式软件程序设计过程中中&#xff0c;经常会遇到超时&#xff08;或定时&#xff09;的处理情况&#xff0c;基本处理思想是在时间到的时候进行相关程序处理&#xff0c;下面介绍两种超时&#xff08;或定时&#xff09;的程序设计方案。 2、方案…

计算机网络 | 应用层

计算机网络 | 应用层 计算机网络 | 应用层应用层概述网络应用模型客户/服务器模型&#xff08;Client/Server&#xff0c;C/S&#xff09;P2P模型&#xff08;Peer-to-Peer&#xff09; 域名系统&#xff08;DNS&#xff09; 参考视频&#xff1a;王道计算机考研 计算机网络 参…

用shell批量修改文件名

场景一 给这些文件都加上.png后缀 #!/bin/bash for i in *; do mv "$i" "$i.png"; done 场景二 给某些文件按某种规则重命名,如按照1,2,3,4…命名,保留原格式 注: Shell中实现整数自增的几种方法示例,此处用于声明是数字类型的declare -i必须添加,否则…

浅谈工业企业能源管理软件的应用

安科瑞 崔丽洁 摘要&#xff1a;在工业企业中&#xff0c;能源是企业正常工作的根本保障&#xff0c;同时也是工业企业成本的主要构成部分。工业企业在相应的工作和使用的能源包括水、电、气等。在过去&#xff0c;企业对能源消耗的关注度比较低&#xff0c;更多的强调安全与保…

跨境电商系统商城源码定制开发的优势与需求

随着互联网的快速发展&#xff0c;跨境电商成为了全球贸易的重要方式之一。为了满足不同企业的需求&#xff0c;跨境电商系统商城源码定制开发应运而生。这种定制开发的方式可以帮助企业打造适合自己的电商系统&#xff0c;提供个性化的功能和服务&#xff0c;迎合不断变化的市…

香港空间在http重定向https出现400状态码

在互联网的发展过程中&#xff0c;随着网络安全意识的提高&#xff0c;越来越多的网站开始采用HTTPS协议来保护用户的数据安全。而为了确保所有的HTTP访问都能重定向到HTTPS站点&#xff0c;一些问题也随之而来。 当我们访问一个使用HTTP协议的网站时&#xff0c;很多浏览器默认…

Linux安装配置MySQL详细

推荐使用 RPM 包进行 Linux 平台下的安装&#xff0c;因为 RPM 包的安装和卸载都很方便&#xff0c;通过简单的命令就可以实现 步骤 1)&#xff1a;进入官方下载页面&#xff08;MySQL :: Download MySQL Community Server&#xff09;选择要下载的包。 步骤 2)&#xff1a;下…

CUDA学习笔记4——自定义设备函数

自定义设备函数 核函数&#xff1a;__global__修饰&#xff1b;在设备中执行&#xff1b;设备函数&#xff1a;__device__修饰&#xff1b;在设备中执行&#xff1b;只能被核函数或其他设备函数调用&#xff1b;主机函数&#xff1a;__host__修饰&#xff08;可省略&#xff0…

webrtc安全性 加密方式

媒体加密与通信安全 有各种不同的做法会让实时通信软件暴露在安全隐患中。其中需要特别值得注意的是在信息传输的过程中截取未加密的媒体或者数据。这可以发生在浏览器到浏览器之间或者浏览器到服务器之间的通信过程中&#xff0c;第三方可以窃取到所有发送的数据。但是在数据加…

Kotlin笔记(二):标准函数,静态方法,延迟初始化,密封类

1. 标准函数 Kotlin的标准函数指的是Standard.kt文件中定义的函数&#xff0c;任何Kotlin代码都可以自由地调用所有的标准函数. 前面用到的let函数就算一个标准函数&#xff0c;它的主要作用就是配合?.操作符来进行辅助判空处理. 1.1 with函数 with函数接收两个参数&#xff…

Empowering Low-Light Image Enhancer through Customized Learnable Priors 论文阅读笔记

中科大、西安交大、南开大学发表在ICCV2023的论文&#xff0c;作者里有李重仪老师和中科大的Jie Huang&#xff08;ECCV2022的FEC CVPR2022的ENC和CVPR2023的ERL的一作&#xff09;喔&#xff0c;看来可能是和Jie Huang同一个课题组的&#xff0c;而且同样代码是开源的&#xf…