# rabbitmq-test

**Repository Path**: sdwcl/rabbitmq-test

## Basic Information

- **Project Name**: rabbitmq-test
- **Description**: springboot整合rabbitmq
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-05-25
- **Last Updated**: 2020-12-18

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 分布式消息队列

## RabbitMQ

### 初识RabbitMQ

> RabbitMQ是一个开源的消息代理和队列服务器，用来通过普通协议在完全不同的应用之间共享数据，RabbitMQ是使用Erlang语言编写的，并且是基于AMQP协议的。

### RabbitMQ高性能原因？

* Erlang语言最初在于交换机零语的架构模式，这样使得RabbitMQ在Broker之间进行数据交互的性能是非常优秀的
* Erlang的优点： Erlang有着和原生Socket一样的延迟

### 什么是AMQP高级消息队列协议？

**AMQP定义：**

> 是具有现代特征的二进制协议。是一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。

#### AMQP核心概念

* Server：又称Broker，接受客户端的连接，实现AMQP实体服务
* Connection：连接，应用程序与Broker的网络连接
* Channel：网络信道，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道。客户端可建立多个Channel，每个Channel代表一个会话任务。
* Message：消息，服务器和应用程序之间传送的数据，由Properties和Body组成。Properties可以对消息进行修饰，比如消息的优先级、延迟等高级特性；Body则就是消息体内容。
* Virtual host：虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual Host里面可以有若干个Exchange和Queue，同一个Virtual Host里面不能有相同名称的Exchange或Queue
* Exchange：交换机，接收消息，根据路由键转发消息到绑定的队列
* Binding：Exchange和Queue之间的虚拟连接，Binding中可以包含routing key
* Routing key：一个路由规则，虚拟机可用它来确定如何路由一个特定消息
* Queue：也成为Message Queue，消息队列，保存消息并将它们转发给消费者

#### 幂等性概念（了解）

**幂等性是什么？**

我们可以借鉴数据库的乐观锁机制：

比如我们执行一条更新库存sql语句

```sql
update t_reps set count = count - 1,version = version + 1 
where version = 1
```

#### 消费端-幂等性保障

**唯一ID+指指纹码机制**

* 唯一ID+指纹码机制，利用数据库主键去重
* select count(1) from t_order where id = 唯一id + 指纹码
* 好处： 实现简单
* 坏处： 高并发下有数据库写入的性能瓶颈
* 解决方案：跟进id进行分库分表进行算法路由

**利用redis原子特性实现**

* 使用Redis进行幂等，需要考虑的问题
* 第一： 我们是否要进行数据落库，如果要落库，关键解决的问题是数据库和缓存如何做到原子性？
* 第二： 如果不进行落库，那么都存储到缓存中，如何设置定时同步的策略？

### RabbitMQ整合应用-SpringBoot2.X

#### 步骤

1. 引入Maven依赖
2. application.properties

#### 生产端核心配置

```properties
spring.rabbitmq.publisher-confirms=true
spring.rabbitmq.publisher-returns=true
spring.rabbitmq.template.mandatory=true
```

#### 消费端配置

```properties
spring.rabbitmq.listener.simple.acknowledge-mode=MANUAL
spring.rabbitmq.listener.simple.concurrency=1
spring.rabbitmq.listener.simple.max-concurrency=5
```

#### @RabbitListener注解使用

@RabbitListener：消费端监听

例：

```java
@RabbitListener(bindings=@QueueBinding(
	value = @Queue(value = "queue-1", durable = "true"), 
    exchange = @Exchange(value = "exchange-1", //名称
                        durable = "true", //持久化
                        type = "topic",  //类型
                        ignoreDeclarationExceptions = "true"),//忽略声明的异常
    key = "springboot.*" //路由的key
))
@RabbitHandler
public void onMessage(Message message, Channel channel){
    
}
```

PS : 由于配置写在代码，非常不友好，建议使用配置文件把写死的常量进行注入。

#### 整合springboot(生产端)

```xml
<dependency>
	<groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```

```properties
server.port=8001
server.servlet.context-path=/
spring.rabbitmq.addresses=192.168.100.99:5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.virtual-host=/
spring.rabbitmq.connection-timeout=15000

##启用消息确认模式
spring.rabbitmq.publisher-confirms=true

##设置return消息模式，注意要和mandatory配合使用
spring.rabbitmq.publisher-returns=true
spring.rabbitmq.template.mandatory=true
```