2个nodejs进程利用redis 实现订阅发布

1.新建文件 redis_db.js

'use strict';const redis = require('redis');
const options = {host: "127.0.0.1",port: 6379,password: "123456", // CONFIG SET requirepass "123456"
}var array = []
for(var i=0; i<3; i++){const client = redis.createClient(options)array.push(client)
}function getDB(index){if(typeof index === "number"){return array[index]}return array
}for(var key in array){const client = array[key]client.on('error', err => console.log('------ client Redis connection failed ------' + err)).on('connect', () => console.log('------ client Redis connection succeed ------'))
}module.exports = {getDB,
}

备注1:安装reids啥的就不说了

备注2:新增3个redis的连接:  [0] 是之前的;  [1] 用于sub; [2] 用于pub

如果没有多个的话,sub和pub的时候会报错 

ReplyError: ERR only (P)SUBSCRIBE / (P)UNSUBSCRIBE / QUIT allowed in this context

2.新建文件 redis_ipc.js

var redis_db = require("./redis_db.js");
const clients  = redis_db.getDB()
const client1  = clients[1]
const client2  = clients[2]function mySub(channelName, handleMessage){// 订阅指定的频道client1.subscribe(channelName, (err, channels) => {if (err) {console.error('无法订阅频道:', err);} else {// 设置每次收到新消息时调用的处理函数client1.on('message', handleMessage);}})
}function myPub(channelName, messageContent){client2.publish(channelName, messageContent, (err, reply) => {if (!err && reply === 0) {console.log(`消息 "${messageContent}" 未被任何人接收。`);} else if (!err && reply > 0) {console.log(`消息 "${messageContent}" 已成功发送给 ${reply} 个订阅者。`);} else {console.error('发送消息失败:', err);}});
}module.exports = {mySub,myPub,
}

3.新增测试代码

3.1新建文件test01.js 测试同个进程的


const redis_ipc = require('./redis_ipc.js')
function testSubPub(){const channelName = 'test_channel_1';function handleMessage(channel, message) {// 在这里编写处理收到消息后的操作console.log(`收到来自 ${channel} 通道的消息:${message}`);}redis_ipc.mySub(channelName, handleMessage)const messageContent = '{"data":{"name":"xxx","age":"18"}}';redis_ipc.myPub(channelName, messageContent)
}testSubPub()

目录如下:

执行指令:node .\test01.js

3.2新建文件test02.js test03.js 测试同个进程的

// test02.js
const redis_ipc = require('./redis_ipc.js')
function testSubPub(){const channelName = 'test_channel_1';function handleMessage(channel, message) {// 在这里编写处理收到消息后的操作console.log(`收到来自 ${channel} 通道的消息:${message}`);}redis_ipc.mySub(channelName, handleMessage)// const messageContent = '{"data":{"name":"xxx","age":"18"}}';// redis_ipc.myPub(channelName, messageContent)
}testSubPub()
test03.js
const redis_ipc = require('./redis_ipc.js')
function testSubPub(){const channelName = 'test_channel_1';// function handleMessage(channel, message) {//     // 在这里编写处理收到消息后的操作//     console.log(`收到来自 ${channel} 通道的消息:${message}`);// }// redis_ipc.mySub(channelName, handleMessage)const messageContent = '{"data":{"name":"xxx","age":"18"}}';redis_ipc.myPub(channelName, messageContent)
}testSubPub()

订阅者:先在一个终端执行 node .\test02.js 

发布者:再在一个终端执行 node .\test03.js

观察第一个终端 会收到 发布者的消息

4.大功告成

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

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

相关文章

git 使用场景 cherry-pick 其他代码仓库代码

Cherry-pick 其他代码库代码 1. git remote add target gitgithub.xxxxxx/testGit.git 1. 添加了一个远程仓库target 2. git fetch target 2. 远程代码抓取到本地 3. git log target/master 3. …

MySQL数据库的CURD、常见函数及UNION和UNION ALL

一、概述 MySQL是一种流行的关系型数据库管理系统&#xff0c;广泛应用于各种应用场景。在MySQL中&#xff0c;CURD操作是指创建&#xff08;Create&#xff09;、读取&#xff08;Read&#xff09;、更新&#xff08;Update&#xff09;和删除&#xff08;Delete&#xff09;…

安装extiverse/mercury时报错

问题描述 作者在安装 Flarum 的插件 extiverse/mercury 时报错&#xff0c;内容如下图所示 解决方案 ⚠警告&#xff1a;请备份所有数据再进行接下来的操作&#xff0c;此操作可能会导致网站不可用&#xff01; 报错原因&#xff1a;主要问题是在安装过程中解决依赖关系。具…

CentOS 9 (stream) 安装 Docker

1. Docker 简介 Docker 是一个开源的容器化平台&#xff0c;可帮助开发者轻松地创建、部署和运行应用程序。Docker 使开发人员能够在一个独立的容器中打包应用程序及其依赖项&#xff0c;这样他们就可以轻松地将应用程序移植到任何其他环境中。 Docker 主要由以下几个组件组成…

使用CentOS 7.6搭建HTTP隧道代理服务器

在现代网络环境中&#xff0c;HTTP隧道代理服务器因其灵活性和安全性而受到广泛关注。CentOS 7.6&#xff0c;作为一个稳定且功能强大的Linux发行版&#xff0c;为搭建此类服务器提供了坚实的基础。 首先&#xff0c;我们需要明确HTTP隧道代理的基本原理。HTTP隧道代理允许客户…

安科瑞变电站综合自动化系统在青岛海洋科技园应用——安科瑞 顾烊宇

摘 要&#xff1a;变电站综合自动化系统是将变电站内的二次设备经过功能的组合和优化设计&#xff0c;利用先进的计算机技术、通信技术、信号处理技术&#xff0c;实现对全变电站的主要设备和输、配电线路的自动监视、测量、控制、保护、并与上级调度通信的综合性自动化功能。 …

HarmonyOS应用开发之DevEco Studio安装与初次使用

1、DevEco Studio介绍 DevEco Studio是基于IntelliJ IDEA Community开源版本打造&#xff0c;面向华为终端全场景多设备的一站式集成开发环境&#xff08;IDE&#xff09;&#xff0c;为开发者提供工程模板创建、开发、编译、调试、发布等E2E的HarmonyOS应用/服务的开发工具。…

Python爬虫抓包常见问题解决

对于Python爬虫和Fiddler抓包&#xff0c;可能遇到的问题及解决&#xff1a; 代理设置错误&#xff1a;如果你在使用Python爬虫时遇到抓不到包的问题&#xff0c;首先应该检查你的浏览器代理设置是否正确。以Chrome为例&#xff0c;代理设置为&#xff1a;右上角菜单按钮>设…

剧本杀小程序/APP搭建,增加玩家游戏体验

近年来&#xff0c;剧本杀游戏成为了年轻人娱乐的新方式&#xff0c;受到了年轻人的追捧。 剧本杀是一种新型的社交游戏&#xff0c;在游戏中&#xff0c;玩家不仅可以进行角色扮演&#xff0c;也能够交到好友&#xff0c;符合当下年轻人的生活模式。 小程序、app是当下剧本杀…

读书之unix环境高级编程_简单笔记2(初步)

手头有比较多的技术书籍&#xff0c;弃之可惜&#xff0c;放之惭愧&#xff0c;借助空闲时间&#xff0c;先草读&#xff0c;再demo整理。 unix环境高级编程 草读简单整理&#xff0c;为下一步整理细节技术点做准备。 &#xff08;仅个人笔记&#xff09; 15&#xff1a;进程…

idea 社区版 Database Navigator插件 列显示顺序错乱解决办法

idea 社区版 Database Navigator插件 列显示顺序错乱 影响&#xff1a;MyBatisCodeHelperPro插件生成代码字段顺序错乱 解决办法&#xff1a;将COLUMN 的排序方式由Name改为Position方式之后&#xff0c;reload即可&#xff01;

base zhixi mode, redo example on local standyalone PC

ref url: https://modelscope.cn/models/ZJUNLP/DeepKE-LLM/summary Linux增大Swap分区&#xff0c;增加虚拟内存&#xff0c;以解决内存不足等问题_增大swapfile能缓解内存不足吗-CSDN博客 Add Local visual RAM 100G: ##增加虚拟内存 mkdir /data/VisualRAM cd VisualRAM…

第一次使用缓存,因为没预热,翻车了

△Hollis, 一个对Coding有着独特追求的人△ 这是Hollis的第 437 篇原创分享 作者 l Hollis 来源 l Hollis&#xff08;ID&#xff1a;hollischuang&#xff09; 预热一般指缓存预热&#xff0c;一般用在高并发系统中&#xff0c;为了提升系统在高并发情况下的稳定性的一种手段。…

使用fabric.js实现对图片涂鸦、文字编辑、平移缩放与保存功能

文章目录 背景1.初始化画布1.创建画布2.设置画布大小 2.渲染图片3.功能&#xff1a;开启涂鸦4.功能&#xff1a;添加文字5.旋转图片6.画布平移7.画布缩放8.保存图片9.上传图片10.销毁实例11.总结 背景 项目中有个需求&#xff0c;需要对图片附件进行简单的编辑操作&#xff0c…

实战AI大模型:构建和优化深度学习巨兽的关键技术【文末送书-15】

文章目录 前言一.模型设计1.1 硬件加速1.2 模型部署 二.模型深度和宽度的平衡2.1引入注意力机制2.1 残差连接 三.实战AI大模型【文末送书-15】3.1 粉丝福利&#xff1a;文末推荐与福利免费包邮送书&#xff01; 前言 随着人工智能领域的迅猛发展&#xff0c;大规模深度学习模型…

《3D数学基础-图形和游戏开发》阅读笔记 | 3D数学基础 (学习中 1.5更新)

文章目录 3D数学基础矢量/向量概述 - 什么是向量单位矢量&#xff1a;只关注方向不关注大小 数学运算矢量的加法与减法减法的几何意义计算一个点到另一个点的位移矢量的点积与叉积 矩阵方阵几何意义 - 表示空间坐标的变换组合变换 矩阵的乘法变换的分类 矩阵的行列式 3D数学基础…

Linux第7步_设置虚拟机的电源

设置ubuntu代码下载源和关闭“自动检查更新”后&#xff0c;就要学习设置“虚拟机的电源”了。 用处不大&#xff0c;主要是了解”螺丝刀和扳手形状的图标“在哪里。 1、打开虚拟机&#xff0c;点击最右边的“下拉按钮”&#xff0c;弹出对话框&#xff0c;得到下图&#xff…

CEEMDAN +组合预测模型(CNN-Transformer + ARIMA)

往期精彩内容&#xff1a; 时序预测&#xff1a;LSTM、ARIMA、Holt-Winters、SARIMA模型的分析与比较-CSDN博客 风速预测&#xff08;一&#xff09;数据集介绍和预处理-CSDN博客 风速预测&#xff08;二&#xff09;基于Pytorch的EMD-LSTM模型-CSDN博客 风速预测&#xff…

栈的数据结构实验报告

一、实验目的&#xff1a; 1、理解栈的定义&#xff1b; 2、利用栈处理实际问题。 二、实验内容&#xff08;实验题目与说明&#xff09; 利用栈实现数据的分类&#xff0c;将输入的整数以奇偶为标准分别存放到两个栈中&#xff0c;并最终从栈1和栈2输出偶数和奇数序列。 …

【卡梅德生物】抗体人源化在肿瘤治疗中的应用

抗体人源化&#xff1a;创新癌症治疗新纪元 抗体人源化技术的崭新应用已在肿瘤治疗领域取得显著进展&#xff0c;为创造更有效、个体化的癌症治疗方案提供了新的可能性。抗体人源化在肿瘤治疗中的应用是生物技术领域一次重要的飞跃&#xff0c;为患者带来了更加安全和精准的治…