JEESZ的消息服务平台已经抛弃了之前的ActiveMQ，改用高吞吐量比较大的Kafka分布式消息中间件方案： JEESZ-kafka消息平台使用spring+kafka的集成方案，详情如下： 1. 使用最高版本2.1.0.RELEASE集成jar包：spring-integration-kafka ...
分类：
其他好文 时间：
2018-07-20 16:50:21
阅读次数：
118
ActiveMQ提供了一个插件式的消息存储，类似于消息的多点传播，主要实现了如下几种： AMQ消息存储-基于文件的存储方式，是以前的默认消息存储 KahaDB消息存储-提供了容量的提升和恢复能力，是现在的默认存储方式 JDBC消息存储-消息基于JDBC存储的 Memory 消息存储-基于内存的消息存 ...
分类：
其他好文 时间：
2018-07-20 11:34:06
阅读次数：
139
1：把整个conf文件夹复制一份，比如叫做conf22：修改里面的activemq.xml文件（1）里面的brokerName 不能跟原来的重复（2）数据存放的文件名称不能重复，比如：<kahaDB directory="${activemq.data}/kahadb_2"/>（3）所有涉及的tra ...
分类：
其他好文 时间：
2018-07-20 11:12:24
阅读次数：
196
准备工作：安装JDK7以上. https://www.cnblogs.com/Dylansuns/p/6974272.html 1. 下载cd /home/downloadwget https://archive.apache.org/dist/activemq/5.14.0/apache-acti ...
分类：
系统相关 时间：
2018-07-19 21:09:34
阅读次数：
185
1.下载地址http://activemq.apache.org/activemq-5154-release.html 2.修改登录账号和密码，在配置文件jetty-realm.properties中。 3.修改端口，61616为对外服务端口号（在activemq.xml中修改），8161为控制器端 ...
applicationContext.xml配置文件： <! 属性文件配置 classpath:jdbc.properties <! dbcp <! 连接初始值，连接池启动时创建的连接数量的初始值 默认值是0 <! 最小空闲值.当空闲的连接数少于阀值时，连接池就会预申请去一些连接，以免洪峰来时来不及 ...
分类：
编程语言 时间：
2018-07-18 14:05:37
阅读次数：
176
最近想要学习MOM（消息中间件：Message Oriented Middleware），就从比较基础的activeMQ学起，rabbitMQ、zeroMQ、rocketMQ、Kafka等后续再去学习。 上面说activeMQ是一种消息中间件，可是为什么要使用activeMQ？ 在没有使用JMS的时 ...
分类：
编程语言 时间：
2018-07-18 10:51:08
阅读次数：
158
// 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。 //brokerURL服务器的ip及端口号 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.2... ...
分类：
其他好文 时间：
2018-07-17 10:42:05
阅读次数：
123
第一步：引用相关的jar包 第二步：配置Activemq整合spring ...
分类：
编程语言 时间：
2018-07-17 10:36:47
阅读次数：
176
问题描述： 在activemq的监听器中，通过注解@Autowired或@Resource注入bean时，获取到的bean为null。调用该bean的方法时会报空指针异常。 问题原因： 当调用bean内方法时，spring容器中还没有完成对注解bean的扫描，dispatcher.xml中配置的注解 ...
分类：
其他好文 时间：
2018-07-15 23:50:59
阅读次数：
448
