检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RabbitMQ实例开启SSL后,证书怎么获取? RabbitMQ 3.x.x版本实例开启SSL后只做单向认证,不需要证书。 父主题: 实例问题
Exchange上,并赋予该绑定一个Routing Key,此Routing Key包含通配符。 当一个携带着Routing Key的消息被发送给Topic Exchange时,Topic Exchange会将Routing Key进行通配符匹配,如果匹配成功,则将它路由给对应的Queue。
CLOUD_SDK_SK in the local environment String ak = System.getenv("CLOUD_SDK_AK"); String sk = System.getenv("CLOUD_SDK_SK");
种进行认证鉴权。 AK/SK认证:通过AK(Access Key ID)/SK(Secret Access Key)加密调用请求。推荐使用AK/SK认证,其安全性比Token认证要高。 Token认证:通过Token认证调用请求。 AK/SK认证 AK/SK签名认证方式仅支持消息
的绑定。 命令行模式连接实例 登录客户端所在服务器。 下载RabbitMQ-Tutorial-SSL.zip示例工程代码。 wget https://dms-demo.obs.cn-north-1.myhuaweicloud.com/RabbitMQ-Tutorial-SSL.zip
SSL方式连接RabbitMQ实例失败? 首先排查安全组的入方向规则,是否放开了端口5671(SSL方式访问)或5672(非SSL访问)。 其次,参考如下内容配置SSL单向认证: 1 2 3 4 5 6 7 8 ConnectionFactory factory =
<version>2.3.1.RELEASE</version> </dependency> (可选)在application.properties文件中填写配置 如果RabbitMQ实例已开启SSL,在“application.properties”文件中填写如下配置。 #开启SSL认证 spring
Routing Key 设置Key值字符串,用于告知Exchange应该将消息投递到哪些目标Exchange中。 Direct Exchange和Topic Exchange需要设置Routing Key,Exchange会将消息路由到Routing Key匹配成功的目标Exchange中。如果不设置Routing
“x-dead-letter-routing-key”参数。队列根据“x-dead-letter-exchange”将死信消息发送到死信交换机中,并根据“x-dead-letter-routing-key”为死信消息设置死信路由Key。 以下示例演示在Java客户端配置死信交换机和路由:
"routing_key" : "binding_key_demo" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 将test-exchange作为源端,与目标端为Queue类型的mirror-queue绑定,绑定路由键为routing_key_1。 1
ype/{destination_type}/destination/{destination}/properties-key/{properties_key}/unbinding 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。
direct:该类型Exchange会将消息路由到Routing Key完全匹配的Queue中。 fanout:该类型Exchange会将消息路由到所有与其绑定的Queue中。 topic:该类型Exchange将Routing Key进行通配符匹配,然后将消息路由到匹配成功的Queue中。
在下拉框中选择需要绑定的目标Queue。 Routing Key 设置Key值字符串,用于告知Exchange应该将消息投递到哪些Queue中。 Direct Exchange和Topic Exchange需要设置Routing Key,Exchange会将消息路由到Routing Key匹配成功的Queue中。如果不设置Routing
CLOUD_SDK_SK in the local environment String ak = System.getenv("CLOUD_SDK_AK"); String sk = System.getenv("CLOUD_SDK_SK");
"destination" : "queue-test", "routing_key" : "test-routing-key", "properties_key" : "test-routing-key" } ] } SDK代码示例 SDK代码示例如下。 Java Python
encoding='utf-8') channel.basic_publish(exchange='', routing_key=conf['queue_name'], body=data) print(" [x] Sent
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 access_key 否 String 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。 secret_key 否 String 密钥。 8-32个字符。 至少包含以下字符中的3种:
状态码: 200 查询实例标签成功。 { "tags" : [ { "key" : "key1", "value" : "value1" }, { "key" : "key2", "value" : "value2" } ] } SDK代码示例
CLOUD_SDK_SK in the local environment String ak = System.getenv("CLOUD_SDK_AK"); String sk = System.getenv("CLOUD_SDK_SK");
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 access_key 否 String 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。 secret_key 否 String 密钥。 8-32个字符。 至少包含以下字符中的3种: