领域模型概述

发布订阅模型 发布订阅模型具有如下特点:消费独立:相比队列模型的匿名消费方式,发布订阅模型中消费方都会具备的身份,一般叫做订阅组(订阅关系),不同订阅组之间相互独立不会相互影响。一对多通信:基于独立身份的设计,同一个主题内...

快速入门概述

队列模型 队列模型消息流 队列模型特性 队列模型基本概念 主题模型:支持一对多的发布订阅模式。主题模型 主题模型消息流 主题模型特性 主题模型基本概念 队列模型快速入门 如 队列模型快速入门流程 所示,本教程以直接在控制台发送和接收...

订阅

订阅者数据库的行为与任何其他 PostgreSQL实例相同,并且可以被用作其他数据库的发布者,只需要定义它自己的发布。如果需要,一个订阅者节点可以有多个订阅。可以在一对发布者-订阅者之间定义多个订阅,在这种情况下要确保被订阅的发布对象...

功能特性

依赖管理视图 提供对 RPC 发布订阅的实时结果,可展示不同应用之间的服务调用关系,以及应用发布和订阅的服务信息。微服务治理中心 提供一系列的服务治理策略,保障服务高质量运行,最终达到对外承诺的服务质量等级协议。服务高可用 支持...

功能特性

依赖管理视图提供对 RPC 发布订阅的实时结果,可展示不同应用之间的服务调用关系,以及应用发布和订阅的服务信息。微服务治理中心 提供一系列的服务治理策略,保障服务高质量运行,最终达到对外承诺的服务质量等级协议。服务高可用支持客户...

消息通知概述

主题模型支持一对多发布和订阅消息,旨在提供一对多的发布订阅以及消息通知功能,支持您实现一站式多种消息通知方式,主题中的一条消息可以同时被多个订阅者订阅,且按照多个订阅指定的推送方式和服务器接入地址进行消息推送,您可以从多个...

什么是消息服务MNS

主题模型 主题模型提供一对多的发布订阅模型,支持消息通知。主题就像一份报纸,多个读者到邮局订阅了这份报纸。当报纸推出最新一期时,读者(包括邮局的合作伙伴)可以选择以下方式来获取:让邮局投递员将报纸都投递(推送)到家里(特定...

ALTER SUBSCRIPTION

支持的选项有:copy_data(boolean)指定在复制启动后是否应复制正在订阅的发布中的现有数据。默认值是 true。(以前订阅的表不会被复制。ENABLE 启用先前禁用的订阅,在事务结束时启动逻辑复制工作。DISABLE 禁用正在运行的订阅,在事务结束...

应用部署

经典应用服务提供应用的发布、回滚功能,您可以对需要发布的应用编辑依赖关系、调整服务器分组,并选择部署策略等。前提条件 应用和服务器绑定,且服务器经过初始化。应用存在发布包。灰度引流功能需要应用绑定 SLB 或添加至 SLB 下的虚拟...

功能发布记录

并且覆盖iOS、Android、Windows、Mac、Electron、小程序、Web、Unity及Linux平台,各平台的发布日志及相关文档如下所示:目录 类别 发布日志 相关文档 RTC SDK iOS iOS接口 iOS回调及监听 Android Android接口 Android回调及监听 Windows ...

一键建仓

在 AnalyticDB PostgreSQL版 实例上刷新订阅的发布信息,新增的logical_tb2表即可同步至 AnalyticDB PostgreSQL版 实例。ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION;停止数据同步 RDS PostgreSQL实例上已创建发布pub1,发布中包含...

产品架构

云消息队列 Kafka 版 的发布/订阅模型 如 云消息队列 Kafka 版的发布/订阅模型 所示,云消息队列 Kafka 版 采用发布/订阅模型。图 2.云消息队列 Kafka 版 的发布/订阅模型 Group 和Topic的对应关系是N:N,即一个 Group 可以同时订阅多个...

MQ监控

ARMS应用监控的MQ监控可展示消息队列Apache RocketMQ版的Topic发布订阅消息的情况。功能入口 登录 ARMS控制台,在左侧导航栏选择 应用监控>应用列表。在 应用列表 页面顶部选择目标地域,然后单击目标应用名称。说明 语言 列显示 图标的...

一定要创建属于自己的实例吗?

不是必要的。您可以申请使用已有的实例,获得实例拥有者批准后,就可在实例上发布或者订阅服务。CSB已经推出共享实例。您开通服务后,自动拥有在共享实例上发布订阅的权限。

MQ监控

MQ监控可展示消息队列RocketMQ版的Topic发布订阅消息的情况。应用限制 EDAS标准版不支持MQ监控,专业版和铂金版支持MQ监控。功能入口 登录 EDAS控制台。在左侧导航栏,单击 应用管理>应用列表,在顶部菜单栏选择地域并在页面上方选择微...

概述

应用依赖 提供对应用 RPC 发布订阅服务的实时分析结果,可展示不同应用之间的服务调用关系,以及应用发布和订阅的服务信息。动态配置 提供应用运行时动态修改配置的服务,提供动态配置的简便接入方式与集中化管理平台,可在管理平台维护...

使用自定义Topic通信

设置是否开启代理订阅 找到 操作权限 为 订阅发布订阅 的Topic类,单击 是否开启代理订阅 开关 或。删除Topic类 警告 删除自定义Topic类后,与该自定义Topic相关的设备通信服务不可用、用户业务中断。请谨慎操作。单击Topic类对应 ...

重要参数

此时,无法正常执行任何发布订阅等操作。ERROR_CAMERA_PERMISSION-104 打开相机预览失败,相机没有正确授权。ERROR_MIC_PERMISSION-105 打开相机预览失败,麦克风没有正确授权。ERROR_OPEN_CAMERA-1007 打开相机预览失败,无法正常打开摄像...

基础术语

同时它并不假定总是用于服务发现,也可用于其他更一般发布-订阅”场景。数据 Data 在服务发现场景下,特指服务提供者的网络地址及其它附加信息。其他场景下,也可以表示任意发布到 SOFARegistry 的信息。单元 Zone 单元化架构关键概念...

逻辑复制(pglogical)

背景信息 pglogical是PostgreSQL的拓展模块,使用发布/订阅模型复制数据,使选择性复制更加高效。提供比Slony、Bucardo或Londiste更快的复制速度,支持跨版本升级。支持多场景复制,具体包括:数据库大版本升级。完整的数据库复制。利用...

什么是 SOFAStack 微服务

微服务(SOFAStack Microservices,简称 SOFAStack MS)主要提供分布式应用常用解决方案。...应用依赖 应用通过 RPC 发布订阅服务时,应用依赖可以提供实时分析结果,可展示不同应用之间的服务调用关系,以及应用发布和订阅的服务信息。

CREATE PUBLICATION

CREATE PUBLICATION 用于向当前数据库添加一个新的发布。简介 CREATE PUBLICATION 向当前数据库添加一个新的发布。发布的名称必须与当前数据库中任何现有发布的名称不同。发布本质上是一组表,其数据更改旨在通过逻辑复制进行复制。语法 ...

架构

订阅者按照数据在发布者上被提交的顺序应用数据,这样任意单一订阅的发布的事务一致性才能得到保证。逻辑复制被构建在一种类似于物理流复制的架构上。它由“walsender”和“apply”进程实现。walsender 进程开始对 WAL 的逻辑解码并且...

回调函数

发布订阅事件 void onPublishEvent(PublishConfig config,PublishEventCode eventCode,String eventDetail,FeedInfo feedInfo);发布相关事件的通知,业务调用 publish 发布接口后,相关的结果从这里通知出去。void onUnpublishEvent...

基本概念

更多信息,请参见 云消息队列 Kafka 版的发布/订阅模型。订阅关系 Topic被 Group 订阅的情况。云消息队列 Kafka 版 支持查看订阅了指定Topic的在线 Group 的情况,非在线 Group 的情况无法查看。Producer 向 云消息队列 Kafka 版 发送消息...

发起方配置

跨服务 FMT 参与者服务订阅 基于 SOFARPC 发布的服务订阅<sofa:reference id="dataServiceSofaRpc" interface=com.xxx.DataService" ><sofa:binding.tr/>基于 Dubbo 发布的服务订阅开启分布式事务 为需要开启分布式事务的接口增加分布式事务...

概述

消息收发模型 消息队列支持发布/订阅模型,消息生产者应用创建 Topic 并将消息发送到 Topic。消费者应用创建对 Topic 的订阅以便从其接收消息。通信可以是一对多(扇出)、多对一(扇入)和多对多。生产者集群 用来表示发送消息应用,一个...

消息过滤

应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中,同一个主题下的消息往往会被多个不同的下游业务方处理,各下游的处理逻辑不同,只关注自身逻辑需要的消息子集。使用 云...

Topic管理

云消息队列 RocketMQ 版 支持发布和订阅模型,通过Topic完成消息的发布订阅。消息生产者将消息发送到Topic中,而消息消费者则通过订阅该Topic来消费消息。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查询Topic。...

鉴权常见问题

使用的Token缺少对指定Topic的发布订阅权限。您可以调用 ApplyToken 接口为Token授权。申请Token权限能同时赋予多种权限吗?不能,一次只能对同一批资源赋予一种权限。如果想对TopicA授予写权限,对TopicB授予读权限,需要调用两次 ...

P2P消息收发模式(MQTT)

除了标准MQTT协议所支持的发布/订阅(Pub/Sub)消息收发模式外,云消息队列 MQTT 版 还支持点对点(Point to Point,简称P2P)模式。本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P,...

P2P消息收发模式(MQTT)

除了标准MQTT协议所支持的发布/订阅(Pub/Sub)消息收发模式外,云消息队列 MQTT 版 还支持点对点(Point to Point,简称P2P)模式。本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P,...

应用场景

通过 云消息队列 Kafka 版 的发布/订阅模型,您可以实时收集网站活动数据(例如注册、登录、充值、支付、购买),根据业务数据类型将消息发布到不同的Topic,然后利用订阅消息的实时投递,将消息流用于实时处理、实时监控或者加载到Hadoop...

MQTT协议规范

MQTT是基于TCP/IP协议栈构建的异步通信消息协议,是一种轻量级的发布订阅信息传输协议。可以在不可靠的网络环境中进行扩展,适用于设备硬件存储空间或网络带宽有限的场景。使用MQTT协议,消息发送者与接收者不受时间和空间的限制。物联网...

快速开始

进入房间后,注册房间中实现操作的回调函数,接收加入房间后的发布订阅和离开房间、对方加入房间和发送信息等回调信息。包含 OnPublish、OnSubscribe、OnGetSign、OnLeaveRoom、OnParticipantLeaveRoom、OnClientJoin、...

基础术语

Group Group 一类 Producer 或 Consumer,这类 Producer 或 Consumer 通常生产或消费同一类消息,且消息发布订阅的逻辑一致。Group ID Group ID Group 的标识。队列 Queue 每个 Topic 下会由一到多个队列来存储消息。每个 Topic 对应队列...

主调接口

config_param 参数:请求参数 类型 是否必填 说明 auto_publish_subscribe int 必填 发布订阅模式:1:自动订阅。2:自动发布。3:自动订阅+自动发布。4:由业务自己操作。5:自动订阅+当房间中有其他人时自动发布。engine int 选填 引擎...

使用MQTT.fx接入物联网平台

单击 Topic列表 页签,单击已订阅Topic对应操作列 发布消息。输入消息内容,例如 This is a test.,单击 确认。回到MQTT.fx上,查看接收到的消息。使用物模型通信Topic通信 物模型通信Topic的详细信息,请参见 什么是Topic。本示例使用物...

直播互动解决方案

名词解释 MQTT 一个基于订阅/发布的长连接双向通信模型,订阅方便灵活,非常适合直播消息互动场景。云消息队列 MQTT 版 基于标准的MQTT协议,广泛服务于终端应用场景。MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点,用于...

基本概念

Group 一类Producer或Consumer,这类Producer或Consumer通常生产或消费同一类消息,且消息发布订阅的逻辑一致。Group ID Group的标识。队列(Message Queue)即Topic Partition,物理上的概念。每个Topic包含一个或多个队列。创建Topic时...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
安全众测 数据传输服务 数据总线 DataHub 智能语音交互 API 网关 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用