产品架构

集群级别的高可用,是 云消息队列 RocketMQ 版 跟其他的消息服务器的主要区别,消息生产者发送一条消息到消息服务器消息服务器会随机的选择一个消费者,只要这个消费者消费成功就认为是成功了。重要 文中所提及的 云消息队列 RocketMQ 版...

产品架构

集群级别的高可用,是消息队列跟其他的消息服务器的主要区别,消息生产者发送一条消息到消息服务器消息服务器会随机的选择一个消费者,只要这个消费者消费成功就认为是成功了。说明 文中所提及的消息队列的服务端或者服务器包含 Name ...

产品架构

发送的消息可以是网站的页面访问、服务器日志,也可以是CPU和内存相关的系统资源信息。Kafka Broker 用于存储消息的服务器。Kafka Broker支持水平扩展。Kafka Broker节点的数量越多,云消息队列 Kafka 版 集群的吞吐率越高。Group 通过pull...

OnsMessageDetail-查询消息详细信息

1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息所属的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。MSG_REGION Name string 消息...

OnsMessageGetByMsgId-通过MsgId查询消息

通过传入 Message ID 查询指定消息的信息以及判断该指定的消息是否曾被消费过。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 Open...

OnsDLQMessageGetById-根据Message ID查询死信消息

0BC16699165C03B925DB8A404E2D*StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。...

OnsMessageGetByKey-根据Message Key查询消息

1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...

OnsMessagePageQueryByTopic-查询Topic内所有消息

1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...

查询Group ID内所有死信消息

1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...

漏洞公告|Windows SMBv3远程执行代码漏洞(CVE-2020-...

漏洞信息 漏洞编号:CVE-2020-0796 漏洞评级:高危,风险极大 补丁更新日期:2020年03月12日 漏洞位置:Windows 10和Windows Server的服务器消息模块3.1.1(Server Message Block 3.1.1,简称SMBv3)影响版本:Windows 10,Version 1903,...

消息 Mesh

流量调度:通过打通 Sidecar 节点之间的通信链路,可以利用 Sidecar 的流量转发来实现任意精度的消息流量调度,帮助基于事件驱动的微服务应用进行多版本流量管理、流量着色、分组路由、细粒度的流量灰度与A/B策略等。消息验证:消息验证在...

物联网平台通信方式概述

背景信息 设备通过消息Topic实现消息的发送和接收,消息通信Topic的定义、使用和分类说明,请参见 什么是Topic。设备上报的原始数据格式,需您在设备端完成开发。阿里云物联网平台提供的设备端Link SDK,可实现设备快速接入物联网平台并...

什么是Topic

在发布/订阅消息的MQTT协议中,Topic用于定义消息传输的通道和路径,设备通过Topic将消息发布到物联网平台,物联网平台将消息发送给订阅Topic的设备。为方便海量设备基于Topic进行通信,简化授权操作,物联网平台定义了产品Topic类和设备...

收发事务消息

本文提供使用TCP协议下的社区版Java SDK收发事务消息的示例代码供您参考。交互流程 事务消息交互流程如下图所示。更多信息,请参见 事务消息。前提条件 您已完成以下操作:下载4.5.2或以上版本的社区版 Java SDK。准备工作。获取阿里云访问...

收发事务消息

当本地事务执行完成(执行成功或执行失败),需要通知服务器当前消息的事务状态。通知方式有以下两种:执行本地事务完成后提交。执行本地事务一直没提交状态,等待服务器回查消息的事务状态。事务状态有以下三种:TransactionStatus....

Go

签名直传服务 签名直传服务响应客户端发送给应用服务器的GET消息,代码片段如下。func handlerRequest(w http.ResponseWriter,r*http.Request){ if(r.Method="GET"){ response:=get_policy_token()w.Header().Set("Access-Control-Allow-...

PHP

前提条件 Web服务器已部署。Web服务器对应的域名可通过公网访问。Web服务器能够解析PHP(执行命令 php -v 进行查看)。说明 PHP需要为PHP 5及以上版本。PC端浏览器支持JavaScript。步骤1:配置Web服务器 本文以Ubuntu16.04为例介绍使用不同...

Ruby

签名直传服务 签名直传服务响应客户端发送给应用服务器的GET消息,代码片段如下:def get_token()expire_syncpoint=Time.now.to_i+$expire_time expire=Time.at(expire_syncpoint).utc.iso8601()response.headers['expire']=expire policy_...

Node.js

上传回调服务 上传回调服务响应OSS发送给应用服务器的POST消息,代码片段如下:/监听/result路径下的POST请求。app.post("/result",(req,res)=>{/通过Base64解码公钥地址。const pubKeyAddr=Buffer.from(req.headers["x-oss-pub-key-url"],...

实例规格族

trans FPGA计算型实例规格族f3 视觉计算型实例规格族ebmgi6s GPU虚拟化型实例规格族vgn5i GPU计算型实例规格族gn5 GPU计算型实例规格族gn5i 弹性裸金属服务器规格族群 推荐 其他在售(如果售罄,建议使用推荐规格族)GPU计算型弹性裸金属...

控制台看到的最近消费时间是什么意思?

消息发布到 云消息队列 Kafka 版 服务器的存储时间。控制台看到的 最近消费时间 是指消息发布到 云消息队列 Kafka 版 服务器的存储时间。如果消费没有堆积,那么这个时间接近发送时间。

使用Spring Cloud框架收发消息

Spring Cloud是用于构建消息驱动的微服务应用程序的框架,提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案,可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 ...

如何提高Nginx Web服务器的安全性

本文介绍如何提高Nginx Web服务器的安全性的操作步骤。背景信息 Nginx是一个轻量级的,高性能的Web服务器以及反向代理和邮箱(IMAP或POP3)代理服务器。它运行在UNIX、GNU、linux、BSD、Mac OS X、Solaris和Windows各种版本。根据调查统计...

消息存储和清理机制

本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制,包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义,消息按照达到服务器的先后顺序被存储到队列中,理论上每个队列都支持无限...

消息队列 Kafka 版何时删除旧消息

Topic详情 页面中的 当前服务器上消息总量 是指Topic上所有发送还未超过消息保留时间的消息量。此数值不作为清理策略的依据。相关文档 如果消息超过 消息保留时长 还未被删除,具体原因,请参见 为什么消息已经过期还未被删除?当磁盘空间...

事件分析概述

消息领域:在传统消息领域,消息Schema管理、消息内容检索一直是无法解决的难题,大部分情况下需要增加订阅者来对消息做离线分析。事件总线EventBridge 的事件分析平台提供消息Schema管理与消息内容查询能力,为消息可视化提供更完整的解决...

接口和参数说明

表 2.Push方式特有参数(批量消费)参数 说明 ConsumeMessageBatchMaxSize 批量消费的最大消息数量,缓存的消息数量达到设置的参数值,云消息队列 RocketMQ 版 会将缓存的消息统一推送给消费者进行批量消费。默认值:32,取值范围:1~1024...

Token鉴权概述

MQTT服务器消息队列 MQTT 版 权限认证和消息收发服务器,用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂,您需要按照下图所示的流程,部署您的应用服务器。而且在初始化时,...

Token鉴权概述

MQTT服务器消息队列 MQTT 版 权限认证和消息收发服务器,用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂,您需要按照下图所示的流程,部署您的应用服务器。而且在初始化时,...

公共参数

Date 是 请求的构造时间,目前只支持GMT格式,如果和 云消息队列 RocketMQ 版 的服务器时间前后差异超过15分钟将返回本次请求非法。Host 是 即在控制台 实例详情 页面查看到的HTTP接入点。x-mq-version 是 调用 云消息队列 RocketMQ 版 的...

设备数据订阅指引

配置服务端订阅后,物联网平台会将产品下所有设备的已订阅类型的消息转发至您的服务器。使用AMQP服务端订阅消息 AMQP(Advanced Message Queuing Protocol)即高级消息队列协议。您配置AMQP服务端订阅后,物联网平台会将产品下所有已订阅...

收发普通消息

普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用,例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...

发送消息(多线程)

Thread thread=new Thread(new Runnable(){@Override public void run(){ try { Message msg=new Message(/普通消息所属的Topic,切勿使用普通消息的Topic来收发其他类型的消息。TopicTestMQ",/Message Tag可理解为Gmail中的标签,对消息...

发送普通消息(三种方式)

i+){ Message msg=new Message(/普通消息所属的Topic,切勿使用普通消息的Topic来收发其他类型的消息。TopicTestMQ",/Message Tag可理解为Gmail中的标签,对消息进行再归类,方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤。...

收发定时消息

本文提供使用TCP协议下的C/C++ SDK收发定时消息的示例代码供您参考。定时消息可以做到在指定时间戳之后才可被消费者消费,适用于对消息生产和消费有时间窗口要求,或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...

收发顺序消息

顺序消息FIFO(First In First Out)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,...

收发定时消息

本文提供使用TCP协议下的Java SDK收发定时消息的示例代码。背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费,适用于对消息生产和消费有时间窗口要求,或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...

如何快速使用微消息队列MQTT版的Java SDK收发消息

本文提供使用 消息队列MQTT版 的Java SDK收发消息的快速入门视频。

收发顺序消息

顺序消息(FIFO消息)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作:下载1.2.7或以上版本的Java SDK。更多信息,请参见...

收发事务消息

本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云服务器 ECS 轻量应用服务器 Web应用防火墙 负载均衡 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用