你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

WebPubSubEventHandler class

用于处理传入 CloudEvents 消息的处理程序

构造函数

WebPubSubEventHandler(string, WebPubSubEventHandlerOptions)

创建用于处理传入 CloudEvents 消息的 WebPubSubEventHandler 实例。

示例用法:

import { WebPubSubEventHandler } from "@azure/web-pubsub-express";

const endpoint = "https://xxxx.webpubsubdev.azure.com";
const handler = new WebPubSubEventHandler("chat", {
  handleConnect: (req, res) => {
    console.log(JSON.stringify(req));
    return {};
  },
  onConnected: (req) => {
    console.log(JSON.stringify(req));
  },
  handleUserEvent: (req, res) => {
    console.log(JSON.stringify(req));
    res.success("Hey " + req.data, req.dataType);
  },
  allowedEndpoints: [endpoint],
});

属性

path

CloudEvents 处理程序侦听的路径

方法

getMiddleware()

获取中间件以处理 CloudEvents 请求

构造函数详细信息

WebPubSubEventHandler(string, WebPubSubEventHandlerOptions)

创建用于处理传入 CloudEvents 消息的 WebPubSubEventHandler 实例。

示例用法:

import { WebPubSubEventHandler } from "@azure/web-pubsub-express";

const endpoint = "https://xxxx.webpubsubdev.azure.com";
const handler = new WebPubSubEventHandler("chat", {
  handleConnect: (req, res) => {
    console.log(JSON.stringify(req));
    return {};
  },
  onConnected: (req) => {
    console.log(JSON.stringify(req));
  },
  handleUserEvent: (req, res) => {
    console.log(JSON.stringify(req));
    res.success("Hey " + req.data, req.dataType);
  },
  allowedEndpoints: [endpoint],
});
new WebPubSubEventHandler(hub: string, options?: WebPubSubEventHandlerOptions)

参数

hub

string

要侦听的中心的名称

options
WebPubSubEventHandlerOptions

用于配置事件处理程序的选项

属性详细信息

path

CloudEvents 处理程序侦听的路径

path: string

属性值

string

方法详细信息

getMiddleware()

获取中间件以处理 CloudEvents 请求

function getMiddleware(): RequestHandler

返回

RequestHandler