OSS私有Bucket回源
在 信任策略 页签，单击 编辑信任策略，输入以下信息之后单击 保存信任策略。{"Statement":[{"Action":"sts:AssumeRole","Effect":"Allow","Principal":{"Service":["cdn.aliyuncs.com" ]} }],"Version":"1"} 切换到 权限管理 页签，单击 ...
SIP软电话接入流程
证书配置包含两种方案，一是仅信任指定证书，二是信任所有证书。第一种方案安全性更高，但是配置流程更复杂，需要安装云呼颁发的指定证书，第二种方案配置更简单，但是安全性稍低，适合普通用户使用。如果客户对安全性没有特别严格的要求，...
OSS私有Bucket回源
在 信任策略 页签，单击 编辑信任策略，输入以下信息之后单击 保存信任策略。{"Statement":[{"Action":"sts:AssumeRole","Effect":"Allow","Principal":{"Service":["cdn.aliyuncs.com" ]} }],"Version":"1"} 切换到 权限管理 页签，单击 ...
使用服务鉴权实现Spring Cloud应用的访问控制
例如，在设置所有Path的鉴权方式下，Consumer 2、Consumer 3可以访问Provider的所有Path，但Provider的Path 2涉及一些核心业务或数据，不希望Consumer 2调用，可以将Path 2对Consumer 2的鉴权方式设置为黑名单（拒绝调用），则Consumer 2...
使用服务鉴权实现Dubbo应用的访问控制
例如，在设置所有Path的鉴权方式下，Consumer 2、Consumer 3可以访问Provider的所有Path，但Provider的Path 2涉及一些核心业务或数据，不希望Consumer 2调用，可以将Path 2对Consumer 2的鉴权方式设置为黑名单（拒绝调用），则Consumer 2...
迁移数据上云
bin/kafka-consumer-groups.sh-new-consumer-describe-bootstrap-server自建集群接入点-group test-consumer-group 往自建集群中发送消息，在 云消息队列 Kafka 版 控制台中查看Topic的分区状态，确认当前服务器上消息总量是否正确。...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），...Single active consumer 不支持。支持。
basic-auth插件
使用_rules_字段进行细粒度规则配置 consumers:credential:'admin:123456' name:consumer1-credential:'guest:abc' name:consumer2_rules_:#规则一：按路由名称匹配生效-_match_route_:route-a-route-b allow:consumer1#规则二：按域名匹配...
教程示例：基于RAM角色实现跨账号访问OSS
如果您希望创建的RAM角色只能被可信阿里云账号下的指定RAM用户或者RAM角色扮演，则需要对已创建RAM角色的信任策略进行手动修改。更多信息，请参见 修改RAM角色的可信实体为阿里云账号。为RAM角色授权。在 角色 页面，单击目标角色 admin-...
配置白名单
该选项一般用于放行您完全信任的流量，例如，受信任的漏洞扫描工具的访问、已认证的第三方系统接口的访问等。自定义生效模块：表示命中匹配条件的请求不受指定的防护规则的检测。基础防护规则：表示命中匹配条件的请求不受指定的基础防护...
订阅消息
订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个Consumer实例，那么在集群消费模式下每个实例平均分摊，只消费其中的3...
SAE控制台镜像部署
Serverless 应用引擎 SAE（Serverless App Engine）支持以镜像方式部署应用 与任务模板。本文介绍SAE拉取镜像的方式、配置路径以及如何通过SAE控制台选择并部署不同类型的镜像。背景信息 SAE支持免密拉取镜像和保密字典拉取镜像两种方式。...
update_check_point
请求语法 aliyunlog log update_check_point-project=<value>-logstore=<value>-consumer_group=<value>-shard=<value>-check_point=[-consumer=][-force_success=][-access-id=][-access-key=][-sts-token=][-region-endpoint=][-client-...
应用场景
服务治理与业务逻辑解耦 在运行时，SDK 和业务应用的代码是混合在一个进程中运行的，耦合度非常高，会产生如下问题：升级成本高：每次升级都需要业务应用修改 SDK 版本号，重新发布。在业务飞速发展的时候，更倾向于专注业务，不希望分散...
IDaaS 术语表
零信任 零信任是一套新兴网络架构，行业内普遍采用。零信任架构打破了原有的可信网络环境边界，要求所有服务访问均需要可信身份、合理授权，有效提高了整体网络架构安全性和使用便捷性，在远程办公、多云架构、BYOD 等现代办公条件中...
配置推空保护
展开查看YAML文件#开启推空保护的 sc-consumer apiVersion:apps/v1 kind:Deployment metadata:name:sc-consumer spec:replicas:1 selector:matchLabels:app:sc-consumer template:metadata:labels:msePilotCreateAppName:sc-consumer app:...
如何在控制台管理Consumer的offset？
本文说明Consumer在读取消息异常中断后，如何在控制台管理Consumer的offset。消费消息并不保证会提交消费位点，Broker记录的是客户端提交的消费位点。提交消费位点的机制取决于您使用的客户端SDK，一般支持以下两种机制：自动提交：按照...
key-auth插件
consumers:credential:2bda943c-ba2b-11ec-ba07-00163e1250b5 name:consumer1-credential:c8c8e9ca-558e-4a2d-bb62-e700dcc40e35 name:consumer2 keys:apikey-x-api-key#使用_rules_字段进行细粒度规则配置_rules_:#规则一：按路由名称匹配...
广播拉取消息模型
null){ System.out.println("consumer1 receive message:"+consumer1Msg.getMessageBodyAsRawString());} else{ System.out.println("the queue is empty");} Message consumer2Msg=queueForConsumer2.popMessage(30);if(consumer2Msg!null...
订阅消息
订阅方式 消息队列支持以下两种订阅方式：集群订阅同一个 Group ID 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息，一个 Group ID 有 3 个 Consumer 实例，那么在集群消费模式下每个实例平均分摊，只消费其中的 3 ...
ConsumerGroupUpdateCheckPoint
404 ConsumerNotExist consumer not exist in the consumer group.消费组中不存在该消费者。404 ShardNotExist shard not exist.Shard不存在。500 InternalServerError Specified Server Error Message.内部服务调用错误。更多信息，请参见...
ConsumerGroup
test-consumer-group timeout integer 超时时间。在超时时间段内没有收到心跳，消费者将被删除。单位：秒。300 order boolean 是否按顺序消费。true：在 Shard 中按顺序消费。Shard 分裂后，先消费原 Shard 中数据，然后同时消费由该 Shard...
Node.js SDK收发消息
console.log(config)var consumer=new Kafka.KafkaConsumer({/*'debug':'all',*/'api.version.request':'true','bootstrap.servers':config['bootstrap_servers'],'group.id':config['consumer_id']});consumer.connect();consumer.on('...
get_check_point
aliyunlog log get_check_point-project="aliyun-test-project"-logstore="logstore-a"-consumer_group="consumer-group-1"-shard_id=1 返回示例[{"checkpoint":"MTUyNDE1NTM3OTM3MzkwODQ5Ng=","consumer":"consumer-group-1","shard":1,...
oauth插件
consumers:name:consumer1 client_id:12345678-xxxx-xxxx-xxxx-xxxxxxxxxxxx client_secret:abcdefgh-xxxx-xxxx-xxxx-xxxxxxxxxxxx-name:consumer2 client_id:87654321-xxxx-xxxx-xxxx-xxxxxxxxxxxx client_secret:hgfedcba-xxxx-xxxx-xxxx...
收发顺序消息
consumer.registerMessageListener(new MessageListenerOrderly(){@Override public ConsumeOrderlyStatus consumeMessage(List<MessageExt>msgs,ConsumeOrderlyContext context){ context.setAutoCommit(true);System.out.printf("%s ...
消息过滤
Consumer consumer=ONSFactory.createConsumer(properties);只订阅Tag的值为tagA且属性price大于30的消息。consumer.subscribe("topicA",MessageSelector.bySql("TAGS IS NOT NULL AND price IS NOT NULL AND TAGS='tagA' AND price>30"),...
配置相关
Consumer consumer=ONSFactory.createConsumer(properties);consumer.subscribe("TestTopic","*",new MessageListener(){ publicAction consume(Message message,ConsumeContext context){ System.out.println("Receive:"+message);return ...
logstash-input-sls插件使用说明
project"logstore=>"logstore1"consumer_group=>"consumer_group1"consumer_name=>"consumer1"position=>"end"checkpoint_second=>30 include_meta=>true consumer_name_with_ip=>true } } output { elasticsearch { hosts=>[...
ConsumerGroupHeartBeat
consumer String Query 是 consumer_1 消费者。Array of Integer Body 是[0]正在消费的Shard ID列表。返回数据 名称 类型 示例值 描述 Date String Sun,27 May 2018 08:25:04 GMT 返回响应的时间。Server String nginx 服务器名称。x-log-...
消息幂等
负载均衡时消息重复（包括但不限于网络抖动、服务端重启以及Consumer应用重启）当 云消息队列 RabbitMQ 版 的服务端或客户端重启、扩容或缩容时，会触发Rebalance，此时Consumer可能会收到重复消息。处理方法 以Message ID为幂等键对消息...
订阅消息
说明 请确保同一个Group ID下所有Consumer实例的订阅关系保持一致。更多信息，请参见 订阅关系一致。云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息...
jwt-auth插件
当没有匹配到 route-b 路由时，因为全局配置中 global_auth 设置为了 true，表明对所有请求开启认证，所以将进行JWT认证，并且允许 consumer1 和 consumer2 都能访问。域名级别开启，但特定路由关闭 consumers:name:consumer1 issuer:abcd ...
配置服务鉴权
设置指定Path的鉴权 在设置所有Path的鉴权基础上，还可以设置Consumer指定Path的鉴权规则，例如按所有Path的鉴权方式，Consumer 2、3可以访问Provider的所有Path，但Provider的Path2涉及一些核心业务或数据，不希望Consumer 2调用，可以将...
使用Cloud Toolkit快速创建Dubbo工程
本文将介绍如何在IntelliJ IDEA使用Cloud Toolkit创建Apache Dubbo应用样例工程（包含一个Provider和Consumer），并完成本地调用验证。前提条件 确保您在IntelliJ IDEA中安装和配置Cloud Toolkit版本在2019.6.2及以上，安装步骤请参见 在...
接口和参数说明
背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push：消息由 云消息队列 RocketMQ 版 推送至Consumer。Push方式下，云消息队列 RocketMQ 版 还支持批量消费功能，可以将消息统一批量推送至Consumer进行消费。更多信息，请...
收发定时消息和延时消息
背景信息 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费，该消息即定时消息。延时消息：Producer将消息发送到 云消息队列 ...
Ruby SDK收发消息
ssl_ca_cert:File.read('./cert.pem'),sasl_plain_username:username,sasl_plain_password:password,)consumer=kafka.consumer(group_id:consumerGroup)consumer.subscribe(topic,start_from_beginning:false)trap("TERM"){ consumer.stop ...
ConsumerGroupUpdateCheckPoint-更新消费进度
404 ConsumerNotExist consumer not exist in the consumer group.消费组中不存在该消费者。404 ShardNotExist shard not exist.Shard 不存在。500 InternalServerError Specified Server Error Message.内部服务调用错误。更多信息，请...
通过消费组消费日志
consumer_group='consumer-group-1' consumer_name1="consumer-group-1-A"consumer_name2="consumer-group-1-B"token=""if not logstore:logstore='consumer_group_test_'+str(time.time()).replace('.','_')assert endpoint and ...
- 产品推荐
- 这些文档可能帮助您