集成RabbitMQ+MQ常用操作

集成RabbitMQ与MQ常用操作指南⚡️

RabbitMQ作为一款开源消息代理软件，在企业级应用中广泛使用。下面介绍如何集成RabbitMQ以及常用操作。

1.RabbitMQ集成📦

首先安装RabbitMQ服务，然后添加客户端依赖：

```java
//Maven依赖

com.rabbitmq
amqp-client
5.14.2

```

2.连接RabbitMQ🔌

```java
ConnectionFactoryfactory=newConnectionFactory();
factory.setHost("localhost");
factory.setUsername("guest");
factory.setPassword("guest");
Connectionconnection=factory.newConnection();
Channelchannel=connection.createChannel();
```

3.常用MQ操作🛠️

声明队列
```java
channel.queueDeclare("my_queue",false,false,false,null);
```

发送消息
```java
Stringmessage="HelloRabbitMQ!";
channel.basicPublish("","my_queue",null,message.getBytes());
System.out.println("[x]Sent'"+message+"'");
```

消费消息
```java
DeliverCallbackdeliverCallback=(consumerTag,delivery)->{
Stringmessage=newString(delivery.getBody(),"UTF-8");
System.out.println("[x]Received'"+message+"'");
};
channel.basicConsume("my_queue",true,deliverCallback,consumerTag->{});
```

交换机操作
```java
//声明直连交换机
channel.exchangeDeclare("direct_exchange","direct");
//绑定队列到交换机
channel.queueBind("my_queue","direct_exchange","routing_key");
```

4.最佳实践💡

1.合理设置消息TTL⏳
2.使用确认机制确保消息可靠投递✅
3.实现死信队列处理失败消息☠️
4.监控队列长度和消费者数量📊

5.关闭连接🚪

```java
channel.close();
connection.close();
```

通过以上操作，你可以轻松集成RabbitMQ到你的应用中，实现高效的消息通信！记得根据实际业务需求调整配置参数，确保系统稳定可靠运行。