【消息队列开发】 虚拟主机设计——操作队列

// 创建队列
public boolean queueDeclare(String queueName, boolean durable, boolean exclusive, boolean autoDelete,
                            Map<String, Object> arguments) {
    // 把队列的名字, 给拼接上虚拟主机的名字.
    queueName = virtualHostName + queueName;
    try {
        synchronized (queueLocker) {
            // 1. 判定队列是否存在
            MSGQueue existsQueue = memoryDataCenter.getQueue(queueName);
            if (existsQueue != null) {
                System.out.println("[VirtualHost] 队列已经存在! queueName=" + queueName);
                return true;
            }
            // 2. 创建队列对象
            MSGQueue queue = new MSGQueue();
            queue.setName(queueName);
            queue.setDurable(durable);
            queue.setExclusive(exclusive);
            queue.setAutoDelete(autoDelete);
            queue.setArguments(arguments);
            // 3. 写硬盘
            if (durable) {
                diskDataCenter.insertQueue(queue);
            }
            // 4. 写内存
            memoryDataCenter.insertQueue(queue);
            System.out.println("[VirtualHost] 队列创建成功! queueName=" + queueName);
        }
        return true;
    } catch (Exception e) {
        System.out.println("[VirtualHost] 队列创建失败! queueName=" + queueName);
        e.printStackTrace();
        return false;
    }
}

// 删除队列
public boolean queueDelete(String queueName) {
    queueName = virtualHostName + queueName;
    try {
        synchronized (queueLocker) {
            // 1. 根据队列名字, 查询下当前的队列对象
            MSGQueue queue = memoryDataCenter.getQueue(queueName);
            if (queue == null) {
                throw new MqException("[VirtualHost] 队列不存在! 无法删除! queueName=" + queueName);
            }
            // 2. 删除硬盘数据
            if (queue.isDurable()) {
                diskDataCenter.deleteQueue(queueName);
            }
            // 3. 删除内存数据
            memoryDataCenter.deleteQueue(queueName);
            System.out.println("[VirtualHost] 删除队列成功! queueName=" + queueName);
        }
        return true;
    } catch (Exception e) {
        System.out.println("[VirtualHost] 删除队列失败! queueName=" + queueName);
        e.printStackTrace();
        return false;
    }
}