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 @@ + + + java_component + com.critc + 1.0-SNAPSHOT + + 4.0.0 + chapter10_1_rest + war + chapter10_1_rest Maven Webapp + http://maven.apache.org + + UTF-8 + 4.3.3.RELEASE + + + + + org.springframework + spring-core + ${spring.version} + + + + org.springframework + spring-beans + ${spring.version} + + + + org.springframework + spring-aspects + ${spring.version} + + + + org.springframework + spring-aop + ${spring.version} + + + org.springframework + spring-context + ${spring.version} + + + org.springframework + spring-context-support + ${spring.version} + + + org.springframework + spring-jdbc + ${spring.version} + + + org.springframework + spring-test + ${spring.version} + + + org.springframework + spring-web + ${spring.version} + + + org.springframework + spring-webmvc + ${spring.version} + + + + jstl + jstl + 1.2 + + + javax.servlet + javax.servlet-api + 3.1.0 + + + mysql + mysql-connector-java + 5.1.18 + + + com.alibaba + druid + 1.0.25 + + + junit + junit + 4.12 + + + + + chapter10_1_rest + + 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 @@ + + + + + + + + + + + + + + + + + + + \ 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 @@ + + + + + springMVC + org.springframework.web.servlet.DispatcherServlet + + contextConfigLocation + classpath*:/servlet-context.xml + + 1 + + + springMVC + / + + \ 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 @@ + + +

Hello World!

+ + 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 createTickets() { List list = new ArrayList<>(); - for (int i = 0; i < 100; i++) { + for (int i = 0; i < 1000; i++) { list.add("车票" + i); } return list; diff --git a/chapter8_1_rabbitmq/pom.xml b/chapter8_1_rabbitmq/pom.xml new file mode 100644 index 0000000..21b821b --- /dev/null +++ b/chapter8_1_rabbitmq/pom.xml @@ -0,0 +1,77 @@ + + + java_component + com.critc + 1.0-SNAPSHOT + + 4.0.0 + chapter8_1_rabbitmq + war + chapter8_1_rabbitmq Maven Webapp + http://maven.apache.org + + UTF-8 + 4.12 + 4.3.3.RELEASE + 1.7.1.RELEASE + 3.6.5 + + + + + org.springframework + spring-aop + ${spring.version} + + + org.springframework + spring-aspects + ${spring.version} + + + org.springframework + spring-beans + ${spring.version} + + + org.springframework + spring-context + ${spring.version} + + + org.springframework + spring-context-support + ${spring.version} + + + org.springframework + spring-core + ${spring.version} + + + org.springframework + spring-test + ${spring.version} + + + + org.springframework.amqp + spring-rabbit + ${spring-rabbit.version} + + + com.rabbitmq + amqp-client + ${amqp-client.version} + + + junit + junit + ${junit.version} + + + + chapter8_1_rabbitmq + + 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..8015314 --- /dev/null +++ b/chapter8_1_rabbitmq/src/main/java/com/critc/RabbitMqTest.java @@ -0,0 +1,27 @@ +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() throws Exception { + for (int i = 0; i < 100; i++) { + amqpTemplate.convertAndSend("test_mq", "第一条消息"); + Thread.sleep(3000); + } + } + +} 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 @@ + + + + rabbitmq 连接服务配置 + + + + + + + + \ 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 @@ + + + + Archetype Created Web Application + 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 @@ + + +

Hello World!

+ + diff --git a/chapter8_2_rabbitmq_listener/pom.xml b/chapter8_2_rabbitmq_listener/pom.xml new file mode 100644 index 0000000..fa878c7 --- /dev/null +++ b/chapter8_2_rabbitmq_listener/pom.xml @@ -0,0 +1,77 @@ + + + java_component + com.critc + 1.0-SNAPSHOT + + 4.0.0 + chapter8_2_rabbitmq_listener + war + chapter8_2_rabbitmq_listener Maven Webapp + http://maven.apache.org + + UTF-8 + 4.12 + 4.3.3.RELEASE + 1.7.1.RELEASE + 3.6.5 + + + + + org.springframework + spring-aop + ${spring.version} + + + org.springframework + spring-aspects + ${spring.version} + + + org.springframework + spring-beans + ${spring.version} + + + org.springframework + spring-context + ${spring.version} + + + org.springframework + spring-context-support + ${spring.version} + + + org.springframework + spring-core + ${spring.version} + + + org.springframework + spring-test + ${spring.version} + + + + org.springframework.amqp + spring-rabbit + ${spring-rabbit.version} + + + com.rabbitmq + amqp-client + ${amqp-client.version} + + + junit + junit + ${junit.version} + + + + chapter8_2_rabbitmq_listener + + 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 @@ + + + + rabbitmq 连接服务配置 + + + + + + + + + + \ 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 @@ + + + contextConfigLocation + + classpath:applicationContext-rabbitmq.xml + + + + org.springframework.web.context.ContextLoaderListener + + + \ 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 @@ + + +

Hello World!

+ + diff --git a/pom.xml b/pom.xml index 8b5b7ba..9e18d68 100644 --- a/pom.xml +++ b/pom.xml @@ -28,6 +28,8 @@ chapter9_2_cxf chapter9_3_axis2 chapter17_echarts + chapter8_1_rabbitmq + chapter8_2_rabbitmq_listener pom