{"id":6474,"date":"2019-12-18T18:11:16","date_gmt":"2019-12-18T09:11:16","guid":{"rendered":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/?p=6474"},"modified":"2021-05-19T11:10:56","modified_gmt":"2021-05-19T02:10:56","slug":"spring-boot-amqp-rabbitmq-%e3%82%92%e8%a9%a6%e3%81%99","status":"publish","type":"post","link":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/archives\/6474","title":{"rendered":"Spring boot + AMQP + RabbitMQ \u3092\u8a66\u3059"},"content":{"rendered":"<div class=\"veu_autoEyeCatchBox\"><img loading=\"lazy\" decoding=\"async\" width=\"750\" height=\"422\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-1024x576.jpg\" class=\"attachment-large size-large wp-post-image\" alt=\"\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-1024x576.jpg 1024w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-300x169.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-768x432.jpg 768w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-320x180.jpg 320w\" sizes=\"auto, (max-width: 750px) 100vw, 750px\" \/><\/div>\n<p>\u3053\u3093\u306b\u3061\u308f\u3001\u732b\u597d\u304d\u30ea\u30fc\u30de\u30f3\u306e\u307b\u3052PG\u3067\u3059\u3002<\/p>\n<p>\u4eca\u56de\u306f <strong>Spring boot + AMQP + RabbitMQ<\/strong> \u3092\u8a66\u3057\u3066\u307f\u307e\u3059\u3002<\/p>\n<h2>\uff11\u3001RabbitMQ\u306e\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\uff06\u8d77\u52d5<\/h2>\n<p>RabbitMQ\u3092\u52d5\u304b\u3059\u524d\u306berlnag\u3092\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u3066\u304a\u304f\u5fc5\u8981\u304c\u3042\u308a\u307e\u3059\u3002<\/p>\n<p>&nbsp;<\/p>\n<h3>erlnag\u306e\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb<\/h3>\n<p>\u3053\u3053\uff08<a href=\"https:\/\/www.erlang.org\/downloads\" target=\"_blank\" rel=\"noopener noreferrer\">https:\/\/www.erlang.org\/downloads<\/a>\uff09\u304b\u3089Windows 64-bit Binary File\u3092\u30af\u30ea\u30c3\u30af\u3057otp_win64_22.1.exe\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9<\/p>\n<p>exe\u3092\u5b9f\u884c\u3057\u3001\u6307\u793a\u306b\u5f93\u3063\u3066\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb<\/p>\n<p>\u74b0\u5883\u5909\u6570\u306b\u4ee5\u4e0b\u3092\u8a2d\u5b9a\u3059\u308b<br \/>\n\u5909\u6570\u540d\uff1aERLANG_HOME<br \/>\n\u5909\u6570\u5024\uff1aC:\\Program Files\\erl10.5\u3000\u2026erlnag\u3092\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u305f\u30d5\u30a9\u30eb\u30c0<\/p>\n<p>&nbsp;<\/p>\n<h3>RabbitMQ\u306e\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb<\/h3>\n<p>\u3053\u3053\uff08<a href=\"https:\/\/www.rabbitmq.com\/install-windows-manual.html\" target=\"_blank\" rel=\"noopener noreferrer\">https:\/\/www.rabbitmq.com\/install-windows-manual.html<\/a>\uff09\u304b\u3089rabbitmq-server-windows-3.8.1.zip\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9<br \/>\n\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3057\u305frabbitmq-server-windows-3.8.1.zip\u3092C:\\work \u306b\u5c55\u958b\u3059\u308b<\/p>\n<p>\u30b3\u30de\u30f3\u30c9\u30d7\u30ed\u30f3\u30d7\u30c8\u3088\u308a\u3001\u4ee5\u4e0b\u3092\u5b9f\u884c<br \/>\nC:\\work\\rabbitmq_server-3.8.1\\sbin\\rabbitmq-server start<\/p>\n<p>\u30d7\u30e9\u30b0\u30a4\u30f3\u306e\u6709\u52b9\u304b<br \/>\n\u30b3\u30de\u30f3\u30c9\u30d7\u30ed\u30f3\u30d7\u30c8\u3088\u308a\u3001\u4ee5\u4e0b\u3092\u5b9f\u884c<br \/>\nC:\\work\\rabbitmq_server-3.8.1\\sbin\\rabbitmq-plugins enable rabbitmq_management<\/p>\n<p>\u8d77\u52d5\u78ba\u8a8d\u3002<\/p>\n<p>\u7ba1\u7406\u753b\u9762\uff08http:\/\/localhost:15672\uff09\u306b\u30a2\u30af\u30bb\u30b9\u3002<\/p>\n<p>\u30e6\u30fc\u30b6\u3068\u30d1\u30b9\u306fguest\/guest<\/p>\n<p>&nbsp;<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"size-full wp-image-6475 alignnone\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-1.jpg\" alt=\"\" width=\"930\" height=\"560\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-1.jpg 930w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-1-300x181.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-1-768x462.jpg 768w\" sizes=\"auto, (max-width: 930px) 100vw, 930px\" \/><\/p>\n<p>&nbsp;<\/p>\n<p>\u8a66\u3057\u306b\u307b\u3052\u3063\u3066\u898b\u308b<br \/>\nQueues\u30bf\u30d6\u3092\u62bc\u4e0b\u3057\u3001Name\u306bhogeQ\u3092\u5165\u529b\u3057\u3001Add queue\u30dc\u30bf\u30f3\u62bc\u4e0b<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"size-full wp-image-6476 alignnone\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-2.jpg\" alt=\"\" width=\"1083\" height=\"466\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-2.jpg 1083w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-2-300x129.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-2-768x330.jpg 768w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-2-1024x441.jpg 1024w\" sizes=\"auto, (max-width: 1083px) 100vw, 1083px\" \/><\/p>\n<p>&nbsp;<\/p>\n<p>Publish messages\u306ePayload\u306bHOGE\u3092\u5165\u529b\u3057\u3001PublishMessage\u30dc\u30bf\u30f3\u62bc\u4e0b<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6478\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-3.jpg\" alt=\"\" width=\"975\" height=\"466\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-3.jpg 975w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-3-300x143.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-3-768x367.jpg 768w\" sizes=\"auto, (max-width: 975px) 100vw, 975px\" \/><\/p>\n<p>&nbsp;<\/p>\n<p>\u30ad\u30e5\u30fc\u304b\u3089\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u53d6\u5f97<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6479\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-4.jpg\" alt=\"\" width=\"558\" height=\"495\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-4.jpg 558w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-4-300x266.jpg 300w\" sizes=\"auto, (max-width: 558px) 100vw, 558px\" \/><\/p>\n<p>&nbsp;<\/p>\n<p>HOGE\u30e1\u30c3\u30bb\u30fc\u30b8\u304c\u30ad\u30e5\u30fc\u306b\u7a4d\u307e\u308c\u3066\u3044\u308b\u306e\u3092\u78ba\u8a8d<\/p>\n<h2>\uff12\u3001Exchange<\/h2>\n<p>\u305b\u3063\u304b\u304f\u306a\u306e\u3067\u4f5c\u3063\u3066\u7f6e\u304d\u307e\u3059\u3002<br \/>\n\u307e\u305a\u3001\u3082\u3046\u3072\u3068\u3064\u30ad\u30e5\u30fc\uff08hogeP\uff09\u3092\u4f5c\u6210\u3057\u307e\u3059\u3002<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6480\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-5.jpg\" alt=\"\" width=\"355\" height=\"134\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-5.jpg 355w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-5-300x113.jpg 300w\" sizes=\"auto, (max-width: 355px) 100vw, 355px\" \/><\/p>\n<p>Exchanges\u30bf\u30d6\u3092\u62bc\u4e0b\u3057\u3001Exchange\u3092\u4f5c\u6210\u3057\u307e\u3059\u3002<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6481\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-6.jpg\" alt=\"\" width=\"774\" height=\"324\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-6.jpg 774w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-6-300x126.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-6-768x321.jpg 768w\" sizes=\"auto, (max-width: 774px) 100vw, 774px\" \/><\/p>\n<p>\u4f5c\u6210\u3055\u308c\u305fhogeEx\u3092\u62bc\u4e0b\u3057\u3001\u4ee5\u4e0b\uff13\u3064\u306ebind\u3092\u4f5c\u6210\u3057\u307e\u3059\u3002<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6482\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-7.jpg\" alt=\"\" width=\"436\" height=\"336\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-7.jpg 436w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-7-300x231.jpg 300w\" sizes=\"auto, (max-width: 436px) 100vw, 436px\" \/><\/p>\n<p>\u3053\u308c\u3067\u3001Exchange=hogeEz\u3001routingkey=hoge \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u4fe1\u3059\u308c\u3070\u3001hogeP\u3068hogeQ\u306b\u7a4d\u307e\u308c\u307e\u3059\u3002<br \/>\nExchange=hogeEz\u3001routingkey=moge \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u4fe1\u3059\u308c\u3070\u3001hogeQ\u306b\u7a4d\u307e\u308c\u307e\u3059\u3002<\/p>\n<h2>\uff13\u3001\u9001\u4fe1\u5074\u30d7\u30ed\u30b0\u30e9\u30e0<\/h2>\n<p>pom.xml<\/p>\n<pre class=\"lang:default highlight:0 decode:true\" title=\"pom.xml\">&lt;?xml version=\"1.0\" encoding=\"UTF-8\"?&gt;\r\n&lt;project xmlns=\"http:\/\/maven.apache.org\/POM\/4.0.0\" xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n  xsi:schemaLocation=\"http:\/\/maven.apache.org\/POM\/4.0.0 http:\/\/maven.apache.org\/maven-v4_0_0.xsd\"&gt;\r\n  &lt;modelVersion&gt;4.0.0&lt;\/modelVersion&gt;\r\n  &lt;groupId&gt;sample&lt;\/groupId&gt;\r\n  &lt;artifactId&gt;hoge-rabbitmq-producer&lt;\/artifactId&gt;\r\n  &lt;packaging&gt;war&lt;\/packaging&gt;\r\n  &lt;version&gt;1.0.0-SNAPSHOT&lt;\/version&gt;\r\n  &lt;name&gt;HogeRabbitMQProducer&lt;\/name&gt;\r\n  &lt;url&gt;http:\/\/maven.apache.org&lt;\/url&gt;\r\n\r\n  &lt;parent&gt;\r\n    &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n    &lt;artifactId&gt;spring-boot-starter-parent&lt;\/artifactId&gt;\r\n    &lt;version&gt;2.2.1.RELEASE&lt;\/version&gt;\r\n  &lt;\/parent&gt;\r\n\r\n  &lt;dependencies&gt;\r\n    &lt;dependency&gt;\r\n      &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n      &lt;artifactId&gt;spring-boot-starter-web&lt;\/artifactId&gt;\r\n    &lt;\/dependency&gt;\r\n    &lt;dependency&gt;\r\n      &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n      &lt;artifactId&gt;spring-boot-starter-amqp&lt;\/artifactId&gt;\r\n    &lt;\/dependency&gt;\r\n    &lt;dependency&gt;\r\n      &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n      &lt;artifactId&gt;spring-boot-starter-tomcat&lt;\/artifactId&gt;\r\n      &lt;scope&gt;provided&lt;\/scope&gt;\r\n    &lt;\/dependency&gt;\r\n    &lt;dependency&gt;\r\n      &lt;groupId&gt;org.projectlombok&lt;\/groupId&gt;\r\n      &lt;artifactId&gt;lombok&lt;\/artifactId&gt;\r\n      &lt;scope&gt;provided&lt;\/scope&gt;\r\n   &lt;\/dependency&gt;\r\n  &lt;\/dependencies&gt;\r\n\r\n  &lt;build&gt;\r\n    &lt;plugins&gt;\r\n      &lt;plugin&gt;\r\n        &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n        &lt;artifactId&gt;spring-boot-maven-plugin&lt;\/artifactId&gt;\r\n      &lt;\/plugin&gt;\r\n    &lt;\/plugins&gt;\r\n  &lt;\/build&gt;\r\n&lt;\/project&gt;\r\n<\/pre>\n<p>HogeApp.java<\/p>\n<pre class=\"lang:default highlight:0 decode:true \" title=\"HogeApp.java\">@EnableAutoConfiguration\r\n@ComponentScan\r\npublic class HogeApp extends SpringBootServletInitializer {\r\n\r\n    @Override\r\n    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {\r\n        return application.sources(HogeApp.class);\r\n    }\r\n\r\n    public static void main(String[] args) throws Exception {\r\n        SpringApplication.run(HogeApp.class, args);\r\n    }\r\n}<\/pre>\n<p>HogeController.java\u3000\u9001\u4fe1\u51e6\u7406\u3067\u3059\u3002<\/p>\n<pre class=\"lang:default highlight:0 decode:true \" title=\"HogeController.java\">@Controller\r\n@Slf4j\r\npublic class HogeController {\r\n\r\n    @Autowired\r\n    RabbitTemplate rabbitTemplate;\r\n\r\n    @RequestMapping(value = \"\/\")\r\n    @ResponseBody\r\n    public String hello() {\r\n        log.debug(\"called.\");\r\n        rabbitTemplate.convertAndSend(\"hogeEx\", \"hoge\", \"HOGE-\"+ new Date());\r\n        return \"hoge!\";\r\n    }\r\n\r\n    @RequestMapping(\"\/hoge\")\r\n    @ResponseBody\r\n    public String hello(HttpServletRequest request, HttpServletResponse response) throws IOException {\r\n        String body = request.getReader().lines().collect(Collectors.joining(\"\\r\\n\"));\r\n        log.debug(\"body.length = {}\", body.length());\r\n        rabbitTemplate.convertAndSend(\"hogeEx\", \"moge\", body);\r\n        return \"hoge!\";\r\n    }\r\n}\r\n<\/pre>\n<p>application.yml<\/p>\n<pre class=\"lang:default highlight:0 decode:true \" title=\"application.yml\">spring.main:\r\n  # \u8d77\u52d5\u30d0\u30ca\u30fc\u306a\u3057\r\n  banner-mode: \"off\"\r\n\r\nserver:\r\n  servlet.context-path: \/api\r\n\r\n# \u30ed\u30b0\r\nlogging: \r\n  pattern:\r\n    console: \"%d{HH:mm:ss.SSS} %thread %-5level \\\\(%file:%line\\\\) %M - %msg%n\"\r\n  level: \r\n    ROOT: INFO\r\n    jp.co.ois.sample: DEBUG\r\n\r\n# MQ\r\nspring.rabbitmq:\r\n  host: localhost\r\n  port: 5672\r\n<\/pre>\n<p>\u8d77\u52d5\u3057\u3001\u307b\u3052\u308a\u307e\u3059\u3002<\/p>\n<p>Producer\u30d7\u30ed\u30b8\u30a7\u30af\u30c8\u30d5\u30a9\u30eb\u30c0\u306b\u3066\u3001\u4ee5\u4e0b\u5b9f\u884c<\/p>\n<p>mvn spring-boot:run<\/p>\n<p>\u30d6\u30e9\u30a6\u30b6\u3088\u308a\u3001http:\/\/localhost:8080\/api \u306b\u30a2\u30af\u30bb\u30b9<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6483\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-8.jpg\" alt=\"\" width=\"386\" height=\"192\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-8.jpg 386w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-8-300x149.jpg 300w\" sizes=\"auto, (max-width: 386px) 100vw, 386px\" \/><\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6484\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-9.jpg\" alt=\"\" width=\"915\" height=\"135\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-9.jpg 915w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-9-300x44.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-9-768x113.jpg 768w\" sizes=\"auto, (max-width: 915px) 100vw, 915px\" \/><\/p>\n<p>\u3082\u3046\u3061\u3087\u3044\u307b\u3052\u308a\u307e\u3059\u3002<\/p>\n<p>postman\u3084jmeter\u306a\u3069\u3067 http:\/\/localhost:8080\/api\/hoge \u306bPOST\u3067\u547c\u3076\u3002Body\u304chogeQ\u306b\u7a4d\u307e\u308c\u308b\u3002<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6485\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-10.jpg\" alt=\"\" width=\"942\" height=\"148\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-10.jpg 942w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-10-300x47.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-10-768x121.jpg 768w\" sizes=\"auto, (max-width: 942px) 100vw, 942px\" \/><\/p>\n<p>&nbsp;<\/p>\n<h2>\uff14\u3001\u53d7\u4fe1\u5074\u30d7\u30ed\u30b0\u30e9\u30e0<\/h2>\n<p>pom.xml<\/p>\n<pre class=\"lang:default highlight:0 decode:true \" title=\"pom.xml\">&lt;?xml version=\"1.0\" encoding=\"UTF-8\"?&gt;\r\n&lt;project xmlns=\"http:\/\/maven.apache.org\/POM\/4.0.0\" xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n  xsi:schemaLocation=\"http:\/\/maven.apache.org\/POM\/4.0.0 http:\/\/maven.apache.org\/maven-v4_0_0.xsd\"&gt;\r\n  &lt;modelVersion&gt;4.0.0&lt;\/modelVersion&gt;\r\n  &lt;groupId&gt;sample&lt;\/groupId&gt;\r\n  &lt;artifactId&gt;hoge-activemq-consumer&lt;\/artifactId&gt;\r\n  &lt;packaging&gt;jar&lt;\/packaging&gt;\r\n  &lt;version&gt;1.0.0-SNAPSHOT&lt;\/version&gt;\r\n  &lt;name&gt;HogeActiveMQConsumer&lt;\/name&gt;\r\n  &lt;url&gt;http:\/\/maven.apache.org&lt;\/url&gt;\r\n\r\n  &lt;parent&gt;\r\n    &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n    &lt;artifactId&gt;spring-boot-starter-parent&lt;\/artifactId&gt;\r\n    &lt;version&gt;2.2.1.RELEASE&lt;\/version&gt;\r\n  &lt;\/parent&gt;\r\n\r\n  &lt;dependencies&gt;\r\n    &lt;dependency&gt;\r\n      &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n      &lt;artifactId&gt;spring-boot-starter&lt;\/artifactId&gt;\r\n    &lt;\/dependency&gt;\r\n    &lt;dependency&gt;\r\n      &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n      &lt;artifactId&gt;spring-boot-starter-amqp&lt;\/artifactId&gt;\r\n    &lt;\/dependency&gt;\r\n    &lt;dependency&gt;\r\n      &lt;groupId&gt;org.projectlombok&lt;\/groupId&gt;\r\n      &lt;artifactId&gt;lombok&lt;\/artifactId&gt;\r\n      &lt;scope&gt;provided&lt;\/scope&gt;\r\n    &lt;\/dependency&gt;\r\n  &lt;\/dependencies&gt;\r\n\r\n  &lt;build&gt;\r\n    &lt;plugins&gt;\r\n      &lt;plugin&gt;\r\n        &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\r\n        &lt;artifactId&gt;spring-boot-maven-plugin&lt;\/artifactId&gt;\r\n      &lt;\/plugin&gt;\r\n    &lt;\/plugins&gt;\r\n  &lt;\/build&gt;\r\n&lt;\/project&gt;<\/pre>\n<p>HogeApp.java<\/p>\n<pre class=\"lang:default highlight:0 decode:true \" title=\"HogeApp.java\">@EnableAutoConfiguration\r\n@ComponentScan\r\npublic class HogeApp {\r\n\r\n    public static void main(String[] args) throws Exception {\r\n        SpringApplication.run(HogeApp.class, args);\r\n    }\r\n}\r\n<\/pre>\n<p>HogeConfig.java<\/p>\n<pre class=\"lang:default highlight:0 decode:true\" title=\"HogeConfig.java\">@Configuration\r\npublic class HogeConfig {\r\n\r\n    @Bean\r\n    public SimpleRabbitListenerContainerFactory myFactory(\r\n            ConnectionFactory connectionFactory,\r\n            SimpleRabbitListenerContainerFactoryConfigurer configurer) {\r\n        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();\r\n        configurer.configure(factory, connectionFactory);\r\n        ExecutorService executor = Executors.newCachedThreadPool(new HogeThreadFactory(\"amqp-%d\"));\r\n        factory.setTaskExecutor(executor);\r\n        return factory;\r\n    }\r\n\r\n    public static class HogeThreadFactory implements ThreadFactory {\r\n        private final AtomicInteger counter = new AtomicInteger(0);\r\n        private final String format;\r\n\r\n        private HogeThreadFactory(String format) {\r\n            this.format = format;\r\n        }\r\n\r\n        @Override\r\n        public Thread newThread(Runnable r) {\r\n            String name = String.format(format, counter.incrementAndGet());\r\n            return new Thread(null, r, name);\r\n        }\r\n    }\r\n}<span style=\"background-color: #ffffff; font-family: \u30e1\u30a4\u30ea\u30aa, Meiryo, '\uff2d\uff33 \uff30\u30b4\u30b7\u30c3\u30af', 'Hiragino Kaku Gothic Pro', '\u30d2\u30e9\u30ae\u30ce\u89d2\u30b4 Pro W3', sans-serif; font-size: 16px;\">\u00a0<\/span>\r\n<\/pre>\n<p>\u88dc\u8db3\uff09<br \/>\n\u30b9\u30ec\u30c3\u30c9\u540d\u304c\u6c17\u306b\u5165\u3089\u306a\u304b\u3063\u305f\u306e\u3067\u81ea\u5206\u3067\u6307\u5b9a\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n<p>HogeConsumer.java\u3000\u53d7\u4fe1\u51e6\u7406\u3067\u3059\u3002\u6587\u5b57\u5217\u3067\u53d6\u5f97\u3057\u307e\u3059\u3002\u30c0\u30df\u30fc\u3067\u30a6\u30a7\u30a4\u30c8\u3055\u305b\u3066\u3044\u307e\u3059\u3002<\/p>\n<pre class=\"lang:default highlight:0 decode:true\" title=\"HogeConsumer.java\">@Slf4j\r\n@Component\r\npublic class HogeConsumer {\r\n\r\n    @RabbitListener(queues = \"hogeQ\", containerFactory=\"myFactory\")\r\n    void receivedQ(String message) throws InterruptedException {\r\n        log.info(\"Message received: {} \", message);\r\n        Thread.sleep(200);\r\n    }\r\n\r\n    @RabbitListener(queues = \"hogeP\", containerFactory=\"myFactory\")\r\n    void receivedP(String message) throws InterruptedException {\r\n        log.info(\"Message received: {} \", message);\r\n        Thread.sleep(200);\r\n    }\r\n}<\/pre>\n<p>application.yml<\/p>\n<pre class=\"lang:default highlight:0 decode:true \" title=\"application.yml\">spring.main:\r\n  # \u8d77\u52d5\u30d0\u30ca\u30fc\u306a\u3057\r\n  banner-mode: \"off\"\r\n  # \u7d44\u307f\u8fbc\u307fWeb\u30b5\u30fc\u30d0\u306e\u81ea\u52d5\u8d77\u52d5\u7121\u52b9\r\n  web-application-type: none\r\n\r\n# \u30ed\u30b0\r\nlogging: \r\n  pattern:\r\n    console: \"%d{HH:mm:ss.SSS} %thread %-5level \\\\(%file:%line\\\\) %M - %msg%n\"\r\n  level: \r\n    ROOT: INFO\r\n    jp.co.ois.sample: DEBUG\r\n\r\n# MQ\r\nspring.rabbitmq:\r\n  host: localhost\r\n  port: 5672\r\n  listener.simple.concurrency: 5\r\n  listener.simple.max-concurrency: 10\r\n  listener.simple.prefetch: 10<\/pre>\n<p>\u8d77\u52d5\u3057\u3066\u3001\u53d7\u4fe1\u3057\u3066\u307f\u307e\u3059\u3002<\/p>\n<p>Consumer\u30d7\u30ed\u30b8\u30a7\u30af\u30c8\u30d5\u30a9\u30eb\u30c0\u306b\u3066\u3001\u4ee5\u4e0b\u5b9f\u884c<\/p>\n<p>mvn spring-boot:run<\/p>\n<pre class=\"lang:default highlight:0 decode:true \" title=\"mvn spring-boot:run\">10:54:38.441 main INFO  (StartupInfoLogger.java:55) logStarting - Starting HogeApp on NDYWM7A3420152 with PID 16088 (C:\\work\\masuda\\myrepo\\HogeRabbitMQConsumer\\target\\classes started by horqu in C:\\work\\masuda\\myrepo\\HogeRabbitMQConsumer)\r\n10:54:38.451 main DEBUG (StartupInfoLogger.java:56) logStarting - Running with Spring Boot v2.2.1.RELEASE, Spring v5.2.1.RELEASE\r\n10:54:38.452 main INFO  (SpringApplication.java:651) logStartupProfileInfo - No active profile set, falling back to default profiles: default\r\n10:54:40.314 main INFO  (AbstractConnectionFactory.java:524) connect - Attempting to connect to: [localhost:5672]\r\n10:54:40.420 main INFO  (AbstractConnectionFactory.java:497) createBareConnection - Created new connection: rabbitConnectionFactory#495b0487:0\/SimpleConnection@13e3c1c7 [delegate=amqp:\/\/guest@127.0.0.1:5672\/, localPort= 62505]\r\n10:54:40.591 main INFO  (StartupInfoLogger.java:61) logStarted - Started HogeApp in 3.459 seconds (JVM running for 6.338)\r\n10:54:40.597 amqp-3 INFO  (HogeConsumer.java:15) receivedQ - Message received: HOGE-Fri Dec 13 10:46:34 JST 2019 \r\n10:54:40.596 amqp-6 INFO  (HogeConsumer.java:21) receivedP - Message received: HOGE-Fri Dec 13 10:46:34 JST 2019 \r\n10:54:40.801 amqp-3 INFO  (HogeConsumer.java:15) receivedQ - Message received: HOGE-fpvnwxjxjayfvavmjxfkeokuwqooebxbnqexfnumszqvcmdhtmrvsmxiagnyvranonohvzpeghlotnhqjzynddajlhbvdohkfvnr<\/pre>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-full wp-image-6486\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-11.jpg\" alt=\"\" width=\"919\" height=\"140\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-11.jpg 919w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-11-300x46.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/hoge2-11-768x117.jpg 768w\" sizes=\"auto, (max-width: 919px) 100vw, 919px\" \/><\/p>\n<p>\u30ad\u30e5\u30fc\u304b\u3089\u307b\u3052\u53d7\u4fe1\u3067\u304d\u307e\u3057\u305f\u3002<\/p>\n<h3>\u3010\u30d7\u30ed\u30b8\u30a7\u30af\u30c8\u4e00\u5f0f\u3011<\/h3>\n<p><a href=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/file\/HogeRabbitMQConsumer.zip\" target=\"_blank\" rel=\"noopener noreferrer\">HogeRabbitMQConsumer.zip<\/a><\/p>\n<p><a href=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/file\/HogeRabbitMQProducer.zip\" target=\"_blank\" rel=\"noopener noreferrer\">HogeRabbitMQProducer.zip<\/a><\/p>\n<p>&nbsp;<\/p>\n<p>\u4eca\u56de\u306f\u3053\u3053\u307e\u3067\u3002<\/p>\n<p><img loading=\"lazy\" decoding=\"async\" class=\"alignnone wp-image-6488 size-large\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-1024x576.jpg\" alt=\"\" width=\"750\" height=\"422\" srcset=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-1024x576.jpg 1024w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-300x169.jpg 300w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-768x432.jpg 768w, https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/12\/IMG_20181224_121622-320x180.jpg 320w\" sizes=\"auto, (max-width: 750px) 100vw, 750px\" \/><\/p>\n<p>&nbsp;<\/p>\n<hr \/>\n<p>\u25c6WEB\u4f1a\u8b70\uff0f\u30bb\u30df\u30ca\u30fc\u30b7\u30b9\u30c6\u30e0\u300eSzia\u300f<br \/>\n<a href=\"https:\/\/www.ois-yokohama.co.jp\/szia\/\" target=\"_blank\" rel=\"noopener noreferrer\">https:\/\/www.ois-yokohama.co.jp\/szia\/<\/a><\/p>\n<p>\u25c6\u30b5\u30fc\u30d0\u30b5\u30a4\u30c9\u3067\u52d5\u4f5c\u3059\u308b\u30df\u30c9\u30eb\u30a6\u30a7\u30a2\u300eReDois\u300f<br \/>\n<a href=\"https:\/\/www.ois-yokohama.co.jp\/redois\/wp_redois\/\" target=\"_blank\" rel=\"noopener noreferrer\">https:\/\/www.ois-yokohama.co.jp\/redois\/wp_redois\/<\/a><\/p>\n<p><a href=\"https:\/\/www.ois-yokohama.co.jp\"><img loading=\"lazy\" decoding=\"async\" class=\"alignleft size-medium wp-image-6056\" src=\"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-content\/uploads\/2019\/06\/ois_logo-300x137.jpg\" alt=\"\u30aa\u30ea\u30a8\u30f3\u30bf\u30eb\u30a4\u30f3\u30d5\u30a9\u30fc\u30e1\u30a4\u30b7\u30e7\u30f3\u30b5\u30fc\u30d3\u30b9\uff08OIS\uff09\" width=\"300\" height=\"137\" \/><\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u3053\u3093\u306b\u3061\u308f\u3001\u732b\u597d\u304d\u30ea\u30fc\u30de\u30f3\u306e\u307b\u3052PG\u3067\u3059\u3002 \u4eca\u56de\u306f Spring boot + AMQP + RabbitMQ \u3092\u8a66\u3057\u3066\u307f\u307e\u3059\u3002 \uff11\u3001RabbitMQ\u306e\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\uff06\u8d77\u52d5 RabbitMQ\u3092\u52d5\u304b\u3059\u524d\u306berlnag\u3092\u30a4\u30f3\u30b9 [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":6488,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"om_disable_all_campaigns":false,"_monsterinsights_skip_tracking":false,"_monsterinsights_sitenote_active":false,"_monsterinsights_sitenote_note":"","_monsterinsights_sitenote_category":0,"vkexunit_cta_each_option":"","footnotes":""},"categories":[6],"tags":[797,28,798,793],"class_list":["post-6474","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-engineer","tag-amqp","tag-hoge","tag-rabbitmq","tag-spring-boot"],"aioseo_notices":[],"_links":{"self":[{"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/posts\/6474","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/comments?post=6474"}],"version-history":[{"count":4,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/posts\/6474\/revisions"}],"predecessor-version":[{"id":7160,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/posts\/6474\/revisions\/7160"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/media\/6488"}],"wp:attachment":[{"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/media?parent=6474"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/categories?post=6474"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/tags?post=6474"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}