阿里云Rocket MQ 管理API Go SDK使用示例Demo

简介: 消息队列 RocketMQ 版产品接口支持 HTTP 调用、SDK 调用和 OpenAPI Explorer 调用,本文主要演示Go SDK的安装和使用。

Step By Step

1、开发环境搭建

阿里云新版人脸识别Go语言调用示例

2、SDK安装

go get -u github.com/aliyun/alibaba-cloud-sdk-go/sdk

3、Code Sample

import (
    "fmt"

    "github.com/aliyun/alibaba-cloud-sdk-go/services/ons"
)

func main() {
    // 阿里云常见参数获取位置:https://developer.aliyun.com/article/693979?spm=a2c6h.13262185.0.0.9a635eb5Guoqxk
    client, err := ons.NewClientWithAccessKey("cn-shanghai", "LTAIOZZg********", "v7CjUJCMk7j9aK****************")

    request := ons.CreateOnsTopicListRequest()
    request.Scheme = "https"

    request.InstanceId = "MQ_INST_18482178********_BXRhsEvb"

    response, err := client.OnsTopicList(request)
    if err != nil {
        fmt.Print(err.Error())
    }
    fmt.Printf("response is %#v\n", response)
}

4、测试结果

response is &ons.OnsTopicListResponse{BaseResponse:(*responses.BaseResponse)(0xc00002a840), RequestId:"941AAB66-E221-46A4-8A46-9231********", HelpUrl:"", Data:ons.DataInOnsTopicList{PublishInfoDo:[]ons.PublishInfoDo{ons.PublishInfoDo{Topic:"newhttptopic", Owner:"18482178********", Relation:1, RelationName:"所有者", CreateTime:1598540117000, Remark:"********", MessageType:0, InstanceId:"MQ_INST_18482178********_BXRhsEvb", IndependentNaming:true}, ons.PublishInfoDo{Topic:"http", Owner:"18482178********", Relation:1, RelationName:"所有者", CreateTime:1598539120000, Remark:"********", MessageType:0, InstanceId:"MQ_INST_18482178********_BXRhsEvb", IndependentNaming:true}}}}

5、异常解决

部分接口请求的时候会出现证书认证异常,可以将:request.Scheme = "https" 替换为:request.Scheme = "http"即可。

更多参考

获取 SDK
阿里云新版人脸识别Go语言调用示例
阿里云常见参数获取位置

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
存储 Java API
【Azure 存储服务】Java Storage SDK 调用 uploadWithResponse 代码示例(询问ChatGTP得代码原型后人力验证)
【Azure 存储服务】Java Storage SDK 调用 uploadWithResponse 代码示例(询问ChatGTP得代码原型后人力验证)
192 0
|
算法 Java Go
运行时管理GO与Java的概要对比
【5月更文挑战第17天】本文介绍Go、Python和Java的运行时机制各异。Go是编译型语言,其runtime负责内存管理、GC和协程调度,强调性能和低延迟。Java的JVM兼顾跨平台和性能,使用字节码和JIT编译,其GC策略复杂且高效。三种语言在设计和优化上各有侧重,适用不同场景。
424 3
|
Java 开发工具
【Azure Developer】示例: 在中国区调用MSGraph SDK通过User principal name获取到User信息,如Object ID
【Azure Developer】示例: 在中国区调用MSGraph SDK通过User principal name获取到User信息,如Object ID
197 1
|
JSON Java API
【Azure API 管理】通过Java APIM SDK创建一个新的API,如何为Reqeust的Representation设置一个内容示例(Sample)?
【Azure API 管理】通过Java APIM SDK创建一个新的API,如何为Reqeust的Representation设置一个内容示例(Sample)?
154 0
|
存储 API 开发工具
【Azure Developer】使用 Python SDK连接Azure Storage Account, 计算Blob大小代码示例
【Azure Developer】使用 Python SDK连接Azure Storage Account, 计算Blob大小代码示例
212 0
|
Java 开发工具 Windows
【Azure Developer】调用SDK的runPowerShellScript方法,在Azure VM中执行PowerShell脚本示例
【Azure Developer】调用SDK的runPowerShellScript方法,在Azure VM中执行PowerShell脚本示例
149 0
|
消息中间件 Shell 数据处理
rocket mq 查看消费进度,消息堆积,清除堆积数据命令
该内容是关于RocketMQ的消费进度管理和堆积数据处理的指导。首先,需进入RocketMQ的bin目录,然后使用`mqadmin consumerProgress`命令查看消费者或生产者的消费进度。`broker offset`和`consumer offset`的差值表示未消费消息。通过`resetOffsetByTime`命令可重置消费位点来清除堆积数据,未消费消息默认3天后会被丢弃。此外,`CONSUME_FROM WHERE`枚举类定义了消费起点选项,包括从最后、最开始或指定时间点消费。
4257 3
|
消息中间件 网络协议 开发工具
MQ产品使用合集之rocketmq5.x只有tcp接入点吗,python sdk需要http接入点,请问怎么使用
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
968 2
|
JSON Go API
go项目实现通过配置文件进行配置项统一管理
go项目实现通过配置文件进行配置项统一管理
210 0
|
Go 持续交付
使用 Makefile 管理和部署 Go 项目
在软件开发中,`Makefile` 用于自动化任务,提升效率。在Go项目中,它简化构建和部署。`Makefile`集成了编译、打包、清理和部署等任务,减少错误,提高效率。通过定义规则和依赖,`make`工具执行任务。示例展示了如何创建`Makefile`进行Go应用的自动化部署,包括构建、传输、停启服务。通过`make deploy-dev`一键执行部署流程。`Makefile`不仅简化部署,还可扩展实现更多复杂自动化,提升开发流程的专业性和效率。
216 0