- 综合排序
- 最热优先
- 最新优先
- 来自专栏MessageQueue
消息过滤
RocketMQ对消息过滤的支持比较完善了，通过SQL92这种方式可以满足各种复杂场景的需求了。 Kafka Kafka目前并没有支持消息过滤，即没有在Topic下提供细分的类型来区分消息。 问题分析 大致了解消息过滤的定义和业界的支持情况之后，回头再思考一下，为什么MQ需要做消息过滤、MQ的过滤应该做到什么程度（用使者需要怎么样的过滤方式呢）？ 在上面这个前提下，逆向考虑这个问题：如果MQ不支持消息过滤（这里的过滤只Topic下的消息细分）但使用方又有过滤的需求，那么会出现什么情况？或者说业务方会怎么去解决这个问题？ HashCode过滤条件的消息内容返回给Consumer Consumer反序列化消息，对比Tag值进一步确认消息是否期望数据 RocketMQ SQL92过滤 ? 总结 本文从消息过滤的问题出发，介绍了RocketMQ的过滤功能实现，分析了消息过滤的需求，然后总结了不同的多Tag功能的实现方案。
3.5K20发布于 2018-07-24 - 来自专栏一个执拗的后端搬砖工
RocketMQ消息过滤实现原理
使用过RocketMQ的小伙伴会注意到该消息组件支持Tag和Sql两种过滤模式。 tag可以理解为topic的子类型,具有某一类型细分属性的集合,sql过滤模式是使用表达式实现通过消息内容的值进行过滤。 我们本篇重点围绕tag消息的发送和消费原理展开介绍,中间涉及到sql过滤的地方会简单做分析。 2.tag消息的过滤 tag消息的过滤我们也分成两块分析,分别是订阅(过滤)关系维护和消息过滤。 消息过滤逻辑是在broker实现,从consumerQueue拉取消息的时候,触发过滤逻辑,将符合条件的tag消息拉到本地消费。
89540编辑于 2022-12-18 - 来自专栏A周立SpringCloud
Spring Cloud Stream实现消息过滤消费
本文探讨Spring Cloud Stream & RocketMQ过滤消息的各种姿势。 在实际项目中，我们可能需要实现消息消费的过滤。 举个例子：实现消息的分流处理： 生产者生产的消息，虽然消息体可能一样，但是header不一样。可编写两个或者更多的消费者，对不同header的消息做针对性的处理！ ", messageBody); } } 5 日志： 2019-08-04 19:10:03.799 INFO 53760 --- [MessageThread_1] c.i.u.rocketmq.MyTestStreamConsumer 支持使用SQL语法过滤消息。 开启SQL 92支持 默认情况下，RocketMQ的SQL过滤支持是关闭的，要想使用SQL 92过滤消息，需要： 1 在 conf/broker.conf 添加 enablePropertyFilter
2.1K10发布于 2019-08-06 - 来自专栏飞鸟的专栏
Spring Cloud Stream 高级特性-消息路由和过滤（二）
消息过滤消息过滤是指根据消息的内容或元数据，选择性地将某些消息传递给处理程序或目的地的过程。 在 Spring Cloud Stream 中，可以使用 @StreamFilter 注释和 MessageFilter 接口来实现消息过滤。 @StreamFilter 注释@StreamFilter 注释可以用于定义一个消息过滤器，它将根据消息的内容或元数据选择性地将某些消息传递给处理程序或目的地。 在 @StreamListener 注释中，我们处理输入消息，并将其传递给下一个处理程序或目的地。在 MessageFilter bean 中，我们选择性地将某些消息传递给下一个处理程序或目的地。 MessageFilter 接口MessageFilter 接口用于定义一个消息过滤器，它将根据消息的内容或元数据选择性地将某些消息传递给处理程序或目的地。
80220编辑于 2023-04-13 - 来自专栏Ray学习笔记
10SpringCloud Stream消息驱动
org.springframework.boot.autoconfigure.SpringBootApplication; /** * @Description: * @Author Ray * @Date 2020/10 * @Author Ray * @Date 2020/10/21 9:14 * @Version 1.0 */ public interface IMessageProvider { * @Author Ray * @Date 2020/10/21 9:14 * @Version 1.0 */ @EnableBinding(Source.class) //定义消息的推送管道 org.springframework.boot.autoconfigure.SpringBootApplication; /** * @Description: * @Author Ray * @Date 2020/10 import org.springframework.stereotype.Component; /** * @Description: * @Author Ray * @Date 2020/10
44140发布于 2020-11-04 - 来自专栏飞鸟的专栏
Spring Cloud Stream 高级特性-消息路由和过滤（一）
消息路由和过滤是 Spring Cloud Stream 的高级特性，它们可以帮助您更好地控制消息的流向和处理。在本文中，我们将介绍消息路由和过滤的基本概念、用途、实现方式以及示例代码。 消息路由消息路由是指根据消息的内容或元数据，将消息分发到不同的目的地或处理程序的过程。 @Router 注释@Router 注释可以用于定义一个消息路由器，它将根据消息的内容或元数据将消息路由到不同的目的地或处理程序。 在 @StreamListener 注释中，我们处理输入消息，并根据消息的内容将其路由到不同的目的地。 在这个 bean 中，我们处理输入消息，并根据消息的内容将其路由到不同的目的地。如果消息的内容以 A 开头，则将其路由到 route-to-a 目的地，否则将其路由到 route-to-b 目的地。
87140编辑于 2023-04-13 - 来自专栏NetCore 从壹开始
【BlogBook书】10、RabbitMQ：消息队列
框架中重点使用RabbitMQ和Kafka作为消息队列的中间件工具，本章节说明RabbitMQ的具体使用方式。 框架已经完整的封装了EventBus事件总线，如果想要使用更加完善的消息队列的方式，建议使用事件总线，当然也可以直接如下文进行使用。 UserName": "admin", "Password": "admin", "Port": "5672", "RetryCount": 2 }, 二、使用方式 1、在任意位置做消息的发送 "myQueue"); return Ok(); } 3、具体的代码，请参考RabbitMQPersistentConnection.cs即可 ///
/// 发布消息 ： 消费这个消息 33910编辑于 2024-02-22 - 来自专栏java架构1+1
iOS 10 消息推送（UserNotifications）秘籍总结
楼主装逼，打他 背景 iOS10 新特性一出，各个大神就早已研究新特性能给场景智能化所带来的好处（唉，可惜我只是一个小白）。我也被安排适配iOS10的推送工作！ 本文主要是针对iOS 10的消息通知做介绍，所以很多代码没有对iOS 10之前做添加适配。 服务端程序向APNS服务发送消息。 APNS服务将消息发送给iPhone应用程序。 NSLog(@"iOS10 收到远程通知:%@",userInfo); }else { // 判断为本地通知 //此处省略一万行需求代码。。。。。。 推送消息的横幅都可以展示出来！
3.5K40发布于 2019-06-19 - 来自专栏老男孩成长之路
使用消息队列的 10 个理由
消息队列降低了进程间的耦合度，所以即使一个处理消息的进程挂掉，加入队列中的消息仍然可以在系统恢复后被处理。 无论有多少进程在从队列中领取数据，每一个消息只能被处理一次。这之所以成为可能，是因为获取一个消息只是"预定"了这个消息，暂时把它移出了队列。 例如,加载一张图片比应用过滤器花费更少的时间。消息队列通过一个缓冲层来帮助任务最高效率的执行--写入队列的处理会尽可能的快速，而不受从队列读的预备处理的约束。 消息系列通过消息被处理的频率，来方便的辅助确定那些表现不佳的处理过程或领域，这些地方的数据流都不够优化。 10. 异步通信 很多时候，你不想也不需要立即处理消息。 消息队列提供了异步处理机制，允许你把一个消息放入队列，但并不立即处理它。你想向队列中放入多少消息就放多少，然后在你乐意的时候再去处理它们。
46010发布于 2020-01-15 - 来自专栏游戏开发司机
UNIX(进程间通信)：10 消息队列
一、消息队列的特点 1.消息队列是消息的链表,具有特定的格式,存放在内存中并由消息队列标识符标识. 2.消息队列允许一个或多个进程向它写入与读取消息. 3.管道和命名管道都是通信数据都是先进先出的原则 4.消息队列可以实现消息的随机查询,消息不一定要以先进先出的次序读取,也可以按消息的类型读取.比FIFO更有优势。 目前主要有两种类型的消息队列：POSIX消息队列以及系统V消息队列，系统V消息队列目前被大量使用。系统V消息队列是随内核持续的，只有在内核重起或者人工删除时，该消息队列才会被删除。 参数: msqid:消息队列ID，消息队列标识符，该值为msgget创建消息队列的返回值。 ,即向消息队列中发送一条消息。
1.3K31发布于 2021-03-04 - 来自专栏DeveWork
【译】WordPress 中的50个过滤器(2)：先介绍10个过滤器
在上一篇文章中，我们介绍了WordPress 世界的过滤器；本篇文章的话我们将要探索50个笔者精选的过滤器，并一一通过例子解释其如何工作的。 事不宜迟，让我们开始吧！ 本文为系列第二篇，原文：50 Filters of WordPress: The First 10 Filters 原文地址 本系列文章翻译自tutsplus，原作者为baris-unver，翻译人 同样的，通过“过滤”body_class()函数，你可以添加后删除相关的类。 locale 这个过滤器可以让我们在某些情况下设置语言。 借助下面找个过滤器，你可以修改它。 自定义发送人的Email 地址 <?
1.5K60发布于 2018-01-22 - 来自专栏腾讯云中间件的专栏
Apache RocketMQ 消息过滤的实现原理与腾讯云的使用实践
消息过滤的应用场景 消息过滤功能指消息生产者向 Topic 中发送消息时，设置消息属性对消息进行分类，消费者订阅 Topic 时，根据消息属性设置过滤条件对消息进行过滤，只有符合过滤条件的消息才会被投递到消费端进行消费 默认情况下，消费组1和消费组2 会全量消费 Topic 里面的所有消息。但如果我们想选择性的消费里面一些消息的时候，就可以使用消息过滤功能对消息进行区分过滤。 消息过滤原理介绍 目前消息过滤主要支持两种过滤方式，分别是 SQL 过滤和 Tag 过滤。 在过滤的时候，如果布隆过滤器判断消息不符合条件，那这条消息肯定是不符合的，就可以直接过滤掉；如果布隆过滤器判断消息符合条件，那还需要进一步做精确匹配。 腾讯云消息过滤轨迹展示 从上述消息过滤的原理介绍可以发现，如果消息被过滤掉了，用户收不到这条消息，和消息本身没有被消费的情况看起来是一样的。
61210编辑于 2025-04-04 - 来自专栏浮躁的喧嚣
对象、消息、运行期--10：runtime关联对象
在category中的使用 @property添加属性 ，不会生成带下划线的成员变量，也不会有setter和getter方法实现，所以我们通过runtime关联对象的技术为已经存在的类添加“属性”，这样我们只是实现了setter和getter方法，依然不会有带下划线的成员变量
39110编辑于 2023-11-22 - 来自专栏Java技术栈
使用消息队列（MQ）的 10 个理由！
消息队列降低了进程间的耦合度，所以即使一个处理消息的进程挂掉，加入队列中的消息仍然可以在系统恢复后被处理。 无论有多少进程在从队列中领取数据，每一个消息只能被处理一次。这之所以成为可能，是因为获取一个消息只是"预定"了这个消息，暂时把它移出了队列。 例如,加载一张图片比应用过滤器花费更少的时间。 消息队列通过一个缓冲层来帮助任务最高效率的执行--写入队列的处理会尽可能的快速，而不受从队列读的预备处理的约束。 消息系列通过消息被处理的频率，来方便的辅助确定那些表现不佳的处理过程或领域，这些地方的数据流都不够优化。 10、异步通信 很多时候，你不想也不需要立即处理消息。 消息队列提供了异步处理机制，允许你把一个消息放入队列，但并不立即处理它。你想向队列中放入多少消息就放多少，然后在你乐意的时候再去处理它们。
94030发布于 2020-12-18 - 来自专栏Java架构师必看
10.Spring-Boot中如何使用filter(过滤器)
在springboot中如何使用filter(过滤器)，其实这个现实可以用aop来实现。 今天说一说10.Spring-Boot中如何使用filter(过滤器),希望能够帮助大家进步!!! 在springboot中如何使用filter(过滤器)，其实这个现实可以用aop来实现。 org.springframework.context.annotation.Configuration; import com.niugang.filter.LogFilter; /** * 过滤器配置文件 * @author niugang *springboot启动类虎自动扫描过滤器配置文件 */ @Configuration public class FilterConfig { /** * z自定义过滤器 * @return */ @Bean public LogFilter logFilter() { return new LogFilter(); } /** *
1.4K30编辑于 2021-12-03 - 来自专栏林德熙的博客
win10 uwp 在 Grid 接收键盘消息
小伙伴问我为什么他的选中的 Grid 无法接收到键盘消息，原因是在 UWP 中只有 Control 类才可以拿到键盘焦点，而 Grid 是 Panel 没有继承 Control 类所以 Grid 无法拿到焦点 void OnKeyDown(KeyRoutedEventArgs e) { Debug.WriteLine("Foo key down"); } } 在需要接收键盘消息的 Grid 里面放这个控件 <Grid x:Name="Grid2" Margin="<em>10</em>,<em>10</em>,<em>10</em>,<em>10</em>" Width="100" Background="#565656" HorizontalAlignment Grid2_OnKeyDown"> <local:Foo x:Name="Foo"></local:Foo> </Grid> 此时在 Foo 有焦点的时候，让 Grid2 收到消息
1K20编辑于 2022-08-07 - 来自专栏攻城狮Chovas
微服务架构Day10-SpringBoot之消息
消息服务 消息服务中间件可以用来提升系统异步通信,扩展解耦能力 消息服务两个重要概念: 消息代理(message broker) 目的地(destination) 当消息发送者发送消息后,将由消息代理接管 ,消息代理保证消息传递到指定目的地 消息队列主要有两种形式的目的地: 队列(queue)-主题(topic) 队列(queue): 点对点消息通信(point-to-point) 点对点式: 消息发送者发送消息 ,消息代理将消息放入一个队列中,消息接收者从队列中获取消息内容,消息读取后被移除队列 消息只有唯一的发送者和接受者,但不是说只有一个接收者 主题(topic): 发布(publish)-订阅(subscribe 消息是不具名的,由消息头和消息体组成 消息体(数据)是不透明的,消息头由一系列可选属性组成 routing-key: 路由键 priority: 优先级 delivery-model: 是否持久性存储 是消息的容器,也是消息的终点 一个消息可以投入一个或多个队列 消息一直在队列里面,等待消费者连接到这个队列取走 Binding: 绑定 用于消息队列和交换器之间的关联 一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则
55120编辑于 2022-01-22 - 来自专栏发哥说消息队列
CMQ系列学习文章 - topic消息过滤类型使用说明（ 一 ）
二、topic消息过滤类型：标签和路由匹配 标签匹配功能说明： https://cloud.tencent.com/document/product/406/6906 创建消息过滤类型为标签的topic ，并添加了3个订阅者，分别设置了消息过滤标签 消息过滤类型为标签的topic的Demo讲解 image.png 消息过滤类型为标签的topic的Demo讲解： image.png msgTag、topicWithTag msgTag：要发送的消息内容 topicWithTag：对应的topic主题名称 tagList：你要匹配订阅者中的那个标签 image.png 路由键匹配功能说明: https://cloud.tencent.com /document/product/406/8127 创建消息过滤类型为路由匹配的topic: image.png image.png msgRoute、topicWithRoute和routingKey 和bbbb.xiaomi，所以会向 Jason1和 Jensen-queue推送消息。
98192发布于 2019-11-26 - 来自专栏腾讯云中间件的专栏
腾讯云消息队列产品10月产品动态
10月动态 消息队列 RocketMQ 版 【商业化】消息队列 RocketMQ 版专享集群正式商业化。基于开源RocketMQ打造，兼容社区SDK，具有低延迟、高性能、高可靠、万亿级消息吞吐等特点。 【新功能】新增消息验证能力，查询到特定消息后，用户可以将指定消息推送给指定的在线客户端，以检测客户端消费逻辑和结果是否符合预期等。 ★ 消息队列 RabbitMQ 版 【商业化】10月9日起，消息队列 RabbitMQ 版专享集群正式商业化。 基于开源 RabbitMQ 消息队列引擎，提供稳定可靠、高扩展性、易用免运维的消息队列服务。AMQP 协议的标杆，提供灵活的路由适应各类业务的消息投递规则。 group页面展示消费客户端优化，支持查看消息的消费状态、订阅关系一致性和过滤表达式等。 控制台支持发送测试消息。 消息队列 RabbitMQ 版 专享集群支持升配。
3.7K20编辑于 2022-11-02 - 来自专栏骤雨重山
H5 端唤醒 win10 消息通知
浏览器也可以调用Win10系统的消息提示，纯JS代码，复制到HTML网页中直接打开即可。
47320编辑于 2022-01-17
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号