日志管理概述

消费端宕机了,消费失败的消息什么时候可以再次被消费?消息发布到主题,Endpoint却迟迟收不到消息?想看一个月前的消息操作日志?这些问题可以通过 消息服务MNS 的日志管理功能解决,方法如下:将日志推送到 SLS,在控制台查看完整消息...

收发事务消息

Check被回调时,业务逻辑都需要什么?事务消息的Check方法里面,应该写一些检查事务一致性的逻辑。云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口,用来处理Broker主动发起的本地事务状态回查请求,因此...

如何配置MNS以支持更大的消息大小?

此属性指定队列中的消息可以包含的字节数限值。可以设置为1024字节(1 KB)到最大65536字节(64 KB)之间的任何值。如果消息长度超过了64 KB,建议将数据存储在OSS中,消息服务MNS 只存储数据访问地址。详情请参见 超大消息传输。

产品架构

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

商品目录模板最佳实践

多件商品消息可以编辑头部信息和正文内容,添加页脚信息。通过单击预览部分的头部信息、正文信息、页脚信息进行对应内容的编辑。保存模板后送审,待模板审核后即可使用。发送产品目录模板消息 在左侧导航栏,选择 消息发送。根据页面提示,...

Queue

超过这段时间,消息可以再次被receive。PollingWaitSeconds(batch)receive message请求最长等待时间,单位:秒。取值范围:0~30秒。当队列中没有消息时,(batch)receive message请求将运行在MNS服务器端。在该属性指定的时间范围内,...

消息负载均衡策略

优势 客户端Java v2.x.x.Final和C++ v3.x.x版本的负载均衡策略有以下优势:消息消费更加灵活,不再按照Queue维度消费,同一Queue的消息可以被多个消费者消费。当消费者个数多于Queue的个数时,也不会产生消费者空转的现象,避免资源浪费。...

JMS概述

消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准,允许基于Java EE(Java平台企业版)的应用...

接入点对比

专有网络VPC:是完全隔离的网络环境,消息可以采用PLAINTEXT协议在安全的网络通道不加密传输。安全要求更高的场景下,消息需结合SASL身份验证鉴权之后再在安全通道传输。您可以根据消息传输的安全要求级别选择PLAIN机制或SCRAM机制进行身份...

收发普通消息

} catch(\Exception$e){ if($e instanceof MQ\Exception\MessageNotExistException){/没有消息可以消费,继续轮询。printf("No message,contine long polling!RequestId:%s",$e->getRequestId());continue;} print_r($e->getMessage()."");...

收发定时消息

定时消息可以做到在指定时间戳之后才可被消费者消费,适用于对消息生产和消费有时间窗口要求,或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项,请参见 定时和延时消息。前提条件 下载.NET SDK。更多信息,请...

收发定时消息和延时消息

} catch(\Exception$e){ if($e instanceof MQ\Exception\MessageNotExistException){/没有消息可以消费,继续轮询。printf("No message,contine long polling!RequestId:%s",$e->getRequestId());continue;} print_r($e->getMessage()."");...

领域模型概述

一对多通信:基于独立身份的设计,同一个主题内的消息可以被多个订阅组处理,每个订阅组都可以拿到全量消息。因此发布订阅模型可以实现一对多通信。传输模型对比 点对点模型和发布订阅模型各有优势,点对点模型更为简单,而发布订阅模型的...

订阅消息API

参数 类型 说明 Code String 错误代码,其中 MessageNotExist 表示没有消息可以消费,是正常的响应。Message String 错误内容。RequestId String 请求ID。HostId String 请求Host。响应示例 有消息可消费?xml version="1.0?...

消费者分组(ConsumerGroup)

取值:重试策略包括:最大重试次数:表示消息可以重新被投递的最大次数,超过最大重试次数还没被成功消费,消息将被投递至死信队列或丢弃。重试间隔:云消息队列 RocketMQ 版 服务端重新投递消息的间隔时间。最大重试次数和重试间隔的取值...

MQTT与RocketMQ的消息结构映射

其他消息不可以设置,云消息队列 MQTT 版 发给 云消息队列 RocketMQ 版 的消息可以直接读取。MQTT子级Topic mqttSecondTopic 具体的子级Topic字符串 云消息队列 RocketMQ 版 发给 云消息队列 MQTT 版 客户端消息时如果需要子级Topic来...

收发事务消息

} catch(\Exception$e){ if($e instanceof MQ\Exception\MessageNotExistException){/没有消息可以消费,继续轮询。printf("No message,contine long polling!RequestId:%s",$e->getRequestId());continue;} print_r($e->getMessage()."");...

调用HTTP协议的SDK收发普通消息

在控制台创建完所有资源之后,您可以调用 云消息队列 RocketMQ 版 的HTTP协议的SDK收发普通消息。前提条件 创建资源 说明 本文以普通消息为例进行说明,因此您创建的普通消息的Topic不能用来收发其他类型的消息,包括定时、延时、顺序和...

收发普通消息

长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回响应。res=await consumer.consumeMessage(3,/一次最多消费3条(最多可设置为16条)。3/长轮询时间3秒(最多可设置为30秒)。if(res.code=...

收发普通消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。List<Message>messages=null;try { messages=consumer.ConsumeMessage(3,/一次最多消费3条(最多可设置为16条)。3/长轮询时间3秒(最多可...

收发事务消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。transProducer->consumeHalfMessage(1,/一次最多消费1条(最多可设置为16条)。3,/长轮询时间3秒(最多可设置为30秒)。halfMsgs);} catch...

收发普通消息

instance_id="${INSTANCE_ID}"consumer=mq_client.get_consumer(instance_id,topic_name,group_id)#长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3秒,3秒内如果有消息可以消费则立即返回响应。长轮询时间3秒(最多可设置为30...

收发定时消息和延时消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。List<Message>messages=null;try { messages=consumer.ConsumeMessage(3,/一次最多消费3条(最多可设置为16条)。3/长轮询时间3秒(最多可...

收发普通消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。messages=consumer.consumeMessage(3,/一次最多消费3条消息(最多可设置为16条)。3/长轮询时间3秒(最多可设置为30秒)。} catch...

收发普通消息

长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回响应。mqConsumer.ConsumeMessage(respChan,errChan,3,/一次最多消费3条(最多可设置为16条)。3,/长轮询时间3s(最多可设置为30s)。...

收发顺序消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则服务端立即返回响应。List<Message>messages=null;try { messages=consumer.ConsumeMessageOrderly(3,/一次最多消费3条(最多可设置为16条)。3/长轮询时间...

使用Spring Cloud框架收发消息

VPC环境(消息传输不鉴权不加密)VPC环境,消息可以采用PLAINTEXT协议不鉴权不加密传输。客户端通过默认接入点访问 云消息队列 Kafka 版。接入点的详细信息,请参见 接入点对比。本示例将Demo包上传在/home/doc/project/aliware-kafka-...

收发定时消息和延时消息

instance_id="${INSTANCE_ID}"consumer=mq_client.get_consumer(instance_id,topic_name,group_id)#长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3秒,3秒内如果有消息可以消费则立即返回响应。长轮询时间3秒(最多可设置为30...

收发定时消息和延时消息

长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回响应。res=await consumer.consumeMessage(3,/一次最多消费3条(最多可设置为16条)。3/长轮询时间3秒(最多可设置为30秒)。if(res.code=...

收发顺序消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则服务端立即返回响应。res=await consumer.consumeMessageOrderly(3,/一次最多消费3条(最多可设置为16条)。3/长轮询时间3秒(最多可设置为30秒)。if(res....

收发顺序消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则服务端立即返回响应。wait_seconds=3#一次最多消费3条(最多可设置为16条)。batch=3 print(("%sConsume And Ak Message From Topic%s TopicName:%s ...

收发定时消息和延时消息

长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回响应。mqConsumer.ConsumeMessage(respChan,errChan,3,/一次最多消费3条(最多可设置为16条)。3,/长轮询时间3s(最多可设置为30s)。...

收发定时消息和延时消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。messages=consumer.consumeMessage(3,/一次最多消费3条消息(最多可设置为16条)。3/长轮询时间3秒(最多可设置为30秒)。} catch...

收发顺序消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则服务端立即返回响应。mqConsumer.ConsumeMessageOrderly(respChan,errChan,3,/一次最多消费3条(最多可设置为16条)。3,/长轮询时间3s(最多可设置为30s)...

收发普通消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。consumer->consumeMessage(3,/一次最多消费3条(最多可设置为16条)。3,/长轮询时间3秒(最多可设置为30秒)。messages);cout()!处理业务...

收发顺序消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则服务端立即返回响应。messages=consumer.consumeMessageOrderly(3,/一次最多消费3条消息(最多可设置为16条)。3/长轮询时间为3秒(最多可设置为30秒)。} ...

收发定时消息和延时消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。consumer->consumeMessage(3,/一次最多消费3条(最多可设置为16条)。3,/长轮询时间3秒(最多可设置为30秒)。messages);cout()!处理业务...

收发顺序消息

若Topic内没有消息,请求会在服务端挂起一段时间(长轮询时间),期间如果有消息可以消费则立即返回客户端。messages=$this->consumer->consumeMessageOrderly(3,/一次最多消费3条(最多可设置为16条)。3/长轮询时间3秒(最多可设置为30秒...

收发顺序消息

长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则服务端立即返回响应。consumer->consumeMessageOrderly(3,/一次最多消费3条(最多可设置为16条)。3,/长轮询时间3秒(最多可设置为30秒)。messages);cout...

收发事务消息

长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回响应。res=await consumer.consumeMessage(3,/一次最多消费3条(最多可设置为16条)。3/长轮询时间3秒(最多可设置为30秒)。if(res.code=...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
消息服务 云消息队列 RocketMQ 版 云消息队列 Kafka 版 云原生数据仓库AnalyticDB MySQL版 智能对话机器人 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用