博客开张：用Spring+ActiveMQ+Jencks开发消息驱动POJO

我近段的一个应用中需要消息驱动POJO。
最近也听说Spring 2.0开始支持消息驱动POJO了，但我的应用使用的Spring1.2。
从网上找了一些文章看来都比较旧了，并且近段ActiveMQ处于Apache的孵化器中，包的结构也有些改变，原来的ActiveMQ中的JCA容器部分也从ActiveMQ中独立也来成了Jencks项目。
后来参考这些文章和Jencks官网上的说明成功实现了消息驱动POJO。
下面记录了我配置的过程：
[list=1]

搞定相依赖的包。

a.Spring相关的一些包，这部分就不再啰嗦了。
b.ActiveMQ相关的包
activemq-ra-4.01
concurrent-1.3.4
  incubator-activemq-4.0.1
c.JCA容器
jencks-1.3-all

服务端配置

<bean id="helloBean" class="mdp.demo.HelloBean" />

	<bean id="jmsTransactionManager"
		class="org.jencks.factory.TransactionManagerFactoryBean" />

	<bean id="activeMQContainer" class="org.jencks.JCAContainer">
		<property name="bootstrapContext" >
			<bean id="bootstrapContext" class="org.jencks.factory.BootstrapContextFactoryBean">
				<property name="transactionManager" ref="jmsTransactionManager"/>
			</bean>
		</property>
		
		<property name="resourceAdapter">
			<bean id="activeMQResourceAdapter"
				class="org.apache.activemq.ra.ActiveMQResourceAdapter">
				<property name="serverUrl"
					value="tcp://localhost:61616" />
			</bean>
		</property>
	</bean>


	<bean id="HelloMDP" class="org.jencks.JCAConnector">
		<property name="jcaContainer" ref="activeMQContainer" />
		<property name="transactionManager" ref="jmsTransactionManager" />
		<property name="activationSpec">
			<bean
				class="org.apache.activemq.ra.ActiveMQActivationSpec">
				<property name="destination" value="Hello.Queue" />
				<property name="destinationType"
					value="javax.jms.Queue" />
			</bean>
		</property>
		<property name="ref" value="helloBean" />
	</bean>

开发HelloBean

package mdp.demo;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;

public class HelloBean implements MessageListener {

	public void onMessage(Message msg) {
		try {
			String name = msg.getStringProperty("name");
			if (name == null) {
				name = "World";
			}

			System.out.println("Hello " + name + "!");
		} catch (JMSException e) {
			e.printStackTrace();
		}

	}

}

客户端配置，这里直接使用Spring的JmsTemplate

<bean id="jmsTemplate"
		class="org.springframework.jms.core.JmsTemplate">
		<property name="defaultDestinationName" value="Hello.Queue" />
		<property name="connectionFactory" ref="connectionFactory" />
	</bean>
<bean id="connectionFactory"
		class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="tcp://localhost:61616" />
	</bean>

客户端示例程序

package mdp.demo;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class MDPClient {
	public static void main(String[] args) {
		ApplicationContext ctx = new ClassPathXmlApplicationContext(
				"spring-client.xml");

		JmsTemplate template = (JmsTemplate) ctx.getBean("jmsTemplate");
		template.setDefaultDestinationName("Hello.Queue");
		template.send(new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {
				MapMessage message = session.createMapMessage();
				message.setStringProperty("name", "消息驱动POJO");
				return message;
			}
		});
		
		
	}
}

上面的示例代码实现了消息驱动POJO，但是POJO类仍需实现MessageListener接口。
上面的配置也不支持XA事务，Jencks官网上有说明，但我没有配置成功(Hibernate和JMS)。有哪位兄弟配置成功请告知，谢谢。
[/list]

评论

5 楼 zlotus 2009-12-03  

版本你好，
若果在1.2版本的基础上加上spring2.0部门对jms支持的jar包，是不是
可以实现jms的对支持呐?

4 楼 skiter 2007-03-02  

照上面配好一切正常，但是我重启activeMQ服务器，helloBean就不能接受到消息，我在jconsole里面看到队列里受到消息了，就是helleBean里取不到，不知道怎么回事？

3 楼 YuLimin 2006-11-19  

1、可以直接启动ActiveMQ做为JMS服务端；
2、可以同JVM一起启动ActiveMQ来做服务端进行测试。

2 楼 Jamsa 2006-11-09  

我的服务端是一个J2EE应用，配置指的就是Spring的配置文件，这里没有使用activemq.xml来配置。
客户端是一个用来做测试的Java程序（配置文件是另一个Spring配置文件)，只是发送一下消息到上面配置的

 <property name="destination" value="Hello.Queue" />  

这个队列里。

1 楼 leidongduo 2006-11-08  

你说的“服务器配置”的配置文件是ActiveMQ服务器的activemq.xml吗？应该不是吧，你说的这个配置文件应该是个spring的配置文件吧？


  这样的话，这个spring配置文件应该放在工程的什么位置呢？这个配置文件的内容中并没有提到ActiveMq broker的信息，应该怎样建立这个jenks的配置文件和ActiveMQ 服务器的信息呢？

  多谢回复