安装步骤参考百度... 笔者环境为win10+JDK1.8
导论：
首先我们学习一样东西之前，得知道这个东西是干啥的对不对，所以我们现在也要知道MQ是干啥的。
市面上的开源MQ特别的多，在此，我列举几个mq以及其优劣势
| 特性 | ActiveMQ | RabbitMQ | RocketMQ | Kafka |
|---|---|---|---|---|
| 单机吞吐量 | 万级，比 RocketMQ、Kafka 低一个数量级 | 同 ActiveMQ | 10 万级，支撑高吞吐 | 10 万级，高吞吐，一般配合大数据类的系统来进行实时数据计算、日志采集等场景 |
| topic 数量对吞吐量的影响 | topic 可以达到几百/几千的级别，吞吐量会有较小幅度的下降，这是 RocketMQ 的一大优势，在同等机器下，可以支撑大量的 topic | topic 从几十到几百个时候，吞吐量会大幅度下降，在同等机器下，Kafka 尽量保证 topic 数量不要过多，如果要支撑大规模的 topic，需要增加更多的机器资源 | ||
| 时效性 | ms 级 | 微秒级，这是 RabbitMQ 的一大特点，延迟最低 | ms 级 | ms 级 |
| 可用性 | 高，基于主从架构实现高可用 | 同 ActiveMQ | 非常高，分布式架构 | 非常高，分布式，一个数据多个副本，少数机器宕机，不会丢失数据，不会导致不可用 |
| 消息可靠性 | 有较低的概率丢失数据 | 基本不丢 | 经过参数优化配置，可以做到 0 丢失 | 同 RocketMQ |
| 功能支持 | MQ 领域的功能极其完备 | 基于 erlang 开发，并发能力很强，性能极好，延时很低 | MQ 功能较为完善，还是分布式的，扩展性好 | 功能较为简单，主要支持简单的 MQ 功能，在大数据领域的实时计算以及日志采集被大规模使用 |
如表格（百度搬运），请判断需要，笔者建议优先学习Kafka...当然，个人选择不同，此处不做赘述
MQ到底是什么？
- 消息队列：本质是个队列，FIFO先入先出，只不过队列中存放的内容是message而已。其主要用途：不同进程Process/线程Thread之间通信。
- 不同进程之间传递消息时，两个进程之间耦合程度过高，改动一个进程，引发必须修改另一个进程，为了隔离这两个进程，在两进程间抽离出一层（一个模块），所有两进程之间传递的消息，都必须通过消息队列来传递，单独修改某一个进程，不会影响另一个；
- 不同进程之间传递消息时，为了实现标准化，将消息的格式规范化了，并且，某一个进程接受的消息太多，一下子无法处理完，并且也有先后顺序，必须对收到的消息进行排队，因此诞生了事实上的消息队列
什么是RabbitMQ
使用erlang语言开发的实现了AMQP协议的开源的可复用的企业消息系统
使用springboot构建一个基础的RabbitMQ的hello-world
首先，先构建一个boot，这个没毛病哈(有毛病的建议出门右转)
然后，导入amqp
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
image-20200323143554330.png
这个就应该是项目结构，在确保本地RabbitMQ启动后，再写出我们的第一个哈喽世界！
启动本地后访问：http://localhost:15672/#/ 默认账号密码（你要是改了就当我没说）
我们先搞个毛坯！
spring:
rabbitmq:
# 默认账号密码
username: guest
password: guest
# rabbitmq的ip
addresses: 127.0.0.1
# rabbitmq的端口，我这里是默认端口
port: 5672
server:
port: 9000
基本配置
然后关键来了
首先！先搞个装修！
@Configuration
public class AppConfig {
public final static String QUEUE_NAME = "helloWorldQueue";
public final static String EXCHANGE_NAME = "helloWorldExchang";
public final static String ROUTING_KEY = "helloWorldKey";
@Bean
public Queue queue(){
//创建一个消息容器
return new Queue(QUEUE_NAME);
}
@Bean
public Binding binding(Queue queue , TopicExchange exchange){
return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
}
@Bean
public TopicExchange topiceExchang(){
//返回Exchange rabbitmq当中有多种Exchange 晚点更新
return new TopicExchange(EXCHANGE_NAME);
}
@Bean
public RabbitTemplate rabbitTemplate (ConnectionFactory connectionFactory){
//这是spring整合rabbit提供的消息模板。是进行发送消息的关键类
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
return rabbitTemplate;
}
}
至此我们的面包店装修（基本配置）已经完成，我们需要来卖面包了
那么我们先搞出来一个大门，让人家进来点单。
所以:
@RestController
public class Producer {
@Autowired
RabbitTemplate template;
@GetMapping("/makeLover")
public String makeLover(){
for (int i = 0; i < 5; i++) {
String msg = "send msg = hello world " + i;
//这里就是发送消息，乞丐版消息队列玩法
template.convertAndSend(AppConfig.EXCHANGE_NAME,AppConfig.ROUTING_KEY,msg);
}
return "OK";
}
}
image-20200323154319489.png
可以见到消息已经发送到了队列，那我面包已经做好了，那我得喊人去拿了吧，那我们：
搞个打工仔！
@Component
public class Consumer { //打工仔类
//这里监听你想要监听的那个队列名
@RabbitListener(queues = AppConfig.QUEUE_NAME)
public void getLover(String msg){
System.out.println(msg);
}
}
然后，重启项目！
发现再启动的时候，
image-20200323155022217.png
这样，我的面包卖出去了，顾客小姐姐也拿到面包了
爷的面包店开业了！
赚到了钱，乏了，明天再开业！
（什么？打工仔怎么办？怕他偷哈？下次说怎么确认面包送出来了！）
PS：打工仔没有工资，我稳赚！
