rabbitmq源码怎么分析

① 求java学习路线图

/*回答内容很长，能看完的少走一个月弯路，绝不抖机灵*/

提前预警：本文适合Java新手阅读(老手可在评论区给下建议)，希望大家看完能有所收获。

废话不多少了，先了解一下Java零基础入门学习路线：

第一阶段：JavaSE阶段

变量、数据类型、运算符

• 二进制和十进制的转化

• 注释、单行注释、多行注释、文本注释、注释内容和字节码的关系

• 标识符、关键字、驼峰原则

• 变量的本质、内存画图、变量声明和初始化

• 变量的分类和作用域（局部变量、成员变量、静态变量）

• 常量和Final

• 基本数据类型介绍

• 整型变量和整型常量

• 浮点类型、float、double

• char字符型、转义字符

• boolean布尔型、if语句使用要点、布尔类型占用空间问题

• 运算符介绍

• 算数运算符（二元、自增、自减）

• 赋值和赋值运算符

• 关系运算符详解

• 逻辑运算符、短路运算符详解

• 位运算符详解

• 字符串连接符

• 条件运算符（三元运算符）

• 运算符优先级问题

• 自动类型转换详解

• 强制类型装换详解

• 基本数据类型装换常见错误、溢出、L问题

• 使用Scanner获取键盘输入

控制语句

• 控制语句和实现逻辑对应

• if单选结构

• if_elseif_else多选结构

• switch语句_IDEA更换主题

• 循环_while

• 循环_for循环_dowhile

• 嵌套循环

• break和continue语句_标签_控制语句底层原理

• 写一个年薪计算机_网络查问题的秘诀（重要）

• 个人所得税计算器软件

• 方法核心详解_天才思维模型教你高手学习思维模式

• 方法的重载

• 递归结构讲解_递归头_递归体

面向对象编程-基础

• 面向过程和面向对象的区别

• 类和对象的概述

• 类的属性和方法

• 创建对象内存分析

• 构造方法（Construtor）及重载

• 对象类型的参数传递

• this关键字

• static关键字详解

• 局部代码块、构造代码块和静态代码块

• package和import详解

• JavaDoc生成API文档

面向对象编程-进阶

• 面向对象的三大特性

• 面向对象之【封装(Encapsulation)】

• 访问权限修饰符

• 面向对象之【继承（Inheritance）】

• Object类

• 方法重写Override

• super关键字详解

• 重写equals()和toString()

• 继承中对象创建的内存分析

• 面向对象之【多态（Polymorphism）】

• 向上转型

• 向下转型

• instanceof运算符

• 编译时和运行时详解

• final修饰符

• 抽象类和抽象方法（abstrct）

• 接口的定义和实现

• JDK8的接口新特性

• 接口应用：内部类比较器Comparable

• 内部类详解

• Java的内存管理与垃圾回收

异常机制

• 异常的概述

• 异常的执行过程与分析

• try-catch-finally捕捉异常

• throw抛出异常

• throws声明异常

• 异常继承体系

• 运行时异常和编译异常

• 自定义异常

Java常用类

Wrapper包装类

• 自动装箱和自动拆箱

• 包装类的源码分析

• String类的使用与内存原理

• String类的源码分析

• StringBuffer

• StringBuilder

• 字符串处理类性能分析

• Date类

• System类

• DateFormat类

• Calendat类

• Math类

• BigInteger类和BigDecimal类

• Random类

• 枚举类

• File类

• 常见的面试题讲述与分析

数据结构算法

• 数据结构的概述

• 线性表

• 顺序表

• 链表

• 栈和队列

• 树

• 二叉树

• 二叉查找树

• 二叉平衡树

• 黑红树

• 图

• 冒泡排序

• 选择排序

• 递归

• 折半查找

集合（容器）

• 集合和数组的联系和区别

• 集合框架体系

• ArrayList的使用和源码分析

• 集合中使用泛型

• LinkedList的使用和源码分析

• HashSet的使用和源码分析

• 哈希表及原理

• TreeSet的使用和源码分析

• 比较器Comparable和Comparator

• HashMap的使用和源码分析

• TreeMap的使用和源码分析

• Iterator于ListIterator

• Collections工具类

• 旧集合类Vector、Hashtable

• 集合总结和选择依据

• 泛型接口

• 泛型类

• 泛型方法

IO流

• IO流的概念

• IO流的分类及其原理分析

• 文件流FlieInputStream、FileOutputStream

• 缓冲流BufferedInputStream、BufferedOutputStream

• 数据流ObjectInputStream、ObjectOutputStream

• 序列化和反序列化

• 转换流InputStreamReader、OutputStreamWriter

• 打印流PrintWrite和PrintStream

• 数组流ByteArrayOutputStream、ByteArrayInputStream

• 使用IO复制文件夹

多线程

• 进程和线程

• 线程的创建与启动

• 创建线程的三种方式对比

• 线程的生命周期

• 线程控制

• 多线程的安全问题与解决办法

• 线程的同步：同步代码块

• 线程的同步：同步方法

• 线程的同步：Lock锁

• 线程的死锁问题

• 线程通信

• Condition

• 线程的完整生命周期

• 线程池ThreadPoolExecutor

• ForkJoin框架

• ThreadLocal类

网络编程

• 计算机网络基础知识

• 网络通信协议

• OSI参考模型

• TCP/IP参考模型

• 数据的封装与拆封原理解析

• TCP协议

• UDP协议

• IP地址和端口号

• URL和Socket

• 使用TCP编程实现登录功能

• 使用UDP编程实现客服系统

• 使用TCP编程实现文件上传

集合提升寻训练

• 手写ArrayList

• 手写单链表

• 手写Linkedlist

• 手写HashMap

• 手写HashSet

• 最新并发集合类

多线程提升训练

• 生产者消费者模式扩展

• Lock锁和Condition

• ReadWriteLock

• BlockingQueue

• volatile关键字

• 多线程题目练习

• JDK新特征

• 面试题详解

设计模式

• 设计模式入门

• 面向对象设计七大原则

• 简单工厂模式

• 工厂方法模式

• 单例模式

• 原型模式

• 装饰模式

• 适配器模式

• 外观模式

第二阶段：数据库

MySQL基础

• 数据库基础知识

• MySQL基础知识

• MySQL8新特征

• 安装和卸载MySQL8

• 使用navicat访问数据库

• SQL语言入门

• 创建数据库表

• DML

• 修改删除数据库表

• 表的完整性约束

• 表的外键约束

• DML扩展

MySQL 查询语句

• 基本select查询

• where子句

• 函数

• group by

• having

• SQL99-内连接查询

• SQL99-外连接查询

• SQL99-自连接查询

• SQL92-连接查询

• 不相关子查询

• 相关子查询

• 分页查询

数据库对象

• 索引

• 事务及其特征

• 事务的并发问题

• 事务的隔离级别

• 存储过程

• 导入导出数据

JDBC

• JDBC概述

• 使用JDBC完成添加/更新/删除操作

• 使用JDBC完成查询操作

• JDBC常用接口

• 使用PreparedStatement

• 使用事务完成银行转账

• 提取DBUtil工具类

• 使用Properties读写属性文件

• 日志框架log4j

• 开发员工管理系统
  

第三阶段：JavaEE阶段

Servlet

• web开发概述

• B/S和C/S架构简介

• HTTP协议

• HTTP请求头和响应头

• Tomcat安装使用

• Tomcat目录结构

• Servlet概述

• Servlet快速入门

• Servlet生命周期

• 读取配置文件信息

• HttpServletRequest

• HttpServletResponse

• GET和POST区别

• 解决中文乱码

• 请求转发与重定向

• 绝对路径和相对路径

• Cookie

• Session

• ServletContext

• ServletConfig

JSP

• JSP技术介绍

• JSP的执行过程

• scriptlet

• 表达式

• 声明

• JSP指令元素

• JSP动作元素

• JSP隐式对象

• JSP底层原理

• 九大内置对象

• 四个作用域

• Servlet和JSP的关系和区别

• MVC模式

• 合并Servlet

JavaScript

• JavaScript概述与特点

• JS基础语法

• 函数

• 数组

• Math对象

• String对象

• Date对象

• 事件event

• 浏览器开发者工具

• console

• DOM和BOM

• window

• location

• navigator

• history

• 认识DOM

• DOM获取元素

jQuery

• jQuery简介及快速入门

• jQuery入口函数

• jQuery对象与DOM对象互相转换

• 基本选择器

• 属性选择器

• 位置选择器

• 表单选择器

• 内容选择器

• jQuery事件

• jQuery动画效果

• DOM操作-操作文本

• DOM操作-操作属性

• DOM操作-操作元素

• 直接操作CSS样式

• 操作CSS类样式

• 购物车案例

• 表单验证

• 正则表达式

EL+JSTL+过滤器+监听器

• EL介绍及使用

• EL取值原理

• EL隐含对象

• EL逻辑运算

• JSTL介绍-核心标签库

• JSTL核心标签库

• JSTL-格式标签库

• Filter原理

• Filter生命周期

• Filter链

• Filter登录验证

• Filter权限控制

• Listener概述及分类

• Listener监听在线用户

Ajax和JSON

• Ajax异步请求和局部刷新的原理

• 使用原生Ajax验证用户唯一性

• jQuery Ajax

• JSON的格式和使用

• 主要JSON解析器

• Jackson的使用

• Jackson的实现原理

• 使用jQuery Ajax实现三级联动

• 使用jQuery Ajax实现自动补全

分页和文件上传/下载

• 分页的意义

• 理解分页工具类

• 实现基本分页

• 实现带查询的分页

• 文件上传原理

• 文件上传API

• 实现文件上传

• 文件下载原理

• 文件下载响应头

• 实现文件下载

第四阶段：框架阶段

MyBatis

• MyBatis概述

• MyBatis入门配置

• 基本的CRUD操作

• 核心配置文件详解

• Mapper.xml基础详解

• 模糊查询

• 分页的实现及插件PageHelper的使用

• 动态sql+sql片段的使用

• 一对多、多对一的关系处理

• 注解的使用

• 一级缓存和二级缓存说明及使用

• generator逆向工程使用

Spring

• Spring框架简介

• Spring官方压缩包目录介绍

• Spring环境搭建

• IoC/DI容器详解

• Spring创建Bean的三种方式

• scope属性讲解

• Spring中几种注入方式

• 静态代理设计模式

• 动态代理设计模式

• AOP详解

• AOP中几种通知类型

• AOP两种实现方式

• 自动注入

• 声明式事务

• 事务传播行为

• 事务隔离级别

• 只读事务

• 事务回滚

• 基于注解式配置

• 常用注解

• Spring 整合MyBatis

• i18n

• Spring整合Junit

SpringMVC

• MVC架构模式

• 手写MVC框架

• SpringMVC简介

• SpringMVC运行原理

• 基于配置文件方式搭建环境

• 基于注解方式搭建环境

• SpringMVC的跳转及视图解析器的配置

• SpringMVC和Ajax的交互

• Spring 参数注入

• SpringMVC作用域传值

• 视图解析器

• 文件下载

• 文件上传

• Spring拦截器/拦截器栈

• 登录状态验证

• SpringMVC容器和Spring容器介绍

• 异常处理4种方式

• SpringMVC5其他常用注解

Maven

• Maven简介

• Maven原理

• linux安装及注意事项

• Maven项目结构

• POM模型

• Maven 中项目类型

• 创建WAR类型的Maven项目

• scope属性可取值

• SSM项目拆分演示

• Maven的常见插件讲解

• 热部署

BootStrap

• BootStrap概述

• BootStrap栅格系统

• BootStrap常用全局CSS样式

• 常用组件

• 常用JavaScript插件

RBAC

• RBAC概述

• RBAC发展历史

• 基于RBAC的数据库表设计

• URL拦截实现

• 动态菜单实现

• 密码学

第五阶段：前后端分离阶段

Spring Boot

• Spring Boot简介

• Spring Boot实现Spring MVC

• 配置文件顺序及类型讲解

• Spring Boot项目结构

• Spring Boot 整合MyBatis

• Spring Boot 整合Druid

• Spring Boot 整合PageHelper

• Spring Boot 整合logback

• Spring Boot 整合JSP

• Spring Boot 整合Thymeleaf

• Spring Boot 开发者工具

• Spring Boot 异常显示页面

• Spring Boot 整合Junit4

• Spring Boot 项目打包部署

• Spring Boot 整合Quartz

• Spring Boot 中Interceptor使用

• Spring Boot Actuator

• HikariCP

Logback

• Logback简介

• Logback依赖说明

• Logback 配置文件讲解

• Logback 控制台输出

• Logback 文件输出

• Logback 数据库输出

Spring Security

• Spring Security简介

• Spring Security架构原理

• 什么是认证和授权

• 基础环境搭建

• 自定义认证流程

• UserDetailsService和UserDetails

• PasswordEncoder

• 自定义认证结果

• 授权-访问路径匹配方式

• 授权-权限管理

• 基于注解实现权限管理

• Thymeleaf整合Security权限管理

• Rememberme 实现

• 退出实现

• CSRF

Linux - CentOS 8

• Linux简介

• VMWare安装及使用

• Linux安装及注意事项

• Linux目录结构及路径

• Linux常用命令

• VMWare常用配置

• XShell安装及使用

• Xftp安装及使用

• JDK解压版配置步骤

• Tomcat配置步骤

• 安装MySQL

• WAR包部署

Docker

• Docker简介

• Docker与VM对比

• Docker特点

• Docker架构

• Docker安装与启动

• 镜像加速器配置

• Docker镜像操作常用命令

• Docker容器操作常用命令

• DockerFile

• 搭建本地镜像仓库

• 推送镜像到阿里云及本地仓库

• Docker容器生命周期

• Docker数据管理

Redis

• Redis简介

• Redis 单机版安装

• Redis 数据类型介绍

• Redis 常用命令

• Redis 持久化方案

• Redis 的主从搭建

• Redis的哨兵搭建

• Redis 的集群搭建

• Spring Boot整合Spring Data Redis

• Redis的缓存穿透

• Redis的缓存雪崩

• Redis的缓存击穿

Vue

• vsCode和插件安装

• webpack介绍

• Vue项目创建

• Vue模板语法

• Vue条件渲染

• Vue列表渲染

• Vue事件处理

• Vue计算属性

• Vue Class与Style

• Vue表单处理

• Vue组件

• Vue组件生命周期

• Vue 路由配置

• Vue Axios网络请求

• Vue跨域处理

• Vue Element

• Mock.js

Swagger

• Swagger2简介

• Springfox

• Swagger2基本用法

• Swagger-UI用法

• Swagger2配置

• Swagger2常用配置

Git/GitEE

• Git的下载和安装

• Git和SVN对比

• Git创建版本库

• Git版本控制

• Git远程仓库

• Git分支管理

• Git标签管理

• GitEE建库

• GitEE 连接及使用

• GitEE 组员及管理员配置

第六阶段：微服务架构

FastDFS

• 分布式文件系统概述

• FastDFS简介

• FastDFS架构

• Tracker Server

• Storage Server

• FastDFS安装

• 安装带有FastDFS模块的Nginx

• Fastdfs-java-client的使用

• 创建Fastdfs-java-client工具类

• 实现文件上传与下载

• KindEditor介绍

• 通过KindEditor实现文件上传并回显

RabbitMQ

• AMQP简介

• RabbitMQ简介

• 安装Erlang

• 安装RabbitMQ

• RabbitMQ原理

• Spring Boot 集成RabbitMQ

• RabbitMQ的交换器

• Spring AMQP的使用

Spring Cloud Netflix Eureka

• Eureka简介

• Eureka和Zookeeper 对比

• 搭建Eureka注册中心

• Eureka 服务管理平台介绍

• 搭建高可用集群

• 集群原理

• Eureka优雅停服

Spring Cloud Netflix Ribbon

• Ribbon简介

• 集中式与进程内负载均衡区别

• Ribbon常见的负载均衡策略

• Ribbon的点对点直连

Spring Cloud OpenFeign

• Feign简介

• Feign的请求参数处理

• Feign的性能优化

• 配置Feign负载均衡请求超时时间

Spring Cloud Netflix Hystrix

• Hystrix简介

• 服务降级

• 服务熔断

• 请求缓存

• Feign的雪崩处理

• 可视化的数据监控Hystrix-dashboard

Spring Cloud Gateway

• Spring Cloud Gateway简介

• Gateway基于配置文件实现路由功能

• Gateway基于配置类实现路由功能

• Gateway中内置过滤器的使用

• Gateway中自定义GatewayFilter过滤器的使用

• Gateway中自定义GlobalFilter过滤器的使用

• Gateway中使用过滤器实现鉴权

• Gateway结合Hystrix实现熔断功能

Spring Cloud Config

• 什么是分布式配置中心

• 创建配置中心服务端

• 创建配置中心客户端

• 基于Gitee存储配置文件

• 基于分布式配置中心实现热刷新

Spring Cloud Bus

• 什么是消息总线

• 基于消息总线实现全局热刷新

ELK

• ElasticSearch介绍

• ElasticSearch单机版安装

• ElasticSearch集群版安装

• ElasticSearch索引管理

• ElasticSearch文档管理

• ElasticSearch文档搜索

• SpringDataElasticSearch访问ElasticSearch

• LogStash介绍

• 基于LogStash收集系统日志

TX-LCN

• 分布式事务简介

• 分布式事务两大理论依据

• 分布式事务常见解决方案

• LCN简介

• TX-LCN的3种模式

• LCN原理

• LCN环境搭建及Demo演示

Nginx

• Nginx的简介

• 什么是正向代理、反向代理

• Nginx的安装

• Nginx配置虚拟主机

• Nginx配置服务的反向代理

• Nginx的负载均衡配置

Spring Session

• Spring Session介绍

• 通过Spring Session共享session中的数据

• 通过Spring Session同步自定义对象

• Spring Session的Redis存储结构

• 设置Session失效时间

• Spring Session序列化器

MyBatis Plus

• MyBatis Plus简介

• Spring整合MyBatis Plus

• MyBatis Plus的全局策略配置

• MyBatis 的主键生成策略

• MyBatis Plus的CRUD操作

• 条件构造器EntityWrapper讲解

• MyBatis Plus的分页插件配置

• MyBatis Plus的分页查询

• MyBatis Plus的其他插件讲解

• MyBatis Plus的代码生成器讲解

• MyBatis Plus的公共字段自动填充

ShardingSphere

• 简介

• 数据库切分方式

• 基本概念

• MySQL主从配置

• 切片规则

• 读写分离

• 实现分库分表

第七阶段：云服务阶段

Kafka

• Kafka简介

• Kafka架构

• 分区和日志

• Kafka单机安装

• Kafka集群配置

• 自定义分区

• 自动控制

• Spring for Apache Kafka

Zookeeper

• Zookeeper简介和安装

• Zookeeper 数据模型

• Zookeeper 单机版安装

• Zookeeper常见命令

• ZClient操作Zookeeper

• Zookeeper 集群版安装

• Zookeeper 客户端常用命令

• Zookeeper分布式锁

RPC

• 什么是分布式架构

• 什么是RFC、RPC

• HttpClient实现RPC

• RestTemplate

• RMI实现RPC

• 基于Zookeeper实现RPC 远程过程调用

Dubbo

• SOA架构介绍

• Dubbo简介

• Dubbo结构图

• Dubbo注册中心

• Dubbo 支持的协议

• Dubbo 注册中心搭建

• Spring Boot 整合 Dubbo

• Admin管理界面

• Dubbo 搭建高可用集群

• Dubbo 负载均衡

Spring Cloud Alibaba Dubbo

• Spring Cloud Alibaba Dubbo简介

• 基于Zookeeper发布服务

• 基于Zookeeper订阅服务

• 实现远程服务调用处理

Spring Cloud Alibaba Nacos

• Spring Cloud Alibaba Nacos简介

• 搭建Nacos服务器

• 基于Nacos发布|订阅服务

• 实现远程服务调用处理

• Nacos Config配置中心

Spring Cloud Alibaba Sentinel

• Spring Cloud Alibaba Sentinel简介

• 搭建Sentinel服务器

• Sentinel-实时监控

• Sentinel-簇点链路

• Sentinel-授权规则

• Sentinel-系统规则

• @SentinelResource注解

• 持久化规则

Spring Cloud Alibaba Seata

• Spring Cloud Alibaba Seata简介

• 搭建Seata服务器

• Seata支持的事务模式-AT模式

• Seata支持的事务模式-TCC模式

• Seata支持的事务模式-Saga模式

• Seata支持的事务模式-XA模式

• SeataAT事务模式应用方式

• SeataTCC事务模式应用方式
  

② 在linux下安装rabbitmq失败怎么解决

RabbitMQ 是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现，由以高性能、健壮以及可伸缩性出名的 Erlang 写成，因此也是继承了这些优点。
AMQP 里主要要说两个组件：Exchange 和 Queue （在 AMQP 1.0 里还会有变动），如下图所示，绿色的 X 就是 Exchange ，红色的是 Queue ，这两者都在 Server 端，又称作 Broker ，这部分是 RabbitMQ 实现的，而蓝色的则是客户端，通常有 Procer 和 Consumer 两种类型：

1：mq的安装需要Erlang，所以首先下载Erlang，下载地址：http://www.erlang.org/download.html直接下载源码，编译安装即可。
将下载好的tar包解压编译安装，如下命令：
tar -zxvf otp_src_R16B03-1.tar.gz

cd otp_src_R16B03-1
./configure && make install

安装过程中可能出现如下错误：
configure:error:
No curses library functions found
configure: error:/bin/sh'/home/niewf/software/erlang_R13B01/erts/configure'
failed for erts

解决方法：
yum list|grep ncurses
yum -y install ncurses-devel
yum install ncurses-devel

或者直接下载ncurses包编译安装。
下载地址：http://download.chinaunix.net/download/0008000/7242.shtml
tar zxvf ncurses.tar.gz #解压缩并且释放 文件包
cd ncurses #进入解压缩的目录（注意版本）
./configure #按照你的系统环境制作安装配置文件
make #编译源代码并且编译NCURSES库
su root #切换到root用户环境
make install #安装编译好的NCURSES库

完成后继续返回上一步操作。

2：安装python，如果系统中python版本低于2.5的话需要升级python到2.6以上，具体可参考：http://gavinshaw.blog.51cto.com/385947/610585

3：安装simplejson，直接下载simplejson源码包编译安装即可，下载地址：https://pypi.python.org/pypi/simplejson/。
下载simplejson源码包后，运行python setup.py install即可完成安装。

4：安装rabbit mq，下载地址：https://www.rabbitmq.com/install-generic-unix.html
下载后放入相应目录解压，进入%RABBITMQ_HOME%/sbin目录下运行：./rabbitmq-server start即可启动mq。
如果遇到如下错误，则参考http://leeon.me/a/rabbitmq-start-fail-note解决方案
ERROR: epmd error for host "xxx": address (cannot connect to host/port)
到此mq已经安装完成。
在%RABBITMQ_HOME%/sbin目录运行./rabbitmqctl status可查看当前mq状态。
同时mq也提供了界面查看当前mq状态，但是需要启用该插件功能，运行如下命令：
rabbitmq-plugins enable rabbitmq_management，然后在浏览器中输入：http://host-name:15672/#/即可访问，页面结果如下：

③ Spring整合rabbitmq实践（一）：基础

Spring整合rabbitmq实践（二）：扩展
Spring整合rabbitmq实践（三）：源码

procer：消息生产者；

consumer：消息消费者；

queue：消息队列；

exchange：接收procer发送的消息按照binding规则转发给相应的queue；

binding：exchange与queue之间的关系；

virtualHost：每个virtualHost持有自己的exchange、queue、binding，用户只能在virtualHost粒度控制权限。

fanout：

群发到所有绑定的queue；

direct：

根据routing key routing到相应的queue，routing不到任何queue的消息扔掉；可以不同的key绑到同一个queue，也可以同一个key绑到不同的queue；

topic：

类似direct，区别是routing key是由一组以“.”分隔的单词组成，可以有通配符，“*”匹配一个单词，“#”匹配0个或多个单词；

headers：

根据arguments来routing。

arguments为一组key-value对，任意设置。

“x-match”是一个特殊的key，值为“all”时必须匹配所有argument，值为“any”时只需匹配任意一个argument，不设置默认为“all”。

通过以下配置，可以获得最基础的发送消息到queue，以及从queue接收消息的功能。

这个包同时包含了一些其它的包：spring-context、spring-tx、spring-web、spring-messaging、spring-retry、spring-amqp、amqp-client，如果想单纯一点，可以单独引入。

最主要的是以下几个包，

spring-amqp：

spring-rabbit：

amqp-client：

个人理解就是，spring-amqp是spring整合的amqp，spring-rabbit是spring整合的rabbitmq（rabbitmq是amqp的一个实现，所以可能spring-rabbit也是类似关系），amqp-client提供操作rabbitmq的java api。

目前最新的是2.0.5.RELEASE版本。如果编译报错，以下信息或许能有所帮助：

(1)

解决方案：spring-amqp版本改为2.0.5.RELEASE。

(2)

解决方案：spring-context版本改为5.0.7.RELEASE。

(3)

解决方案：spring-core版本改为5.0.7.RELEASE。

(4)

解决方案：spring-beans版本改为5.0.7.RELEASE。

(5)

解决方案：spring-aop版本改为5.0.7.RELEASE。

总之，需要5.0.7.RELEASE版本的spring，及相匹配版本的amqp-client。

后面所讲的这些bean配置，spring-amqp中都有默认配置，如果不需要修改默认配置，则不用人为配置这些bean。后面这些配置也没有涉及到所有的属性。

这里的ConnectionFactory指的是spring-rabbit包下面的ConnectionFactory接口，不是amqp-client包下面的ConnectionFactory类。

上面这个bean是spring-amqp的核心，不论是发送消息还是接收消息都需要这个bean，下面描述一下里面这些配置的含义。

setAddresses ：设置了rabbitmq的地址、端口，集群部署的情况下可填写多个，“,”分隔。

setUsername ：设置rabbitmq的用户名。

setPassword ：设置rabbitmq的用户密码。

setVirtualHost ：设置virtualHost。

setCacheMode ：设置缓存模式，共有两种， CHANNEL 和 CONNECTION 模式。

CHANNEL 模式，程序运行期间ConnectionFactory会维护着一个Connection，所有的操作都会使用这个Connection，但一个Connection中可以有多个Channel，操作rabbitmq之前都必须先获取到一个Channel，否则就会阻塞（可以通过setChannelCheckoutTimeout()设置等待时间），这些Channel会被缓存（缓存的数量可以通过setChannelCacheSize()设置）；

CONNECTION 模式，这个模式下允许创建多个Connection，会缓存一定数量的Connection，每个Connection中同样会缓存一些Channel，除了可以有多个Connection，其它都跟CHANNEL模式一样。

这里的Connection和Channel是spring-amqp中的概念，并非rabbitmq中的概念，官方文档对Connection和Channel有这样的描述：

关于 CONNECTION 模式中，可以存在多个Connection的使用场景，官方文档的描述：

setChannelCacheSize ：设置每个Connection中（注意是每个Connection）可以缓存的Channel数量，注意只是缓存的Channel数量，不是Channel的数量上限，操作rabbitmq之前（send/receive message等）要先获取到一个Channel，获取Channel时会先从缓存中找闲置的Channel，如果没有则创建新的Channel，当Channel数量大于缓存数量时，多出来没法放进缓存的会被关闭。

注意，改变这个值不会影响已经存在的Connection，只影响之后创建的Connection。

setChannelCheckoutTimeout ：当这个值大于0时， channelCacheSize 不仅是缓存数量，同时也会变成数量上限，从缓存获取不到可用的Channel时，不会创建新的Channel，会等待这个值设置的毫秒数，到时间仍然获取不到可用的Channel会抛出AmqpTimeoutException异常。

同时，在 CONNECTION 模式，这个值也会影响获取Connection的等待时间，超时获取不到Connection也会抛出AmqpTimeoutException异常。

setPublisherReturns、setPublisherConfirms ：procer端的消息确认机制（confirm和return），设为true后开启相应的机制，后文详述。

官方文档描述publisherReturns设为true打开return机制，publisherComfirms设为true打开confirm机制，但测试结果（2.0.5.RELEASE版本）是，任意一个设为true，两个都会打开。

addConnectionListener、addChannelListener、setRecoveryListener ：添加或设置相应的Listener，后文详述。

setConnectionCacheSize ：仅在 CONNECTION 模式使用，设置Connection的缓存数量。

setConnectionLimit ：仅在 CONNECTION 模式使用，设置Connection的数量上限。

上面的bean配置，除了需要注入的几个listener bean以外，其它设置的都是其默认值（2.0.5.RELEASE版本），后面的bean示例配置也是一样，部分属性不同版本的默认值可能有所不同。

一般不用配置这个bean，这里简单提一下。

这个ConnectionFactory是rabbit api中的ConnectionFactory类，这里面是连接rabbitmq节点的Connection配置。

如果想修改这些配置，可以按如下方式配置：

consumer端如果通过@RabbitListener注解的方式接收消息，不需要这个bean。

不建议直接通过ConnectionFactory获取Channel操作rabbitmq，建议通过amqpTemplate操作。

setConnectionFactory ：设置spring-amqp的ConnectionFactory。

setRetryTemplate ：设置重试机制，详情见后文。

setMessageConverter ：设置MessageConverter，用于java对象与Message对象（实际发送和接收的消息对象）之间的相互转换，详情见后文。

setChannelTransacted ：打开或关闭Channel的事务，关于amqp的事务后文描述。

setReturnCallback、setConfirmCallback ：return和confirm机制的回调接口，后文详述。

setMandatory ：设为true使ReturnCallback生效。

这个bean仅在consumer端通过@RabbitListener注解的方式接收消息时使用，每一个@RabbitListener注解的方法都会由这个创建一个MessageListenerContainer，负责接收消息。

setConnectionFactory ：设置spring-amqp的ConnectionFactory。

setMessageConverter ：对于consumer端，MessageConverter也可以在这里配置。

setAcknowledgeMode ：设置consumer端的应答模式，共有三种：NONE、AUTO、MANUAL。

NONE，无应答，这种模式下rabbitmq默认consumer能正确处理所有发出的消息，所以不管消息有没有被consumer收到，有没有正确处理都不会恢复；

AUTO，由Container自动应答，正确处理发出ack信息，处理失败发出nack信息，rabbitmq发出消息后将会等待consumer端的应答，只有收到ack确认信息才会把消息清除掉，收到nack信息的处理办法由setDefaultRequeueRejected()方法设置，所以在这种模式下，发生错误的消息是可以恢复的。

MANUAL，基本同AUTO模式，区别是需要人为调用方法给应答。

setConcurrentConsumers ：设置每个MessageListenerContainer将会创建的Consumer的最小数量，默认是1个。

setMaxConcurrentConsumers ：设置每个MessageListenerContainer将会创建的Consumer的最大数量，默认等于最小数量。

setPrefetchCount ：设置每次请求发送给每个Consumer的消息数量。

setChannelTransacted ：设置Channel的事务。

setTxSize ：设置事务当中可以处理的消息数量。

setDefaultRequeueRejected ：设置当rabbitmq收到nack/reject确认信息时的处理方式，设为true，扔回queue头部，设为false，丢弃。

setErrorHandler ：实现ErrorHandler接口设置进去，所有未catch的异常都会由ErrorHandler处理。

AmqpTamplate里面有下面几个方法可以向queue发送消息：

这里，exchange必须存在，否则消息发不出去，会看到错误日志，但不影响程序运行：

Message是org.springframework.amqp.core.Message类，spring-amqp发送和接收的都是这个Message。

从Message类源码可以看到消息内容放在byte[]里面，MessageProperties对象包含了非常多的一些其它信息，如Header、exchange、routing key等。

这种方式，需要将消息内容（String，或其它Object）转换为byte[]，示例：

也可以直接调用下面几个方法，Object将会自动转为Message对象发送：

有两种方法接收消息：

1.polling consumer，轮询调用方法一次获取一条；

2.asynchronous consumer，listener异步接收消息。

polling consumer

直接通过AmqpTemplate的方法从queue获取消息，有如下方法：

如果queue里面没有消息，会立刻返回null；传入timeoutMillis参数后可阻塞等待一段时间。

如果想直接从queue获取想要的java对象，可调用下面这一组方法：

后面4个方法是带泛型的，示例如下：

使用这四个方法需要配置org.springframework.amqp.support.converter.SmartMessageConverter，这是一个接口，Jackson2JsonMessageConverter已经实现了这个接口，所以只要将Jackson2JsonMessageConverter设置到RabbitTemplate中即可。

asynchronous consumer

有多种方式可以实现，详情参考官方文档。

最简单的实现方式是@RabbitListener注解，示例：

这里接收消息的对象用的是Message，也可以是自定义的java对象，但调用Converter转换失败会报错。

注解上指定的queue必须是已经存在并且绑定到某个exchange的，否则会报错：

如果在@RabbitListener注解中指明binding信息，就能自动创建queue、exchange并建立binding关系。

direct和topic类型的exchange需要routingKey，示例：

fanout类型的exchange，示例：

2.0版本之后，可以指定多个routingKey，示例：

并且支持arguments属性，可用于headers类型的exchange，示例：

@Queue有两个参数exclusive和autoDelete顺便解释一下：

exclusive，排他队列，只对创建这个queue的Connection可见，Connection关闭queue删除；

autoDelete，没有consumer对这个queue消费时删除。

对于这两种队列，rable=true是不起作用的。

另外，如果注解申明的queue和exchange及binding关系都已经存在，但与已存在的设置不同，比如，已存在的exchange的是direct类型，这里尝试改为fanout类型，结果是不会有任何影响，不论是修改或者新增参数都不会生效。

如果queue存在，exchange存在，但没有binding，那么程序启动后会自动建立起binding关系。