活动

天翼云最新优惠活动,涵盖免费试用,产品折扣等,助您降本增效!
热门活动
  • 安全隔离版OpenClaw NEW OpenClaw云服务器专属“龙虾“套餐低至1.5折起
  • 聚力AI赋能 天翼云大模型专项 大模型特惠专区·Token Plan 轻享包低至9.9元起
  • 青云志云端助力计划 NEW 一站式科研助手,海外资源安全访问平台,助力青年翼展宏图,平步青云
  • 出海产品促销专区 NEW 爆款云主机低至2折,高性价比,不限新老速来抢购!
  • 天翼云信创专区 NEW “一云多芯、一云多态”,国产化软件全面适配,国产操作系统及硬件芯片支持丰富
  • 中小企业服务商合作专区 国家云助力中小企业腾飞,高额上云补贴重磅上线
  • 云上钜惠 爆款云主机全场特惠,2核4G只要1.8折起!
  • 天翼云奖励推广计划 加入成为云推官,推荐新用户注册下单得现金奖励
免费活动
  • 免费试用中心 HOT 多款云产品免费试用,快来开启云上之旅
  • 天翼云用户体验官 NEW 您的洞察,重塑科技边界

息壤智算

领先开放的智算服务平台,提供算力、平台、数据、模型、应用“五位一体”智算服务体系,构建全流程的AI基础设施能力
AI Store
  • 算力市场
  • 模型市场
  • 应用市场
公共算力服务
  • 裸金属
  • 定制裸金属
训推服务
  • 模型开发
  • 训练任务
  • 服务部署
模型推理服务
  • 模型广场
  • 体验中心
  • 服务接入
应用托管
  • 应用实例
科研助手
  • 科研智能体
  • 科研服务
  • 开发机
  • 并行计算
大模型
  • DeepSeek-V4-Flash
  • GLM-5.1
  • Qwen3.5-122B-A10B
  • DeepSeek-V3.2(旗舰版)
  • GLM-5(正式版)
  • Qwen3.5-397B-A17B(正式版)
智算一体机
  • 智算一体机
模型适配专家服务
  • 模型适配专家服务
算力服务商
  • 入驻算力服务商

应用商城

天翼云精选行业优秀合作伙伴及千余款商品,提供一站式云上应用服务
进入甄选商城进入云市场进入AI Store创新解决方案公有云生态专区智云上海应用生态专区
建站工具
  • 新域名服务
  • SSL证书
  • 翼建站
企业办公
  • 安全邮箱
  • WPS 365 天翼云版
  • 天翼企业云盘(标准服务版)
灾备迁移
  • 云管家2.0
  • 翼备份(SaaS版)

定价

协助您快速了解云产品计费模式、价格详情,轻松预估上云成本
价格计算器
  • 动态测算产品价格
定价策略
  • 快速了解计费模式

合作伙伴

天翼云携手合作伙伴,共创云上生态,合作共赢
天翼云生态合作中心
  • 天翼云生态合作中心
天翼云渠道合作伙伴
  • 天翼云代理渠道合作伙伴
天翼云服务合作伙伴
  • 天翼云集成商交付能力认证
天翼云应用合作伙伴
  • 天翼云云市场合作伙伴
  • 天翼云甄选商城合作伙伴
天翼云技术合作伙伴
  • 天翼云OpenAPI中心
天翼云培训认证
  • 天翼云学堂
  • 天翼云市场商学院
天翼云合作计划
  • 云汇计划
天翼信创云专区
  • 信创云专区
  • 适配互认证

开发者

开发者相关功能入口汇聚
技术社区
  • 专栏文章
  • 互动问答
  • 技术视频
资源与工具
  • OpenAPI中心
培训与认证
  • 天翼云学堂
  • 天翼云认证
开源社区
  • 魔乐社区
  • OpenTeleDB

支持与服务

为您提供全方位支持与服务,全流程技术保障,助您轻松上云,安全无忧
文档与工具
  • 文档中心
  • 新手上云
  • 自助服务
  • OpenAPI中心
定价
  • 价格计算器
  • 定价策略
基础服务
  • 售前咨询
  • 在线支持
  • 在线支持
  • 工单服务
  • 服务保障
  • 会员中心
增值服务
  • 红心服务
  • 首保服务
  • 客户支持计划
  • 专家技术服务
  • 备案管家
我要反馈
  • 建议与反馈
  • 用户体验官
信息公告
  • 客户公告

了解天翼云

天翼云秉承央企使命,致力于成为数字经济主力军,投身科技强国伟大事业,为用户提供安全、普惠云服务
品牌介绍
  • 关于天翼云
  • 智算云
  • 天翼云4.0
  • 新闻资讯
  • 天翼云APP
基础设施
  • 全球基础设施
  • 信任中心
最佳实践
  • 精选案例
  • 超级探访
  • 云杂志
  • 分析师和白皮书
  • 天翼云·创新直播间
市场活动
  • 2026智能云生态大会
  • 2025智能云生态大会
  • 2024智算云生态大会
  • 2023云生态大会
  • 2022云生态大会
  • 天翼云中国行
天翼云
  • 活动
  • 息壤智算
  • 产品
  • 解决方案
  • 应用商城
  • 定价
  • 合作伙伴
  • 开发者
  • 支持与服务
  • 了解天翼云
      • 文档
      • 控制中心
      • 备案
      • 管理中心
      安全生产_相关内容
      • RocketMQ C++ SDK
        收取普通消息 include include include "rocketmq/DefaultMQPushConsumer.h" using namespace rocketmq; class ConcurrentMessageListener : public MessageListenerConcurrently { public: ConsumeStatus consumeMessage(const std::vector &msgs) { for (auto item msgs.begin(); item ! msgs.end(); item++) { std::cout getTopic() getMsgId() setNamesrvAddr("your access point"); consumer>setSessionCredentials("ak", "sk"); ConcurrentMessageListener messageListener new ConcurrentMessageListener(); consumer>subscribe("topicname", "tag"); consumer>registerMessageListener(messageListener); consumer>start(); std::thisthread::sleepfor(std::chrono::seconds(60)); consumer>shutdown(); return 0; } 使用C++客户端收发顺序消息 简介 顺序消息分为两类,全局顺序消息和分区顺序消息,通过队列数区分。 全局顺序: 对于指定的一个 Topic,所有消息的生产和消费需要遵循一定的顺序,消息的消费顺序必须和生产顺序一致,即需要严格的先入先出 FIFO的顺序进行发布和消费。 分区顺序: 对于指定的一个 Topic,其中每一个分区的消息生产与消费是有序的,同一个队列内的消息按照严格的 FIFO 顺序进行发布和订阅。消息投递到哪一个分区由消息的 Sharding Key 来进行区分。在 SDK 中可以通过指定 Sharding Key 和回调函数来控制消息投递到哪个分区。 发送顺序消息 include include include include "rocketmq/DefaultMQProducer.h" using namespace std; using namespace rocketmq; class DefineSelectMessageQueue : public MessageQueueSelector { public: MQMessageQueue select(const std::vector &mqs, const MQMessage &msg, void arg) { //若希望全局有序,请修改对应index int orderId staticcast (arg); int index orderId % mqs.size(); return mqs[index]; } }; int main(){ DefaultMQProducer producer("groupname"); //填写分布式消息服务RocketMQ版的接入点 producer.setNamesrvAddr("your access point"); //填写分布式消息服务RocketMQ版的ak、sk producer.setSessionCredentials("ak", "sk", "channel"); producer.start(); DefineSelectMessageQueue queueSelector new DefineSelectMessageQueue(); int count 64; for (int i 0; i < count; ++i) { MQMessage msg("youtopicname", "TAG", "msg content"); try { SendResult sendResult producer.send(msg, queueSelector, &i, 3, false); std::cout << "SendResult:" << sendResult.getSendStatus() << ", Message ID: " << sendResult.getMsgId() << std::endl; thisthread::sleepfor(chrono::seconds(1)); } catch (MQException e) { std::cout << "ErrorCode: " << e.GetError() << " Exception:" << e.what() << std::endl; } } std::cout << "Send " << count << " messages OK, costs" << std::endl; producer.shutdown(); return 0; }
        来自:
        帮助文档
        分布式消息服务RocketMQ
        SDK参考
        RocketMQ C++ SDK
      • 功能特性
        多样化的数据导入方式 DWS 支持多数据源高效入库,典型的入库方式如下所示。详细指导请参见《数据仓库服务用户开发指南》中的“迁移数据到DWS”章节。 从OBS并行导入数据 使用GDS从远端服务器导入数据 从MRS导入数据到集群 从DWS集群导入数据到新集群 使用gsql元命令COPY导入数据 使用COPY FROM STDIN导入数据 使用CDM迁移数据到DWS 使用DSC工具迁移SQL脚本 使用gsdump和gsdumpall命令导出元数据 使用gsrestore导入数据 应用程序接口 支持调用JDBC(Java database connectivity)、ODBC(Open Database Connectivity)等标准接口开发应用程序访问DWS 集群中的数据库。 详细内容请参见《数据仓库服务用户指南》中“使用JDBC和ODBC连接集群”章节。 高可靠性 通过实例冗余、数据冗余,实现整个系统无单点故障。 数据多副本,且所有数据可手工备份至OBS。 自动隔离有故障的节点,利用副本重新恢复数据,并在必要时替换节点。 自动快照结合OBS存储,实现跨AZ容灾,若用户生产集群所处的地理位置发生自然灾害,或者集群内部出现了故障从而导致生产集群无法正常对外提供读写服务,那么灾备集群可以切换为生产集群,从而保障业务连续性。 当集群状态为“非均衡”时会出现某些节点主实例增多,从而负载压力较大,用户可在业务低峰期进行集群主备恢复操作。 用户使用客户端连接DWS集群时,如果用户仅连接一个CN节点地址,通过该CN节点内网IP或弹性公网IP连接时,只能连接到固定的CN节点上,存在CN单点问题。因此DWS引入了弹性负载均衡服务,解决集群访问的单点问题。弹性负载均衡(ELB)是将访问流量根据转发策略分发到后端多台弹性云主机的流量分发控制服务,可以通过流量分发扩展应用系统对外的服务能力,提高应用程序的容错能力。 当用户集群创建后,实际需要的CN数量会随着业务需求而发生变化,因此DWS提供了增删CN节点功能,实现用户可以根据实际需求动态调整集群CN数量的要求。
        来自:
        帮助文档
        数据仓库服务
        产品简介
        功能特性
      • 流水线管理
        本节主要介绍流水线管理 通过流水线工程可以完成一键部署,实现“源码拉取>编译>打包>归档>部署”的全流程自动化。利于集成环境统一、交付流程标准化。 新版流水线中,将原有流水线的“阶段/任务”泛化模型优化为“构建/环境”模型,每条流水线包含一组构建任务和一组或多组环境(如开发环境、类生产环境、生产环境等)任务,每组环境任务又包含一个或多个子任务(如部署、测试等任务),并提供了模板功能。 创建流水线 1、登录ServiceStage控制台,选择“持续交付 > 发布”,单击“创建流水线”。 2、填写流水线基本信息。 1. 输入“流水线名称”。 2. 设置“企业项目”。 企业项目是一种云资源管理方式,企业项目管理服务提供统一的云资源按项目管理,以及项目内的资源管理、成员管理。 开通企业项目后可以使用。 3. (可选)输入流水线“描述”。 3、选择流水线模板。 ServiceStage内置了典型场景的流水线模板,选择之后自动生成“构建/环境”模型,用户可以直接使用。 表 模板说明 模板名称 说明 操作说明 空模板 需要用户自行添加“构建/环境”模型 根据需要设置,操作步骤请参考步骤3 简易模板 自动添加“构建”模型,对代码库的源码进行编译构建。 操作步骤请参考步骤3 常用模板 自动添加“构建/环境”模型,对代码库的源码进行编译构建, 将产生的软件包或镜像,持续发布到应用的生产环境。 操作步骤请参考步骤3 1. 添加构建任务 单击“选择构建”,选择已创建的构建工程,单击“确定”。 若不存在构建任务,选择“选择构建 > 新建构建任务”,新创建源码构建任务或软件包构建任务,具体操作请参考创建源码构建任务或创建软件包构建任务。 重复此步骤,可以添加多个构建任务。 2. 添加部署任务 单击“添加环境”,输入环境名称。选择已部署的应用组件。 若在该环境下不存在对应应用组件,需创建并部署应用组件,具体步骤请参考部署组件。 “选择构建”选择步骤3中添加的构建任务。 选择构建输出。 重复此步骤,可以添加多个环境。 3. 设置流水线审核 单击环境区域的,设置“审核模式”及“审核者”。 − 审核模式:支持全部通过和单人通过两种方式。 − 审核者:可以选择多个,系统自动加载该帐号下所有子帐号。 4、流水线编辑完成后,单击“创建并执行”启动流水线。 单击“创建”仅保存设置,不执行流水线。
        来自:
        帮助文档
        微服务云应用平台
        用户指南
        持续交付
        流水线管理
      • 购买类问题
        本文主要介绍购买类问题。 存储容灾服务是如何计费的? 存储容灾服务只收取使用SDRS的费用,不包含ECS、EVS等被保护资源的费用。 存储容灾服务按照保护实例个数和使用时长,按小时收费相应的费用。SDRS支持按需计费和资源包计费两种计费方式,详细信息请参考产品价格详情。 按需计费:单个保护实例收取的费用使用时长(小时)单位价格 资源包计费:类似手机的流量套餐,单个资源包每个月包含744小时总可用时长,详细信息请参见资源包如何使用。 由用户创建的生产站点资源保持原有计费方式不变,由SDRS创建的容灾站点资源需要按需收取所使用的ECS和EVS资源的费用,容灾站点创建的ECS默认处于关机状态。ECS和EVS的计费情况请分别参考对应服务的价格详情。 存储容灾服务支持资源包吗? 目前不支持。只支持按需计费。 容灾资源是否需要手动创建? 通过SDRS创建保护实例时,生产站点资源为用户的已有资源,SDRS会自动创建容灾站点所需的资源,不需要用户手动进行创建。 创建的容灾站点资源,需要按需收取所使用的ECS和EVS资源的费用,容灾站点创建的ECS默认处于关机状态。 ECS和EVS的计费情况请分别参考对应服务的价格详情。
        来自:
        帮助文档
        存储容灾服务
        常见问题
        购买类问题
      • 实例节点故障处理
        单节点实例 单节点实例仅有一个 mongod 节点供用户读写访问。如果节点发生故障,系统会对节点进行检查和恢复。但是故障期间实例不可用。 单节点实例主要是在保证数据可靠性的前提下,为用户降低使用成本。适合测试、教学等非核心业务场景。生产环境建议使用集群实例或者副本集实例,保障服务的高可用。
        来自:
        帮助文档
        文档数据库服务
        故障排除
        实例节点故障处理
      • 设置应用生命周期(1)
        停止前处理(PreStop设置) 在应用生命周期管理 区域的停止前处理 (PreStop设置)页签配置PreStop。 说明 CAE提供了两种不同的Shell解释器可供您选择,分别是: > /bin/sh > /bin/bash 例如在容器终止前执行Perform cleanup操作并将其写入到/cleanup.log文件中,然后等待100秒以便进行验证。 (在生产环境中,请根据实际业务场景进行配置。本文提供的示例仅为最小化验证配置功能可用性,不可直接用于生产环境。) 结果验证: 在应用的基础信息 页面,单击停止应用 ,然后使用Webshell 进入应用实例的字符界面,查看/cleanup.log文件是否存在并写入了相应的内容。 优雅下线超时设置(TerminationGracePeriodSeconds) 在应用生命周期管理区域的优雅下线超时设置(TerminationGracePeriodSeconds)页签配置优雅下线超时时间。 如果您设置的优雅下线超时时间小于容器优雅终止的时间(包括PreStop钩子执行耗时和容器处理SIGTERM耗时),则在优雅下线超时时间耗尽时强制终止(信号名称:SIGKILL,退出码:137)容器,导致优雅终止流程中断。例如容器优雅终止的时间为100秒,而设置的优雅超时时间为60秒,那么容器会在优雅终止之前被杀死。
        来自:
      • 产品定义
        本章节介绍故障演练服务的产品定义。 产品定义 故障演练服务是云原生混沌工程平台,深度融合云原生应用产品体系,提供标准化引导、正确性约束和自动化运行的实验管理,支持大规模、低成本、影响可控、形式多样的应用故障演练,帮助企业增强应用系统的容错能力和恢复能力,提升客户应用云上运行的稳定性。 为什么需要故障演练 应用高可用建设往往是基于先验设计的具体实施,描绘一幅全面但静态的蓝图。而问题在于,随着部署环境、流量模式和调用依赖的日益复杂,系统运行时的动态变化远超预设,没人能预判所有潜在问题。每一次故障都是独特的,但故障的成因是可枚举的,从基础设施到上层服务,功能趋同形成内聚的节点,这有限的故障归因,是高可用建设的结果能够预期的基础。 每一种容灾手段就像针对某类疾病的靶向药,从实验室开发到药品上市,要经过一期又一期的临床实验,才能勉力对抗人类基因的无限性,确保药品在广泛的病患群体中取得符合预期的疗效。异常是不可避免的,高可用建设不是消灭异常,而是消化异常。故障演练就是应用高可用的临床实验,在生产的可控范围内进行可预期的异常暴露和处理,随着不断迭代改进,演练形成的风险处置预案就像给系统注入的疫苗,随时应对真实的生产故障。
        来自:
        帮助文档
        应用高可用
        产品简介
        故障演练服务
        产品定义
      • 反向注册
        本文为您介绍反向注册的操作流程。 操作场景 在生产中心的受保护的服务器完成确认故障切换后,可以对容灾中心的云主机进行反向注册操作,为后续的反向复制做准备。完成反向注册后,受保护的服务器将变为容灾中心的云主机。 本示例中ecmtest为生产中心的云主机,ecmrecovery为容灾中心的云主机。 前提条件 受保护的服务器状态为“确认故障切换完成”。 操作步骤 1. 登录控制中心。 2. 单击控制中心左上角的,选择地域。 3. 在存储产品中选择“云容灾”,进入云容灾页面。 4. 在云容灾页面,单击“云上容灾”,进入保护组板块展示页面。 5. 在保护组板块展示页面,找到目标保护组,单击目标保护组板块,进入保护组页面。 6. 在保护组页面,在“受保护的服务器”页签,找到目标主机名,在操作列选择“更多>故障恢复>反向注册”。本节以ecmtest为例。 7. 弹出“反向注册”确认页面,确认信息无误后单击“确定”,云主机状态变为“反向注册中”。 8. 待云主机状态变为“已反向初始化”,说明反向注册完成。 此时,受保护的服务器变为容灾中心的云主机,本示例中为ecmrecovery。
        来自:
        帮助文档
        云容灾 CDR
        用户指南
        故障恢复
        反向注册
      • 停止反向复制
        本文为您介绍停止反向复制的操作流程。 操作场景 反向复制过程中,用户可根据需要停止反向复制。停止反向复制后,容灾中心将停止反向复制数据至生产中心。若想再次进行反向复制,可以重启反向复制。 本示例中ecmtest为生产中心的云主机,ecmrecovery为容灾中心的云主机。 前提条件 受保护的服务器状态为“反向全量复制中”或“反向实时复制中”。 操作步骤 1. 登录控制中心。 2. 单击控制中心左上角的,选择地域。 3. 在存储产品中选择“云容灾”,进入云容灾页面。 4. 在云容灾页面,单击“云上容灾”,进入保护组板块展示页面。 5. 在保护组板块展示页面,找到目标保护组,单击目标保护组板块,进入保护组页面。 6. 在保护组页面,在“受保护的服务器”页签,找到目标主机名,在操作列选择“更多>故障恢复>停止反向复制”。 7. 在弹窗中,确认信息无误后单击“确定”。 若服务器之前状态为反向全量复制中,点击确定后,服务器状态变为反向全量复制停止中,之后变为反向全量复制停止。 若服务器之前状态为反向实时复制中,点击确定后,服务器状态变为反向实时复制停止中,之后变为反向实时复制停止。
        来自:
        帮助文档
        云容灾 CDR
        用户指南
        故障恢复
        停止反向复制
      • 服务基础配置修改建议
        本章节主要介绍服务的基础配置修改建议。 核心原则:混部部署场景下的资源总量控制 在翼 MR 集群中,多个大数据组件(如 HDFS、HBase、YARN 等)可能会部署在同一台 ECS 实例上(即混部场景)。为避免资源竞争导致系统不稳定,请遵循以下基本原则: · 总内存控制 :所有组件 JVM 堆内存之和 ≤ 实例总内存 ×80%。预留至少 20% 的内存给操作系统、Page Cache、堆外内存及突发流量。 · CPU 资源控制 :各组件线程池参数(如 Kafka 的num.io.threads等)配置之和不宜超过实例 vCPU 核数的 2~3 倍,避免过度竞争。 · YARN 资源隔离 :若该节点同时运行 YARN NodeManager,其yarn.nodemanager.resource.memorymb配置不应超过实例总内存的 60%,以保证其他常驻组件的内存安全。 说明 以下各组件配置建议均基于独立部署场景给出。若您采用混部部署,请务必参照上述核心原则,适当调低各组件内存及线程参数。 Doris Doris 所在节点配置升级后,需根据实际内存和磁盘情况调整 FE 和 BE 配置。 FE(Frontend)配置建议 JVM 堆内存 :修改fe.conf中的 JVM 参数。推荐使用 G1 垃圾回收器,堆内存初始与最大值保持一致。生产环境下建议按业务调整, 最大不超过 100 GB 。示例:JAVAOPTS"Xms16g Xmx16g XX:+UseG1GC XX:MaxGCPauseMillis200" 日志路径 :避免将日志放在系统目录。平台默认(翼 MR 版本 ≥ 2.21)会将日志放到数据目录下;低版本需手动修改fe.conf中的LOGDIR、syslogdir、auditlogdir为目标路径。请确保日志盘有至少 50 GB 空间。 日志滚动数量 :syslogrollnum(默认 10 个,每个 1 GB)、auditlogrollnum(默认 30 个,每个 1 GB),可根据需要调整。
        来自:
        帮助文档
        翼MapReduce
        用户指南
        服务配置修改建议
        服务基础配置修改建议
      • ACL策略管理(1)
        ACL 策略指为用户自定义的一组权限规则,允许/拒绝用户通过 IP 或网段 生产/消费 Topic 资源。当前提供有2种匹配方式: 1)预设策略:新建策略时不关联到Topic,新建或编辑Topic时可关联到该ACL策略。 2)前缀模糊匹配策略:前缀模糊匹配策略提供了一种高效的批量授权方式,特别适用于对具有相同前缀的多个Topic进行统一授权管理。当生产环境中存在遵循统一命名规范的Topic时(例如:项目相关Topic都以"project"开头,包括project1、projectb等),可以通过前缀模糊匹配策略快速完成授权配置。一次配置即可覆盖所有匹配前缀的Topic,包括后续新增的Topic。 创建ACL策略 (1)登录管理控制台,进入Kafka管理控制台。 (2)在实例列表页操作列,目标实例行单击“管理”>“用户管理”>“创建用户”。 (3)创建用户,输入用户密码后点击确认,完成用户的创建。如果已经创建了则可以跳过此步骤。 (4)单击”ACL策略管理”>“创建策略”进入配置 ACL 策略页面。 (5)选择其中一种匹配方式(预设策略或前缀模糊匹配)。 (6)如选择前缀模糊匹配策略,则输入Topic前缀字符串,将匹配所有以输入内容为前缀的Topic。 "匹配Topic"里展示的是当前已经匹配到的Topic,后面新建的Topic也能自动匹配上。 (7)输入规则名称,单击“添加规则”绑定策略对应的规则。 规则参数说明: 参数 说明 权限 ACL 策略的操作权限分为两类:允许和拒绝。 若只设置允许规则,则除允许的规则外的其他IP或网段都无法连接实例。 若只设置拒绝规则,则除拒绝的规则外的其他IP或网段需要设置了允许规则后才可以连接实例。 若同时设置允许规则和拒绝规则,则只有允许规则中的IP或网段可以连接实例,其他IP或网段都无法连接实例。 用户 选择需要设置权限的用户。 IP或网段 填写需要设置权限的 IP 或网段,用 ; 隔开,若 IP 为空,则默认为全部 IP 添加权限。 操作 选择策略生效的动作,即向 Topic 生产或消费消息。 自动应用后续所有新增topic 开启后,后续页面上创建的Topic会自动关联此规则,多个策略只允许一条策略开启。 (8)单击“确定”,完成 ACL 策略创建。
        来自:
      • 重启反向复制
        本文为您介绍重启反向复制的操作流程。 操作场景 当受保护的服务器被停止反向复制后,您可以重启反向复制,重新开始容灾中心反向复制数据到生产中心的过程。 本示例中ecmtest为生产中心的云主机,ecmrecovery为容灾中心的云主机。 前提条件 受保护的服务器状态为“反向全量复制停止”或“反向实时复制停止”。 操作步骤 1. 登录控制中心。 2. 单击控制中心左上角的,选择地域。 3. 在存储产品中选择“云容灾”,进入云容灾页面。 4. 在云容灾页面,单击“云上容灾”,进入保护组板块展示页面。 5. 在保护组板块展示页面,找到目标保护组,单击目标保护组板块,进入保护组页面。 6. 在保护组页面,在“受保护的服务器”页签,找到目标主机名,在操作列选择“更多>故障恢复>重启反向复制”。 7. 在弹窗中,确认信息无误后单击“确定”。 若服务器之前状态为反向全量复制停止,点击确定后,服务器状态变为启动反向全量复制中,之后变为反向全量复制中。 若服务器之前状态为反向实时复制停止,点击确定后,服务器状态变为启动反向实时复制中,之后变为反向实时复制中。
        来自:
        帮助文档
        云容灾 CDR
        用户指南
        故障恢复
        重启反向复制
      • 应用组件流水线
        本节主要介绍应用组件流水线 通过流水线工程可以完成一键部署,实现“源码拉取>编译>打包>归档>部署”的全流程自动化。利于集成环境统一、交付流程标准化。 新版流水线中,将原有流水线的“阶段/任务”泛化模型优化为“构建/环境”模型,每条流水线包含一组构建任务和一组或多组环境(如开发环境、类生产环境、生产环境等)任务,每组环境任务又包含一个或多个子任务(如部署、测试等任务),并提供了模板功能。 说明 不支持为运行时为Docker的组件创建流水线。 创建流水线 1、登录ServiceStage控制台,在“应用管理 > 应用列表”界面,单击应用名称,进入应用详情“概览”页。 2、在“组件列表”页签,单击组件名称,进入组件“概览”页。 3、选择“流水线”页签,单击“创建流水线”。 4、填写流水线基本信息。 1. 输入"流水线名称"。 2. (可选)输入流水线"描述"。 5、设置流水线。 1. 添加构建任务 自动加载该组件的构建任务。 2. 添加部署任务 单击“添加环境”,自动加载已部署的组件。 3. 设置流水线审核 单击环境区域的,设置“审核模式”及“审核者”。 审核模式:支持“全部通过”和“单人通过”两种方式。 审核者:可以选择多个,系统自动加载该帐号下所有子帐号。 6、流水线编辑完成后,单击“创建并执行”启动流水线。 单击“创建”仅保存设置,不执行流水线。
        来自:
        帮助文档
        微服务云应用平台
        用户指南
        应用管理
        应用组件流水线
      • 云容器引擎 智算版
        云容器引擎 CCE 智算版是利用云原生架构和技术,在云容器引擎上快速定制化构建AI生产系统,提供智算场景下的调度策略(共享GPU调度、批作业调度、拓扑感知调度)、GPU/RDMA异构资源管理和GPU资源监控基础能力,为用户提供AI数据集管理,AI模型开发、训练、评测,以及模型推理等服务。
        来自:
        帮助文档
        云容器引擎 智算版
      • 函数计算事件目标
        结果验证 1. 触发一次事件,可在对应总线处点击发布事件按钮,生产一个事件。 2. 登录函数计算控制台。 3. 在函数计算控制台页面中,单击目标函数名称。 4. 在目标函数详情页面,单击监控页签,查看对应函数的调用情况,调用时延等信息。如图2所示。
        来自:
        帮助文档
        事件总线
        用户指南
        事件总线
        事件规则
        事件目标
        目标服务类型
        函数计算事件目标
      • 计费样例
        计费模式:按需 例如:用户选择了单机版通用型2C4G的实例,且为按需计费。由于生产需要将实例类型升级为主备版2C4G,其他配置不变。 那么规格扩容后每小时的新增费用为:(主备版2C4G规格按需费用+主备版高IO 100GB按需费用)(单机版2C4G规格按需费用+单机版高IO 100GB按需费用)0.58元/小时。
        来自:
        帮助文档
        关系数据库MySQL版
        计费说明
        计费方式
        计费样例
      • 智算场景NVIDIA GPU镜像组件的安装指南
        5.2 用户升级内核前的准备工作 在生产环境中,建议在进行升级之前进行测试和备份,以确保系统的稳定性和可用性,注意以下几点: ● 备份重要数据:防止意外数据丢失的预防措施。 ● 确保网络连接:下载所需文件和更新。 ● 确认当前系统信息:了解当前内核版本和系统配置。 5.3 用户升级内核方法 使用包管理器APT(Advanced Package Tool)进行内核升级是最简单的方法。进行任何系统更改之前,务必备份重要数据和配置文件,以防意外发生。 查看当前内核版本: uname r 升级步骤如下: (1)更新软件包列表,确保软件包列表是最新的: sudo apt update y (2)升级现有软件包: sudo apt upgrade y (3)搜索可用的内核版本: apt list grep linuximage 查看可用版本 apt list installed grep linuximage 查看已安装版本 (4)安装新内核: sudo apt install linuximage 例如sudo apt install linuximage5.4.0159generic,确保 替换为选择的内核版本号 (5)更新引导加载程序: sudo updategrub 内核升级后需要更新引导加载程序,以便在启动时可以选择新的内核版本。 (6)重新启动系统: 内核升级完成后,重新启动系统,以使更改生效。 reboot (7)验证新内核版本 uname r 5.4 用户升级内核后的注意事项 注意事项: ● 验证内核版本:在重启后,使用 uname r 命令来确保您已经成功切换到了新的内核版本。 ● 检查硬件兼容性:新内核可能会影响硬件兼容性。确保您的硬件(如GPU、网卡等)与新内核兼容。如果您遇到问题,请查看硬件制造商的支持文档。 ● 备份数据:在进行内核升级前,始终备份重要数据。虽然内核升级通常不应影响数据,但出现问题时,数据丢失可能是一种风险。 ● 旧内核保留:通常,旧内核版本不会立即被删除,它们会保留在系统中。这可以用来回滚到旧内核,如果新内核出现问题。 ● 测试系统:在升级后,测试系统以确保所有功能正常工作,特别是与硬件相关的功能。 ● 查阅文档:在执行内核升级之前,查阅官方文档和Ubuntu社区以获取与您特定情况相关的信息和指导。 一些建议: ● 备份配置文件:在升级内核之前,确保备份系统的重要配置文件,例如/etc目录下的文件。这可以帮助您在出现问题时快速还原系统配置。 ● 监控性能:在升级后,监控系统性能,特别是在处理高负载任务时。新内核可能会影响性能,因此及时发现和解决性能问题是重要的。 ● 检查第三方驱动程序:如果您使用第三方硬件驱动程序(如NVIDIA的闭源驱动程序),请确保这些驱动程序与新内核版本兼容。您可能需要更新这些驱动程序以确保它们与新内核一起正常工作。 ● 查看系统日志:定期查看系统日志文件(通常位于/var/log目录下)以获取关于系统健康状况的信息。如果出现与内核相关的错误消息,您可以进一步研究和解决问题。 ● 安全性更新:内核升级通常包括修复安全漏洞的更新。因此,定期升级内核是维护系统安全性的重要一部分。 最重要的是,内核升级应该谨慎进行,特别是在生产环境中。在升级之前,确保您了解新内核版本的特性、改进和潜在问题,并在非关键系统上进行测试,以减小潜在的风险。在升级内核时,持续监控系统,并准备好应对可能出现的问题。
        来自:
        帮助文档
        物理机 DPS
        最佳实践
        智算场景NVIDIA GPU镜像组件的安装指南
      • 权限控制相关
        本小节介绍权限控制相关的常见问题。 客户SSL VPN接入之后,是否能够做到文档权限只能浏览不能下载? VPN Web或者L3VPN接入无法控制应用的内容权限控制。如果客户是出于保密的需求,可以引导使用VDI的桌面云或应用虚拟化技术,所有资源都只能浏览,不能下载。 是否可以做到SSL VPN拨号之后,不允许访问互联网? VPN专线就可以实现,EC和aWork都支持,用户拨号进入VPN之后,不允许访问本地局域网,增强安全性。 SSL VPN与CAS对接认证的场景下,用户角色授权如何实现? CAS认证支持组映射和角色映射。(自M766R1版本开始支持)。 能否限制某个资源只能够从指定IP接入访问? 背景:客户内网有OA和财务系统,OA类的系统在办公网,财务类的系统在生产网,平时访问财务系统都需要切换网线,比较麻烦,打算用VPN统一发布内网业务系统,但要求财务系统通过VPN也只能够在内网使用。 解决方案:维护两套账号,普通账号只能访问OA,不限制接入网络;财务账号可以访问财务系统,但限制接入IP必须是内网。
        来自:
        帮助文档
        SSL VPN(文档停止维护)
        常见问题
        其他操作类
        权限控制相关
      • 安全违规信息类型说明
        危害网络安全类内容 包括但不限于以下违规内容的信息: 利用系统漏洞、捆绑软件、网页挂马、电子邮件、即时聊天工具等途径传播病毒、木马、钓鱼信息等有害程序,可能对用户的正常运行造成损害或中断; 利用网络技术手段或者分享网络技术手段对计算机系统、网络或设备进行破坏、干扰、窃取等违法犯罪行为,包含黑客攻击技术、黑客工具、违规跨境加速或传输服务/软件/教程、违规提供 DNS 解析服务、开展虚拟币“挖矿等违法违规活动。 相关法律法规参考:《中华人民共和国网络安全法》、《计算机信息网络国际互联网安全保护管理办法》、《中国公用计算机互联网国际联网管理办法》、《国际通信出入口局管理办法》、《中华人民共和国刑法》、《关于办理扰乱无线电通讯管理秩序等刑事案件适用法律若干问题的解释》、《中华人民共和国治安管理处罚法》、《关于依法办理非法生产销售使用“伪基站”设备案件的意见》。 违法活动及违禁化学品类 包括但不限于以下违规内容的信息: 发布网络雇凶、网络雇佣追债等违法事件行为。 发布拐卖妇女、儿童、买卖人体器官、提供赴港代孕中介服务、亲子鉴定服务、胎儿鉴定服务等。 发布国家禁止出售的化学品的交易信息,包括但不限于毒品、剧毒化学品、禁止出售的危险化学品、精神类等)。 发布或者存储国家禁止出售的违禁商品/器具类及其相关教程、书籍的交易信息,包括但不限于易燃易爆品、军警服装、管制刀具等)。 相关法律法规参考:《中华人民共和国刑法》、《易制毒化学品管理条例》、《中华人民共和国药品管理法》、《中华人民共和国药品管理法实施条例》、《中华人民共和国禁毒法》、《反兴奋剂条例》、《药品注册管理办法》、《放射性药品管理办法》、《中药品种保护条例》、《麻醉药品和精神药品管理条例》、《互联网药品信息服务管理办法》、《危险品管理条例》等相关法律法规的规定。
        来自:
        帮助文档
        法律声明
        安全管控规则
        安全管控规则
        云平台安全规则细则
        安全违规信息类型说明
      • 注册配置中心实例问题
        本章节介绍注册配置中心常见实例问题 订购的ZooKeeper/Nacos/Eureka实例为什么没有外网地址? 如果购买的实例没有绑定ELB,那么您的实例没有外网地址。您绑定ELB就可以用ELB的地址实现外网访问实例。 Nacos实例升级会不会影响用户正常服务? 对于多节点集群,重启不影响用户服务,实例升级过程中,各节点服务器依次滚动重启,保证用户使用Nacos服务不间断;对于单机实例,重启可能会受到服务中断影响,所以建议生产(线上)环境使用三节点以上的集群进行服务。 生产环境下Nacos设置多少个节点比较好呢? Nacos建议的规格书2n+1个节点,最佳值需根据实际需求和规格能力计算获得。 Nacos支持开源的Nacos控制台吗? 默认不支持访问Nacos开源控制台。 Nacos Client支持哪些版本,推荐使用哪个版本? Nacos Client 1.2.1版本以上均支持,推荐使用Nacos 2.x系列版本的Nacos Client。 MSE里的Nacos服务怎么下线? 服务管理页面,选择指定的命名空间和服务名称,查看服务详情,按服务实例的维度进行下线操作。 如果 注册配置中心的某个实例被删除, 天翼云会提供恢复的解决方案吗?如果有的话需要多久能恢复? 实例过期时间提前7天会有短信通知,实例退订后数据会保留15天,在此期间可以恢复实例。超过时间则无法恢复。
        来自:
        帮助文档
        微服务引擎
        常见问题
        注册配置中心
        注册配置中心实例问题
      • PHP
        编译工程生产消费 引入依赖 composer.json plaintext { "require": { "phpamqplib/phpamqplib":"v3.6.2" } } 生产消息 php channel(); $channel>queuedeclare($queue, false, true, false, false); $channel>exchangedeclare($exchange, AMQPExchangeType::DIRECT, false, true, false); $channel>queuebind($queue, $exchange); $messageBody implode(' ', arrayslice($argv, 1)); $message new AMQPMessage($messageBody, array('contenttype' > 'text/plain', 'deliverymode' > AMQPMessage::DELIVERYMODEPERSISTENT)); $channel>basicpublish($message, $exchange); $channel>close(); $connection>close(); 消费消息 php channel(); $channel>queuedeclare($queue, false, true, false, false); $channel>exchangedeclare($exchange, AMQPExchangeType::DIRECT, false, true, false); $channel>queuebind($queue, $exchange); function processmessage($message) { echo "nn"; echo $message>body; echo "nn"; $message>ack(); // Send a message with the string "quit" to cancel the consumer. if ($message>body 'quit') { $message>getChannel()>basiccancel($message>getConsumerTag()); } } $channel>basicconsume($queue, $consumerTag, false, false, false, false, 'processmessage'); / @param PhpAmqpLibChannelAMQPChannel $channel @param PhpAmqpLibConnectionAbstractConnection $connection / function shutdown($channel, $connection) { $channel>close(); $connection>close(); } registershutdownfunction('shutdown', $channel, $connection); $channel>consume();
        来自:
        帮助文档
        分布式消息服务RabbitMQ
        开发指南
        PHP
      • 什么是多活容灾服务
        本文为您介绍多活容灾服务的定义。 定义 天翼云多活容灾服务(Multiactive Disaster Recovery Service Platform)衍生于用户对数据、应用和业务的多活、高可用需求。通过预案编排、资源同步、智能调度、故障切换等能力组合确保故障场景下用户业务的连续性,实现业务恢复与故障恢复的相互解耦,满足用户对容灾能力的建设要求。产品通过纳管在不同地理位置的云上云下资源,实现数据的分布式存储和处理,从而提高系统的容错能力和抗灾能力,其主要目的是在生产故障发生时,能够迅速地恢复业务运行,减少停机时间和数据丢失,满足用户对RTO和RPO的要求。 特性 产品形态:目前支持3种产品形态,同城多活、同城主备、异地主备。 统一入口:作为云上的统一入口,可基于IaaS和PaaS云产品搭建多活容灾业务系统。 资源隔离:通过命名空间和容灾管理中心实现业务隔离、故障隔离。 故障隔离:通过演练空间实现容灾演练故障隔离,演练过程不影响生产业务。 监控告警:提供网络、应用、云主机、数据库、存储等资源的容灾监控告警功能。 容灾切换:故障监控和容灾切换预案管理,提供不同灾难场景下的自动或手动切换和回切。 容灾演练:故障演练验证容灾架构的可靠性,满足容灾审计要求和验证系统RTO。
        来自:
        帮助文档
        多活容灾服务
        产品介绍
        什么是多活容灾服务
      • 应用SQL审核
        SQL审核功能够对提交的SQL语句进行规范审查,并提供针对性的优化建议。这一功能有助于防止使用未建立索引或格式不规范的SQL语句,从而有效减少SQL注入的安全风险。 前提条件 组织版本为企业版。 目前仅支持MySQL、PostgreSQL、DRDS、Oracle数据库。 功能介绍 在项目开发阶段,业务逻辑和数据显示依赖于数据库的SQL操作。上线前,必须对所有SQL进行严格审核,以防不规范语句影响生产环境。为避免人工审核的低效和资源浪费,DMS提供了SQL审核功能,依据自定义安全规则提出优化建议,如设定表需有主键、主键类型限制等,以提高研发效率和保障数据库规范。SQL相关规则详细配置请参考SQL规范。 操作步骤 创建SQL审核工单 1. 登录DMS控制台。 2. 在左侧导航栏,选择SQL治理 > SQL审核 ,进入SQL审核管理页面。 3. 单击SQL审核按钮,弹出SQL审核工单填写界面,工单需要输入的内容说明见下表1。 4. 填写完SQL审核工单后,单击提交按钮,即完成工单的提交,进入SQL规范检查。 5. SQL审核工单检查通过之后,会自动进入审批流程。管理员将再次确认SQL,审批完成则工单流程结束。 表1 SQL审核工单输入内容说明 输入内容 说明 : 目标实例 必填项,选择执行SQL语句的目标实例,目前支持MySQL,PostgreSQL,DRDS,Oracle数据源。 目标数据库 选填项,选择执行SQL语句的目标数据库。如果未选中目标数据库,则会只检查“离线规则”,“在线规则”和“离线规则”详见 SQL规范。 关联人 选填项,选择需要看到此工单的用户名,关联人可在工单列表页面查看到此工单。 审核内容 必填项,上传或编辑审核内容。 注意 支持单个SQL文件、MyBatis框架XML文件或多文件打包成ZIP。单SQL/XML文件最大2M。ZIP不可超过20M,路径深度最大5层,最多包含200个文件。 如果上传文件为单文件,上传的文件内容将自动解析至输入框中,覆盖输入框内原有内容;如果上传文件为ZIP,上传的文件目录、文件名将自动展示到页面。 工单说明 描述工单备注内容。 说明 检查结果中如果有强制改进项,用户需要改进该项命中的SQL并重新检查通过之后,才能进入审批流程。 如果有建议改进项,不会阻断任务流程,但会出现改进建议。 强制改进和建议改进的定义,详见
        来自:
        帮助文档
        数据管理服务
        用户指南
        SQL治理
        应用SQL审核
      • 环境变量
        概述 API分组环境变量用于在不同的环境(生产,测试,开发)中引用同一个环境变量中不同的值,从而可以灵活引用变量。通常用于动态调整配置项,比如数据库连接、外部服务的 URL、认证密钥等。这减少了硬编码,并使得应用程序能够根据部署环境自动适应配置变化。 创建环境变量 1. 进入API托管>分组管理菜单页 2. 点击环境变量管理,进入环境变量管理页,在对应的环境tab页下点击新增环境变量按钮,填写变量名和变量值进行创建。 注意 每个环境下允许最多创建50个变量;创建同名环境变量时会覆盖已有环境变量值。 删除环境变量 用户可以对环境下的环境变量进行删除操作。注意:删除前请先确保该环境变量没有在API定义中使用。 使用环境变量 创建了环境变量后,可以在API定义中在请求Path、入参默认值、后端服务地址部分加入变量,以 变量名 表示,如请求path可以填写“/ version ”。 当该API定义发布到该环境时,API定义中的变量就会取值对应的变量值,即发布过程中变量标识会被相应环境的变量值替换。例如在生产环境中定义了变量version的值为v1,则上述API的请求path会被解析为/v1。 注意 1. 变量名严格区分大小写。 2. 如果在API定义中设置了变量,那么一定要在要发布的环境上配置变量名&变量值,否则变量无赋值,API将无法正常调用。 3. API调试暂不支持进行环境变量解析。
        来自:
        帮助文档
        微服务引擎
        用户指南
        云原生网关
        API托管
        分组管理
        环境变量
      • 生产者实践
        Batch Batch 的基本思路是:把消息缓存在内存中,并进行打包发送。Kafka 通过 Batch 来提高吞吐,但同时也会增加延迟,生产时应该对两者予以权衡。 在构建 Producer 时,需要考虑以下两个参数: batch.size : 发往每个分区(Partition)的消息缓存量(消息内容的字节数之和,不是条数)达到这个数值时,就会触发一次网络请求,然后客户端把消息真正发往服务器; linger.ms : 每条消息待在缓存中的最长时间。若超过这个时间,就会忽略 batch.size 的限制,然后客户端立即把消息发往服务器。 由此可见,Kafka 客户端什么时候把消息真正发往服务器,是通过上面两个参数共同决定的。batch.size 有助于提高吞吐,linger.ms有助于控制延迟。您可以根据具体业务需求进行调整。 OOM 结合 Kafka 的 Batch 设计思路,Kafka 会缓存消息并打包发送,如果缓存太多,则有可能造成 OOM(Out of Memory)。 buffer.memory : 所有缓存消息的总体大小超过这个数值后,就会触发把消息发往服务器。此时会忽略 batch.size 和 linger.ms 的限制。 buffer.memory 的默认数值是 32 MB,对于单个 Producer 来说,可以保证足够的性能。需要注意的是,如果你在同一个 JVM 中启动多个 Producer,那么每个 Producer 都有可能占用 32 MB 缓存空间,此时便有可能触发 OOM。 在生产时,一般没有必要启动多个 Producer;如果特殊情况需要,则需要考虑buffer.memory的大小,避免触发 OOM。
        来自:
        帮助文档
        分布式消息服务Kafka
        最佳实践
        生产者实践
      • (可选)步骤三:创建Topic
        本文主要介绍步骤三:创建Topic。 Topic,即消息主题。创建Kafka实例成功后,如果没有开启“Kafka自动创建Topic”,需要手动创建Topic,然后才能进行生产消息和消费消息。如果实例开启了“Kafka自动创建Topic”,则该操作为可选,在进行生产时,会自动创建一个Topic,此Topic的默认参数值如下:分区数为3,副本数为3,老化时间为72小时,不开启同步复制和同步落盘。 本文主要介绍手动创建Topic的操作,有以下三种方式,您可以根据实际情况选择任意一种方式: 方式1:在控制台创建 方式2:在Kafka Manager创建 方式3:在Kafka客户端上创建 方式1:在控制台创建 步骤 1 登录分布式消息服务Kafka控制台,选择Kafka实例所在的区域。 步骤 2 在“Kafka专享版”页面,单击Kafka实例的名称,进入实例详情页面。 步骤 3 在“Topic管理”页签,单击“创建Topic”,弹出“创建Topic”对话框。 步骤 4 填写Topic名称和配置信息,单击“确定”,完成创建Topic。 方式2:在Kafka Manager创建 登录Kafka Manager后,在页面顶部选择“Topic > Create”,然后按照界面参数填写即可。 注意 Topic名称开头包含特殊字符,例如下划线“”、 号“ ”时,监控数据无法展示。 方式3:在Kafka客户端上创建 仅在Kafka客户端版本为2.2以上 时,支持通过kafkatopics.sh创建Topic,以及管理Topic的各类参数。 注意 Topic名称开头包含特殊字符,例如下划线“”、
        来自:
        帮助文档
        分布式消息服务Kafka
        快速入门
        (可选)步骤三:创建Topic
      • 黑名单检查
        本文主要介绍黑名单检查 检查项内容 当前检查用户是否处于升级黑名单列表中。 解决方案 CCE基于以下几点原因暂时关闭该集群升级功能: 基于客户提供的信息,该集群被识别为核心重点保障生产集群 正在或即将进行提高集群稳定性的其他运维任务,例如Master节点3AZ改造等。 请联系技术支持人员了解限制原因并申请解除升级限制。
        来自:
        帮助文档
        云容器引擎
        用户指南
        集群管理
        集群升级
        升级前检查
        黑名单检查
      • 生产消费验证
        本文介绍分布式消息服务RocketMQ入门指引的生产消费验证内容。 背景信息 RocketMQ的生产消费验证是指在使用RocketMQ进行消息生产和消费时的验证过程。具体而言,验证包括以下几个方面: 生产者验证:RocketMQ提供了丰富的生产者API,开发人员可以使用这些API将消息发送到RocketMQ的消息队列中。在验证阶段,可以通过发送消息并检查返回结果来确保消息成功发送到Broker节点。此外,生产者还应该验证消息的顺序性、事务性以及可靠性等方面。 消费者验证:RocketMQ的消费者可以订阅特定的消息主题,从而消费这些主题下的消息。在验证阶段,消费者应该能够正确地从Broker节点拉取消息并进行消费处理。消费者还可以验证消息的顺序性、重试机制以及消息过滤等功能。 操作步骤 1、 天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。 2、 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。 3、 进入实例列表,点击【管理】按钮进入管理菜单。 4、 进入Topic管理菜单,点击【拨测】按钮,进行生产消费的拨测验证,验证开通的消息实例和主题。 1)生产测试拨测: 选择消息类型,默认普通消息。 填写需要产生的测试消息数量,以及每条消息的大小,默认每条消息1KB,建议不超过4MB(4096KB)。 选择已建的消息主题,若无选项,请新增主题,详见上文创建主题和订阅组。 点击【测试】按钮,按照已填写规格及数量产生测试消息数据,展示消息数据的信息,包括消息ID(messageID)、发送状态、主题名(topic名)、Broker名、队列ID。 拨测功能涉及消息发送状态码,以下是RocketMQ消息发送状态码及其说明: ✧ SENDOK(发送成功):表示消息成功发送到了消息服务器。 ✧ FLUSHDISKTIMEOUT(刷新磁盘超时):表示消息已经成功发送到消息服务器,但是刷新到磁盘上超时。这可能会导致消息服务器在宕机后,尚未持久化到磁盘上的数据丢失。 ✧ FLUSHSLAVETIMEOUT(刷新从服务器超时):表示消息已经成功发送到消息服务器,但是刷新到从服务器上超时。这可能会导致主从同步不一致。 ✧ SLAVENOTAVAILABLE(从服务器不可用):表示消息已经成功发送到消息服务器,但是从服务器不可用。这可能是由于网络故障或从服务器宕机引起的。 ✧ UNKNOWNERROR(未知错误):表示发送消息时遇到了未知的错误。一般情况下建议重试发送消息。 ✧ MESSAGESIZEEXCEEDED(消息大小超过限制):表示消息的大小超过了消息服务器的限制。需要检查消息的大小是否合适。 ✧ PRODUCETHROTTLE(消息生产被限流):表示消息生产者的频率超出了消息服务器的限制。这可能是由于消息发送频率过高引起的。 ✧ SERVICENOTAVAILABLE(服务不可用):表示消息服务器不可用。这可能是由于网络故障或者消息服务器宕机引起的。 请注意,以上状态码仅适用于RocketMQ消息发送阶段,并且不代表消息是否成功被消费者接收。同时,这些状态码也可能因版本变化而有所不同,建议查阅官方文档获取最新信息。 2)消费测试拨测: 选择消息顺序,下拉选择无序/有序,默认选项为无序。 RocketMQ是一种开源的分布式消息中间件,它支持有序消息和无序消息。 ✧ 有序消息是指消息的消费顺序与发送顺序完全一致。在某些业务场景下,消息的处理需要保证顺序性,例如订单的处理或者任务的执行。RocketMQ提供了有序消息的支持,通过指定消息的顺序属性或使用消息队列的分区机制,可以确保消息按照指定的顺序进行消费。 ✧ 无序消息则是指消息的消费顺序与发送顺序无关。无序消息的特点是高吞吐量和低延迟,适用于一些不要求严格顺序的业务场景,如日志收集等。 在RocketMQ中,有序消息和无序消息的实现方式略有不同。有序消息需要借助MessageQueue的分区机制和消费者端的顺序消息消费来实现。而无序消息则是通过消息的发送和接收的并发处理来实现的。 总的来说,RocketMQ既支持有序消息也支持无序消息,根据业务需求选择合适的消息类型来满足业务的要求。 选择消费方式,目前仅提供pull方式。值得注意的是,RocketMQ还提供了推送(push)方式的消费模式,其中消息队列服务器会主动将消息推送给消费者。但在当前仅限于pull方式的消费模式。 填写消费数量。 下拉选择选择已建的消息主题和订阅组,若无选项,请新增主题和订阅组,详见上文创建主题和订阅组。 点击【测试】按钮,按照已填写规格及数量产生消费数据,展示消息数据的信息,包括消息ID(messageID)、主题名称(topicName)、生成时间、存储时间、队列ID、消费状态。 拨测功能涉及消息消费状态码,RocketMQ消费状态码是指在消息消费过程中,对消费结果进行标识的状态码。以下是常见的RocketMQ消费状态码: ✧ CONSUMESUCCESS(消费成功):表示消息成功被消费。 ✧ RECONSUMELATER(稍后重试):表示消费失败,需要稍后再次进行消费。 ✧ CONSUMEFAILURE(消费失败):表示消息消费出现异常或失败。 ✧ SLAVENOTAVAILABLE(从节点不可用):表示消费者无法访问从节点来消费消息。 ✧ NOMATCHEDMESSAGE(无匹配的消息):表示当前没有匹配的消息需要消费。 ✧ OFFSETILLEGAL(偏移量非法):表示消费的偏移量参数不合法。 ✧ BROKERTIMEOUT(Broker超时):表示由于Broker超时导致消费失败。 5、 用户应用按照规范接入RocketMQ,发送、消费消息。 1)生产者示例API 以下适用于南京3、上海7、重庆2、乌鲁木齐27、保定、石家庄20、内蒙6、晋中、北京5节点。 ctgmq引擎版本,SDK下载方式详见环境准备其他工具章节。 package com.ctg.guide; import com.ctg.mq.api.CTGMQFactory; import com.ctg.mq.api.IMQProducer; import com.ctg.mq.api.PropertyKeyConst; import com.ctg.mq.api.bean.MQMessage; import com.ctg.mq.api.bean.MQSendResult; import com.ctg.mq.api.exception.MQException; import com.ctg.mq.api.exception.MQProducerException; import java.util.Properties; / Producer,发送消息 / public class Producer { public static void main(String[] args) throws InterruptedException, MQException { Properties properties new Properties(); properties.setProperty(PropertyKeyConst.ProducerGroupName, "producergroup"); properties.setProperty(PropertyKeyConst.NamesrvAddr, "10.50.208.1:9876;10.50.208.2:9876;10.50.208.3:9876"); properties.setProperty(PropertyKeyConst.NamesrvAuthID, "app4test"); properties.setProperty(PropertyKeyConst.NamesrvAuthPwd, ""); properties.setProperty(PropertyKeyConst.ClusterName, "defaultMQBrokerCluster"); properties.setProperty(PropertyKeyConst.TenantID, "defaultMQTenantID"); IMQProducer producer CTGMQFactory.createProducer(properties);//建议应用启动时创建 int connectResult producer.connect(); if(connectResult ! 0){ return; } for (int i 0; i mqResultList) { //mqResultList 默认为1,可通过批量消费数量设置 for(MQResult result : mqResultList) { //TODO System.out.println(result); } return ConsumerTopicStatus.CONSUMESUCCESS;//对消息批量确认(成功) //return ConsumerTopicStatus.RECONSUMELATER;//对消息批量确认(失败) } }); } } 以下适用于华东1、华北2、西南1、华南2、上海36、青岛20、长沙42、南昌5、武汉41、杭州7、西南2贵州、太原4、郑州5、西安7、呼和浩特3节点。 rocketmq引擎版本,SDK下载方式详见环境准备其他工具章节。 importorg.apache.rocketmq.client.consumer.DefaultMQPushConsumer; importorg.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus; importorg.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently; importorg.apache.rocketmq.client.exception.MQClientException; publicclassPushConsumer{ public static void main(String[] args) throws Exception{ AclClientRPCHook rpcHook newAclClientRPCHook(newSessionCredentials(ACCESSKEY, SECRETKEY)); DefaultMQPushConsumer consumer new DefaultMQPushConsumer(rpcHook); consumer.setConsumerGroup("ConsumerGroupName"); // 填入元数据地址 consumer.setNamesrvAddr("XXX:xxx"); ; //如果需要开启SSL,请增加此行代码 consumer.subscribe("YOUR TOPIC",""); consumer.registerMessageListener((MessageListenerConcurrently)(msgs, context)>{ System.out.printf("%s Receive New Messages: %s %n",Thread.currentThread().getName(), msgs); returnConsumeConcurrentlyStatus.CONSUMESUCCESS; }); consumer.start(); System.out.printf("Consumer Started.%n"); } } 示例参数说明: Namesrv地址 Namesrv地址可从控制台查看,多个地址按分号分隔。 应用用户和密码 这个应用用户和密码就是控制台创建的应用用户和密码。 租户id和集群名 集群名和租户id可以从应用用户管理查询。 订阅组 消费组名需要在控制台提前创建好。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        快速入门
        生产消费验证
      • 控制台权限管理
        本章主要介绍控制台权限管理 创建用户并授权使用软件开发生产线控制台 如果您需要对您所拥有的软件开发生产线控制台进行精细的权限管理,您可以使用统一身份认证服务(Identity and Access Management,简称IAM),通过IAM,您可以: 根据企业的业务组织,在您的帐号中,给企业中不同职能部门的员工创建IAM用户,让员工拥有唯一安全凭证,并使用软件开发生产线资源。 根据企业用户的职能,设置不同的访问权限,以达到用户之间的权限隔离。 将软件开发生产线资源委托给更专业、高效的其他帐号或者云服务,这些帐号或者云服务可以根据权限进行代运维。 如果帐号已经能满足您的要求,不需要创建独立的IAM用户,您可以跳过本章节,不影响您使用软件开发生产线的其它功能。 本章节为您介绍对用户授权的方法,操作流程如下图所示。 前提条件 给用户组授权之前,请您了解用户组可以添加的软件开发生产线控制台权限,并结合实际需求进行选择,软件开发生产线支持的系统权限,请参见“《软件开发生产线产品介绍》>权限管理”。 示例流程 给用户授予软件开发生产线控制台权限流程 1. 创建用户组并授权 在IAM控制台创建用户组,并授予软件开发生产线控制台只读权限“DevCloud Console ReadOnlyAccess”。 2. 创建用户并加入用户组 在IAM控制台创建用户,并将其加入上面1中创建的用户组。 3. 并验证权限 新创建的用户登录控制台,验证权限: 在“服务列表”中选择软件开发生产线,进入“总览”页面,单击基础版“立即购买”,尝试开通软件开发生产线,如果无法开通软件开发生产线(假设当前权限仅包含DevCloud Console ReadOnlyAccess),表示“DevCloud Console ReadOnlyAccess”已生效。 在“服务列表”中选择除软件开发生产线外(假设当前策略仅包含DevCloud Console ReadOnlyAccess)的任一服务,若提示权限不足,表示“DevCloud Console ReadOnlyAccess”已生效。
        来自:
      • OpenClaw(原Clawdbot)集成企业微信
        本文介绍通过OpenClaw集成企业微信。 概述 OpenClaw(原Clawdbot)是一款开源的本地优先AI 代理与自动化平台。您可以通过OpenClaw将多渠道通信能力与大语言模型深度集成,创建拥有持久记忆与主动执行能力的定制化 AI 助理。本文介绍通过OpenClaw集成企业微信。 重要:OpenClaw 为开源 AI 助手,请在使用前充分评估其安全性与稳定性并严格遵循许可协议,以切实保障您的系统环境与数据安全。 1. 请避免在 OpenClaw 中绑定生产级敏感账号。如需使用 API 服务,建议使用受限的 API Key 或临时 Token,并建立定期轮换机制,以降低密钥泄露带来的风险。 2. 建议优先使用天翼云官方提供的skills与插件,避免安装来源不明的第三方技能,防止恶意代码注入。 3. 请通过密码或 Token 对 OpenClaw 服务进行访问授权,严格限制访问 IP 范围,避免公网暴露,拦截非授权访问请求。 4. 建议启用详细的日志记录与行为监控,对操作行为和数据处理过程进行持续审计,及时发现并处置异常行为。 步骤一:部署OpenClaw 1. 在应用托管部署OpenClaw,详见 通过应用托管部署OpenClaw 。 步骤二:集成企业微信 说明:应用托管的OpenClaw应用最新版本默认已内置企业微信插件,无需额外安装。
        来自:
        帮助文档
        应用托管
        最佳实践
        部署OpenClaw(原Clawdbot)
        OpenClaw(原Clawdbot)集成企业微信
      • 通过智能管理面板配置OpenClaw
        本文介通过智能管理面板配置绍OpenClaw的内容。 前置说明 1.该文档为介绍通过应用托管应用市场体验OpenClaw 智能管理面板的内容。 2.本产品中的应用由第三方主体提供,尽管天翼云已尽最大努力进行识别和维护,但仍无法保证应用的可用性。请客户按照该产品的服务协议使用该产品,做好甄别工作,并对自行选择的服务承担相应责任。 概述 OpenClaw智能管理面板是集网关连接、模型配置、会话交互、日志调试、节点管理于一体的可视化操作界面。面板采用轻量化侧边栏布局,功能模块划分清晰,保障 AI 智能体的高效使用。以下为详细操作步骤。 重要:OpenClaw 为开源 AI 助手,请在使用前充分评估其安全性与稳定性并严格遵循许可协议,以切实保障您的系统环境与数据安全。 1. 请避免在 OpenClaw 中绑定生产级敏感账号。如需使用 API 服务,建议使用受限的 API Key 或临时 Token,并建立定期轮换机制,以降低密钥泄露带来的风险。 2. 建议优先使用天翼云官方提供的skills与插件,避免安装来源不明的第三方技能,防止恶意代码注入。 3. 请通过密码或 Token 对 OpenClaw 服务进行访问授权,严格限制访问 IP 范围,避免公网暴露,拦截非授权访问请求。 4. 建议启用详细的日志记录与行为监控,对操作行为和数据处理过程进行持续审计,及时发现并处置异常行为。
        来自:
        帮助文档
        应用托管
        最佳实践
        部署OpenClaw(原Clawdbot)
        通过智能管理面板配置OpenClaw
      • GPU加速型实例安装GRID驱动
        部署和配置License Server 我们以CentOS 7.5操作系统的云主机为例演示部署和配置License Server。 说明 云主机规格不小于2vCPU,内存不小于4GiB。 请提前记录云主机MAC地址。 如用作生产用途,建议采用高可用模式部署,主备高可用模式部署License Server 请参考NVIDIA官方License Server高可用部署文档( licenseserverhighavailability) 。 1. 配置网络: 1. 如使用VPC网络访问License Server:请确保License Server和使用GRID驱动的GPU加速型实例处在同一个VPC子网内。 2. 如使用公网IP访问License Server:请配置License Server所在的安全组,增加入方向规则:TCP 7070和TCP 8080。 2. 安装License Server。 具体过程请参考NVIDIA官方License Server安装文档 ( installingnvidiagridlicenseserver)。 3. 获取License文件 a. 新建页签,登录NVIDIA网站( SERVERS”。 图 选择LICENSE SERVERS b. 单击“CREATE SERVER”. c. 填写Server Name、Description、MAC Address(License服务器的MAC地址)。 d. 选择Feature,在Licenses框中输入需要的license数目,单击“ADD”。 如果是主备部署的情况需要把备服务器的名称填入 Failover License Server,MAC地址填入Failover MAC Address中。 e. 单击“CREATE LICENSE SERVER”。 图 填写LICENSE SERVERS信息 f. 下载license文件 图 下载license文件 4. 在Web浏览器中,根据安装时配置的管理页面链接,访问License Server管理界面的主页。 默认访问链接为: 5. 单击“License Server > License Management”,使用License服务器配置菜单导入,并单击“Upload”上传许可证.bin文件,完成License Server的配置。 图 上传许可证文件
        来自:
        帮助文档
        弹性云主机 ECS
        用户指南
        实例
        安装驱动和工具包(可选)
        GPU加速型实例安装GRID驱动
      • 1
      • ...
      • 9
      • 10
      • 11
      • 12
      • 13
      • ...
      • 242
      跳转至
      推荐热词
      天翼云运维管理审计系统天翼云云服务平台云服务备份云日志服务应用运维管理云手机云电脑天翼云云hbase数据库电信云大数据saas服务电信云大数据paas服务轻量型云主机天翼云客户服务电话应用编排服务天翼云云安全解决方案云服务总线CSB天翼云服务器配置天翼云联邦学习产品天翼云云安全天翼云企业上云解决方案天翼云产品天翼云视频云存储

      天翼云最新活动

      安全隔离版OpenClaw

      OpenClaw云服务器专属“龙虾“套餐低至1.5折起

      聚力AI赋能 天翼云大模型专项

      大模型特惠专区·Token Plan 轻享包低至9.9元起

      青云志云端助力计划

      一站式科研助手,海外资源安全访问平台,助力青年翼展宏图,平步青云

      出海产品促销专区

      爆款云主机低至2折,高性价比,不限新老速来抢购!

      天翼云信创专区

      “一云多芯、一云多态”,国产化软件全面适配,国产操作系统及硬件芯片支持丰富

      中小企业服务商合作专区

      国家云助力中小企业腾飞,高额上云补贴重磅上线

      云上钜惠

      爆款云主机全场特惠,2核4G只要1.8折起!

      天翼云奖励推广计划

      加入成为云推官,推荐新用户注册下单得现金奖励

      产品推荐

      多活容灾服务 MDR

      GPU云主机

      镜像服务 IMS

      轻量型云主机

      应用托管

      科研助手

      一站式智算服务平台

      智算一体机

      知识库问答

      推荐文档

      集群信息

      产品续订

      编辑

      产品定义

      • 7*24小时售后
      • 无忧退款
      • 免费备案
      • 专家服务
      售前咨询热线
      400-810-9889转1
      关注天翼云
      • 旗舰店
      • 天翼云APP
      • 天翼云微信公众号
      服务与支持
      • 备案中心
      • 售前咨询
      • 智能客服
      • 自助服务
      • 工单管理
      • 客户公告
      • 涉诈举报
      账户管理
      • 管理中心
      • 订单管理
      • 余额管理
      • 发票管理
      • 充值汇款
      • 续费管理
      快速入口
      • 天翼云旗舰店
      • 文档中心
      • 最新活动
      • 免费试用
      • 信任中心
      • 天翼云学堂
      云网生态
      • 甄选商城
      • 渠道合作
      • 云市场合作
      了解天翼云
      • 关于天翼云
      • 天翼云APP
      • 服务案例
      • 新闻资讯
      • 联系我们
      热门产品
      • 云电脑
      • 弹性云主机
      • 云电脑政企版
      • 天翼云手机
      • 云数据库
      • 对象存储
      • 云硬盘
      • Web应用防火墙
      • 息壤智算平台
      • CDN加速
      热门推荐
      • 云服务备份
      • 边缘安全加速平台
      • 全站加速
      • 安全加速
      • 云服务器
      • 云主机
      • 智能边缘云
      • 应用编排服务
      • 微服务引擎
      • 共享流量包
      更多推荐
      • web应用防火墙
      • 密钥管理
      • 等保咨询
      • 安全专区
      • 应用运维管理
      • 云日志服务
      • 文档数据库服务
      • 云搜索服务
      • 数据湖探索
      • 数据仓库服务
      友情链接
      • 中国电信集团
      • 天翼云国际站
      • 189邮箱
      • 天翼企业云盘
      • 天翼云盘
      ©2026 天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
      公司地址:北京市东城区青龙胡同甲1号、3号2幢2层205-32室
      • 用户协议
      • 隐私政策
      • 个人信息保护
      • 法律声明
      备案 京公网安备11010802043424号 京ICP备 2021034386号