rabbitmq常用配置

以下是 RabbitMQ 常用配置：

1. 配置文件路径：RabbitMQ 的配置文件位于 /etc/rabbitmq/rabbitmq.conf 或 %APPDATA%\RabbitMQ\rabbitmq.conf。

2. 端口号：RabbitMQ 默认端口为 5672，如果您需要使用 SSL 加密连接，则需要使用 5671 端口。

3. 用户名和密码：默认的用户名和密码为 guest/guest，建议在生产环境下更改为更安全的凭据。

4. 虚拟主机：虚拟主机是 RabbitMQ 中的逻辑概念，它提供了隔离不同应用程序之间的消息队列。默认虚拟主机为 /。

5. 消息持久化：如果您希望消息在 RabbitMQ 重新启动后仍然存在，则需要将消息标记为持久化。

6. 集群：RabbitMQ 支持将多个节点组成集群，以提高可用性和容错能力。集群中的节点可以相互通信并共享消息。

7. 日志记录：RabbitMQ 的日志记录功能可以帮助您诊断和解决问题。您可以在配置文件中设置日志级别和日志位置。

8. 插件：RabbitMQ 提供了许多插件，可以扩展其功能，如管理插件、STOMP 插件和 MQTT 插件等。您可以在配置文件中启用或禁用插件。

以上是 RabbitMQ 常用配置，您可以根据需要进行相应的配置。

相关问题

rabbitmq 常用命令

RabbitMQ 是一个开源的消息队列系统，常用于分布式应用之间的通信。以下是一些常用命令，它们可以帮助你管理和监控 RabbitMQ 集群：

1. ** rabbitmq-plugins list **：列出所有安装的 RabbitMQ 插件。
2. ** rabbitmq-server start/stop/restart **：启动、停止或重启 RabbitMQ 服务器。
3. ** rabbitmqctl status **：检查 RabbitMQ 服务的状态。
4. ** rabbitmqctl list_users **：查看当前用户列表。
5. ** rabbitmqctl add_user [username] [password] **：添加新用户。
6. ** rabbitmqctl set_user_tags [username] administrator **：设置用户角色（如管理员）。
7. ** rabbitmqctl create_vhost [vhost_name] **：创建虚拟主机。
8. ** rabbitmqctl delete_vhost [vhost_name] **：删除虚拟主机。
9. ** rabbitmqctl list_vhosts **：列出所有虚拟主机。
10. ** rabbitmq-plugins enable [plugin_name] **：启用插件。
11. ** rabbitmqctl list_exchanges [vhost_name] [--tree] **：查看交换机（包括树形结构）。
12. ** rabbitmqctl declare_exchange [exchange_name] [type] [vhost_name] **：声明交换机。
13. ** rabbitmqctl declare_queue [queue_name] [vhost_name] [--durable] [--auto_delete] **：声明队列。
14. ** rabbitmqctl bind_queue [queue_name] [exchange_name] [routing_key] [vhost_name] **：绑定队列到交换机。
15. ** rabbitmqctl consume [queue_name] [consumer_tag] [--no_ack] **：消费消息。
16. ** rabbitmqctl cancel_consumer [consumer_tag] **：取消消费者。

这些命令需要在控制台上输入，并且通常在拥有管理权限的用户环境下运行。注意，生产环境中的操作应谨慎，避免误删或影响正常服务。如果你需要更详细的信息，可以查阅 RabbitMQ 的官方文档。

帮我写个rabbitmq 常用的java工具类

好的，下面是一个 RabbitMQ 常用的 Java 工具类示例：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class RabbitMQUtil {

    // RabbitMQ 服务器地址
    private static final String HOST = "localhost";
    // RabbitMQ 服务器端口号
    private static final int PORT = 5672;
    // RabbitMQ 用户名
    private static final String USERNAME = "guest";
    // RabbitMQ 密码
    private static final String PASSWORD = "guest";
    // RabbitMQ 默认交换机名称
    private static final String DEFAULT_EXCHANGE_NAME = "";
    // RabbitMQ 默认队列名称
    private static final String DEFAULT_QUEUE_NAME = "default_queue";

    private static ConnectionFactory connectionFactory = new ConnectionFactory();

    static {
        // 设置 RabbitMQ 服务器地址、端口号、用户名和密码
        connectionFactory.setHost(HOST);
        connectionFactory.setPort(PORT);
        connectionFactory.setUsername(USERNAME);
        connectionFactory.setPassword(PASSWORD);
    }

    /**
     * 发送消息到指定队列
     *
     * @param queueName 队列名称
     * @param message   消息内容
     */
    public static void sendMessage(String queueName, String message) throws IOException, TimeoutException {
        Connection connection = connectionFactory.newConnection();
        Channel channel = connection.createChannel();
        // 声明队列
        channel.queueDeclare(queueName, true, false, false, null);
        // 发送消息到队列中
        channel.basicPublish(DEFAULT_EXCHANGE_NAME, queueName, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
        channel.close();
        connection.close();
    }

    /**
     * 从指定队列中接收消息
     *
     * @param queueName 队列名称
     * @return 接收到的消息内容
     */
    public static String receiveMessage(String queueName) throws IOException, TimeoutException {
        Connection connection = connectionFactory.newConnection();
        Channel channel = connection.createChannel();
        // 声明队列
        channel.queueDeclare(queueName, true, false, false, null);
        // 从队列中接收消息
        channel.basicQos(1);
        String message = null;
        // 开启手动确认模式
        channel.basicConsume(queueName, false, (consumerTag, delivery) -> {
            message = new String(delivery.getBody(), "UTF-8");
            // 手动确认消息已被接收
            channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
        }, consumerTag -> {
        });
        channel.close();
        connection.close();
        return message;
    }

    /**
     * 删除指定队列
     *
     * @param queueName 队列名称
     */
    public static void deleteQueue(String queueName) throws IOException, TimeoutException {
        Connection connection = connectionFactory.newConnection();
        Channel channel = connection.createChannel();
        // 删除队列
        channel.queueDelete(queueName);
        channel.close();
        connection.close();
    }
}

上面这个工具类提供了 RabbitMQ 常用的三个操作：发送消息、接收消息和删除队列。其中，发送消息和删除队列都比较简单，主要是调用 RabbitMQ 的 API 完成相应操作。而接收消息则需要一些特殊的设置，比如手动确认消息已被接收等。需要注意的是，在使用时需要先安装 RabbitMQ 服务器，并在该服务器上创建相应的队列。