下载和安装请参考前文。
ActiveMQ配置文件介绍(挑选了几个常用的和关键的,部分扩展功能的就不列出来了):
activemq.xml
<!-- 读入properties文件,准许在此XML中使用这些系统变量--> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <value>file:${activemq.conf}/credentials.properties</value> </property> </bean>
<!-- 准许访问服务器日志,为日志工具提供的接口 --> <bean id="logQuery" class="io.fabric8.insight.log.log4j.Log4jLogQuery" lazy-init="false" scope="singleton" init-method="start" destroy-method="stop"> </bean>
下面这个是重点:
<!-- <broker>用于配置ActiveMQ broker的参数. --> <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}"> <destinationPolicy> <policyMap> <policyEntries> <policyEntry topic=">" > <!-- constantPendingMessageLimitStrategy通过限制保存的消息数量用于防止 慢消费者阻塞生产者和其他消费者 --> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> <!-- managementContext 是用于管理ActiveMQ与JMX的对接。默认情况下ActiveMQ使用JVM中的MBean。在ActiveMQ中默认为不启用,如需使用设置createConnector属性为true并添加connectorPort和jmxdomainName属性 --> <managementContext> <managementContext createConnector="false"/> </managementContext> <!-- 消息持久化配置,目前给的是持久到文件里的默认写法。持久到数据库的配置方法会在后面 的开发中提到 --> <persistenceAdapter> <kahaDB directory="${activemq.data}/kahadb"/> </persistenceAdapter> <!-- systemUsage 控制broker的最大数量,将在缓存禁用 和/或 生产者减缓前使用。在后面的 开发中会有这部分的修改。 --> <systemUsage> <systemUsage> <memoryUsage> <memoryUsage percentOfJvmHeap="70" /> </memoryUsage> <storeUsage> <storeUsage limit="100 gb"/> </storeUsage> <tempUsage> <tempUsage limit="50 gb"/> </tempUsage> </systemUsage> </systemUsage> <!-- ActiveMQ提供一种连接机制,使用传输连接器实现客户端与其他代理之间的通信,注意此处的transportConnector里有的uri端口号即为和tomcat连接的端口号,对应各种协议如需修改只要改动URI参数的端口号即可。 --> <transportConnectors> <!-- DOS攻击保护,限制当前最大连接数(maximumConnections)为1000,大小(wireFormat.maxFrameSize)为100MB --> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> </transportConnectors> <!-- 销毁spring上下文来关闭jetty --> <shutdownHooks> <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /> </shutdownHooks> </broker>
jetty.xml(节选)
<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start"> <!-- 这个应该很熟悉了,就是更改ActiveMQ的web端口号的 --> <property name="host" value="0.0.0.0"/> <property name="port" value="8161"/> </bean>
<bean id="securityConstraint" class="org.eclipse.jetty.util.security.Constraint"> <property name="name" value="BASIC" /> <property name="roles" value="user,admin" /> <!-- 这个是用来修改登录用户名和密码的,将authenticate的值设为true,则用户的登录读取 会自动使用jetty-realm.properties的配置,其中配置文件的格式为 用户名:密码,角色 其中角色可选,如不填则为 用户名:密码 --> <property name="authenticate" value="false" /> </bean>
确认并修改完这些配置文件。参看我写的ActiveMQ(一)启动ActiveMQ,访问localhost:6161/admin输入你修改后的帐号密码登录ActiveMQ后台。至成功登录,你的ActiveMQ已经安装完毕,可以投入使用,congratulations。
相关推荐
ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。 附件资料主要含:ActiveMQ包,安装配置文档,将服务端...
apache-activemq-5.15.15二进制包,安装包,apache-activemq-5.15.15-bin.tar.gz
二、activemq介绍及安装 1、消息中间件简介 2、activemq 2.1、activemq简介 2.2、activemq下载 2.3、运行activemq服务 2.4、测试 2.5、监控 3、activemq特性 4、activemq使用场景 三、activemq简单实例 四、...
ActiveMQ5.0 的二进制发布包中bin目录中包含一个名为activemq的脚本,直接运行这个脚本就可以启动一个broker。
您将需要来自 Apache Software Foundation 的 ActiveMQ 二进制文件: http://activemq.apache.org/ 然后你必须从你的终端启动 ActiveMQ 服务器: ${ACTIVE_MQ_HOME}/bin/activemq start 现在您可以
NULL 博文链接:https://xkorey.iteye.com/blog/2114391
第一行为常规Python访问,第二行为使用Jython访问的方式,四个操作。 Python访问ActiveMQ需要使用stomp.py,见其官网。 下载官网的代码,解压,命令行进入其目录,使用pyhthon setup.py install即可安装好,然后就...
ActiveMQ_实践之路(一)ActiveMQ_实践之路(二)ActiveMQ_实践之路(三)ActiveMQ_实践之路(四)
n 二: ActiveMQ安装和基本使用 包括:通过源码安装、基本的配置示例、启动、测试运行、关闭等 n 三:理解和掌握JMS 包括:基本概念、消息结构、可靠性机制、PTP、Pub/Sub、API结构、JMS应用开 发的基本步骤、持久和...
本文实例讲述了Linux环境ActiveMQ部署方法。分享给大家供大家参考,具体如下: ActiveMQ环境部署 下载地址:...二、安装ActiveMQ 1、解压apache-activemq-5.14.3-bin.tar.gz tar -zxvf
二. 单服务器异步访问 3. Spring 整合JMS和ActiveMq流程 1) 下载和部署ActiveMq服务器 2) Spring jms和activemq相关依赖引入 3) Spring整合activemq配置 4) 定义消息发布者(生产者) 5) 定义消息订阅者(消费者) 6) ...
Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件;由于ActiveMQ是一个纯Java程序,因此只需要操作系统支持Java虚拟机,ActiveMQ便可执行。
本文实例讲述了php ActiveMQ的安装与使用方法。分享给大家供大家参考,具体如下: ...二、安装jdk http://www.oracle.com/technetwork/java/javase/downloads/index.html 如:jdk-8u121-linux-x64.tar.
在上一篇文章中,我们已经明确知道了ActiveMQ并不能保证消费的顺序性,即便我们使用了消息优先级。而在实际开发中,有些场景又是需要对消息进行顺序消费的,比如:用户从下单、到支付、再到发货等。如果
NULL 博文链接:https://yingzhuo.iteye.com/blog/1566635
个人花大量时间整理出的实战资料,内容丰富,文档也很详细。无论做毕业设计还是用于学习技能,或工作中当做参考资料,都能发挥重要作用 亲们下载我任何一个付费资源后,即可私信联系我免费下载其他相关资源哦~ ...
确保Confluent企业和ActiveMQ都已安装并在默认端口上运行。 ActiveMQ下载: : ,合流下载: : 确保在ActiveMQ和Confluent中都创建了队列(合流中的主题) reply-queue , request-queue和invalid-queue 在一个...
二、项目特点 实战性强:这些项目均来自实际业务场景多个领域,具有很强的实战性和参考价值。 技术先进:所有项目均采用最新的SSM框架版本,包括Spring 、SpringMVC 和MyBatis 等,确保技术的先进性和稳定性。 代码...