Go

本文以Go语言为例,讲解在服务端通过Go代码完成签名,并且设置上传回调,然后通过表单直传数据到OSS。前提条件 应用服务器对应的域名可通过公网访问。应用服务器已经安装Go 1.6以上版本(执行命令 go version 进行验证)。PC端浏览支持...

产品架构

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

PHP

应用服务器核心代码解析 应用服务器源码包含了签名直传服务和上传回调服务两个功能。签名直传服务 签名直传服务响应客户端发送给应用服务器的GET消息代码文件是 aliyun-oss-appserver-php/php/get.php 。代码片段如下:$response=array()...

Node.js

本文以Node.js语言为例,介绍如何通过Node.js代码服务端先完成签名,并设置上传回调,然后通过表单直传数据到OSS。前提条件 应用服务器对应的域名可通过公网访问。应用服务器已经安装Node.js 8.0以上版本。您可以执行 node-v 命令验证...

服务端签名直传并设置上传回调概述

应用服务器侧的签名直传服务会处理客户端发过来的Get请求消息,您可以设置对应的代码让应用服务器能够给客户端返回正确的消息。各个语言版本的配置文档中都有明确的说明供您参考。以下是签名直传服务返回给客户端消息Body内容的示例,Body...

网络

10 网络连接没有打开,无法发送消息 请正常连接服务器后再调用 my.sendSocketMessage 发送数据消息,可通过 my.onSocketOpen 监听事件来判断与服务器建立正确连接。注意:通过 WebSocket 连接发送数据,需要先使用 my.connectSocket 发起...

收发定时消息

发送定时消息的代码示例如下所示。using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Runtime.InteropServices;using ons;namespace ons { class onscsharp { private static readonly ...

产品架构

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

订阅关系一致

正确示例代码一 C1、C2、C3的订阅关系一致,即C1、C2、C3订阅消息的代码必须完全一致,代码示例如下:Properties properties=new Properties();properties.put(PropertyKeyConst.GROUP_ID,"GID_test_1");Consumer consumer=ONSFactory....

消息查询

例如,当前时间是2019年06月10日15:09:48,那么能查询到的某Topic下的消息最早的时间点为2019年06月07日15:09:48。三种查询方式的特点和对比如下表所述。查询方式 查询条件 查询类别 说明 按Message ID查询 Topic+Message ID 精确查询 根据...

收发事务消息

发送事务消息 发送事务消息的示例代码如下。import com.aliyun.mq.http.MQClient;import com.aliyun.mq.http.MQTransProducer;import com.aliyun.mq.http.common.AckMessageException;import com.aliyun.mq.http.model.Message;import ...

收发事务消息

发送事务消息 发送事务消息的示例代码如下。php require "vendor/autoload.php";use MQ\Model\TopicMessage;use MQ\MQClient;class ProducerTest { private$client;private$transProducer;private$count;private$popMsgCount;public ...

收发事务消息

发送事务消息 发送事务消息的示例代码如下。usr/bin/env python#coding=utf8 import sys from mq_http_sdk.mq_exception import MQExceptionBase from mq_http_sdk.mq_producer import *from mq_http_sdk.mq_client import *import time ...

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

} } 三种发送方式的对比 发送方式 发送TPS 发送结果反馈 可靠性 同步发送 快 有 不丢失 异步发送 快 有 不丢失 单向发送 快 无 可能丢失 订阅普通消息 订阅普通消息的方式只有以下一种。import java.util.List;import org.apache....

Ruby SDK收发消息

本文介绍如何使用Ruby SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 您已安装Ruby。更多信息,请参见 安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备配置 可选:下载SSL根...

快速使用MQTT.fx模拟SDK收发消息

背景信息 云消息队列 MQTT 版 最简单的使用场景即MQTT客户端消息的自发自收。如下图所示,您可以使用MQTT.fx作为MQTT客户端,在MQTT.fx客户端配置相关参数后接入 云消息队列 MQTT 版 实现消息的发送和接收。云消息队列 MQTT 版 同时提供了 ...

消息过滤

若消费者只需要关注部分消息,可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤,只获取到需要关注的消息子集,避免接收到大量无效的消息。应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务...

普通消息

普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意,云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用,例如,您创建的普通消息...

自助建站方式汇总

搭建环境 阿里云云服务ECS提供了多种镜像,您可以通过云市场镜像快速部署环境,也可以通过操作系统镜像创建服务器后手动搭建运维环境。搭建环境教程如下所示。部署LNMP环境 Nginx是一款小巧而高效的Web服务器软件,可帮您在Linux系统下...

定时和延时消息

本文主要介绍 云消息队列 RocketMQ 版 的定时消息和延时消息的概念、适用场景以及使用过程中的注意事项。概念介绍 定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是推迟到在当前时间点...

示例代码

本文为您介绍RocketMQ 5.x系列C#SDK的消息收发示例代码。表 1.示例代码函数说明 消息类型 发送消息示例代码 订阅消息示例代码(SimpleConsumer)普通消息 ProducerNormalMessageExample.cs SimpleConsumerExample.cs 顺序消息 ...

示例代码

本文介绍Apache RocketMQ Go SDK的消息收发示例代码消息类型 发送消息示例代码 订阅消息示例代码(SimpleConsumer)普通消息 同步发送:ExampleProducerNormalMessage.go 异步发送:AsyncExampleProducerNormalMessage.go ...

产品优势

全托管服务 一键开通 云消息队列 RabbitMQ 版 服务,即享有免部署免运维的云消息服务。依托于阿里云专业的自动化运维团队,核心链路秒级、分钟级进行多维度巡检,全面的健康诊断报告,针对不健康的状态进行告警与及时恢复,保证服务的可用...

示例代码

本文介绍Apache RocketMQ Java SDK的消息收发示例代码消息类型 发送消息示例代码 订阅消息示例代码 PushConsumer SimpleConsumer 普通消息 同步发送:ProducerNormalMessageExample.java 异步发送:AsyncProducerExample.java ...

使用限制

企业铂金版:存储时长为3天,若您购买实例的存储空间规格不足时,云消息队列 RocketMQ 版 会按存储时间滚动删除的消息,此时消息的存储时长可能不足3天。说明 定时消息和延时消息的存储时长以定时或延时时长到期的时间为开始进行计算。...

收发普通消息

普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作:下载.NET SDK。更多信息,请参见 版本...

消费进度管理

虽然消息队列逻辑上是无限存储,但由于服务端物理节点的存储空间有限,云消息队列 RocketMQ 版 会滚动删除队列中存储的消息。因此,消息的最小消费位点和最大消费位点会一直递增变化。消费位点(ConsumerOffset)云消息队列 RocketMQ ...

收发顺序消息

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

仪表盘

晚一条拉取消息的位点-晚一条提交消息的位点 已就绪的消息(ready messages)消息在 云消息队列 RocketMQ 版 服务端已就绪,对消费者可见可被消费的消息。最大消息位点-晚一条拉取消息的位点 消息堆积量(consumer lag)所有未处理...

API概览

OnsConsumerTimeSpan 查询Topic可重置时间范围 查询Topic可重置的时间范围,即该Topic中储存的早的和晚的消息的生产时间。OnsMessagePush 向指定的消费者推送消息 调用OnsMessagePush向指定的消费者推送消息。消息收发数据统计 API ...

实例规格

不支持 消息存储时长 3天 若您购买实例的存储空间规格不足时,云消息队列 RocketMQ 版 会按存储时间滚动删除的消息,此时消息的存储时长可能不足3天。说明 若您对消息存储时长有特殊要求,您可以联系 云消息队列 RocketMQ 版 技术支持...

基本概念

晚一条拉取消息的位点-晚一条提交消息的位点 已就绪的消息(ready messages)消息在 云消息队列 RocketMQ 版 服务端已就绪,对消费者可见可被消费的消息。最大消息位点-晚一条拉取消息的位点 消息堆积量(consumer lag)所有未处理...

消费端从服务端拉取不到消息或拉取消息缓慢

可能的原因包括消息流量达到网络带宽、单个消息大小超过网络带宽或者Consumer每次拉取的消息量超过网络带宽。问题现象 Topic中有消息并且Consumer未消费到最新的位置,出现消费端从服务端拉取不到消息或拉取消息缓慢的情况(特别是公网消费...

收发普通消息

普通消息是指阿里云 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件 安装CPP动态库 获取阿里云访问密钥AccessKey ...

集群消费和广播消费

设置集群消费和广播消费 云消息队列 RocketMQ 版 的消费方式支持在消费者客户端修改,您需要在订阅消息的SDK代码中设置相关参数。若未设置,则默认使用集群消费方式。TCP协议SDK Java SDK示例 集群消费/MessageModel设置为CLUSTERING(不...

云端Demo工程

Demo工程包含发送消息、接收消息以及接收客户端上下线消息的示例代码及相关配置。前提条件 安装IDEA。请下载IntelliJ IDEA Ultimate版本,并参见IntelliJ IDEA说明进行安装。更多信息,请参见 下载地址。您也可以使用Eclipse,本文以...

仪表盘

晚一条拉取消息的位点-晚一条提交消息的位点 已就绪的消息(ready messages)消息在 云消息队列 RocketMQ 版 服务端已就绪,对消费者可见可被消费的消息。最大消息位点-晚一条拉取消息的位点 消息堆积量(consumer lag)所有未处理...

通过创建规则实现邮件推送事件通知

更多信息,请参见 开通消息服务MNS并授权。开通邮件推送服务。注意事项 事件通知规则创建完成后,约10分钟生效。事件通知规则指定消息接收端时,如果选择主题,就不能选择其他的接收终端。即如果选择了主题,那只能继续选择主题;如果选择...

通过创建规则实现日志服务事件通知

消息服务MNS 支持通过创建规则实现 日志服务 SLS(Simple Log Service)事件通知。前提条件 开通消息服务MNS并授权 注意事项 事件通知规则创建完成后,约10分钟生效。事件通知规则指定消息接收端时,如果选择主题,就不能选择其他的接收...

收发顺序消息

顺序消息(FIFO消息)是阿里云 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类:全局顺序:对于指定的一个Topic,所有...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云服务器 ECS 轻量应用服务器 云数据库 RDS 负载均衡 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用