（十三）集成RabbitMQ

pom.xml

@@ -179,6 +179,12 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-cache</artifactId>
         </dependency>
+
+        <!-- Rabbit MQ -->
+        <dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-amqp</artifactId>
+		</dependency>
 
 		<!-- swagger -->
 		<dependency>

src/main/java/com/training/rabbitmq/controller/DemoRabbitMqController.java

@@ -0,0 +1,36 @@
+package com.training.rabbitmq.controller;
+
+import io.swagger.annotations.ApiOperation;
+
+import javax.servlet.http.HttpSession;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.training.core.dto.ResultDataDto;
+import com.training.rabbitmq.sender.DemoRabbitMqSender;
+
+/**
+ * 测试Rabbit MQ
+ */
+@RestController
+@RequestMapping(value="/rabbitmq")
+public class DemoRabbitMqController {
+
+	@Autowired
+	private DemoRabbitMqSender demoRabbitMqSender;
+
+	/**
+	 * 发送测试消息队列
+	 */
+	@ApiOperation(value="发送测试消息队列", notes="addEntity")
+    @RequestMapping(value = "/addRabbitMq", method = RequestMethod.GET)
+	public @ResponseBody ResultDataDto addEntity(HttpSession httpSession) {
+		demoRabbitMqSender.send("jkljklkjljjkljl");
+		return ResultDataDto.addAddSuccess();
+	}
+
+}

src/main/java/com/training/rabbitmq/dto/DemoRabbitMqDto.java

@@ -0,0 +1,5 @@
+package com.training.rabbitmq.dto;
+
+public class DemoRabbitMqDto {
+
+}

src/main/java/com/training/rabbitmq/receiver/DemoRabbitMqReceiver.java

@@ -0,0 +1,19 @@
+package com.training.rabbitmq.receiver;
+
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * 消息队列接收类
+ */
+@Component
+@RabbitListener(queues = "hello")
+public class DemoRabbitMqReceiver {
+
+	@RabbitHandler
+	public void process(String content) {
+		System.out.println("Receiver : " + content);
+	}
+
+}

src/main/java/com/training/rabbitmq/sender/DemoRabbitMqSender.java

@@ -0,0 +1,18 @@
+package com.training.rabbitmq.sender;
+
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class DemoRabbitMqSender {
+
+	@Autowired
+	private AmqpTemplate rabbitTemplate;
+
+	public void send(String content) {
+		System.out.println("Sender : " + content);
+		this.rabbitTemplate.convertAndSend("hello", content);
+	}
+
+}

src/main/resources/application.yml

@@ -40,6 +40,11 @@ spring:
                 smtp:
                     auth: true
                     timeout: 25000
+    rabbitmq:
+        host: 192.168.2.71
+        port: 5672
+        username: hxb
+        password: hxb
 
 
 #指定log的配置文件，以及记录Spring Boot的log级别  

src/main/resources/logbak.xml

@@ -15,7 +15,7 @@
 　　　　　　　　</encoder>
 　 </appender>    
 
-  <root level="INFO">             
+  <root level="ERROR">             
     <appender-ref ref="STDOUT" />   
   </root>