Spring Boot教程之利用ActiveMQ实现延迟消息

一、安装activeMQ

Linux环境ActiveMQ部署方法：https://www.jb51.net/article/162320.htm

安装步骤参照上面这篇文章，本文不做介绍

Windows下安装ActiveMQ：

到官网（http://activemq.apache.org/download-archives.html）下载最新发布的压缩包（我下的是5.15.9）到本地后解压（我解压到D盘Dev目录下）即可。进入解压后的bin目录，我是64位机器，再进入win64目录后，双击activemq.bat启动：

wrapper | --> Wrapper Started as Consolewrapper | Launching a JVM...jvm 1 | Wrapper (Version 3.2.3) http://wrapper.tanukisoftware.orgjvm 1 | Copyright 1999-2006 Tanuki Software, Inc. All Rights Reserved.jvm 1 |jvm 1 | Java Runtime: Oracle Corporation 1.8.0_181 C:/Program Files/Java/jre1.8.0_181jvm 1 | Heap sizes: current=125952k free=115299k max=932352kjvm 1 | JVM args: -Dactivemq.home=../.. -Dactivemq.base=../.. -Djavax.net.ssl.keyStorePassword=password -Djavax.net.ssl.trustStorePassword=password -Djavax.net.ssl.keyStore=../../conf/broker.ks -Djavax.net.ssl.trustStore=../../conf/broker.ts -Dcom.sun.management.jmxremote -Dorg.apache.activemq.UseDedicatedTaskRunner=true -Djava.util.logging.config.file=logging.properties -Dactivemq.conf=../../conf -Dactivemq.data=../../data -Djava.security.auth.login.config=../../conf/login.config -Xmx1024m -Djava.library.path=../../bin/win64 -Dwrapper.key=mChNCWMZ2FoXhZ9g -Dwrapper.port=32000 -Dwrapper.jvm.port.min=31000 -Dwrapper.jvm.port.max=31999 -Dwrapper.pid=3500 -Dwrapper.version=3.2.3 -Dwrapper.native_library=wrapper -Dwrapper.cpu.timeout=10 -Dwrapper.jvmid=1jvm 1 | Extensions classpath:jvm 1 | [../../lib,../../lib/camel,../../lib/optional,../../lib/web,../../lib/extra]jvm 1 | ACTIVEMQ_HOME: ../..jvm 1 | ACTIVEMQ_BASE: ../..jvm 1 | ACTIVEMQ_CONF: ../../confjvm 1 | ACTIVEMQ_DATA: ../../datajvm 1 | Loading message broker from: xbean:activemq.xmljvm 1 | INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@f0ef68d: startup date [Fri May 24 15:16:21 CST 2019]; root of context hierarchyjvm 1 | INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[D:/Dev/apache-activemq-5.15.9/bin/win64/../../data/kahadb]jvm 1 | INFO | PListStore:[D:/Dev/apache-activemq-5.15.9/bin/win64/../../data/localhost/tmp_storage] startedjvm 1 | INFO | Apache ActiveMQ 5.15.9 (localhost, ID:wulf00-51057-1558682182909-0:1) is startingjvm 1 | INFO | Listening for connections at: tcp://wulf00:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600jvm 1 | INFO | Connector openwire startedjvm 1 | INFO | Listening for connections at: amqp://wulf00:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600jvm 1 | INFO | Connector amqp startedjvm 1 | INFO | Listening for connections at: stomp://wulf00:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600jvm 1 | INFO | Connector stomp startedjvm 1 | INFO | Listening for connections at: mqtt://wulf00:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600jvm 1 | INFO | Connector mqtt startedjvm 1 | INFO | Starting Jetty serverjvm 1 | INFO | Creating Jetty connectorjvm 1 | WARN | ServletContext@o.e.j.s.ServletContextHandler@17bc7c8a{/,null,STARTING} has uncovered http methods for path: /jvm 1 | INFO | Listening for connections at ws://wulf00:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600jvm 1 | INFO | Connector ws startedjvm 1 | INFO | Apache ActiveMQ 5.15.9 (localhost, ID:wulf00-51057-1558682182909-0:1) startedjvm 1 | INFO | For help or more information please see: http://activemq.apache.orgjvm 1 | WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: D:/Dev/apache-activemq-5.15.9/bin/win64/../../data/kahadb only has 92649 mb of usable space. - resetting to maximum available disk space: 92649 mbjvm 1 | INFO | No Spring WebApplicationInitializer types detected on classpathjvm 1 | INFO | ActiveMQ WebConsole available at http://0.0.0.0:8161/jvm 1 | INFO | ActiveMQ Jolokia REST API available at http://0.0.0.0:8161/api/jolokia/jvm 1 | INFO | Initializing Spring FrameworkServlet 'dispatcher'jvm 1 | INFO | No Spring WebApplicationInitializer types detected on classpathjvm 1 | INFO | jolokia-agent: Using policy access restrictor classpath:/jolokia-access.xml