RabbitMQ虚拟主机_rabbitmq 虚拟主机

前言

代码在仓库里有https://gitee.com/song_mengyu/Example/tree/master/Project/rabbit-vhost

一、介绍

每一个RabbitMQ服务器都能创建虚拟的消息服务器，我们称之为虚拟主机（virtual host)，简称vhost.每一个vhost是一个独立的小型服务器，拥有自己独立的队列，交换器等。它拥有自己独立的权限。vhost之于这个RabbitMQ服务器就像虚拟机于物理服务器一样。它能将众多客户分割开来，又可以避免队列和交换器等的命名冲突。vhost之间是绝对隔离的。
通常来讲，默认的vhost名字是"/".

二、创建

使用命令行模式

rabbitmqctl add_vhost  [name]   //添加vhost
rabbitmqctl delete_vhost[name]  //删除vhost
rabbitmqctl list_vhosts   显示vhost列表
1
2
3

这样就是创建成功
然后就需要为某个用户添加对于这个vhost的权限

rabbitmqctl set_permissions -p [vhost_name] [username] [conf] [write] [read]
rabbitmqctl set_permissions -p vhost1 admin ".*" ".*" ".*" //我的示例
1
2

也可以用网页管理工具，按图片上这样就可以创建
这样创建完，是默认admin对这个新的vhost有权限。如果想添加其它用户的支持
对这个vhost进行配置
然后进行配置就可以了

三、代码

首先yml 文件

server:
  port: 8080
spring:
  application:
    name: vhost1
  rabbitmq:
    host: 192.168.136.128
    port: 5673
    username: admin
    password: admin
    virtual-host: vhost1
1
2
3
4
5
6
7
8
9
10
11

然后config类

package com.my;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class Config {
    @Bean
    public Queue queue(){
        return new Queue("queue");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13

最后是Controller

package com.my;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class Controller {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @GetMapping("/send")
    public String send(){
        rabbitTemplate.convertAndSend("queue", "hello!");
        return "ok";

    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

这是vhost1的，而vhost2,只需要复制然后在yml里改个vhost的配置即可。

四、结果

可以看出vhost1里和vhost2都有一个名为queue队列，但是里边的消息数是不同的，这意味着这vhost1和vhost2是互不影响的