{"id":6462,"date":"2019-12-13T14:40:33","date_gmt":"2019-12-13T05:40:33","guid":{"rendered":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/?p=6462"},"modified":"2021-05-19T11:12:43","modified_gmt":"2021-05-19T02:12:43","slug":"spring-boot-jms-activemq-%e3%82%92%e8%a9%a6%e3%81%99","status":"publish","type":"post","link":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/archives\/6462","title":{"rendered":"Spring boot + JMS + ActiveMQ \u3092\u8a66\u3059"},"content":{"rendered":"
\"\"<\/div>\n

\u3053\u3093\u306b\u3061\u308f\u3001<\/p>\n

\u732b\u597d\u304d\u30ea\u30fc\u30de\u30f3\u306e\u307b\u3052PG\u3067\u3059\u3002<\/p>\n

\u4eca\u56de\u306f Spring boot + JMS + ActiveMQ \u3092\u8a66\u3057\u3066\u307f\u307e\u3059\u3002<\/p>\n

 <\/p>\n

\uff11\u3001ActiveMQ\u306e\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\uff06\u8d77\u52d5<\/h2>\n

\u3053\u3053\uff08https:\/\/activemq.apache.org\/<\/a>\uff09\u304b\u3089ActiveMQ 5 “Classic”\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b<\/p>\n

\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3057\u305fapache-activemq-5.15.10-bin.zip\u3092C:\\java \u306b\u5c55\u958b\u3059\u308b<\/p>\n

\u30b3\u30de\u30f3\u30c9\u30d7\u30ed\u30f3\u30d7\u30c8\u3088\u308a\u3001\u4ee5\u4e0b\u3092\u5b9f\u884c\uff08java.exe\u306epath\u306f\u901a\u3063\u3066\u3044\u308b\u524d\u63d0\uff09
\nC:\\java\\apache-activemq-5.15.10\\bin\\activemq start<\/p>\n

\u8d77\u52d5\u78ba\u8a8d\u3002<\/p>\n

\u7ba1\u7406\u753b\u9762\uff08http:\/\/localhost:8161\/admin\/\uff09\u306b\u30a2\u30af\u30bb\u30b9\u3002\u30e6\u30fc\u30b6\u3068\u30d1\u30b9\u306fadmin\/admin<\/p>\n

\u8a66\u3057\u306b\u307b\u3052\u3063\u3066\u898b\u308b<\/p>\n

Queue Name\u306bhogeQ\u3092\u5165\u529b\u3057\u3001Create\u30dc\u30bf\u30f3\u62bc\u4e0b<\/p>\n

\"\"<\/p>\n

\"\"<\/p>\n

 <\/p>\n

hogeQ\u306e send \u30ea\u30f3\u30af\u3092\u62bc\u4e0b<\/p>\n

\"\"<\/p>\n

 <\/p>\n

MessageBody \u306b HOGE \u3092\u5165\u529b\u3057\u3001Send\u30dc\u30bf\u30f3\u62bc\u4e0b<\/p>\n

\"\"<\/p>\n

\u30e1\u30c3\u30bb\u30fc\u30b8\u304chogeQ\u306b\u7a4d\u307e\u308c\u307e\u3057\u305f\u3002<\/p>\n

 <\/p>\n

\uff12\u3001\u9001\u4fe1\u5074\u30d7\u30ed\u30b0\u30e9\u30e0<\/h2>\n

pom.xml<\/p>\n

<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<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\">\r\n  <modelVersion>4.0.0<\/modelVersion>\r\n  <groupId>sample<\/groupId>\r\n  <artifactId>hoge-activemq-producer<\/artifactId>\r\n  <packaging>war<\/packaging>\r\n  <version>1.0.0-SNAPSHOT<\/version>\r\n  <name>HogeActiveMQProducer<\/name>\r\n  <url>http:\/\/maven.apache.org<\/url>\r\n\r\n  <parent>\r\n    <groupId>org.springframework.boot<\/groupId>\r\n    <artifactId>spring-boot-starter-parent<\/artifactId>\r\n    <version>2.2.1.RELEASE<\/version>\r\n  <\/parent>\r\n\r\n  <dependencies>\r\n    <dependency>\r\n      <groupId>org.springframework.boot<\/groupId>\r\n      <artifactId>spring-boot-starter-web<\/artifactId>\r\n    <\/dependency>\r\n    <dependency>\r\n      <groupId>org.springframework.boot<\/groupId>\r\n      <artifactId>spring-boot-starter-activemq<\/artifactId>\r\n    <\/dependency>\r\n    <dependency>\r\n      <groupId>org.springframework.boot<\/groupId>\r\n      <artifactId>spring-boot-starter-tomcat<\/artifactId>\r\n      <scope>provided<\/scope>\r\n    <\/dependency>\r\n    <dependency>\r\n      <groupId>org.projectlombok<\/groupId>\r\n      <artifactId>lombok<\/artifactId>\r\n      <scope>provided<\/scope>\r\n   <\/dependency>\r\n  <\/dependencies>\r\n\r\n  <build>\r\n    <plugins>\r\n      <plugin>\r\n        <groupId>org.springframework.boot<\/groupId>\r\n        <artifactId>spring-boot-maven-plugin<\/artifactId>\r\n      <\/plugin>\r\n    <\/plugins>\r\n  <\/build>\r\n<\/project>\r\n<\/pre>\n
 <\/p>\n
HogeApp.java<\/p>\n
@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
HogeController.java\u3000\u9001\u4fe1\u51e6\u7406\u3067\u3059\u3002\u6587\u5b57\u5217\u3092\u5358\u306b\u9001\u4fe1\u3057\u307e\u3059\u3002<\/p>\n
@Controller\r\n@Slf4j\r\npublic class HogeController {\r\n\r\n    @Autowired\r\n    JmsTemplate jmsTemplate;\r\n\r\n    @RequestMapping(value = \"\/\")\r\n    @ResponseBody\r\n    public String hello() {\r\n        log.debug(\"called.\");\r\n        jmsTemplate.convertAndSend(\"hogeQ\", \"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        jmsTemplate.convertAndSend(\"hogeQ\", body);\r\n        return \"hoge!\";\r\n    }\r\n}<\/pre>\n
application.yml<\/p>\n
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.activemq:\r\n  broker-url: tcp:\/\/localhost:61616<\/pre>\n
 <\/p>\n
\u8d77\u52d5\u3057\u3001\u307b\u3052\u308b
\nProducer\u30d7\u30ed\u30b8\u30a7\u30af\u30c8\u30d5\u30a9\u30eb\u30c0\u306b\u3066\u3001\u4ee5\u4e0b\u5b9f\u884c
\nmvn spring-boot:run<\/p>\n
\u30d6\u30e9\u30a6\u30b6\u3088\u308a\u3001http:\/\/localhost:8080\/api \u306b\u30a2\u30af\u30bb\u30b9<\/p>\n
\"\"<\/p>\n
\"\"<\/p>\n
\u3082\u3046\u3061\u3087\u3044\u307b\u3052\u308b
\npostman\u3084jmeter\u306a\u3069\u3067 http:\/\/localhost:8080\/api\/hoge \u306bPOST\u3067\u547c\u3076\u3002Body\u304chogeQ\u306b\u7a4d\u307e\u308c\u308b\u3002<\/p>\n
\u4ee5\u4e0b\u306f100\u3053\u307b\u3069jmeter\u3067\u547c\u51fa\u305f\u7d50\u679c<\/p>\n
\"\"<\/p>\n
\uff13\u3001\u53d7\u4fe1\u5074\u30d7\u30ed\u30b0\u30e9\u30e0<\/h2>\n
pom.xml<\/p>\n
<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<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\">\r\n  <modelVersion>4.0.0<\/modelVersion>\r\n  <groupId>sample<\/groupId>\r\n  <artifactId>hoge-activemq-consumer<\/artifactId>\r\n  <packaging>jar<\/packaging>\r\n  <version>1.0.0-SNAPSHOT<\/version>\r\n  <name>HogeActiveMQConsumer<\/name>\r\n  <url>http:\/\/maven.apache.org<\/url>\r\n\r\n  <parent>\r\n    <groupId>org.springframework.boot<\/groupId>\r\n    <artifactId>spring-boot-starter-parent<\/artifactId>\r\n    <version>2.2.1.RELEASE<\/version>\r\n  <\/parent>\r\n\r\n  <dependencies>\r\n    <dependency>\r\n      <groupId>org.springframework.boot<\/groupId>\r\n      <artifactId>spring-boot-starter<\/artifactId>\r\n    <\/dependency>\r\n    <dependency>\r\n      <groupId>org.springframework.boot<\/groupId>\r\n      <artifactId>spring-boot-starter-activemq<\/artifactId>\r\n    <\/dependency>\r\n    <dependency>\r\n      <groupId>org.projectlombok<\/groupId>\r\n      <artifactId>lombok<\/artifactId>\r\n      <scope>provided<\/scope>\r\n    <\/dependency>\r\n    <dependency>\r\n      <groupId>org.springframework.boot<\/groupId>\r\n      <artifactId>spring-boot-configuration-processor<\/artifactId>\r\n      <optional>true<\/optional>\r\n    <\/dependency>\r\n  <\/dependencies>\r\n\r\n  <build>\r\n    <plugins>\r\n      <plugin>\r\n        <groupId>org.springframework.boot<\/groupId>\r\n        <artifactId>spring-boot-maven-plugin<\/artifactId>\r\n      <\/plugin>\r\n    <\/plugins>\r\n  <\/build>\r\n<\/project><\/pre>\n
HogeApp.java<\/p>\n
@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
@Configuration\r\npublic class HogeConfig {\r\n\r\n    @Bean\r\n    @ConfigurationProperties(prefix = \"spring.activemq\")\r\n    public ActiveMQConnectionFactory connectionFactory() {\r\n        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();\r\n        return factory;\r\n    }\r\n\r\n    @Bean\r\n    public DefaultJmsListenerContainerFactory myFactory(\r\n            ConnectionFactory connectionFactory,\r\n            DefaultJmsListenerContainerFactoryConfigurer configurer) {\r\n        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();\r\n        configurer.configure(factory, connectionFactory);\r\n        ExecutorService executor = Executors.newCachedThreadPool(new HogeThreadFactory(\"Consumer-%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}<\/pre>\n
\u88dc\u8db3\uff09
\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
\n\u30d7\u30ea\u30d5\u30a7\u30c3\u30c1\u3092\u8a2d\u5b9a\u3057\u3066\u3044\u307e\u3059\u3002\u521d\u671f\u5024\u304c1000\u306a\u306e\u3067\u30ad\u30e5\u30fc\u304c\u6e9c\u307e\u3063\u3066\u3044\u308b\u72b6\u614b\u3067\u30b3\u30f3\u30b7\u30e5\u30fc\u30de\u30fc\u3092\u8d77\u52d5\u3059\u308b\u3068\u30e1\u30c3\u30bb\u30fc\u30b8\u304c1000\u4ee5\u4e0a\u306a\u3044\u3068\u5206\u6563\u51e6\u7406\u3057\u3066\u304f\u308c\u306a\u3044\u306e\u3067\u5c0f\u3055\u304f\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n
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
@Slf4j\r\n@Component\r\npublic class HogeConsumer {\r\n\r\n    @JmsListener(destination = \"hogeQ\", containerFactory = \"myFactory\")\r\n    void received(String message) throws InterruptedException {\r\n        log.info(\"Message received: {} \", message);\r\n        Thread.sleep(200);\r\n    }\r\n}\r\n<\/pre>\n
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.activemq:\r\n  broker-url: tcp:\/\/localhost:61616\r\n  prefetch-policy.queue-prefetch: 10\r\n#  broker-url: tcp:\/\/localhost:61616?jms.prefetchPolicy.queuePrefetch=1\r\n\r\nspring.jms:\r\n  listener:\r\n    concurrency: 5\r\n    max-concurrency: 10<\/pre>\n
\u88dc\u8db3\uff09
\nbroker-url: tcp:\/\/localhost:61616?jms.prefetchPolicy.queuePrefetch=1\u3000\u3092\u6307\u5b9a\u3057\u3066\u3082\u30d7\u30ea\u30d5\u30a7\u30c3\u30c1\u3092\u6307\u5b9a\u3067\u304d\u307e\u3059\u3002<\/p>\n
 <\/p>\n
\u8d77\u52d5\u3057\u3066\u3001\u53d7\u4fe1\u3057\u3066\u307f\u307e\u3059\u3002<\/p>\n
Consumer\u30d7\u30ed\u30b8\u30a7\u30af\u30c8\u30d5\u30a9\u30eb\u30c0\u306b\u3066\u3001\u4ee5\u4e0b\u5b9f\u884c<\/p>\n
mvn spring-boot:run<\/p>\n
\"\"<\/p>\n
\u30ad\u30e5\u30fc\u304b\u3089\u307b\u3052\u53d7\u4fe1\u3067\u304d\u307e\u3057\u305f\u3002<\/p>\n
\u3010\u30d7\u30ed\u30b8\u30a7\u30af\u30c8\u4e00\u5f0f\u3011<\/h3>\n
HogeActiveMQConsumer.zip<\/a><\/p>\n
HogeActiveMQProducer.zip<\/a><\/p>\n
 <\/p>\n
\u4eca\u56de\u306f\u3053\u3053\u307e\u3067\u3001\u6b21\u56de\u306fRabbitMQ<\/a>\u3092\u8a66\u3057\u307e\u3059\u3002<\/p>\n
\"\"<\/p>\n
\n
\u25c6WEB\u4f1a\u8b70\uff0f\u30bb\u30df\u30ca\u30fc\u30b7\u30b9\u30c6\u30e0\u300eSzia\u300f
\nhttps:\/\/www.ois-yokohama.co.jp\/szia\/<\/a><\/p>\n
\u25c6\u30b5\u30fc\u30d0\u30b5\u30a4\u30c9\u3067\u52d5\u4f5c\u3059\u308b\u30df\u30c9\u30eb\u30a6\u30a7\u30a2\u300eReDois\u300f
\nhttps:\/\/www.ois-yokohama.co.jp\/redois\/wp_redois\/<\/a><\/p>\n
\"\u30aa\u30ea\u30a8\u30f3\u30bf\u30eb\u30a4\u30f3\u30d5\u30a9\u30fc\u30e1\u30a4\u30b7\u30e7\u30f3\u30b5\u30fc\u30d3\u30b9\uff08OIS\uff09\"<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
\u3053\u3093\u306b\u3061\u308f\u3001 \u732b\u597d\u304d\u30ea\u30fc\u30de\u30f3\u306e\u307b\u3052PG\u3067\u3059\u3002 \u4eca\u56de\u306f Spring boot + JMS + ActiveMQ \u3092\u8a66\u3057\u3066\u307f\u307e\u3059\u3002   \uff11\u3001ActiveMQ\u306e\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\uff06\u8d77\u52d5 \u3053\u3053\uff08https:\/\/active […]<\/p>\n","protected":false},"author":1,"featured_media":6472,"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":[795,28,794,796,793],"class_list":["post-6462","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-engineer","tag-activemq","tag-hoge","tag-jms","tag-prefetch","tag-spring-boot"],"aioseo_notices":[],"_links":{"self":[{"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/posts\/6462","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=6462"}],"version-history":[{"count":4,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/posts\/6462\/revisions"}],"predecessor-version":[{"id":7161,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/posts\/6462\/revisions\/7161"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/media\/6472"}],"wp:attachment":[{"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/media?parent=6462"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/categories?post=6462"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.ois-yokohama.co.jp\/oisblog2018\/wp-json\/wp\/v2\/tags?post=6462"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}