检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
业务链通常都是多个系统相互协作完成一次作业,上层服务强依赖于下层服务,上层服务的性能会强依赖于下层服务,当业务链过深,则会严重影响外层服务的性能和用户体验。 在电商促销活动中,需要用户拥有订阅通知的能力。 分布式消息服务RocketMQ版为搭建电商系统提供了更多的选择。
扩容代理个数时,系统会根据当前磁盘大小进行相应比例的存储空间扩容。例如扩容前实例的代理数为1,每个代理的磁盘大小为300GB,扩容后实例的代理数为2,此时代理的磁盘大小依旧为300GB,但是总磁盘大小为600GB。
消费端限流 在分布式消息服务RocketMQ版中,消费者消费消息时,可能会出现消费过快导致下游业务来不及处理的情况,进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码,以保障系统的稳定。
查询可用区信息 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 region_id
final CompletableFuture<List<MessageView>> future0 = consumer.receiveAsync(maxMessageNum, invisibleDuration);
将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。
existed { fmt.Printf("unknow msg: %v, return Commit", msg) return primitive.CommitMessageState } state := v.
Message(topic) msg.set_keys('XXX') msg.set_tags('XXX') msg.set_property('property', 'test') msg.set_body('message body') return
existed { fmt.Printf("unknow msg: %v, return Commit", msg) return primitive.CommitMessageState } state := v.
msg def check_callback(msg): print('check: ' + msg.body.decode('utf-8')) return TransactionStatus.COMMIT def local_execute(msg,
public class TopicEntity { private String name; //Topic名称 private String messageType; //消息类型 public String getName() { return
the transaction resolution according to your business logic. // 检查本地事务并返回本地事务状态 return TransactionResolution.COMMIT;
ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT; } return ConsumeOrderlyStatus.SUCCESS; }
Message(topic) msg.set_keys('XXX') msg.set_tags('XXX') msg.set_property('property', 'test') msg.set_body('message body') return
kafka.ssl.2way.modify.enable,kafka.new.pod.port,message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections
support_features Array of RocketMQProductSupportFeaturesEntity objects 支持的特性功能。 qingtian_incompatible Boolean 是否为擎天实例。
LocalTransactionState executeLocalTransaction(Message message, Object o) { System.out.println("开始执行本地事务: " + message); return
message_trace_enable,features.pod.token.access,kafka.ssl.cert.modify.enable,roma.user.manage.no.support,feature.physerver.kafka.pulbic.dynamic
将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。
删除指定消费组 功能介绍 删除指定消费组。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 project_id