- 综合排序
- 最热优先
- 最新优先
云顾问-云护航AI Agent重塑传统订阅播报
传统订阅播报面临哪些挑战？ 传统的订阅播报，用户可通过平台提供的固定的功能界面交互，完成订阅播报。 例如在云计算资源水位情况订阅播报场景中，通常需要以下几步操作： 选择云产品以及云产品下的指标，如：CVM CPU利用率 选择指标的播报计算点，如：指标值、平均值等 选择播报渠道、播报周期，进行订阅播报 2.智能识别定制播报内容，降低定制成本 方式一：描述关注云产品、指标，AI快速生成播报内容 订阅配置-播报指标提供快速云产品、指标快捷指令，可快速描述关注的云产品、指标。 NL2MQL提升指标查询计算稳定性 NL2MQL(Natural Language to Metrics Query Language)：这种路径也是ML2SQL之上的全新探索的方向，抽象指标语义层，增强大模型对业务指标的理解与口径对齐 2.
32220编辑于 2025-06-30- 来自专栏以Java架构赢天下
设计模式之发布订阅模式(2) Redis 发布订阅模式
Redis 发布/订阅命令 Redis 通过 PUBLISH 、 SUBSCRIBE 等命令实现了发布订阅模式。该功能提供两种信息机制， 分别是“发布订阅到频道”和“发布订阅到模式”。 下面我们就演示一下 PUBLISH命令和SUBSCRIBE命令的用法： 首先是订阅单个频道： ? 然后是订阅多个频道： ? PSUBSCRIBE 模式订阅命令 ? Redis发布/订阅存储结构如下图所示： ? Spring Data Redis 实现发布/订阅模式 下面带你一步步通过 Spring Data Redis 来实现发布与订阅。 然后我们定义了两个“subscriber”，“subscriber1”订阅了“topic1”和“topic2”，“subscriber2”只订阅了“topic2”。 :Topic2 Message : 6967291d-aad4-4aa3-b44a-b988a9589700] 总结 本文从 Redis 发布和订阅相关的命令开始，逐步讲解了 Redis 发布订阅的存储结构
1.8K31发布于 2019-06-06 - 来自专栏悠扬前奏的博客
Redis-2.发布与订阅
基础 发布与订阅（pub/sub）是一种消息通信模式：发送者（pub）发送消息，订阅者（sub）接受消息。 订阅者（listener）订阅频道（channel）；发送者（publisher）向频道发送二进制字符串消息（binary string message）。 2.命令 Redis中发布于订阅的命令 命令 描述 SUBSCRIBE SUBSCRIBE channel [channel ...] ：订阅给定的一个或者多个频道 UNSUBSCRIBE UNSUBSCRIBE [channel [channel ...]] ：订阅与给定模式相匹配的所有频道 PUNSUBSCRIBE PUNSUBSCRIBE [pattern [pattern ...]]：退订给定的模式，如果没有指定模式，则退订所有模式
57630发布于 2019-06-13 - 来自专栏机器人课程与技术
ROS2与Arduino发布订阅
一个订阅发布代码如下： #include <ros2arduino.h> #define XRCEDDS_PORT Serial #define PUBLISH_FREQUENCY 1 //hz 主题 Arduino发布消息到主题ros2_chatter，并订阅主题ros2_led。 使用如下命令控制LED灯： 点亮：ros2 topic pub /ros2_led std_msgs/msg/Bool "{data: 1}" 关闭：ros2 topic pub /ros2_led std_msgs ros2cartographer参考：https://github.com/ros2/cartographer。 下面详细介绍一下如何使用ros2arduino： 必须安装ROS2，必须安装Micro-XRCE-DDS。 ROS2安装可以参考: 1.
2.4K61发布于 2019-09-27 - 来自专栏小狐狸说事
7b2美化-侧边栏添加动态播报
7b2美化-侧边栏添加动态播报 ---- 代码放到后台-小工具-自定义html 内容可以自定义 <section id="custom_html-<em>2</em>" class="widget_text widget div:first-child{animation:show 8s linear infinite}.flip-box-1-1{background-color:#FF7E40}.flip-box-1-<em>2</em>{ </div> </div><div><div class="flip-box-1-2">心情也舒畅了！
你好我也好，不要忘记哦!
Android 语音播报
MainActivity.this,"成功输出语音", // Toast.LENGTH_SHORT).show(); // Locale loc1=new Locale("us"); // Locale loc2= new Locale("china"); int result1 = tts.setLanguage(Locale.US); int result2 = tts.setLanguage(Locale.CHINESE (result1 == TextToSpeech.LANG_MISSING_DATA || result1 == TextToSpeech.LANG_NOT_SUPPORTED || result2 == TextToSpeech.LANG_MISSING_DATA || result2 == TextToSpeech.LANG_NOT_SUPPORTED) { Toast.makeText (Xueya.this, "数据丢失或不支持", Toast.LENGTH_SHORT).show(); } } } }); //在需要语音播报的地方 //tts.speak("语音播报的内容
js 语音播报
<el-button @ click = " speak " > 播放 </el-button>
Android技能树 — Rxjava取消订阅小结(2):RxLifeCycle
(1):自带方式 Android技能树 — Rxjava取消订阅小结(2):RxLifeCycle 现在很多项目都在使用Rxjava了，对于RxJava的使用，估计都很熟悉了，但是很多人在使用RxJava 和RxLifeCycle关系不大，但是可以当了解，不想看的可以跳过 1. 2 基础知识。 getObservable(){ return ((Observable) subject); } //比如你调用play方法，按照要求只能发送1，2， ((BehaviorSubject) getObservable()).onNext(99999); 复制代码 而在Rxjava 2 中只是把这个asObservable 方法改成了 hide方法而已。 2 RxLife源码解析 我们已Activity中取消订阅为例： RxActivity.java（代码说明具体查看源码里面的备注）: public abstract class RxActivity extends
7b2美化-手机菜单页底部添加滚动播报
7b2美化-手机菜单页底部添加滚动播报 ---- 以下代码放到b2/Modules/Templates/Header.php 搜索
RabbitMQ：订阅模型-消息订阅模式
---- 文章目录 一、RabbitMQ 订阅模型-消息订阅（Fanout）模式 1、RabbitMQ 消息订阅（Fanout）模式 2、消息订阅（Fanout）模式组成 3、消息订阅（Fanout）模式流程 二、RabbitMQ 订阅模型-消息订阅（Fanout）模式实现 1、添加 Maven 依赖 2、封装工具类 ConnectionUtil 3、生产者实现 4、消费者-1 实现 5、消费者-2 实现 6、消费者-3 实现 三、订阅模型 三种模式区别 1、RabbitMQ 消息订阅（Fanout）模式 2、RabbitMQ 路由（direct）模式 3、RabbitMQ 主题（topic）模式 --- 2、消息订阅（Fanout）模式组成 RabbitMQ 订阅模型-消息订阅（Fanout）模式主要有以下五个角色构成： 生产者（producer/ publisher）：一个发送消息的用户应用程序。 -消息订阅（Fanout）模式 消费者 * @date 2022-12-26 11:45 上午 **/ public class Customer2 { public static void
Springboot2使用redis 进行消息的订阅发布
我们都知道redis 也有发布订阅模式， 但是使用的比较少。 并且redis的发布订阅不会持久化落入磁盘。总的来说就是不可靠。 但是在一些场景我们还是会用到的。 这里我们就来springboot 整合一下redis 进行发布订阅。 2， 注册完监听器之后，在监听自己的适配器，里面监听自己自定义的方法 也可以实现MessageListener, 不需要指定方法。 里面也能获取到topic的名字。 2" ，咱们设置的topic 和发送的topic "test.12" 说明模糊匹配是可以的， 再试一下全量匹配。 把 "test.?2" 变成 test.* 发布的时候置顶两个。 ? ? 好了，今天的springboot整合redis 消息的发布订阅就完成了。 这里有一个问题，就是新加入的订阅者不会消费之后的数据，也不支持动态的添加topicName , 就是发布者。
RxJava2.X 源码分析（三）：订阅线程切换
本次我们将探索RxJava2.x线程切换的实现原理。做到知其然，知其所以然。 Ok，开始我们的探索之旅吧！ 从Demo到源码 本次我们将在上次的demo基础了做点改动。 ? ? 版本2:切换线程（切换操作是如此的潇洒） ? 输出结果： ? 存在版本切换的版本： 1、被观察者的onSubscribe在调用subscribe的线程中执行 2、被观察者的subscribe在RxJava2的RxCachedThreadScheduler-1中运行 所以run里面的source.subscribe(parent);即为wrapper的observer订阅了上游的observable,触发了上游observable的subscribeActual，开始执行数据的分发 装饰者模式的使用贯穿了RxJava2的各处(个人理解），再次体会了设计模式的魅力。 由于本篇过长，observeOn订阅者线程的切换就再分一篇吧。
vue2知识点：消息订阅与发布
@toc3.23消息订阅与发布3.23.1知识点总结问题：“全局事件总线”和“消息订阅与发布”都可以实现任意组件间通信，那用哪个好？ “全局事件总线”不同，取消订阅指定订阅返回的id，且每次返回的id都不同，而“全局事件总线”指定的是“自定义事件名称”注意点4：订阅回调配置一定要使用箭头函数或者外部定义方法 /font>消息订阅会接收到2个参数，第1个参数为消息名称，第2个参数才是传递过来的值，如写法1，但是实际msgName参数1他跟用不到它，所以可使用下划线“_”占个位，如写法2写法1：this.pubId .vue2知识点：动态组件17.vue2知识点：混入18.vue2知识点：浏览器本地缓存19.vue2知识点：全局事件总线（GlobalEventBus）20.vue2知识点：消息订阅与发布21.vue2 ：把案例Todo-list改成使用消息订阅与发布32.vue2基础组件通信案例练习：把案例Todo-list新增编辑按钮33.vue2基础组件通信案例练习：把案例Todo-list改成使用动画与过度34
Springboot2 整合redis发布订阅 解决订阅多个频道重复代码过多 创建很多bean问题
SEPARATOR = ","; private static final String HOST_PORT_SEPARATOR = ":"; /** * redis 发布订阅配置 ; }); log.info("subscribe end"); return container; } /** * 初始化订阅频道及处理方法适配器映射
ROS2 C++ Subscriber Publisher 订阅发布例子
文章目录 ROS2 Subscriber Publisher 例子 ROS2 Subscriber Publisher 例子 运行环境 Ubuntu 20.04 ROS Foxy sub #include << msg->data.c_str() << std::endl; } int main(int argc, char **argv) { std::cout << "Hello, ROS2 #include <std_msgs/msg/string.hpp> int main(int argc, char **argv) { std::cout << "Hello, ROS2 rclcpp::shutdown(); return 0; } CMakeLists.txt cmake_minimum_required(VERSION 3.5.1) project(ros2_
【EventBus】EventBus 源码解析 ( 注册订阅者 | 订阅方法 | 查找订阅方法 )
文章目录 一、EventBus 注册订阅者 二、订阅方法 三、查找订阅方法 findSubscriberMethods 方法 四、查找订阅方法 findUsingInfo 方法 五、查找订阅方法 findUsingReflectionInSingleClass 一、EventBus 注册订阅者 ---- EventBus 中调用 EventBus.getDefault().register(this) 注册订阅者 ; 该方法中主要进行了如下 2 个步骤 : ① 获取 订阅者 集合 , 查找当前订阅类中符合条件的订阅方法集合 ; ② 遍历 订阅者 集合 , 进行事件订阅 , 保存数据 , 这些数据就是一些映射关系 /** * EventBus是Java (subscriberClass); // 2. findSubscriberMethods 方法 ---- 订阅方法缓存机制 : 从缓存中获取 订阅方法 , METHOD_CACHE 缓存是一个 HashMap 集合 ; 如果订阅者有很多方法 ,
Redis使用及源码剖析-15.Redis发布订阅-2021-2-2
文章目录 前言 一、发布订阅命令简介 二、频道的订阅和退订 1.频道订阅 2.频道退订 2.频道退订 四、发布消息 五、Redis源码 总结 前言 本文对Redis的发布订阅功能的实现做了简单介绍，包括发布订阅命令和内部实现 一个pubsub_channels 词典的示意图如下： 2.频道退订 UNSUBSCRIBE 命令的行为和 SUBSCRIBE 命令的行为正好相反，当一个客户端退订某个或某些频道的时候， 服务器将从 2.频道退订 当有客户端退订某个模式时，服务端就会遍历pubsub_patterns链表，找到模式和客户端均匹配的pubsubPattern对象，将它从链表中移除。 // 'channel-a' : [c1, c2, c3], // 'channel-b' : [c5, c2, c1], // 'channel-c ' : [c10, c2, c1] // } /* Add the client to the channel -> list of clients hash table
通配符订阅
附录 A - 主题通配符 订阅可能包含特殊字符，允许您一次订阅多个主题。 主题级别分隔符用于将结构引入主题，因此可以为此目的在主题中指定。 多级通配符和单级通配符可用于订阅，但消息发布者不能在主题中使用。 主题级别分隔符 正斜杠 （/） 用于分隔主题树中的每个级别，并为主题空间提供分层结构。 当在订阅者指定的主题中遇到两个通配符时，使用主题级别分隔符非常重要。 多级通配符 数字符号 （#） 是与主题中任意数量的级别匹配的通配符。 例如，如果您订阅了 finance/stock/ibm/#，则会收到有关以下主题的消息： finance/stock/ibm finance/stock/ibm/closingprice
用Python实现语音播报
确保已经安装python，本例使用python，操作系统为：Windows 10 专业版； 2. 设置环境变量，设置两个path路径。 安装pywin32， Step 2: Installing pywin32 The pyttsx library/package has a dependence of pywin32,so you missing lost sys.stderr 解决如下：(参考：http://www.bubuko.com/infodetail-2089657.html) （1）右键管理员身份运行cmd命令提示符： （2）
Redis订阅模式的高级功能-同步订阅
同步订阅在Redis中，订阅频道时，客户端会一直阻塞等待消息到来。如果频道中没有消息到来，客户端将一直阻塞。这种订阅方式称为同步订阅。 =6379, db=0)r2 = redis.Redis(host='localhost', port=6379, db=0)# 发布消息的方法def publish_message(): while def subscribe_channel(): p = r2.pubsub() p.subscribe('my_channel') while True: message if __name__ == '__main__': t1 = threading.Thread(target=publish_message) t2 = threading.Thread( target=subscribe_channel) t1.start() t2.start()在上面的示例中，我们使用p.get_message(timeout=1)方法等待订阅频道中的消息
