正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
0/0 TCP协议访问实例的端口 入方向 TCP 8080 0.0.0.0/0 gRPC协议访问实例的端口 父主题: 配置RocketMQ网络连接
配置RocketMQ网络连接 连接RocketMQ网络要求 配置RocketMQ实例的公网访问 父主题: 连接实例
使用gRPC协议,通过内网访问实例的端口 入方向 TCP 8081 0.0.0.0/0 使用gRPC协议,通过公网访问实例的端口 父主题: 配置RocketMQ网络连接
公网访问状态。单击“公网访问”后的,开启/关闭公网访问。 公网连接地址 仅开启公网访问后可见。 开启公网访问后,连接实例的地址。 在“华东二”区域,开启IPv6的实例暂不支持通过公网访问。 ACL访问控制 实例的ACL访问状态。单击“ACL访问控制”后的,开启ACL访问。 开启ACL权限控制功能后,生产消息和消费消息时,需要鉴权。
后,不支持修改。 设置IPv6开关。 仅当子网选择了支持IPv6地址后,才会显示该参数。开启IPv6后,客户端可以使用IPv6的内网连接地址连接实例。 此功能仅在“华东二”区域上线,且仅4.8.0版本支持创建IPv6实例。 实例创建成功后,不支持修改IPv6开关。 在“安全组”下拉列表,可以选择已经创建好的安全组。
使用客户端连接RocketMQ(关闭SSL) 本文主要介绍在Linux系统的命令行模式下,调用TCP协议连接未开启SSL的RocketMQ实例。 前提条件 已创建RocketMQ实例,并记录实例详情中的“连接地址”(内网访问)/“公网连接地址”(公网访问)。内网访问的连接端口为8
连接实例 配置RocketMQ网络连接 配置RocketMQ访问控制 使用客户端连接RocketMQ(关闭SSL) 使用客户端连接RocketMQ(开启SSL) 使用控制台连接RocketMQ
default_az Boolean 是否为默认可用区。 remain_time Long 剩余时间。 ipv6_enable Boolean 是否支持IPv6。 请求示例 查询可用区信息。 GET https://{endpoint}/v2/available-zones?engine=reliability
storage_type String 存储类型。 extend_times Long 扩展时间。 ipv6_enable Boolean 是否开启IPv6。 support_features String 实例支持的特性功能。 disk_encrypted Boolean 是否开启磁盘加密。
企业项目ID。若为企业项目账号,该参数必填。 enable_acl 否 Boolean 是否开启访问控制列表。 ipv6_enable 否 Boolean 是否支持IPv6。 true:支持 false:不支持 enable_publicip 否 Boolean 是否开启公网访问功能。默认不开启公网。 true:开启
storage_type String 存储类型。 extend_times Long 扩展时间。 ipv6_enable Boolean 是否开启IPv6。 support_features String 实例支持的特性功能。 disk_encrypted Boolean 是否开启磁盘加密。
TransactionStatus.ROLLBACK:回滚事务,消息将被丢弃不允许消费。 TransactionStatus.UNKNOWN:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题: Python(TCP协议)
111或以上版本,并完成环境变量配置,具体操作可参见快速连接RocketMQ并生产消费消息。 准备网络环境。 RocketMQ实例分内网地址以及公网地址两种网络连接方式。如果使用公网地址,则消息生产与消费客户端需要有公网访问权限,并配置如表1所示安全组。 表1 安全组规则 方向 协议 端口 源地址 说明
LocalTransactionState.ROLLBACK_MESSAGE:回滚事务,消息将被丢弃不允许消费。 LocalTransactionState.UNKNOW:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题: Java(TCP协议)
TransactionResolution.ROLLBACK:回滚事务,消息将被丢弃不允许消费。 TransactionResolution.UNKNOW:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息相同。 父主题: Java(gRPC协议)
消息对应的业务逻辑有时间窗口要求,如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息,5分钟以后投递给消费者,消费者收到此消息后需要判断对应订单是否完成支付,如果未完成支付,则关闭订单。如果已完成,则忽略。 通过消息触发定时任务的场景,如在某些固定时间点向用户发送提醒消息。
primitive.RollbackMessageState:回滚事务,消息将被丢弃不允许消费。 primitive.UnknowState:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题: Go(TCP协议)
晰,提高效率。可以根据如下几方面判断Topic和Tag的具体使用场景: 根据消息类型判断:RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息,不同类型的消息需要用不同的Topic来区分,无法通过Tag区分。 根据消息优先级判断:在业务中紧急程度高和紧急程度一
主节点重启过程中,客户端的生产和消费请求会被拒绝,持续时间不超过30s,建议在业务量少时重启节点。重启备节点,不会影响业务的使用。 怎么判断哪个是主节点? 主节点为“Broker ID”显示“0”的节点。 图1 重启节点 仅在RocketMQ实例4.8.0版本支持重启节点,5.x版本不支持。
400 DMS.00400049 The availability zone does not support ipv6. 可用分区不支持IPv6。 请重新选择可用分区 400 DMS.00400051 not found the new setup version tar to upgrade