使用开放的Web服务发布订阅消息传递-js教程-PHP中文网

使用开放的Web服务发布订阅消息传递

心靈之曲

发布： 2025-02-10 23:46:20

原创

751人浏览过

本文将演示如何利用eyevinn开源云提供的开放式web服务构建一个发布/订阅消息传递（pub/sub）应用程序。pub/sub是一种异步通信模型，是构建可扩展和分布式系统的重要组成部分。我们将使用valkey，一个基于eyevinn开源云的开放式web服务，来实现此功能。

使用开放的Web服务发布订阅消息传递

本教程将指导您完成以下步骤：

获取API访问令牌并设置项目
开发订阅者应用程序
开发发布者应用程序

先决条件:

一个Eyevinn开源云账户。

1. 获取API访问令牌和项目设置:

在Eyevinn开源云网络控制台中，导航到“设置/API”页面。复制API访问令牌，并将其存储在环境变量OSC_ACCESS_TOKEN中。

使用开放的Web服务发布订阅消息传递

export OSC_ACCESS_TOKEN=<access-token-copied-above>

登录后复制

创建一个Node.js项目：

mkdir pubsub
cd pubsub
npm init

登录后复制

安装必要的JavaScript客户端SDK：

npm install --save @osaas/client-core @osaas/client-services

登录后复制

2. 订阅者应用程序:

首先，创建一个名为subscriber.js的文件。以下代码设置Valkey实例，用于管理主题和消息。Valkey是一个开源的内存数据存储，其API与Redis客户端兼容。

const { context, getportsforinstance } = require('@osaas/client-core');
const {
  createvalkeyiovalkeyinstance,
  getvalkeyiovalkeyinstance
} = require('@osaas/client-services');

async function setup() {
  // ... (代码与原文相同)
}

登录后复制

setup函数返回连接到Valkey实例的Redis URL。接下来，安装Redis客户端：

杰易OA办公自动化系统6.0

基于Intranet/Internet 的Web下的办公自动化系统，采用了当今最先进的PHP技术，是综合大量用户的需求,经过充分的用户论证的基础上开发出来的，独特的即时信息、短信、电子邮件系统、完善的工作流、数据库安全备份等功能使得信息在企业内部传递效率极大提高，信息传递过程中耗费降到最低。办公人员得以从繁杂的日常办公事务处理中解放出来，参与更多的富于思考性和创造性的工作。系统力求突出体系结构简明

查看详情

npm install --save ioredis

登录后复制

在subscriber.js中添加以下代码，订阅名为“messages”的主题：

const redis = require('ioredis');

async function main() {
  // ... (代码与原文相同)
}

main();

登录后复制

运行订阅者应用程序：

node subscriber.js

登录后复制

您将看到输出“waiting for messages...”。

3. 发布者应用程序:

在一个新的终端中，创建一个名为publisher.js的文件。复制订阅者应用程序中的setup函数，并添加以下代码：

async function publishmessage(topic, message) {
  // ... (代码与原文相同)
}

if (!process.argv[2]) {
  console.error('please provide a message to publish');
  process.exit(1);
}
publishmessage('messages', process.argv[2]);

登录后复制

运行发布者应用程序，并发布一条消息：