检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RocketMQ配置名称。 value 否 String RocketMQ配置目标值。 响应参数 无 请求示例 修改RocketMQ配置的参数,将文件保留时间修改为72小时。 PUT https://{endpoint}/v2/{project_id}/rocketmq/instanc
x版本批量创建不同类型的Topic 新建“topics.txt”文件,用于存放待创建的Topic信息。 文件内容格式为“Topic名称 消息类型”,消息类型包含普通(NORMAL)、顺序(FIFO)、定时(DELAY)、事务(TRANSACTION)四种。文件内容填写示例如下: topic-test01
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address
Access Manager,简称RAM)服务的机制,VPC的所有者可以将VPC内的子网共享给一个或者多个账号使用。通过共享VPC功能,可以简化网络配置,帮助您统一配置和运维多个账号下的资源,有助于提升资源的管控效率,降低运维成本。有关VPC子网共享的更多信息,请参见共享VPC。
-c {RocketMQ集群名称} -f {导出的元数据文件的存放路径} 例如:“nameserver地址及端口号”为“192.168.0.65:8100”,“RocketMQ集群名称”为“DmsCluster”,“导出的元数据文件的存放路径”为“/tmp/rocketmq/export”。
MQ消息存储在CommitLog文件中,CommitLog文件大小为1GB,当一个CommitLog文件写满后,会生成一个新的CommitLog文件。RocketMQ删除消息是删除CommitLog文件,而不是删除一条消息。CommitLog文件为顺序写入,当最后写入的一条消息过
RocketMQ相关概念 主题(Topic) 消息关联的基础逻辑单元。消息生产与消费时的基础单位。 队列(Queue) 一个主题由多个队列组成。队列数越大消费的并发度越大。 生产者(Producer) 消息写入的触发者,负责将消息推送到服务端。 生产者组(Producer Group)
分布式消息服务RocketMQ版”。 通过以下任意一种方法,为RocketMQ实例续费。 勾选RocketMQ实例名称左侧的方框,可选一个或多个,单击信息栏左上侧的“续费”,弹出“续费”对话框,单击“是”,跳转到“续费”页面。 在待续费的RocketMQ实例所在行,单击“更多 > 续费”,跳转到“续费”页面。
ACL用户 RocketMQ实例开启ACL权限控制功能后,生产和消费消息时,须增加ACL用户信息,才能成功生产和消费消息。您还可以通过创建多个用户并为其赋予不同的Topic和消费组权限,以达到用户之间的权限隔离。 前提条件 已购买RocketMQ实例。 已开启ACL访问控制。 创建用户
“jdk-8u321-linux-x64.tar.gz”为JDK的版本,请根据实际情况修改。 执行以下命令编辑环境变量文件“.bash_profile”。 vim ~/.bash_profile 在环境变量文件中添加如下内容。 export JAVA_HOME=/opt/java/jdk1.8.0_321
典型应用场景 电商应用 电商应用存在诸多难题: 电商场景中通常会涉及到订单、支付和通知等等场景的业务处理。业务链通常都是多个系统相互协作完成一次作业,上层服务强依赖于下层服务,上层服务的性能会强依赖于下层服务,当业务链过深,则会严重影响外层服务的性能和用户体验。 在电商促销活动中,需要用户拥有订阅通知的能力。
emo中获取。 下文所有RocketMQ的配置信息,如实例连接地址、Topic名称、用户信息等,请参考收集连接信息获取。 在pom.xml文件中引入RocketMQ-Spring依赖 <dependency> <groupId>org.apache.rocketmq</groupId>
"ROCKETMQ_SK", # 角色密钥 '' )#用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 producer.start() msg = create_message()
DefaultMQPushConsumer("Group1"); consumer.subscribe("Topic_A", "Tag_A||Tag_B"); 订阅多个Topic且订阅多个Tag 同一消费组Group1中的消费者Consumer1、Consumer2和Consumer3都订阅了Topic_A和Top
AccessKey: os.Getenv("ROCKETMQ_AK"), //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey: os.Getenv("ROCKETMQ_SK"), }), )
接近特定客户的要求,或满足不同地区的法律或其他要求。 可用区:一个可用区是一个或多个物理数据中心的集合,有独立的风火水电,AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region中的多个AZ间通过高速光纤相连,以满足用户跨AZ构建高可用性系统的需求。 项目 区域默认
AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK") ) func main()
关闭公网访问 修改“公网访问”为关闭。 变更规格 扩容存储空间 扩容代理数量 扩容代理规格 批量删除消费组 选择多个消费组,进行批量删除。 批量删除Topic 选择多个Topic,进行批量删除。 消息轨迹变更 消息轨迹发生变化。 重启节点 重启Broker节点。 元数据迁移 迁移元数据。
在需要更改计费模式的RocketMQ实例所在行,单击操作列“更多 > 到期转按需”。 勾选RocketMQ实例名称左侧的方框,可选一个或多个,单击信息栏左上侧的“到期转按需”,弹出“到期转按需”对话框,单击“是”。 查看资费变更的相关信息,确认无误后单击“到期转按需”。 在费用中心转按需
"yourEndpoints"; // 填入用户名/密钥,用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。创建实例时,如果开启了ACL才需要添加以下代码。 String accessKey =