From 8ca437cb04d61d338c2da1d4d3795040813ed940 Mon Sep 17 00:00:00 2001
From: qq276105859 <276105859@qq.com>
Date: Sun, 3 Dec 2017 20:29:00 +0800
Subject: [PATCH 1/6] =?UTF-8?q?guava=E5=A4=9A=E7=BA=BF=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/critc/multithread/GuavaMultiThread.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/chapter11_2_multithread_guava/src/main/java/com/critc/multithread/GuavaMultiThread.java b/chapter11_2_multithread_guava/src/main/java/com/critc/multithread/GuavaMultiThread.java
index e488941..0a37438 100644
--- a/chapter11_2_multithread_guava/src/main/java/com/critc/multithread/GuavaMultiThread.java
+++ b/chapter11_2_multithread_guava/src/main/java/com/critc/multithread/GuavaMultiThread.java
@@ -24,7 +24,7 @@ public class GuavaMultiThread {
      */
     public List<String> createTickets() {
         List<String> list = new ArrayList<>();
-        for (int i = 0; i < 100; i++) {
+        for (int i = 0; i < 1000; i++) {
             list.add("车票" + i);
         }
         return list;

From f27b6e15e21001b808405bbf2dae408b66e25d6c Mon Sep 17 00:00:00 2001
From: qq276105859 <276105859@qq.com>
Date: Sun, 3 Dec 2017 20:29:48 +0800
Subject: [PATCH 2/6] =?UTF-8?q?rest=E5=BA=94=E7=94=A8=E4=BE=8B=E5=AD=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 chapter10_1_rest/pom.xml | 103 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 103 insertions(+)
 create mode 100644 chapter10_1_rest/pom.xml

diff --git a/chapter10_1_rest/pom.xml b/chapter10_1_rest/pom.xml
new file mode 100644
index 0000000..7f720cc
--- /dev/null
+++ b/chapter10_1_rest/pom.xml
@@ -0,0 +1,103 @@
+<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 http://maven.apache.org/maven-v4_0_0.xsd">
+    <parent>
+        <artifactId>java_component</artifactId>
+        <groupId>com.critc</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>chapter10_1_rest</artifactId>
+    <packaging>war</packaging>
+    <name>chapter10_1_rest Maven Webapp</name>
+    <url>http://maven.apache.org</url>
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <spring.version>4.3.3.RELEASE</spring.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-core</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-beans</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-aspects</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-aop</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context-support</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-jdbc</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-webmvc</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>jstl</groupId>
+            <artifactId>jstl</artifactId>
+            <version>1.2</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.servlet</groupId>
+            <artifactId>javax.servlet-api</artifactId>
+            <version>3.1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>5.1.18</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid</artifactId>
+            <version>1.0.25</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.12</version>
+        </dependency>
+
+    </dependencies>
+    <build>
+        <finalName>chapter10_1_rest</finalName>
+    </build>
+</project>

From fee5a0f1c289ffe7036ee286eb19e22e87c83746 Mon Sep 17 00:00:00 2001
From: qq276105859 <276105859@qq.com>
Date: Sun, 3 Dec 2017 20:30:26 +0800
Subject: [PATCH 3/6] =?UTF-8?q?rest=E5=BA=94=E7=94=A8=E4=BE=8B=E5=AD=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 chapter8_1_rabbitmq/pom.xml | 24 ++++++++++++++++++++++++
 pom.xml                     |  1 +
 2 files changed, 25 insertions(+)
 create mode 100644 chapter8_1_rabbitmq/pom.xml

diff --git a/chapter8_1_rabbitmq/pom.xml b/chapter8_1_rabbitmq/pom.xml
new file mode 100644
index 0000000..712a5b5
--- /dev/null
+++ b/chapter8_1_rabbitmq/pom.xml
@@ -0,0 +1,24 @@
+<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 http://maven.apache.org/maven-v4_0_0.xsd">
+    <parent>
+        <artifactId>java_component</artifactId>
+        <groupId>com.critc</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>chapter8_1_rabbitmq</artifactId>
+    <packaging>war</packaging>
+    <name>chapter8_1_rabbitmq Maven Webapp</name>
+    <url>http://maven.apache.org</url>
+    <dependencies>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>3.8.1</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    <build>
+        <finalName>chapter8_1_rabbitmq</finalName>
+    </build>
+</project>
diff --git a/pom.xml b/pom.xml
index 8b5b7ba..f4c4c7b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -28,6 +28,7 @@
         <module>chapter9_2_cxf</module>
         <module>chapter9_3_axis2</module>
         <module>chapter17_echarts</module>
+        <module>chapter8_1_rabbitmq</module>
     </modules>
     <packaging>pom</packaging>
 

From dd068550fc5010e0763c4aaa220b5bd22bda0036 Mon Sep 17 00:00:00 2001
From: qq276105859 <276105859@qq.com>
Date: Sun, 3 Dec 2017 20:31:08 +0800
Subject: [PATCH 4/6] =?UTF-8?q?rest=E5=BA=94=E7=94=A8=E4=BE=8B=E5=AD=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/critc/controller/FirstController.java | 20 +++++++++++++
 .../src/main/resources/servlet-context.xml    | 28 +++++++++++++++++++
 .../src/main/webapp/WEB-INF/web.xml           | 20 +++++++++++++
 chapter10_1_rest/src/main/webapp/index.jsp    |  5 ++++
 4 files changed, 73 insertions(+)
 create mode 100644 chapter10_1_rest/src/main/java/com/critc/controller/FirstController.java
 create mode 100644 chapter10_1_rest/src/main/resources/servlet-context.xml
 create mode 100644 chapter10_1_rest/src/main/webapp/WEB-INF/web.xml
 create mode 100644 chapter10_1_rest/src/main/webapp/index.jsp

diff --git a/chapter10_1_rest/src/main/java/com/critc/controller/FirstController.java b/chapter10_1_rest/src/main/java/com/critc/controller/FirstController.java
new file mode 100644
index 0000000..f673634
--- /dev/null
+++ b/chapter10_1_rest/src/main/java/com/critc/controller/FirstController.java
@@ -0,0 +1,20 @@
+package com.critc.controller;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * Created by 孔垂云 on 2017/11/30.
+ */
+@RestController
+@RequestMapping("/")
+public class FirstController {
+
+    @RequestMapping("/sayHello")
+    public String sayHelllo(HttpServletRequest request, @RequestParam("name") String name) {
+        return request.getLocalPort() + "hello:" + name;
+    }
+}
diff --git a/chapter10_1_rest/src/main/resources/servlet-context.xml b/chapter10_1_rest/src/main/resources/servlet-context.xml
new file mode 100644
index 0000000..1112fba
--- /dev/null
+++ b/chapter10_1_rest/src/main/resources/servlet-context.xml
@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:aop="http://www.springframework.org/schema/aop"
+       xmlns:mvc="http://www.springframework.org/schema/mvc"
+       xmlns:context="http://www.springframework.org/schema/context"
+       xsi:schemaLocation="
+	http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
+	http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
+	http://www.springframework.org/schema/aop
+	http://www.springframework.org/schema/aop/spring-aop.xsd
+	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
+
+    <context:component-scan base-package="com.critc"/>
+
+    <!-- 默认的注解映射的支持，自动注册DefaultAnnotationHandlerMapping和AnnotationMethodHandlerAdapter -->
+    <mvc:annotation-driven/>
+
+    <!-- 视图解释类 -->
+    <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
+        <property name="prefix" value="/WEB-INF/views/"/>
+        <property name="suffix" value=".jsp"/>
+        <property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>
+    </bean>
+
+    <!-- 对静态资源文件的访问-->
+    <mvc:resources mapping="/assets/**" location="/assets"/>
+
+</beans>
\ No newline at end of file
diff --git a/chapter10_1_rest/src/main/webapp/WEB-INF/web.xml b/chapter10_1_rest/src/main/webapp/WEB-INF/web.xml
new file mode 100644
index 0000000..526e4a9
--- /dev/null
+++ b/chapter10_1_rest/src/main/webapp/WEB-INF/web.xml
@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
+	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
+	version="2.5">
+	<!-- ================spring mvc 适配器================ -->  
+	<servlet> 
+		<servlet-name>springMVC</servlet-name>  
+		<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>  
+		<init-param>  
+			<param-name>contextConfigLocation</param-name>  
+			<param-value>classpath*:/servlet-context.xml</param-value>  
+		</init-param>  
+		<load-on-startup>1</load-on-startup>  
+	</servlet>  
+	<servlet-mapping>
+		<servlet-name>springMVC</servlet-name>  
+		<url-pattern>/</url-pattern>
+	</servlet-mapping>
+</web-app>
\ No newline at end of file
diff --git a/chapter10_1_rest/src/main/webapp/index.jsp b/chapter10_1_rest/src/main/webapp/index.jsp
new file mode 100644
index 0000000..c38169b
--- /dev/null
+++ b/chapter10_1_rest/src/main/webapp/index.jsp
@@ -0,0 +1,5 @@
+<html>
+<body>
+<h2>Hello World!</h2>
+</body>
+</html>

From 23c34929add28bcd4bc13f5a192e1a8e8a719dc6 Mon Sep 17 00:00:00 2001
From: qq276105859 <276105859@qq.com>
Date: Sun, 3 Dec 2017 20:44:24 +0800
Subject: [PATCH 5/6] =?UTF-8?q?rabbitmq=E5=92=8Cspring=E6=95=B4=E5=90=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 chapter8_1_rabbitmq/pom.xml                   | 57 ++++++++++++++++++-
 .../src/main/java/com/critc/RabbitMqTest.java | 24 ++++++++
 .../src/main/resources/application.properties |  5 ++
 .../resources/applicationContext-rabbitmq.xml | 23 ++++++++
 .../src/main/webapp/WEB-INF/web.xml           |  7 +++
 chapter8_1_rabbitmq/src/main/webapp/index.jsp |  5 ++
 chapter8_2_rabbitmq_listener/pom.xml          | 24 ++++++++
 pom.xml                                       |  1 +
 8 files changed, 144 insertions(+), 2 deletions(-)
 create mode 100644 chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java
 create mode 100644 chapter8_1_rabbitmq/src/main/resources/application.properties
 create mode 100644 chapter8_1_rabbitmq/src/main/resources/applicationContext-rabbitmq.xml
 create mode 100644 chapter8_1_rabbitmq/src/main/webapp/WEB-INF/web.xml
 create mode 100644 chapter8_1_rabbitmq/src/main/webapp/index.jsp
 create mode 100644 chapter8_2_rabbitmq_listener/pom.xml

diff --git a/chapter8_1_rabbitmq/pom.xml b/chapter8_1_rabbitmq/pom.xml
index 712a5b5..21b821b 100644
--- a/chapter8_1_rabbitmq/pom.xml
+++ b/chapter8_1_rabbitmq/pom.xml
@@ -10,12 +10,65 @@
     <packaging>war</packaging>
     <name>chapter8_1_rabbitmq Maven Webapp</name>
     <url>http://maven.apache.org</url>
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <junit.version>4.12</junit.version>
+        <spring.version>4.3.3.RELEASE</spring.version>
+        <spring-rabbit.version>1.7.1.RELEASE</spring-rabbit.version>
+        <amqp-client.version>3.6.5</amqp-client.version>
+    </properties>
+
     <dependencies>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-aop</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-aspects</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-beans</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context-support</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-core</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <!-- rabbitmq -->
+        <dependency>
+            <groupId>org.springframework.amqp</groupId>
+            <artifactId>spring-rabbit</artifactId>
+            <version>${spring-rabbit.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.rabbitmq</groupId>
+            <artifactId>amqp-client</artifactId>
+            <version>${amqp-client.version}</version>
+        </dependency>
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
-            <version>3.8.1</version>
-            <scope>test</scope>
+            <version>${junit.version}</version>
         </dependency>
     </dependencies>
     <build>
diff --git a/chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java b/chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java
new file mode 100644
index 0000000..cb3e71e
--- /dev/null
+++ b/chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java
@@ -0,0 +1,24 @@
+package com.critc;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * Created by 孔垂云 on 2017/12/3.
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath*:applicationContext-rabbitmq.xml"})
+public class RabbitMqTest {
+    @Autowired
+    private AmqpTemplate amqpTemplate;
+
+    @Test
+    public void send() {
+        amqpTemplate.convertAndSend("test_mq", "第一条消息");
+    }
+
+}
diff --git a/chapter8_1_rabbitmq/src/main/resources/application.properties b/chapter8_1_rabbitmq/src/main/resources/application.properties
new file mode 100644
index 0000000..696baf3
--- /dev/null
+++ b/chapter8_1_rabbitmq/src/main/resources/application.properties
@@ -0,0 +1,5 @@
+rabbit.host=127.0.0.1
+rabbit.username=test1
+rabbit.password=123
+rabbit.port=5672
+rabbit.vhost=/
\ No newline at end of file
diff --git a/chapter8_1_rabbitmq/src/main/resources/applicationContext-rabbitmq.xml b/chapter8_1_rabbitmq/src/main/resources/applicationContext-rabbitmq.xml
new file mode 100644
index 0000000..cfc2159
--- /dev/null
+++ b/chapter8_1_rabbitmq/src/main/resources/applicationContext-rabbitmq.xml
@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:rabbit="http://www.springframework.org/schema/rabbit"
+       xmlns:context="http://www.springframework.org/schema/context"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans
+    http://www.springframework.org/schema/beans/spring-beans.xsd 
+    http://www.springframework.org/schema/context
+	http://www.springframework.org/schema/context/spring-context.xsd
+    http://www.springframework.org/schema/rabbit
+    http://www.springframework.org/schema/rabbit/spring-rabbit.xsd">
+
+    <description>rabbitmq 连接服务配置</description>
+    <context:property-placeholder ignore-unresolvable="true" location="classpath:/application.properties"/>
+    <rabbit:connection-factory id="rabbitConnectionFactory" host="${rabbit.host}" port="${rabbit.port}"
+                               username="${rabbit.username}" password="${rabbit.password}"
+                               virtual-host="${rabbit.vhost}" channel-cache-size="50"/>
+    <rabbit:admin connection-factory="rabbitConnectionFactory"/>
+
+    <rabbit:template id="rabbitTemplate" connection-factory="rabbitConnectionFactory"
+                     message-converter="simpleMessageConverter">
+    </rabbit:template>
+    <bean id="simpleMessageConverter" class="org.springframework.amqp.support.converter.SimpleMessageConverter"></bean>
+</beans>
\ No newline at end of file
diff --git a/chapter8_1_rabbitmq/src/main/webapp/WEB-INF/web.xml b/chapter8_1_rabbitmq/src/main/webapp/WEB-INF/web.xml
new file mode 100644
index 0000000..9f88c1f
--- /dev/null
+++ b/chapter8_1_rabbitmq/src/main/webapp/WEB-INF/web.xml
@@ -0,0 +1,7 @@
+<!DOCTYPE web-app PUBLIC
+ "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
+ "http://java.sun.com/dtd/web-app_2_3.dtd" >
+
+<web-app>
+  <display-name>Archetype Created Web Application</display-name>
+</web-app>
diff --git a/chapter8_1_rabbitmq/src/main/webapp/index.jsp b/chapter8_1_rabbitmq/src/main/webapp/index.jsp
new file mode 100644
index 0000000..c38169b
--- /dev/null
+++ b/chapter8_1_rabbitmq/src/main/webapp/index.jsp
@@ -0,0 +1,5 @@
+<html>
+<body>
+<h2>Hello World!</h2>
+</body>
+</html>
diff --git a/chapter8_2_rabbitmq_listener/pom.xml b/chapter8_2_rabbitmq_listener/pom.xml
new file mode 100644
index 0000000..edebfd2
--- /dev/null
+++ b/chapter8_2_rabbitmq_listener/pom.xml
@@ -0,0 +1,24 @@
+<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 http://maven.apache.org/maven-v4_0_0.xsd">
+    <parent>
+        <artifactId>java_component</artifactId>
+        <groupId>com.critc</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>chapter8_2_rabbitmq_listener</artifactId>
+    <packaging>war</packaging>
+    <name>chapter8_2_rabbitmq_listener Maven Webapp</name>
+    <url>http://maven.apache.org</url>
+    <dependencies>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>3.8.1</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    <build>
+        <finalName>chapter8_2_rabbitmq_listener</finalName>
+    </build>
+</project>
diff --git a/pom.xml b/pom.xml
index f4c4c7b..9e18d68 100644
--- a/pom.xml
+++ b/pom.xml
@@ -29,6 +29,7 @@
         <module>chapter9_3_axis2</module>
         <module>chapter17_echarts</module>
         <module>chapter8_1_rabbitmq</module>
+        <module>chapter8_2_rabbitmq_listener</module>
     </modules>
     <packaging>pom</packaging>
 

From be1a2e234de6e3aaa6740253e83062a4f9b4a666 Mon Sep 17 00:00:00 2001
From: qq276105859 <276105859@qq.com>
Date: Sun, 3 Dec 2017 21:38:36 +0800
Subject: [PATCH 6/6] =?UTF-8?q?rabbitmq=E6=B6=88=E8=B4=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/critc/RabbitMqTest.java |  7 ++-
 chapter8_2_rabbitmq_listener/pom.xml          | 57 ++++++++++++++++++-
 .../com/critc/service/RabbitmqService.java    | 19 +++++++
 .../src/main/resources/application.properties |  5 ++
 .../resources/applicationContext-rabbitmq.xml | 24 ++++++++
 .../src/main/webapp/WEB-INF/web.xml           | 15 +++++
 .../src/main/webapp/index.jsp                 |  5 ++
 7 files changed, 128 insertions(+), 4 deletions(-)
 create mode 100644 chapter8_2_rabbitmq_listener/src/main/java/com/critc/service/RabbitmqService.java
 create mode 100644 chapter8_2_rabbitmq_listener/src/main/resources/application.properties
 create mode 100644 chapter8_2_rabbitmq_listener/src/main/resources/applicationContext-rabbitmq.xml
 create mode 100644 chapter8_2_rabbitmq_listener/src/main/webapp/WEB-INF/web.xml
 create mode 100644 chapter8_2_rabbitmq_listener/src/main/webapp/index.jsp

diff --git a/chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java b/chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java
index cb3e71e..8015314 100644
--- a/chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java
+++ b/chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java
@@ -17,8 +17,11 @@ public class RabbitMqTest {
     private AmqpTemplate amqpTemplate;
 
     @Test
-    public void send() {
-        amqpTemplate.convertAndSend("test_mq", "第一条消息");
+    public void send() throws Exception {
+        for (int i = 0; i < 100; i++) {
+            amqpTemplate.convertAndSend("test_mq", "第一条消息");
+            Thread.sleep(3000);
+        }
     }
 
 }
diff --git a/chapter8_2_rabbitmq_listener/pom.xml b/chapter8_2_rabbitmq_listener/pom.xml
index edebfd2..fa878c7 100644
--- a/chapter8_2_rabbitmq_listener/pom.xml
+++ b/chapter8_2_rabbitmq_listener/pom.xml
@@ -10,12 +10,65 @@
     <packaging>war</packaging>
     <name>chapter8_2_rabbitmq_listener Maven Webapp</name>
     <url>http://maven.apache.org</url>
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <junit.version>4.12</junit.version>
+        <spring.version>4.3.3.RELEASE</spring.version>
+        <spring-rabbit.version>1.7.1.RELEASE</spring-rabbit.version>
+        <amqp-client.version>3.6.5</amqp-client.version>
+    </properties>
+
     <dependencies>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-aop</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-aspects</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-beans</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context-support</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-core</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+        <!-- rabbitmq -->
+        <dependency>
+            <groupId>org.springframework.amqp</groupId>
+            <artifactId>spring-rabbit</artifactId>
+            <version>${spring-rabbit.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.rabbitmq</groupId>
+            <artifactId>amqp-client</artifactId>
+            <version>${amqp-client.version}</version>
+        </dependency>
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
-            <version>3.8.1</version>
-            <scope>test</scope>
+            <version>${junit.version}</version>
         </dependency>
     </dependencies>
     <build>
diff --git a/chapter8_2_rabbitmq_listener/src/main/java/com/critc/service/RabbitmqService.java b/chapter8_2_rabbitmq_listener/src/main/java/com/critc/service/RabbitmqService.java
new file mode 100644
index 0000000..b10935d
--- /dev/null
+++ b/chapter8_2_rabbitmq_listener/src/main/java/com/critc/service/RabbitmqService.java
@@ -0,0 +1,19 @@
+package com.critc.service;
+
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.core.MessageListener;
+import org.springframework.stereotype.Service;
+
+/**
+ * Created by 孔垂云 on 2017/12/3.
+ */
+@Service
+public class RabbitmqService implements MessageListener {
+    public void onMessage(Message message) {
+        try {
+            String msg = new String(message.getBody(), "utf-8");
+            System.out.println("消息消费者 = " + msg);
+        } catch (Exception e) {
+        }
+    }
+}
diff --git a/chapter8_2_rabbitmq_listener/src/main/resources/application.properties b/chapter8_2_rabbitmq_listener/src/main/resources/application.properties
new file mode 100644
index 0000000..696baf3
--- /dev/null
+++ b/chapter8_2_rabbitmq_listener/src/main/resources/application.properties
@@ -0,0 +1,5 @@
+rabbit.host=127.0.0.1
+rabbit.username=test1
+rabbit.password=123
+rabbit.port=5672
+rabbit.vhost=/
\ No newline at end of file
diff --git a/chapter8_2_rabbitmq_listener/src/main/resources/applicationContext-rabbitmq.xml b/chapter8_2_rabbitmq_listener/src/main/resources/applicationContext-rabbitmq.xml
new file mode 100644
index 0000000..a70383e
--- /dev/null
+++ b/chapter8_2_rabbitmq_listener/src/main/resources/applicationContext-rabbitmq.xml
@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:rabbit="http://www.springframework.org/schema/rabbit"
+       xmlns:context="http://www.springframework.org/schema/context"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans
+    http://www.springframework.org/schema/beans/spring-beans.xsd 
+    http://www.springframework.org/schema/context
+	http://www.springframework.org/schema/context/spring-context.xsd
+    http://www.springframework.org/schema/rabbit
+    http://www.springframework.org/schema/rabbit/spring-rabbit.xsd">
+
+    <description>rabbitmq 连接服务配置</description>
+    <context:property-placeholder ignore-unresolvable="true" location="classpath:/application.properties"/>
+    <rabbit:connection-factory id="rabbitConnectionFactory" host="${rabbit.host}" port="${rabbit.port}"
+                               username="${rabbit.username}" password="${rabbit.password}"
+                               virtual-host="${rabbit.vhost}" channel-cache-size="50"/>
+    <!-- 消费者 -->
+    <bean name="rabbitmqService" class="com.critc.service.RabbitmqService"></bean>
+    <rabbit:queue id="test_mq" name="test_mq" durable="true" auto-delete="false" exclusive="false" />
+    <!-- 配置监听 -->
+    <rabbit:listener-container connection-factory="rabbitConnectionFactory" acknowledge="auto" >
+        <rabbit:listener queues="test_mq" ref="rabbitmqService" />
+    </rabbit:listener-container>
+</beans>
\ No newline at end of file
diff --git a/chapter8_2_rabbitmq_listener/src/main/webapp/WEB-INF/web.xml b/chapter8_2_rabbitmq_listener/src/main/webapp/WEB-INF/web.xml
new file mode 100644
index 0000000..1401dab
--- /dev/null
+++ b/chapter8_2_rabbitmq_listener/src/main/webapp/WEB-INF/web.xml
@@ -0,0 +1,15 @@
+<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://xmlns.jcp.org/xml/ns/javaee"
+         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
+         id="WebApp_ID"
+         version="3.1">
+    <context-param>
+        <param-name>contextConfigLocation</param-name>
+        <param-value>
+            classpath:applicationContext-rabbitmq.xml
+        </param-value>
+    </context-param>
+    <listener>
+        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
+    </listener>
+
+</web-app>
\ No newline at end of file
diff --git a/chapter8_2_rabbitmq_listener/src/main/webapp/index.jsp b/chapter8_2_rabbitmq_listener/src/main/webapp/index.jsp
new file mode 100644
index 0000000..c38169b
--- /dev/null
+++ b/chapter8_2_rabbitmq_listener/src/main/webapp/index.jsp
@@ -0,0 +1,5 @@
+<html>
+<body>
+<h2>Hello World!</h2>
+</body>
+</html>