领先一步
VMware提供培训和认证,助你加速前行。
了解更多在Spring 2.0的所有新特性和改进中,我必须承认消息驱动POJO是我个人最喜欢的一项。我感觉很多其他Spring用户也会有同感。
我在这里提供一个快速介绍。还有很多内容可以展示,我将在后续文章中补充。但目前,这应该足以让你了解如何使用真正基于POJO的异步JMS并开始运行!希望你和我一样对此感到兴奋;)
你需要在类路径中包含以下JAR文件。我也列出了我使用的版本(任何spring-2.x版本都可以。事实上我大约在两分钟前刚把RC3放进去)。
首先,我们需要设置环境。我将使用ActiveMQ,但更换提供商的影响将仅限于修改这一个文件。我将这个文件命名为"shared-context.xml",因为正如你稍后会看到的那样,我将在JMS通信的两端导入这些bean定义。以下是“共享”的bean定义:连接工厂和两个队列(一个用于请求,一个用于回复)。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<bean id="requestQueue" class="org.activemq.message.ActiveMQQueue">
<constructor-arg value="requestQueue"/>
</bean>
<bean id="replyQueue" class="org.activemq.message.ActiveMQQueue">
<constructor-arg value="replyQueue"/>
</bean>
<bean id="connectionFactory" class="org.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>
</beans>
正如你所见,我将在tcp上运行ActiveMQ(我只是在分发包的bin目录下运行'activemq')。也可以运行嵌入式(使用"vm://localhost"代替)——或者你可以运行org.activemq.broker.impl.Main类的main方法。如果你想获取分发包,请访问:http://www.activemq.org。
我在这里故意保持简单——主要目标是演示各个部分如何协同工作。然而,我想指出的最重要的事情之一是我的“领域”中的这些类都是POJO。你将完全看不到任何Spring或JMS依赖。
最终,我们将接受用户的输入(通过标准输入获取一个“name”),并将其转换为某个未指定事件的“注册请求”。消息将异步发送,但我们将有另一个队列来处理回复。ReplyNotifier然后将确认(或“未确认”消息)写入标准输出。
顺便说一句,我将所有这些类创建在“blog.mdp”包中。第一个类是 RegistrationRequest
package blog.mdp;
import java.io.Serializable;
public class RegistrationRequest implements Serializable {
private static final long serialVersionUID = -6097635701783502292L;
private String name;
public RegistrationRequest(String name) {
this.name = name;
}
public String getName() {
return name;
}
}
接下来是 RegistrationReply
package blog.mdp;
import java.io.Serializable;
public class RegistrationReply implements Serializable {
private static final long serialVersionUID = -2119692510721245260L;
private String name;
private int confirmationId;
public RegistrationReply(String name, int confirmationId) {
this.name = name;
this.confirmationId = confirmationId;
}
public String toString() {
return (confirmationId >= 0)
? name + ": Confirmed #" + confirmationId
: name + ": Not Confirmed";
}
}
以及 RegistrationService
package blog.mdp;
import java.util.HashMap;
import java.util.Map;
public class RegistrationService {
private Map registrations = new HashMap();
private int counter = 100;
public RegistrationReply processRequest(RegistrationRequest request) {
int id = counter++;
if (id % 5 == 0) {
id = -1;
}
else {
registrations.put(new Integer(id), request);
}
return new RegistrationReply(request.getName(), id);
}
}
正如你所见,这只是提供一个示例。实际上,可能会对registrations映射做一些处理。此外,你还会看到20%的注册尝试将被拒绝(给出-1的确认ID)——这不是处理注册请求的非常实用的方法,但它会为回复消息提供一些变化。同样,重要的是这个服务类与Spring或JMS没有任何关联。然而,正如你稍后将看到的那样,它将处理通过JMS发送的消息的有效载荷。换句话说,这个RegistrationService*就是*消息驱动POJO。
最后,创建一个简单的类来记录回复消息
package blog.mdp;
public class ReplyNotifier {
public void notify(RegistrationReply reply) {
System.out.println(reply);
}
}
现在是最重要的部分。我们如何使用Spring来配置POJO服务,使其能够接收JMS消息?答案在于2个bean定义(如果算上服务本身就是3个)。在这个接下来的bean定义文件中,请注意实际接收消息并启用异步 listener 使用的“container”。该container需要知道 connectionFactory 以及接收消息的 destination。有多种类型的container可用,但这超出了本文博客的范围。更多信息请阅读参考文档:消息监听容器。
在这种情况下,“listener”是Spring的 MessageListenerAdapter 的一个实例。它引用了 delegate(POJO服务)和处理方法的名称。在本例中,我们还提供了一个 defaultResponseDestination。对于返回void的方法,显然不需要这样做。此外(在生产应用中可能更常见),你可以省略此项,改为设置入站JMS消息的“reply-to”属性。
现在我们已经讨论了各种参与者,以下是bean定义(我将此文件命名为"server-context.xml")
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<import resource="shared-context.xml"/>
<bean id="registrationService" class="blog.mdp.RegistrationService"/>
<bean id="listener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<property name="delegate" ref="registrationService"/>
<property name="defaultListenerMethod" value="processRequest"/>
<property name="defaultResponseDestination" ref="replyQueue"/>
</bean>
<bean id="container" class="org.springframework.jms.listener.SimpleMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="messageListener" ref="listener"/>
<property name="destination" ref="requestQueue"/>
</bean>
</beans>
这里的最后一步是提供一个用于运行服务的引导机制,因为这是一个简单的独立示例。我只是创建了一个简单的main方法来启动包含相关bean定义的ApplicationContext,然后阻塞
package blog.mdp;
import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class RegistrationServiceRunner {
public static void main(String[] args) throws IOException {
new ClassPathXmlApplicationContext("/blog/mdp/server-context.xml");
System.in.read();
}
}
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<import resource="shared-context.xml"/>
<bean id="replyNotifier" class="blog.mdp.ReplyNotifier"/>
<bean id="listener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<property name="delegate" ref="replyNotifier"/>
<property name="defaultListenerMethod" value="notify"/>
</bean>
<bean id="container" class="org.springframework.jms.listener.SimpleMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="messageListener" ref="listener"/>
<property name="destination" ref="replyQueue"/>
</bean>
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="defaultDestination" ref="requestQueue"/>
</bean>
</beans>
这里还定义了另一个bean——Spring的"jmsTemplate"的一个实例。我们将使用它将注册请求消息发送到其 defaultDestination。Spring提供的简单的 convertAndSend(..) 方法使得发送JMS消息变得非常简单。我创建了一个类,该类接受用户输入,然后使用这个"jmsTemplate"发送消息
package blog.mdp;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
public class RegistrationConsole {
public static void main(String[] args) throws IOException {
ApplicationContext context = new ClassPathXmlApplicationContext("/blog/mdp/client-context.xml");
JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
for (;;) {
System.out.print("To Register, Enter Name: ");
String name = reader.readLine();
RegistrationRequest request = new RegistrationRequest(name);
jmsTemplate.convertAndSend(request);
}
}
}