本文共 1567 字,大约阅读时间需要 5 分钟。
ActiveMQ性能测试
1、下载ActiveMQ
官网:2、安装ActiveMQ
解压压缩包即可直接使用3、修改端口号、账号密码
默认连接端口为61616,按如下我把它修改为61617:vi conf/activemq.xml默认web console端口为8161,按如下我把它修改为8162:
vi conf/jetty.xml默认账号密码为admin/admin,按如下我把它修改为admin/admin123456
vi conf/users.propertiesadmin=admin123456
4、调整配置
1) 修改持久化kahaDB的配置,如下:其中参数,大家网上查一下kahaDB的配置了解下便可,这样配置满足一般应用了,我测试速度在2500 - 4000多的样子。不过具体还要看机器硬件。
2) 对一个broker的阈值是通过在activemq.xml中的配置中的部分设定的。这个特征允许producer仍然能够在consumer由于耗尽内存或转向producer flow control而变慢时发送消息,memoryUsage 默认值为20m,调整为128m
5、启动和停止
启动:${ActiveMQ_HOME}/bin/activemq start停止:${ActiveMQ_HOME}/bin/activemq stop6、顺便提几点关于使用Spring集成JMS的
1) 三种消息监听器可以参考帖子 2) 消息的重投策略:使用事务,并且调用了rollback()方法; 一个事务session,关闭之间调用了commit; session中使用CLIENT_ACKNOWLEDGE签收模式,并且调用了Session.recover()方法。
3) 如果使用JTA分布式事务,需要修改 jms:listener-container 的 acknowledge="transacted"
4) 指定异步/同步发送jms.alwaysSyncSend=false&jms.useAsyncSend=true 当alwaysSyncSend=false时,对于“NON_PERSISTENT”(非持久化)消息将使用“异步发送”;对于非持久化消息,使用异步发送是最佳的选择,我们通常使用这种手段调优。 当alwaysSyncSend=false时,如果指定了useAsyncSend=true,则“PERSISTENT”类型的消息,也将使用异步发送,但broker仍无法担保消息一定被持久化成功。 当alwaysSyncSend=false时,无论如何,在事务中的消息,都将使用异步发送。
转载地址:http://rhvol.baihongyu.com/