Spring学习笔记29

    技术2022-05-12  8

    Spring中使用JMS

           JMS为了Java开发人员与消息代理(message broker)交互和收发消息提供了一套标准API。而且,由于每个message broker都支持JMS,所以我们就不需要学习额外的消息API了。但是,由于JMS是如此的通用以至于使用它并不是十分方便。

    1.      处理JMS样本代码

    我们还记得一般的JDBC是如何笨拙地处理连接、语句、结果集和异常的。不幸地是,JMS处理方式和它类似,有很多样本代码。很多JMS例子中的代码都是重复的。因此,与JdbcTemplate类似,Spring提供了JmsTemplate来处理样本代码。

    2.      使用JMS模板

    你可以使用JmsTemplate来创建连接,获取会话并进行收发消息。这样就可以只关注于发送消息的开发或是处理接收消息。另外,JmsTemplate还可以细化JMSException的处理。JmsTemplate能够捕获该异常并不同的未检查(unchecked)子类异常,如:DestinationResolutionExceptionIllegalStateException等。

    其实,JMSException提供了一组子类用于详尽地表明异常原因,但是他们都是checked类型的,所以也就必须被捕获,而JmsTemplate将会为你做这件事情。

    绑定JmsTemplate

           若要使用JmsTemplate,你需要在Spring配置文件中将其声明为一个bean,方法如下:

    <bean id="jmsTemplate"

        class="org.springframework.jms.core.JmsTemplate">

        <property name="connectionFactory" ref="connectionFactory" />

    </bean>

    因此JmsTemplate需要知道如何连接到message broker,所以我们需要设置connectionFactory属性,令其引用一个JMSConnectionFactory接口实现类,在这里是connectionFactoryJmsTemplate还有一些其他属性,如果需要我们再介绍。

    消息发送

    对于RoadRantz例子来说,RoadRantz应用会给每个motorist发送一些有用的第三方信息,如果motorist对此感兴趣,他的信息就将被加到一个单独的销售系统中。当首次注册时,如果用户选择接收第三方信息,那么他们的名字和邮件地址就以JMS消息的方式被发送到这个系统中。

    而在RoadRantz端,我们希望使用JmsTemplate来发送motorist信息给Roadantz销售系统。下面的RantzMarketingGateImpl即实现了与销售系统的交互。

    public class RantzMarketingGatewayImpl

    implements RantzMarketingGateway {

           public RantzMarketingGatewayImpl() {}

           public void sendMotoristInfo(final Motorist motorist) {

                  jmsTemplate.send(destination, new MessageCreator() {

           public Message createMessage(Session s) throws JMSException

           {

                  MapMessage msg = s.createMapMessage();

                  msg.setString(“lastName”, motorist.getLastName());

                  msg.setString(“firstName”, motorist.getFirstName());

                  msg.setString(“email”, motorist.getEmail());

                  return msg;

           }

    });

    }

    private JmsTemplate jmsTemplate;

    public void setJmsTemplate(JmsTemplate jmsTemplate) {

           this.jmsTemplate = jmsTemplate;

    }

    private Destination destination;

    public void setDestination(Destination destination) {

           this.destination = destination;

    }

    }

    上面代码中的sendMotoristInfo方法最为关键。其实它只是调用JmsTemplatesend方法来发送消息。

           send方法的第一个参数是一个JMS Destination对象。这里使用了destination属性被注入到RantzMarketingGatewayImpl类。当调用send方法时,JmsTemplate将会获取一个JMS连接和会话并在发送端发送消息。代码中的MessageCreator用于创建消息,这里使用了一个匿名内部类。MessageCreator类的createMessage方法使用JMSMapMessage来保存motorist的姓名和邮件地址。createMessage方法是一个回调方法,JmsTemplate使用它来创建用于被发送的消息。

           JmsTemplateDestination通过setter注入到RantzMarketingGateImpl。所以,在Spring中配置RantzMarketingGateImpl时,我们必须指定jmsTemplaterantzDestination bean的引用:

    <bean id="marketingGateway"

        class="org.roadrantz.marketing.RantzMarketingGatewayImpl">

        <property name="jmsTemplate" ref="jmsTemplate" />

        <property name="destination" ref="rantzDestination />

    </bean>

    值得注意的是,sendMotorist方法只关注于消息的创建和发送——JmsTemplate为我们处理其他的代码,而且我们不需要手工去编写捕获JMSException的代码,JmsTemplate将会捕获被抛出的JMSException并将其以Spring的未检查异常重新抛出。

    设置默认destination

           前面我们已经指定了一个Destination用于将消息发送给它。这种方式非常方便,但是对于RantzMarketingGateImpl而言,我们总是发送motorist消息给相同的destination,所以这种方式就不那么方便了。除了每次发送消息时显式地指定destination,我们可以采用默认destination的方式:

    <bean id="jmsTemplate"

        class="org.springframework.jms.core.JmsTemplate">

        <property name="connectionFactory" ref="connectionFactory" />

        <property name="defaultDestination" ref="rantzDestination" />

    </bean>

    现在调用send方法就不用再指定了destination参数了,只需要一个MessageCreator即可。JmsTemplate会将消息发送到默认的destination处,我们也不需要在RantzMarketingGateImplbean配置中指定destination了:

    <bean id="marketingGateway"

        class="org.roadrantz.marketing.RantzMarketingGatewayImpl">

        <property name="jmsTemplate" ref="jmsTemplate" />

    </bean>

    因为我们不再需要在RantzMarketingGateImpl中指定destination,所以destination属性和代码中的setter方法都可以去掉了。

    接收消息

    JmsTemplate可以负责发送消息,它可以接收消息吗?是的,它可以。实际上用JmsTemplate接收消息更简单。你只需调用JmsTemplatereceive方法。

    public class MarketingReceiverGatewayImpl {

           public MarketingReceiverGatewayImpl() {}

           public SpammedMotorist receiveSpammedMotorist() {

                  MapMessage msg = (MapMessage)jmsTemplate.receive();

                  SpammedMotorist motorist = new SpammedMotorist();

                  try {

                         motorist.setFistName(msg.getString(“firstName”));

                         motorist.setLastName(msg.getString(“lastName”));

                         motorist.setEmail(msg.getString(“email”));

    }

    catch (JMSException e) {

           throw JmsUtils.convertJmsAccessException(e);

    }

    Return motorist;

    }

    private JmsTemplate jmsTemplate;

    public void setJmsTemplate(JmsTemplate jmsTemplate) {

           this.jmsTemplate = jmsTemplate;

    }

    }

    当调用receive方法时,JmsTemplate会再次帮我们处理那些诸如连接,会话之类的样本工作,然后再调用receive方法。JmsTemplatereceive方法是同步的。默认情况下,调用receive方法之后将会等待消息发送至destination。不过你可以指定一个接收超时receiveTimeout属性,例如:

    <bean id="jmsTemplate"

        class="org.springframework.jms.core.JmsTemplate">

        <property name="connectionFactory" ref="connectionFactory" />

        <property name="defaultDestination" ref="rantzDestination" />

        <property name="receiveTimeout" value="60000" />

    </bean>

    当然,你可以使用指定的destination,如:

    MapMessage msg = (MapMessage) jmsTemplate.receive(destination);

    另外,你还可以通过名字来指定一个destination,并让Springdestination解析器自动地解析destination,如:

    MapMessage msg =

    (MapMessage) jmsTemplate.receive(“rantz.marketing.queue”);

    同步接收消息并不是唯一的选择。Spring也提供了消息的异步接收方式。下面让我们看看如何让JmsTemplate自动实现XML消息和Java对象之间的转换。

    3.      消息转换

    被发送的消息是由createMessage方法中的异步MessageCreator实例创建的,通过使用Motorist对象属性将其放入一个MapMessage对象。同时在接收端,MarketingReceiverGatewayImplreceiveSpammedMotorist方法会从消息中获取值并赋值到一个SpammedMotorist对象中。本例中的转换工作并不复杂,但如果应用中的多个点多需要接收或发送相同的消息,那么就会出现很多重复代码。

    Spring提供了专门用于消息转换的接口:MessageConverter

    public interface MessageConverter {

           public Message toMessage(Object object, Session session);

           public Object fromMessage(Message message);

    }

    MessageConverter接口很简单,只有两个方法。如果要发送消息,toMessage方法会将一个Java对象转换成消息。在接收端,fromMessage方法将消息转换成Java对象。我们需要在应用中实现该接口

    收发转换过的消息

           虽然我们可以使用toMessagefromMessage方法来发送和接收消息,但Spring提供了更好的方法。除了显式地调用toMessage方法,我们可以调用JmsTemplateconvertAndSend方法。这样的话,RantzMarketingGateImplsendMotoristInfo方法就可以得到极大地简化:

    public void sendMotoristInfo(final Motorist motorist) {

           jmsTemplate.convertAndSend(motorist);

    }

    JmsTemplateconvertAndSend方法会自动地调用toMessage方法用于发送消息。不适用默认destination的调用方式如下:

    jmsTemplate.convertAndSend(destination, motorist);

    jmsTemplate.convertAndSend(“rantz.marketing.queue”, motorist);

    在接收端,我们也不必调用fromMessage方法,相反,我们可以使用receiveAndConvert方法:

    public SpammedMotorist receiveSpammedMotorist() {

           return (SpammedMotorist) jmsTemplate.receiveAndConvert();

    }

    同样你也可是传递一个destination参数来使用非默认的destination。现在还有一个问题需要搞清楚,JmsTemplateconvertAndSendreceiveAndConvert方法使用消息转化器来进行消息转换,那么JmsTemplate是怎么知道这个消息转换器呢?

    指定消息转换器

           为了使之能够工作,我们需要在Spring中对其进行配置:

    <bean id="motoristConverter"

        class="com.roadrantz.marketing.MotoristMessageConverter" />

    然后,在JmsTemplate的配置中你需要将此converter指定到messageConverter属性上,如:

    <bean id="jmsTemplate"

        class="org.springframework.jms.core.JmsTemplate">

        <property name="connectionFactory" ref="connectionFactory" />

        <property name="defaultDestination" ref="rantzDestination" />

        <property name="receiveTimeout" value="60000" />

        <property name="motoristConverter" ref="motoristConverter" />

    </bean>

           你可能已经发现了JdbcTemplateJmsTemplate的许多相同之处,下面就让我们看看Spring是如何通过JmsGatewaySupport类来构建JMS通路的。

    4.      JMS通路支持类

    你可能还记得,因为有了JdbcDaoSupport这个用于编写基于JDBCDAO的类,Spring可以更加方便地使用JdbcTemplate。同样地,Spring提供了JmsGatewaySupport类,它是提供JMS通路支持的基类。

    目前为止我们创建了jmsTemplatedestination属性。尽管现在的代码量不多,但是如果应用中存在多个JMS通路,那必将导致大量重复的代码。为了解决这个问题,我们需要令RantzMarketingGateImpl类继承JmsGatewaySupport类,例如:

    public class RantzMarketingGatewayImpl extends JmsGatewaySupport

           implements RantzMarketingGateway {

           public RantzMarketingGatewayImpl() {}

           public void sendMotoristInfo(final Motorist motorist) {

                  getJmsTemplate().send(“rantz.marketing.queue”,

                         new MessageCreator() {

                         public Message createMessage(Session session)

    throws JMSException {

    MapMessage msg = session.createMapMessage();

    msg.setString(“lastName”, motorist.getLastName());

    msg.setString(“firstName”, motorist.getFirstName());

    msg.setString(“email”, motorist.getEmail());

    return msg;

                         }

                  });

    }

    }

    注意jmsTemplate属性和setJmsTemplate方法不见了。这个版本的RantzMarketingGateImpl会调用getJmsTemplate来获取JmsTemplate对象。所以,jmsTemplate和它的setter方法就不需要了。

           不过JmsGatewaySupport是从哪里获得JmsTemplate对象的呢?你可以将一个JmsTemplate对象直接注入到jmsTemplate属性中,你也可以利用一个连接工厂属性:

    <bean id="marketingGateway"

        class="com.roadrantz.marketing.RantzMarketingGatewayImpl" />

        <property name="connectionFactory" ref="connectionFactory" />

    </bean>

    这样配置的话,JmsGatewaySupport将自动根据指定的连接工厂来创建JmsTemplate对象。在Spring中不需额外声明JmsTemplate。不过这种方法也有不足之处:

    ·你只能为一个JmsTemplate指定一个默认destination。如果JmsGatewaySupport创建了自己的JmsTemplate,你就不能再指定默认destination了。你就只能显式地调用带有destination参数的sendreceive方法。

    ·你只能为一个JmsTemplate编写一个消息转换器。如果JmsGatewaySupport创建了JmsTemplate,你就不能使用消息转换器了。你也必须显式地处理消息转换。

     


    最新回复(0)