redis 异步队列

在这里插入图片描述

//produceMessage.ts 模拟生产者
import Redis from 'ioredis';
const redis = new Redis();
// 生产者:将消息推送到队列
async function produceMessage(queueName:string, message:string) {try {await redis.rpush(queueName, message);console.log(`Produced message: ${message}`);} catch (error) {console.error('Error producing message:', error);}
}
// 例子
const queueName = 'myQueue';
for (let i = 0; i < 100; i++) {// 生产者推送消息到队列produceMessage(queueName, 'Hello, World!' +i);
}

在这里插入图片描述

// consumeMessages.ts 模拟消费者
import Redis from 'ioredis';
const redis = new Redis();// 消费者:从队列中获取消息并处理
async function consumeMessages(queueName:string) {while (true) {try {// 从队列左侧弹出一条消息const message = await redis.blpop(queueName, 0);// 0 表示无超时,一直阻塞直到有消息可用/10 表示在10秒内阻塞等待消息。if (message) {// 处理消息的逻辑console.log(`Consumed message: ${message}`);}console.log("处理完成...");} catch (error) {console.error('Error consuming message:', error);}}
}// 例子
const queueName = 'myQueue';// 消费者处理队列中的消息
consumeMessages(queueName);

Redis 多个消费者发布订阅模式

在这里插入图片描述

import Redis from 'ioredis';// 创建 Redis 客户端
const redisClient = new Redis();// 发布消息到频道
async function publishMessage(channel: string, message: string) {try {// 发布消息到指定频道await redisClient.publish(channel, message);console.log(`Message "${message}" published to channel "${channel}"`);} catch (error) {console.error('Error publishing message:', error);}
}// 例子
const channelName = 'myChannel';
const messageContent = 'Hello, Redis!';// 发布消息到频道
publishMessage(channelName, messageContent);
import Redis from 'ioredis';
const redis = new Redis();// 订阅频道的函数
async function subscribeChannel(channelName:any) {try {console.log(`Subscribing to channel ${channelName}...`);// 创建 Redis 客户端并订阅指定频道redis.subscribe(channelName);// 监听消息redis.on('message', (channel, message) => {console.log(`Received message on channel ${channel}: ${message}`);});} catch (error) {console.error('Error subscribing to channel:', error);}
}// 例子
const channelName = 'myChannel';// 创建多个订阅者
subscribeChannel(channelName);

Redis pub/sub 缺点

在这里插入图片描述
解决方式: rabbitMQ,…等专业消息队列中间键

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

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

相关文章

Unity摄像机跟随

Unity摄像机跟随 方法一&#xff1a;摄像机子物体 将摄像机直接拖拽到被跟随的目标下面即可&#xff0c;这样摄像机永远在目标的后面 缺点&#xff1a; 屏幕旋转太平滑了目标物体在屏幕上的位置永远不变目标物体被销毁时总不能把摄像机也销毁了吧 方法二&#xff1a;子物体…

19个Web前端交互式3D JavaScript框架和库

JavaScript &#xff08;JS&#xff09; 是一种轻量级的解释&#xff08;或即时编译&#xff09;编程语言&#xff0c;是世界上最流行的编程语言。JavaScript 是一种基于原型的多范式、单线程的动态语言&#xff0c;支持面向对象、命令式和声明式&#xff08;例如函数式编程&am…

从零开始手写mmo游戏从框架到爆炸(十六)— 客户端指定回调路由与登录

导航&#xff1a;从零开始手写mmo游戏从框架到爆炸&#xff08;零&#xff09;—— 导航-CSDN博客 我们这次来把注册、登录、选择英雄&#xff0c;进入主页-选择地图的功能完善。 在这之前&#xff0c;我们还要解决一个问题&#xff0c;就是服务端往客户端发消息的路由问题…

phpcms v9敏感词内容替换

后台先在"扩展"——>"敏感词管理"中添加敏感词&#xff0c;然后修改phpcms\modules\content\content.php文件来实现添加或者编辑内容时敏感词的替换。&#xff08;如果涉及会员投稿和留言等&#xff0c;也需要在对应模块中做类似处理&#xff09; 在ad…

ADO.NET实现读写分离

在 ADO.NET 中&#xff0c;分片和垂直分表的支持并不是直接提供的&#xff0c;而是需要你在应用程序设计和数据库架构中手动实现。下面是如何在 ADO.NET 中支持分片和垂直分表的一些步骤和策略&#xff1a; 分片 (Sharding) 1. 设计分片策略 首先&#xff0c;你需要设计一个…

《基于CEEMDAN-小波包分析的隧道爆破信号去噪方法》论文思路

相比于小波降噪&#xff0c;小波包分析具有更高的频率分辨率&#xff0c;可以进一步消除高频部分存在的噪声余量&#xff0c;提高去噪精度 依据EEMD 分解的取值范围&#xff0c;利用“试错法”得到本次试验中CEEMDAN分解的特征参数为&#xff1a;正负高斯白噪声标准差为0.2&a…

Linux--shell编程中有关while循环的详细内容

文章关于while循环的内容目录 一、while循环 ​​​​​​​​​​​​​​二、无限循环 ​​​​​​​​​​​​​​三、case语句 ​​​​​​​四、跳出循环 ​​​​​​​​​​​​​​五、break ​​​​​​​六、continue​​​​​​​ ​​​​​​​一、w…

Java Web(六)--XML

介绍 官网&#xff1a;XML 教程 为什么需要&#xff1a; 需求 1 : 两个程序间进行数据通信&#xff1f;需求 2 : 给一台服务器&#xff0c;做一个配置文件&#xff0c;当服务器程序启动时&#xff0c;去读取它应当监听的端口号、还有连接数据库的用户名和密码。spring 中的…

二叉树及其练习题

文章目录 树概念及结构树的概念树的相关概念树的表示形式树的应用 二叉树概念及结构概念两种特殊的二叉树二叉树的性质二叉树的存储二叉树的基本操作二叉树的遍历前中后序遍历递归实现二叉树的基本操作 二叉树相关oj题 树概念及结构 树的概念 树是一种非线性的数据结构&#…

c++:蓝桥杯中的基础算法1(枚举,双指针)

枚举 基础概念&#xff1a; 枚举&#xff08;Enum&#xff09;是一种用户定义的数据类型&#xff0c;用于定义一个有限集合的命名常量。在C中&#xff0c;枚举类型可以通过关键字enum来定义。 下面是一个简单的枚举类型的定义示例&#xff1a; #include <iostream>enum…

【面试题】谈谈MySQL的索引

索引是啥 可以把Mysql的索引看做是一本书的目录&#xff0c;当你需要快速查找某个章节在哪的时候&#xff0c;就可以利用目录&#xff0c;快速的得到某个章节的具体的页码。Mysql的索引就是为了提高查询的速度&#xff0c;但是降低了增删改的操作效率&#xff0c;也提高了空间…

数字经济概念辨析

一些常见的数字经济&#xff0c;数字金融概念辨析 博士学位点-应用经济学、统计学、工商管理、管理科学与工程 可以不懂&#xff0c;但不能装懂&#xff1b;可以不会&#xff0c;但不能不学&#xff1b;可以偷懒&#xff0c;但不能停滞。 增程式和混合动力的电动车都是混合动…

医疗在线问诊小程序:开启数字化医疗新篇章

随着科技的飞速发展&#xff0c;医疗行业正逐步向数字化转型。其中&#xff0c;医疗在线问诊小程序作为一种新型的医疗健康服务模式&#xff0c;为人们提供了更为便捷、高效的医疗咨询服务。本文将探讨医疗在线问诊小程序的发展背景、优势及应用场景&#xff0c;以期为医疗行业…

【JavaScript】模块的导入和导出

文章目录 1. 导出模块1.1 基本导出1.2 默认导出 2. 导入模块2.1 基本导入2.2 导入全部2.3 默认导入 3. 在实际项目中的应用3.1 模块化开发3.2 组织项目结构 4. 模块的导入导出语法比较4.1 命名导出4.2 默认导出 5. 总结 在现代 JavaScript 开发中&#xff0c;模块化编程是一项关…

elementUI 动态校验表单数据的方法

elementUI 动态校验表单数据的方法 直接设置如下 list 为动态获取的数据值列表数据 这里主要设置两块内容 prop为动态数据 rules设置需要校验的值 :prop“list.${index}.title” :rules“rules.title” //title 名称可自己定义 //这里主要设置两块内容 prop为动态数据 rules…

axios介绍和使用

1. Axios是什么 Axios框架全称&#xff08;ajax – I/O – system&#xff09; Axios是一个基于Promise的JavaScript HTTP客户端&#xff0c;用于浏览器和Node.js环境。它可以发送HTTP请求并支持诸如请求和响应拦截、转换数据、取消请求以及自动转换JSON数据等功能。 Axios提…

当服务器磁盘空间报警时怎么处理?

1、df -hT 查看磁盘使用情况 [rootapplication01 ~]# df -hT 文件系统 类型 容量 已用 可用 已用% 挂载点 /dev/mapper/centos-root xfs 44G 8.3G 36G 19% / devtmpfs devtmpfs 7.8G 0 7.8G 0% /dev tmpfs …

服务器防火墙的应用技术有哪些?

随着互联网的发展&#xff0c;网络安全问题更加严峻。服务器防火墙技术作为一种基础的网络安全技术&#xff0c;对于保障我们的网络安全至关重要。本文将介绍服务器防火墙的概念和作用&#xff0c;以及主要的服务器防火墙技术&#xff0c;包括数据包过滤、状态检测、代理服务、…

【HarmonyOS应用开发】三方库(二十)

三方库的基本使用 一、如何获取三方库 目前提供了两种途径获取开源三方库&#xff1a; 通过访问Gitee网站开源社区获取 在Gitee中&#xff0c;搜索OpenHarmony-TPC仓库&#xff0c;在tpc_resource中对三方库进行了资源汇总&#xff0c;可以供开发者参考。 通过OpenHarmony三…

小程序--模板语法

一、插值{{}}语法 1、内容绑定 <view>{{iptValue}}</view> 2、属性绑定 <switch checked"{{true}}" /> Page({data: {iptValue: 123} }) 二、简易双向数据绑定 model:value&#xff1a;支持双向数据绑定 注&#xff1a;仅input和textarea支持&a…