# 2.AMQP（RabbitMQ）

## 一、添加依赖

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

## 二、配置文件

```java
# RABBIT (RabbitProperties)
#spring.rabbitmq.host=localhost
#spring.rabbitmq.port=5672
#spring.rabbitmq.password=
#spring.rabbitmq.username=
```

## 三、代码实现

启用注解： `@EnableRabbit`

加到main函数之上

具体实现

![](https://3562539340-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-LfnT314x6hQ7gJbPKxx%2F-LfnTB6gvTwJcyb-RbKo%2F-LfnTIMKozdS6H3uf-T6%2F2.1.png?generation=1558862969372852\&alt=media)

util/configuration/AmqpConfiguration.java

```java
package com.shuju.test2.util.configuration;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


/**
 * amqp 队列配置
 */
@Configuration
public class AmqpConfiguration {

    @Bean
    public Queue queue() {
        return new Queue("demodemo.queue"); //创业队列
    }
}
```

component/DemoAmqpComponent.java

```java
package com.shuju.test2.component;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

    @Component
    public class DemoAmqpComponent {

        @Autowired
        private AmqpTemplate amqpTemplate;

        public void send(String msg) {
            this.amqpTemplate.convertAndSend("demodemo.queue", msg);
        }

        @RabbitListener(queues = "demodemo.queue")
        public void receiveQueue(String text) {
            System.out.println("接受到：" + text);
        }

    }
```

测试类

```java
package com.shuju.test2;

import com.shuju.test2.component.DemoAmqpComponent;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;


@RunWith(SpringRunner.class)
@SpringBootTest
public class Test2ApplicationTests {

    @Autowired
    private DemoAmqpComponent demoAmqpComponent;

    @Test
    public void send() {
        demoAmqpComponent.send("hello world2");
    }
}
```

运行测试

![](https://3562539340-files.gitbook.io/~/files/v0/b/gitbook-legacy-files/o/assets%2F-LfnT314x6hQ7gJbPKxx%2F-LfnTB6gvTwJcyb-RbKo%2F-LfnTIMNqBwfaBfYjuJO%2F2.2.png?generation=1558862974437035\&alt=media)

## 资料

RabbitMQ下载地址：<http://www.rabbitmq.com/download.html>

erlang 下载地址：<http://www.erlang.org/downloads>

[RabbitMQ详解](https://blog.csdn.net/ityouknow/article/details/70153640)

### docker rabbitmq

[RabbitMQ 通过Docker方式快速安装](https://blog.csdn.net/antma/article/details/81334932)

[docker 安装rabbitMQ](https://www.cnblogs.com/yufeng218/p/9452621.html)

-management结尾的镜像是带管理界面的

```
sudo docker run -d --hostname my-rabbit --name some-rabbit -p 5672:5672 -p 15672:15672 -v `pwd`/data:/work/docker/data/rabbitmq -e RABBITMQ_DEFAULT_VHOST=my_vhost -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin  rabbitmq:3-management
```