diff --git a/pom.xml b/pom.xml
index 4924917..8a3417c 100644
--- a/pom.xml
+++ b/pom.xml
@@ -16,6 +16,7 @@
 
     <modules>
         <module>starter-actuator</module>
+        <module>starter-amqp</module>
         <module>starter-aop</module>
 <!--        <module>starter-batch</module>-->
         <module>starter-cache</module>
diff --git a/starter-amqp/README.md b/starter-amqp/README.md
new file mode 100644
index 0000000..cc6b9ad
--- /dev/null
+++ b/starter-amqp/README.md
@@ -0,0 +1,24 @@
+# starter-amqp
+
+**MQ消息中间件: rabbitmq**
+
+- [rabbitmq 官网](https://www.rabbitmq.com/)
+- [rabbitmq spring官网](https://spring.io/projects/spring-amqp)
+- [rabbitmq github](https://github.com/rabbitmq)
+- [rabbitmq 参考](https://www.jianshu.com/p/a205606182e7)
+
+## 依赖引入
+
+```xml
+        <!--MQ rabbitmq-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+            <!--内置 amqp-client 5.9.0-->
+        </dependency>
+        <!--MQ rabbitmq Json 消息转换器-->
+        <dependency>
+            <groupId>com.fasterxml.jackson.dataformat</groupId>
+            <artifactId>jackson-dataformat-xml</artifactId>
+        </dependency>
+```
diff --git a/starter-amqp/pom.xml b/starter-amqp/pom.xml
new file mode 100644
index 0000000..b058b2d
--- /dev/null
+++ b/starter-amqp/pom.xml
@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.zja</groupId>
+        <artifactId>spring-boot-starter-test-root</artifactId>
+        <version>2.0-SNAPSHOT</version>
+    </parent>
+
+    <groupId>com.zja</groupId>
+    <artifactId>starter-amqp</artifactId>
+    <packaging>jar</packaging>
+
+    <dependencies>
+        <!--MQ rabbitmq-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+            <!--内置 amqp-client 5.9.0-->
+        </dependency>
+        <!--MQ rabbitmq Json 消息转换器-->
+        <dependency>
+            <groupId>com.fasterxml.jackson.dataformat</groupId>
+            <artifactId>jackson-dataformat-xml</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-boot-starter</artifactId>
+            <version>3.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>
diff --git a/starter-amqp/src/main/java/com/zja/AmqpApplication.java b/starter-amqp/src/main/java/com/zja/AmqpApplication.java
new file mode 100644
index 0000000..cf6c8c9
--- /dev/null
+++ b/starter-amqp/src/main/java/com/zja/AmqpApplication.java
@@ -0,0 +1,24 @@
+/**
+ * @Company: 上海数慧系统技术有限公司
+ * @Department: 数据中心
+ * @Author: 郑家骜[ào]
+ * @Email: zhengja@dist.com.cn
+ * @Date: 2022-12-16 10:22
+ * @Since:
+ */
+package com.zja;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * http://localhost:8080/swagger-ui/index.html#/
+ */
+@SpringBootApplication
+public class AmqpApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(AmqpApplication.class, args);
+    }
+
+}
diff --git a/starter-amqp/src/main/java/com/zja/config/FanoutConfig.java b/starter-amqp/src/main/java/com/zja/config/FanoutConfig.java
new file mode 100644
index 0000000..182076c
--- /dev/null
+++ b/starter-amqp/src/main/java/com/zja/config/FanoutConfig.java
@@ -0,0 +1,61 @@
+/**
+ * @Company: 上海数慧系统技术有限公司
+ * @Department: 数据中心
+ * @Author: 郑家骜[ào]
+ * @Email: zhengja@dist.com.cn
+ * @Date: 2022-12-14 17:15
+ * @Since:
+ */
+package com.zja.config;
+
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.FanoutExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class FanoutConfig {
+
+    /**
+     * 声明交换机
+     * @return Fanout类型交换机
+     */
+    @Bean
+    public FanoutExchange fanoutExchange() {
+        return new FanoutExchange("stone.fanout");
+    }
+
+    /**
+     * 第1个队列
+     */
+    @Bean
+    public Queue fanoutQueue1() {
+        return new Queue("fanout.queue1");
+    }
+
+    /**
+     * 绑定队列和交换机
+     */
+    @Bean
+    public Binding bindingQueue1(Queue fanoutQueue1, FanoutExchange fanoutExchange) {
+        return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);
+    }
+
+    /**
+     * 第2个队列
+     */
+    @Bean
+    public Queue fanoutQueue2() {
+        return new Queue("fanout.queue2");
+    }
+
+    /**
+     * 绑定队列和交换机
+     */
+    @Bean
+    public Binding bindingQueue2(Queue fanoutQueue2, FanoutExchange fanoutExchange) {
+        return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);
+    }
+}
diff --git a/starter-amqp/src/main/java/com/zja/config/RabbitConfig.java b/starter-amqp/src/main/java/com/zja/config/RabbitConfig.java
new file mode 100644
index 0000000..3f4bebc
--- /dev/null
+++ b/starter-amqp/src/main/java/com/zja/config/RabbitConfig.java
@@ -0,0 +1,26 @@
+/**
+ * @Company: 上海数慧系统技术有限公司
+ * @Department: 数据中心
+ * @Author: 郑家骜[ào]
+ * @Email: zhengja@dist.com.cn
+ * @Date: 2022-12-14 17:54
+ * @Since:
+ */
+package com.zja.config;
+
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.amqp.support.converter.MessageConverter;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RabbitConfig {
+
+    /**
+     * 配置 Json 消息转换器
+     */
+    @Bean
+    public MessageConverter jsonMessageConverter() {
+        return new Jackson2JsonMessageConverter();
+    }
+}
diff --git a/starter-amqp/src/main/java/com/zja/config/Swagger3Config.java b/starter-amqp/src/main/java/com/zja/config/Swagger3Config.java
new file mode 100644
index 0000000..f074f2f
--- /dev/null
+++ b/starter-amqp/src/main/java/com/zja/config/Swagger3Config.java
@@ -0,0 +1,40 @@
+/**
+ * @Company: 上海数慧系统技术有限公司
+ * @Department: 数据中心
+ * @Author: 郑家骜[ào]
+ * @Email: zhengja@dist.com.cn
+ * @Date: 2021-10-22 15:17
+ * @Since:
+ */
+package com.zja.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import springfox.documentation.builders.ApiInfoBuilder;
+import springfox.documentation.builders.PathSelectors;
+import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.oas.annotations.EnableOpenApi;
+import springfox.documentation.service.ApiInfo;
+import springfox.documentation.service.Contact;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+
+/**
+ * http://localhost:8080/swagger-ui/index.html#/
+ */
+@EnableOpenApi
+@Configuration
+public class Swagger3Config {
+
+    @Bean
+    public Docket createRestApi() {
+        return new Docket(DocumentationType.OAS_30).apiInfo(apiInfo()).select()
+                .apis(RequestHandlerSelectors.basePackage("com.zja")).paths(PathSelectors.any())
+                .build();
+    }
+
+    private ApiInfo apiInfo() {
+        return new ApiInfoBuilder().title("提供rest服务").description("我是描述").contact(new Contact("联系人", "www.baidu.com", "123@qq.com"))
+                .version("1.0").build();
+    }
+}
diff --git a/starter-amqp/src/main/java/com/zja/controller/RabbitTemplateController.java b/starter-amqp/src/main/java/com/zja/controller/RabbitTemplateController.java
new file mode 100644
index 0000000..e180a80
--- /dev/null
+++ b/starter-amqp/src/main/java/com/zja/controller/RabbitTemplateController.java
@@ -0,0 +1,288 @@
+/**
+ * @Company: 上海数慧系统技术有限公司
+ * @Department: 数据中心
+ * @Author: 郑家骜[ào]
+ * @Email: zhengja@dist.com.cn
+ * @Date: 2022-12-14 16:38
+ * @Since:
+ */
+package com.zja.controller;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.zja.config.FanoutConfig;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.amqp.core.ExchangeTypes;
+import org.springframework.amqp.rabbit.annotation.Exchange;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.QueueBinding;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalTime;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * http://localhost:8080/swagger-ui/index.html#/
+ *
+ * 消息消费后就会从Queue中消失（后续的几种模型都是如此）
+ */
+@RestController
+@RequestMapping("/rabbit/template")
+public class RabbitTemplateController {
+
+    @Autowired
+    RabbitTemplate rabbitTemplate;
+
+    //------------------------- BasicQueue ----------------------------------
+
+    /**
+     * 消息接收  监听器  先建 simple.queue
+     * @param msg 消息
+     */
+    @RabbitListener(queues = "simple.queue")
+    public void listenSimpleQueueMsg(String msg) {
+        //被消费掉的消息，会从RabbitMQ服务端中消失，不能够再被消费
+        System.out.println("消费方接收到消息：" + msg);
+    }
+
+    /**
+     * 消息发送 rabbitTemplate
+     */
+    @ApiOperation("发送消息 BasicQueue 队列")
+    @GetMapping("convertAndSend")
+    public void convertAndSend() {
+        // 队列名称 需手动创建
+        String queueName = "simple.queue";
+        // 消息
+        String message = "Hello, Spring AMQP!";
+        // 发送消息
+        rabbitTemplate.convertAndSend(queueName, message);
+    }
+
+
+    //------------------------- WorkQueue ----------------------------------
+
+    /**
+     * 消息接收
+     * 注意先手动创建 simple.queue2 队列
+     */
+    @RabbitListener(queues = "simple.queue2")
+    public void listenWorkQueue1(String msg) throws InterruptedException {
+        System.out.println("消费者1接收到消息：【" + msg + "】" + LocalTime.now());
+        Thread.sleep(20);
+    }
+
+    @RabbitListener(queues = "simple.queue2")
+    public void listenWorkQueue2(String msg) throws InterruptedException {
+        System.err.println("消费者2-接收到消息：【" + msg + "】" + LocalTime.now());
+        Thread.sleep(200);
+    }
+
+    /**
+     * 消息发送 模拟消息堆积
+     */
+    @ApiOperation(value = "发送消息 WorkQueue 队列", notes = "支持一对多发布消息,多个消费者可以提高消息消费速度，消息消费后就会从Queue中消失")
+    @GetMapping("convertAndSend/v2")
+    public void convertAndSend2() throws InterruptedException {
+        // 队列名称 需手动创建
+        String queueName = "simple.queue2";
+        // 消息
+        String message = "Message_";
+        for (int i = 1; i <= 50; i++) {
+            // 发送消息
+            rabbitTemplate.convertAndSend(queueName, message + i);
+            Thread.sleep(20);
+        }
+    }
+
+
+    //------------------------- Fanout ----------------------------------
+
+    /**
+     * 消息接收
+     * @see FanoutConfig 查看 交换机和和队列绑定
+     */
+    @RabbitListener(queues = "fanout.queue1")
+    public void listen1FanoutQueueMsg(String msg) {
+        System.out.println("Listener1 get :" + msg);
+    }
+
+    @RabbitListener(queues = "fanout.queue2")
+    public void listen2FanoutQueueMsg(String msg) {
+        System.out.println("Listener2 get :" + msg);
+    }
+
+    /**
+     * 消息发送
+     */
+    @ApiOperation("发送消息 Fanout 队列")
+    @GetMapping("convertAndSend/v3")
+    public void convertAndSend3() {
+        // 交换机名称 会自动创建
+        String exchangeName = "stone.fanout";
+        // 消息
+        String message = "Hello, Fanout!";
+        rabbitTemplate.convertAndSend(exchangeName, "", message);
+    }
+
+
+    //------------------------- Direct ----------------------------------
+
+    /**
+     * 消息接收
+     * 会自动创建 Queue、Exchange
+     */
+    @RabbitListener(bindings = @QueueBinding(
+            value = @Queue(name = "direct.queue1"),
+            exchange = @Exchange(name = "stone.direct", type = ExchangeTypes.DIRECT),
+            key = {"talkshow", "musicshow"} //配置订阅
+    ))
+    public void listenDirectQueue1(String msg) {
+        System.out.println("DirectQueue1 :" + msg);
+    }
+
+    @RabbitListener(bindings = @QueueBinding(
+            value = @Queue(name = "direct.queue2"),
+            exchange = @Exchange(name = "stone.direct", type = ExchangeTypes.DIRECT),
+            key = {"talkshow", "news"}
+    ))
+    public void listenDirectQueue2(String msg) {
+        System.out.println("DirectQueue2 :" + msg);
+    }
+
+    /**
+     * 消息发送
+     */
+    @ApiOperation("发送消息 Direct 队列")
+    @GetMapping("convertAndSend/v4")
+    public void convertAndSend4() {
+        // 交换机名称 会自动创建
+        String exchangeName = "stone.direct";
+        // 消息
+        String messageNews = "新闻：2022的第一场雪比往年来的稍晚一些";
+        // 发送消息
+        rabbitTemplate.convertAndSend(exchangeName, "news", messageNews);
+        // 消息
+        String messageTalks = "脱口秀：大赛即将开始";
+        // 发送消息
+        rabbitTemplate.convertAndSend(exchangeName, "talkshow", messageTalks);
+    }
+
+
+    //------------------------- Topic ----------------------------------
+
+    /**
+     * 消息接收
+     * 会自动创建 Queue、Exchange
+     */
+    @RabbitListener(bindings = @QueueBinding(
+            value = @Queue(name = "topic.queue1"),
+            exchange = @Exchange(name = "stone.topic", type = ExchangeTypes.TOPIC),
+            key = {"China.#"}
+    ))
+    public void listenTopicQueue1(String msg) {
+        System.out.println("TopicQueue1 :" + msg);
+    }
+
+    @RabbitListener(bindings = @QueueBinding(
+            value = @Queue(name = "topic.queue2"),
+            exchange = @Exchange(name = "stone.topic", type = ExchangeTypes.TOPIC),
+            key = {"#.news"}
+    ))
+    public void listenTopicQueue2(String msg) {
+        System.out.println("TopicQueue2 :" + msg);
+    }
+
+    /**
+     * 消息发送
+     */
+    @ApiOperation("发送消息 Topic 队列")
+    @GetMapping("convertAndSend/v5")
+    public void convertAndSend5() {
+        // 交换机名称
+        String exchangeName = "stone.topic";
+        // 消息
+        String message = "新闻：china新闻消息";
+        // 发送消息
+        rabbitTemplate.convertAndSend(exchangeName, "china.news", message);
+//        rabbitTemplate.convertAndSend(exchangeName, "China.news", message);
+    }
+
+
+    //------------------------- 消息转换器 默认 ----------------------------------
+
+    /**
+     * 消息接收
+     * 先手动创建 queues
+     */
+    @RabbitListener(queues = "object.queue")
+    public void listenObjectQueue(HashMap<String, Object> msg) {
+        System.out.println("object.queue get msg is: " + msg);
+    }
+
+    /**
+     * 消息发送
+     */
+    @ApiOperation("发送消息 默认消息转换器")
+    @GetMapping("convertAndSend/v6")
+    public void convertAndSend6() {
+        // 准备消息
+        Map<String, Object> msg = new HashMap<>();
+        msg.put("name", "Jackson");
+        msg.put("age", 24);
+        // 发送消息
+        rabbitTemplate.convertAndSend("object.queue", msg);
+    }
+
+    //------------------------- calss对象消息发送和接收 ----------------------------------
+
+    /**
+     * 消息接收
+     * 先手动创建 queues
+     */
+    @RabbitListener(queues = "class.queue")
+    public void listenCalssQueue(String msg) throws JsonProcessingException {
+        System.out.println("class.queue get msg is: " + msg);
+
+        ObjectMapper objectMapper = new ObjectMapper();
+        UserDemo userDemo = objectMapper.readValue(msg, UserDemo.class);
+        System.out.println(userDemo);
+    }
+
+    /**
+     * 消息发送
+     */
+    @ApiOperation("发送消息 calss对象传输")
+    @GetMapping("convertAndSend/v7")
+    public void convertAndSend7() throws JsonProcessingException {
+        // 准备消息
+        UserDemo userDemo = new UserDemo();
+        userDemo.setUsername("Jackson");
+        userDemo.setAge(22);
+
+        ObjectMapper objectMapper = new ObjectMapper();
+        String jsonStr = objectMapper.writeValueAsString(userDemo);
+
+        // 发送消息
+        rabbitTemplate.convertAndSend("class.queue", jsonStr);
+    }
+
+    @Data
+    @NoArgsConstructor
+    @AllArgsConstructor
+    public static class UserDemo {
+        private String username;
+        private int age;
+        private String sex;
+    }
+
+}
diff --git a/starter-amqp/src/main/resources/application.yaml b/starter-amqp/src/main/resources/application.yaml
new file mode 100644
index 0000000..f3d6a31
--- /dev/null
+++ b/starter-amqp/src/main/resources/application.yaml
@@ -0,0 +1,21 @@
+spring:
+  rabbitmq:
+    #    addresses: amqp://admin:pass@localhost
+    host: 192.168.159.136
+    port: 5672
+    username: admin
+    password: pass
+    virtual-host: /
+    #下面是，可选的配置
+    publisher-confirm-type: correlated  # 开启生产者的消息确认
+    publisher-returns: true             # 开启消费者的消息确认
+    listener:
+      simple:
+        # ack模式 手动
+        acknowledge-mode: manual
+        # 消费者限流，每次只能获取一条消息，处理完成才能获取下一个消息
+        prefetch: 1
+        # 并发处理的线程最小数目，不能大于 max-concurrency
+        concurrency: 3
+        # 并发处理的线程最大数目，不能小于 concurrency
+        max-concurrency: 5