RocketMQ 过滤消息 基于tag过滤和SQL过滤
RocketMQ 过滤消息分为两种，一种tag过滤，另外一种是复杂的sql过滤。
tag过滤
首先创建producer然后启动，在这里创建了字符串的数组tags。字符串数组里面放置了多个字符串，然后去发送15条消息。
15条消息随着i的增长，然后取模做了一个哈希，值是0 1 2。要么是taga，要么是tagb，或者tagc。也就是topic TagFilterTest 里面的每条消息都会有一个tag。
15条消息会从taga到c。前面三条是 Tag A B C，到了第四条开始也是从A开始，第五条B，第六条C。
上面就是将15条消息打上tag然后发送过去。
消费者创建了consumer，消费者也去订阅这个主题。consumer会从这个主题上面去进行消费。
和之前消费者不同的地方在于"TagA || TagC" 这里写上了tag过滤的表达式。也就是消费者会去订阅这个主题里面标签为taga和tagc这样的消息，消费者是可以收到的。
这个过滤是在broker端还是消费端？
如果是broker端进行过滤的，那么会将a和c直接发给消费者，tagb是不会发送的。
如果是消费端过滤，那么会将所有的消息发给消费者，消费者收到所有消息的时候，那么会去消费a和c，那么b就不消费了。
消费者这里只消费了10条消息，可以看到消息带着的标签。只有a c是收到的，b是没有收到的。
实际上是broker过滤这些消息，broker将一些消费者需要的消息发送过去。其实也就是broker将消息已经过滤了。
这样来说，消费者的性能是得到了保证，这样就不需要在消费者这端再做一次消息的过滤。而是broker将已经过滤好的消息推送给你，你直接消费就行了。
tag过滤的限制，限制是⼀条消息只能有⼀个 标签，这可能不适⽤于复杂的场景。在这种情况下，您可以使⽤ SQL 表达式来过滤掉消息。
使⽤SQL过滤
msg对象创建之后，在发送之前做了一件事情，叫做msg.putUserProperty。也就是它存放着用户属性，这个属性是我们定义的属性。这个属性是一对键值对，可以放任意的键和任意的值，
之后往msg对象里面放入了键和值。每条消息有个键叫做a，创建了15个消息，每个消息键a对应的值都是不一样的。m1 a 0，m2 a 1，m3 a 2。这样的消息就会发送给broker。
很显然现在要去过滤a的键它的值是什么样的范畴。
消费者这边去订阅主题，同时消费者这边加上了一句话，意思就是tag不能是空的，并且tag是在a和b之间的。并且后面还带上了逻辑a属性不能为空。消费者其实是去消费TagA和TagB，并且0-3之间消息消费到。
要想现在实现这个效果，在broker里面配置加上下面配置，然后重启broker即可，那么sql的消息过滤就可以实现了
相关文章：
RocketMQ 过滤消息 基于tag过滤和SQL过滤
RocketMQ 过滤消息分为两种，一种tag过滤，另外一种是复杂的sql过滤。 tag过滤 首先创建producer然后启动，在这里创建了字符串的数组tags。字符串数组里面放置了多个字符串，然后去发送15条消息。 15条消息随着i的增长，…...
AI开发： 知识图谱的初识，学会制作知识图谱- Python 机器学习
一、知识图谱的概念 知识图谱是一个通过图结构来表示和组织知识的工具，它将事物、概念和它们之间的关系以图的形式呈现出来，图中的节点代表实体（比如人物、地点、事件等），而边代表这些实体之间的各种关系（…...
不能编辑可能是这个原因)
windows系统的环境变量(系统变量)不能编辑可能是这个原因
有些电脑从开始菜单那搜索“环境变量”后是没法编辑系统变量的，只能从设置里面进”环境变量“来进行编辑。 可以观察到系统环境变量即便是点击到了,但还是无法进行编辑...
各种服务器使用 yum 安装 nginx
1. 在Red Hat Enterprise Linux (RHEL) 及其衍生版本（如CentOS, Oracle Linux, Rocky Linux, AlmaLinux）上安装Nginx的步骤如下： 安装前提条件 首先，确保系统已安装yum-utils工具，这将有助于管理软件包和仓库&#x…...
基于BesselJ函数，构建AI中的卷积神经网络之新型卷积核
原创：daode3056(daode1212) BesselJ函数,来自微分方程： 它有通解有以下形式： 就取J0--J5的函数图像，如下： 现取J1(x),也就是红色的这支，作新的函数： 这一函数的导数与不定积分如下：…...
容器镜像仓库
文章目录 1、docker hub1_注册2_登录3_创建容器镜像仓库4_在本地登录Docker Hub5_上传容器镜像6_下载容器镜像 2、harbor1_获取 docker compose二进制文件2_获取harbor安装文件3_获取TLS文件4_修改配置文件5_执行预备脚本6_执行安装脚本7_验证运行情况8_访问harborUI界面9_harb…...
qtcanpool 知 08：Docking
文章目录 前言口味改造后语 前言 很久以前，作者用 Qt 仿照前端 UI 设计了一个 ministack（https://gitee.com/icanpool/qtcanpool/blob/release-1.x/src/libs/qcanpool/ministack.h） 控件，这个控件可以折叠。部分用户体验后&#…...
车载VR可视化解决方案
车载VR可视化解决方案是通过融合跟踪用户头部运动的特殊预测算法与惯性测量数据而开发的。该系统将大范围虚拟现实跟踪技术与IMU传感器相结合，为VR和AR应用打造了一套全面的运动跟踪与渲染流程，极大地方便了虚拟现实头显制造商定制可视化流程。 该车载VR…...
)
hhdb数据库介绍(10-43)
安全 密码安全管理 密码安全管理为用户提供了对计算节点数据库用户与存储节点的连接用户、备份用户的密码有效期监控提醒。到期后自动提示用户修改密码以提升系统的安全性。 数据库用户密码 （一）密码修改 用户可以在“安全->密码安全管理->数据…...
【优选算法 二分查找】二分查找入门详解：二分查找 ＆ 在排序数组中查找元素的第一个和最后一个位置
二分查找 题目描述 题目解析 暴力解法 我们可以从左往右遍历一次数组，如果存在 target 则返回数组的下标，否则返回 -1； 时间复杂度 O(N)，因为没有利用数组有序的特点，每次比较只能舍弃一个要比较的数&…...
Python导入moviepy找不到editor 视频没有声音设置audio_codec参数
moviepy合成视频出错： 问题一：导入moviepy.editor找不到editor，No module named moviepy.editor问题二：合成的视频没有声音 问题一：导入moviepy.editor找不到editor，No module named moviepy.editor from …...
FreeSWITCH auto-rtp-bugs 研究
还在探索中... 抓一个现场的包， Fs 收 rtp 包正常，但 发 rtp 包有问题，比如上次 ts 是 1 万 ，而这次是 1000，并且居然没有 marker。百思不得解。 vars.xml 增加一个全局变量的配置： <X-PRE-PROCESS …...
TypeScript 在 React 中的应用
文章目录 前言一、为什么要在 React 中使用 TypeScript？二、如何在React中使用 TypeScript三、高级类型结语 前言 随着前端开发的复杂度不断提升，开发者对于代码质量、可维护性和开发效率的要求也日益增高。TypeScript 作为一种为 JavaScript 添加静态类…...
汇编和C语言访问存储器
一、汇编语言访问存储器 1、读存储器 LDR R1, [R2] 2、写存储器 STR R1, [R2] 二、C语言访问存储器 1、读存储器 data *ADDR; 2、写存储器 *ADDR data;...
14.3、特洛伊木马分析与防护
目录 特洛伊木马概念与分类特洛伊木马运行机制特洛伊木马植入技术特洛伊木马隐藏技术特洛伊木马存活技术特洛伊木马防范技术Rootkit是什么? 特洛伊木马概念与分类 病毒不具备传播能力，但是蠕虫具备 特洛伊木马运行机制 木马攻击过程主要分为五个部分: ① 寻找攻…...
SpringBoot 分层解耦
从没有分层思想到传统 Web 分层，再到 Spring Boot 分层架构 1. 没有分层思想 在最初的项目开发中，很多开发者并没有明确的分层思想，所有逻辑都堆砌在一个类或一个方法中。这样的开发方式通常会导致以下问题： 代码混乱࿱…...
--icon图标系列之svg)
不一样的CSS(4)--icon图标系列之svg
序言 上一节内容我们讲解了如何利用css去画一个五角星，其中包括了使用svg的方法，有些小伙伴们对svg的使用不是很了解，那么本节内容我们主要来讲一下，关于svg标签的的使用。 目录 序言一、svg的介绍二、安装SVG扩展插件三、SVG基…...
Go-知识依赖管理2
Go-知识依赖管理2 1. go.sum1.1 go.sum 文件记录1.2 生成1.3 校验1.4 校验和数据库2. 模块代理2.1 GOPROXY 介绍2.2 代理协议2.2.1 获取模块列表2.2.2 获取模块元素数据2.2.3 获取 go.mod 文件2.2.4 获取代码压缩包2.2.5 获取模块的最新可用版本2.2.6 下载过程2.3 观察下载步骤…...
el-select的搜索功能
el-select的相关信息： 最基本信息 v-model的值为当前被选中的el-option的 value 属性值 :label是选择器可以看到的内容 过滤搜索 普通过滤搜索 <el-selectv-model"selectedCountry"placeholder"请选择国家"filterable:loading"lo…...
批量将不同的工作簿合并到同一个Excel文件
批量将不同的工作簿合并到同一个Excel文件 下面是一个示例，展示如何批量将不同的工作簿合并到同一个Excel文件，并生成模拟数据。我们将使用 Python 的 pandas 库来完成这个任务。具体步骤如下： 步骤 1: 安装必要的库 首先确保你已安装 pan…...
git遇见冲突怎么解决？
问： 回答：...
Spring和SpringBoot的关系和区别？
大家好，我是锋哥。今天分享关于【Spring和SpringBoot的关系和区别？】面试题。希望对大家有帮助； Spring和SpringBoot的关系和区别？ 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 Spring和Spring Boot是两种相关但有所…...
python学习——字符串的编码和解码
在Python中，字符串的编码和解码是处理文本数据时非常重要的概念。以下是对字符串编码和解码的详细解释： 字符串编码 字符串编码是将字符串转换成字节序列的过程。Python中的字符串是Unicode编码的，所以在将字符串转换成字节序列时ÿ…...
Web游戏开发指南：在 Phaser.js 中读取和管理游戏手柄输入
前言 Phaser.js 是一个广受欢迎的 HTML5 游戏框架，为开发者提供了创建跨平台 2D 游戏的强大工具。在现代游戏开发中，支持游戏手柄已成为提升玩家体验的重要方面。本文将详细介绍如何在 Phaser.js 中监听和处理游戏手柄的输入，帮助开发者为他…...
HTML5系列（13）-- 微数据与结构化数据指南
前端技术探索系列：HTML5 微数据与结构化数据指南 📊 致读者：探索数据语义化的世界 👋 前端开发者们， 今天我们将深入探讨 HTML5 微数据与结构化数据，学习如何让网页内容更易被搜索引擎理解和解析。 微数…...
MAA ADB问题
模拟器官方MUMU12 连接设置 | MaaAssistantArknights 参考文档，找谷歌platform ADB，放入MAA文件夹 选择谷歌ADB，选择MUMU12的ADB代码 MuMu 模拟器 12 127.0.0.1:16384 重新连接 ok...
基于VTX356语音识别合成芯片的智能语音交互闹钟方案
一、方案概述 本方案旨在利用VTX356语音识别合成芯片强大的语音处理能力，结合蓝牙功能、APP或小程序，打造一款功能全面且智能化程度高的闹钟产品。除了基本的时钟显示和闹钟提醒功能外，还拥有正计时、倒计时、日程安排、重要日提醒以及番茄钟…...
大语言模型应用开发框架LangChain
大语言模型应用开发框架LangChain 一、LangChain项目介绍1、简介2、LangChain的价值3、实战演练 二、LangChain提示词大语言模型应用1、简介1.1、提示词模板化的优点1.2、提示词模板LLM 的应用1.3、Prompt 2、应用实战2.1、PromptTemplate LLM2.2、PromptTemplate LLM Outpu…...
php7.4安装pg扩展-contos7
今天接到一个需求，就是需要用thinkphp6链接pg(postgresql)数据库。废话不多说，直接上操作步骤 一、安装依赖 yum install -y sqlite-devel libxml2 libxml2-devel openssl openssl-devel bzip2 bzip2-devel libcurl libcurl-devel libjpeg libjpeg-dev…...
【开源】A064—基于JAVA的民族婚纱预定系统的设计与实现
🙊作者简介：在校研究生，拥有计算机专业的研究生开发团队，分享技术代码帮助学生学习，独立完成自己的网站项目。 代码可以查看项目链接获取⬇️，记得注明来意哦~🌹 赠送计算机毕业设计600个选题ex…...
网络安全防护指南：筑牢网络安全防线（5/10）
一、网络安全的基本概念 （一）网络的定义 网络是指由计算机或者其他信息终端及相关设备组成的按照一定的规则和程序对信息收集、存储、传输、交换、处理的系统。在当今数字化时代，网络已经成为人们生活和工作中不可或缺的一部分。它连接了世…...
集合框架（2）List
Collection的子接口：List、Set 1、List接口 鉴于Java中数组用来存储数据的局限性，我们通常使用java.util.List替代数组List集合类中元素有序、且可重复，集合中的每个元素都有其对应的顺序索引。JDK API中List接口的实现类常用的有ÿ…...
12.5作业
1.完成指针的练习 1.已知数组a[10]和b[10]中元素的值递增有序，用指针实现将两个数组中的元素按递增的顺序输出。 ex: int arr[5]{1,3,5,7,9}; int arr1[5]{2,4,6,8,10}; 程序结束后输出1，2，3，4，5，6&am…...
61 基于单片机的小车雷达避障及阈值可调
所有仿真详情导航： PROTEUS专栏说明-CSDN博客 目录 一、主要功能 二、硬件资源 三、主程序编程 四、资源下载 一、主要功能 基于51单片机，采用超声波传感器检测距离，通过LCD1602显示屏显示，三个按键，第一个按键是…...
116. UE5 GAS RPG 实现击杀掉落战利品功能
这一篇，我们实现敌人被击败后，掉落战利品的功能。首先，我们将创建一个新的结构体，用于定义掉落体的内容，方便我们设置掉落物。然后，我们实现敌人死亡时的掉落函数，并在蓝图里实现对应的逻辑&…...
原子类相关
原子引用 JUC 并发包提供了： AtomicReferenceAtomicMarkableReferenceAtomicStampedReference AtomicReference 使用举例 public interface DecimalAccount {// 获取余额BigDecimal getBalance();// 取款void withdraw(BigDecimal amount);/*** 方法内会启动 10…...
DeCoOp: Robust Prompt Tuning with Out-of-Distribution Detection
文章汇总 me：看得很迷糊 新型检测器 M D \mathcal M_D MD的训练是为了对一个子基类去划分子基类中的base和new。 在获得每个子基类之后，为每个检测器训练子分类器 M C \mathcal M_C MC 在推理时，如果最高得分的检测器 M D i ( x ) \ma…...
Tinker热修复框架详解：Android应用补丁生成，提升应用稳定性
Tinker 是腾讯开源的Android热修复框架，通过动态更新和修复应用中的代码、资源和本地库文件，无需用户重新安装 APK，便可以及时修复应用中的 bug，优化用户体验。 下面是Tinker在Android项目中的详细用法，结合Kotlin 代…...
手写—— netty 实现 rabbitMq客户端
要使用 Netty 实现一个 RabbitMQ 客户端，你可以将 RabbitMQ 协议封装在 Netty 中，通过自定义编码和解码来实现与 RabbitMQ 的通信。RabbitMQ 使用 AMQP (Advanced Message Queuing Protocol) 协议，因此我们需要创建合适的协议封装和处理逻辑。…...
调用高德地图天气查询api
之前使用的api一直用不了，才发现web端类型的没有天气查询功能 web服务才有 然后在linux的环境变量中配置一下 发现linux中配的环境变量不行，于是给输入amap_weather给的字典明文token。 # 选用RolePlay 配置agent from modelscope_agent.agents.role_p…...
【Vulkan入门】03-创建Device
目录 先叨叨git信息关键代码VulkanEnv::CreateDevice() 编译并运行程序题外话 先叨叨 在上篇已经选择了一个合适的PhysicalDevice。 本篇要为这个PhysicalDevice创将一个Device。Device可以理解为APP与PhysicalDevice之间的代理。 所有APP与PhysicalDevice之间交互的资源都通过…...
【Axios】如何在Vue中使用Axios请求拦截器
✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯，先赞后看哦~🎈🎈 🏆 作者简介：景天科技苑 🏆《头衔》：大厂架构师，华为云开发者社区专家博主，…...
query did not return a unique result: 2；
文章目录 错误原因分析关键位置可能原因解决方法1. 检查数据库数据2. 修改查询方法3. 限定查询返回唯一结果4. 检查业务逻辑 总结 1、LoginLogRepository2、LoginLogService3、LoginLogApiService4、MyAuthenticationSuccessHandler 微信小程序开发者工具控制台报错 {"tim…...
PHP升级
PHP升级CentOs8 wget http://rpms.famillecollet.com/enterprise/remi-release-8.rpm rpm -ivh remi-release-8.rpm --nodeps --force rpm -qa | grep remi dnf module list php dnf module enable php:remi-7.4首先，重置当前的 PHP 模块，以便清理所有已…...
C++设计模式（原型、代理、适配器、组合）
一、原型模式 1.定义 用原型实例指定创建对象的种类，并且通过拷贝这些原型创建新的对象。 原型模式允许通过复制现有的对象来创建新对象，而不是通过实例化类来创建。这种方式可以避免创建重复的对象，从而提高性能和降低内存消耗。 2.组成 …...
超详细搭建PhpStorm+PhpStudy开发环境
刚开始接触PHP开发，搭建开发环境是第一步，网上下载PhpStorm和PhpStudy软件，怎样安装和激活就不详细说了，我们重点来看一看怎样搭配这两个开发环境。 前提：现在假设你已经安装完PhpStorm和PhpStudy软件。 我的PhpStor…...
Axure RP在智慧农场可视化大屏系统设计中的应用
随着科技的飞速发展，智慧农业已成为现代农业的重要发展方向。智慧农场可视化大屏系统作为智慧农业的重要组成部分，正逐步成为农场管理、决策和展示的核心工具。Axure RP，作为一款强大的原型设计工具，其在智慧农场可视化大屏系统的…...
《嵌入式硬件设计》
一、引言 嵌入式系统在现代科技中占据着至关重要的地位，广泛应用于消费电子、工业控制、汽车电子、医疗设备等众多领域。嵌入式硬件设计作为嵌入式系统开发的基础，直接决定了系统的性能、可靠性和成本。本文将深入探讨嵌入式硬件设计的各个方面ÿ…...
【C语言篇】C 语言总复习（上）：点亮编程思维，穿越代码的浩瀚星河
我的个人主页 我的专栏：C语言，希望能帮助到大家！！！点赞❤ 收藏❤ 在计算机科学的广袤宇宙中，C语言犹如一颗璀璨的恒星，散发着持久而耀眼的光芒。它作为一种基础且强大的编程语言，承载…...
多线程——04
本节目标 1. wait 和 notify 方法 2. 代码案例 1. wait 和 notify 方法 1. 方法使用 多个线程的执行顺序本身是随机的（抢占式执行） wait —— 让指定线程进入阻塞状态 notify —— 唤醒对应的阻塞状态的线程 注意： wait, notify, notifyAl…...