Spring boot集成RabbitMq_springboot集成rabbitmq

一、搭建RabbitMq

1.1 参考

RabbitMQ教程

1.2 配置erlong的环境变量

输入erl，可以看到输出

C:\Program Files\RabbitMQ Server\rabbitmq_server-3.8.0\sbin>erl
Eshell V10.0.1  (abort with ^G)
1>
1
2
3

1.3 RabbitMQ对应的在注册表中的位置

计算机\HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services
1

二、使用教程

2.1 打开服务端

• cmd 打开 C:\Program Files\RabbitMQ Server\rabbitmq_server-3.8.0\sbin，
• 输入：rabbitmq-plugins enable rabbitmq_management
  出现:

The following plugins have been configured:
  rabbitmq_management
  rabbitmq_management_agent
  rabbitmq_web_dispatch
Applying plugin configuration
1
2
3
4
5

• 浏览器输入:localhost:15672
• 账号和密码都是guest
  

2.2 注意的问题

• 配置文件中的端口号不能是15672
• 配置文件:

#RabbitMQ配置
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.virtual-host=/
#消费者数量
spring.rabbitmq.listener.simple.concurrency=10
#消费者最大数量
spring.rabbitmq.listener.simple.max-concurrency=10
#消费，每次从队列中取多少个,取多了，可能处理不过来
spring.rabbitmq.listener.simple.prefetch=1
spring.rabbitmq.listener.direct.auto-startup=true
#消费失败的数据重新压入队列
spring.rabbitmq.listener.simple.default-requeue-rejected=true
#发送,队列满的时候，发送不进去，启动重置
spring.rabbitmq.template.retry.enabled=true
#一秒钟之后重试
spring.rabbitmq.template.retry.initial-interval=1000
#
spring.rabbitmq.template.retry.max-attempts=3
#最大间隔 10s
spring.rabbitmq.template.retry.max-interval=10000
#spring.rabbitmq.template.retry.multiplier=1.0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

2.3 Queue的包

import org.springframework.amqp.core.Queue;
1

三、git命令

3.1 git remote

查看当前的远程库

3.2 git remote add origin “xxxx”

将xxx远程库简单命名origin，并且将添加该远程库

3.3 git push -u origin master

相当于: git push -u origin master:master
把本地仓库master的修改提交到远程仓库的master。

3.4 查看暂存区已经添加的文件

git ls-files
1

3.5 将当前HEAD复位到指定状态。

一般用于撤消之前的一些操作(如：git add,git commit等)。

git reset xx
1

3.6 将文件移除暂存区

 git rm --cached RabbitMq
1

3.7 初始化文件为一个仓库

 git rm --cached RabbitMq
1

3.8 仓库分类

工作区，暂存区和提交区，工作区就是我们操作文件的地方，git add之后文件被存到暂存区，git commit之后文件被提交到提交区。

3.9 提交文件到提交区

四、rabbitmq 使用

rabbitmq 使用