检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
请参见如何调用API。 URI GET /v2/rabbitmq/{project_id}/instances/{instance_id}/vhosts/{vhost}/exchanges/{exchange}/binding 表1 路径参数 参数 是否必选 参数类型 描述 project_id
ce_id}/vhosts/{vhost}/queues/{queue} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID vhost 是 String
d}/vhosts/{vhost}/queues 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID vhost 是 String Vhost名称 请求参数
RELEASE</version> </dependency> (可选)在application.properties文件中填写配置 如果RabbitMQ实例已开启SSL,在“application.properties”文件中填写如下配置。 #开启SSL认证 spring.rabbitmq.ssl.enabled=true
d}/vhosts/{vhost}/queues 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID vhost 是 String Vhost名称 请求参数
ance_id}/vhosts/{vhost}/exchanges 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID vhost 是 String 所属Vhost名称
= "{user_name}" vhostVhosts:= "default" confVhosts:= "^janeway-.*" writeVhosts:= ".*" readVhosts:= ".*" var listVhostsbody = []model.AmqpUserPerm{
InstanceId = "{instance_id}" vhostVhosts:= "default" confVhosts:= ".*" writeVhosts:= ".*" readVhosts:= ".*" var listVhostsbody = []model.AmqpUserPerm{
开启RabbitMQ ACL访问 通过ACL可以实现对RabbitMQ实例中生产者和消费者身份的精确识别,为不同用户赋予不同的Vhost和Vhost下不同资源的权限,以达到不同用户之间权限隔离的目的。开启ACL权限控制功能后,生产消息和消费消息时,需要鉴权。 仅RabbitMQ
new ConnectionFactory(); factory.setHost(host); factory.setPort(port); factory.setVirtualHost("VHOST_NAME"); factory.setUsername(user);
new ConnectionFactory(); factory.setHost(host); factory.setPort(port); factory.setVirtualHost("VHOST_NAME"); factory.setUsername(user);
RabbitMQ实例Vhost 1分钟 vhost_channels 通道数 统计该Vhost中的总通道数。 单位:个 >= 0 RabbitMQ实例Vhost 1分钟 vhost_queues 队列数 统计该Vhost中的总队列数。 单位:个 >= 0 RabbitMQ实例Vhost 1分钟
含预编译好的jar文件。 cd RabbitMQ-Tutorial 运行生产消息示例。 java -cp .:rabbitmq-tutorial.jar Send ${host} ${port} ${user} ${password} 参数说明如下: host:从创建实例中获取的连接地址。
在左侧导航栏选择“消息查询”,进入消息列表页面。 参考表1,设置查询参数。 表1 查询消息参数说明 参数名称 说明 Vhost 选择待查询消息所属的Vhost。 Queue 选择待查询消息所属的Queue。 存储时间 选择消息存储到Queue的时间。 单击“查询”,查询消息。 查询结果如下:
再次输入密码,确认本次输入的密码和“密码”中输入的一致。 Vhost 可访问的Vhost:在下拉框中选择用户可以访问的Vhost。 可配置的资源:为用户授予Vhost下资源的权限,使用正则表达式匹配资源。例如输入“^test-.*”,表示为用户授予Vhost下所有名称以“test-”开头的资源的权限。
不能与名称或倒序的名称相同。 vhosts Array of AMQPUserPerm objects 需要配置权限的Vhost,一个用户可以配置多个Vhost下的资源权限。 表5 AMQPUserPerm 参数 参数类型 描述 vhost String 需要配置权限的Vhost名称,一个用户可以配置多个Vhost下的资源权限。
新规格实例的规格变更 Vhost管理 包括: 创建Vhost 查询Vhost列表 批量删除指定Vhost Exchange管理 包括: 创建Exchange 查询Exchange列表 批量删除指定Exchange Queue管理 包括: 创建Queue 查询所属Vhost下Queue的列表
x版本实例在监控页面中,队列名称存在两种显示。如果队列在默认Vhost下,会直接显示队列名。如果队列不在默认Vhost下,队列名称显示为:队列所在的Vhost名称_队列名。例如:队列test01在Vhost-13142708中,此时监控中显示的队列名为“Vhost-13142708_test01”。 图1
以下加粗内容需要替换为实例自有信息,请根据实际情况替换。 SSL认证方式 import pika import ssl # 连接信息 conf = { 'host': 'ip', 'port': 5671, 'queue_name': 'queue-test', 'username':
Queue名称。 vhost String 对应的Vhost。 表8 vhosts 参数 参数类型 描述 name String Vhost名称。 表9 exchanges 参数 参数类型 描述 name String Exchange名称。 vhost String 对应的Vhost。 表10