Spring整合Blazeds实现ActiveMQ JMS消息服务

转载：http://yunzhongxia.iteye.com/blog/789698

 

 

  上一篇中简单实现了Blazeds的JMS消息服务功能，但是JMS相关的配置信息都在messaging-config.xml文件中配置的，项目部署人员需要同时维护messaging-config.xml和Spring的jms配置信息，如果能把两者整合在那是一件很美妙的事情。经过我的一番努力终于统一了blazeds和spring的jms消息服务。

      先来说下我的大概思路：JMSAdapter是jms的消息适配器，它会加载messaging-config.xml里面jms的配置信息，JMSProxy是JMS服务的代理，它会根据配置信息连接ConnectionFactory、创建Destination。知道了，JMS的工作流程那就开始改造代码：

      修改JMSAdapter.java

     

    protected void validate()
    {
        if (isValid())
            return;

        super.validate();

//        if (settings.getConnectionFactory() == null)
//        {
//            // JMS connection factory of message destinations with JMS Adapters must be specified.
//            ConfigurationException ce = new ConfigurationException();
//            ce.setMessage(MISSING_CONNECTION_FACTORY);
//            throw ce;
//        }
//
//        if (settings.getDestinationJNDIName() == null)
//        {
//            // JNDI names for message destinations with JMS Adapters must be specified.
//            ConfigurationException ce = new ConfigurationException();
//            ce.setMessage(JMSConfigConstants.MISSING_DESTINATION_JNDI_NAME);
//            throw ce;
//        }

//        if (settings.getMessageType() == null)
//        {
//            // Unsupported JMS Message Type ''{0}''. Valid values are javax.jms.TextMessage and javax.jms.ObjectMessage.
//            ConfigurationException ce = new ConfigurationException();
//            ce.setMessage(INVALID_JMS_MESSAGE_TYPE, new Object[] {null});
//            throw ce;
//        }
    }

    protected void validate()
    {        
        if (isValid())
            return;
        
        super.validate();
        
//        if (settings.getConnectionFactory() == null)
//        {
//            // JMS connection factory of message destinations with JMS Adapters must be specified.            
//            ConfigurationException ce = new ConfigurationException();
//            ce.setMessage(MISSING_CONNECTION_FACTORY);
//            throw ce;
//        }
//        
//        if (settings.getDestinationJNDIName() == null)
//        {
//            // JNDI names for message destinations with JMS Adapters must be specified.
//            ConfigurationException ce = new ConfigurationException();
//            ce.setMessage(JMSConfigConstants.MISSING_DESTINATION_JNDI_NAME);
//            throw ce;            
//        }

//        if (settings.getMessageType() == null)
//        {
//            // Unsupported JMS Message Type ''{0}''. Valid values are javax.jms.TextMessage and javax.jms.ObjectMessage. 
//            ConfigurationException ce = new ConfigurationException();
//            ce.setMessage(INVALID_JMS_MESSAGE_TYPE, new Object[] {null});
//            throw ce;            
//        }        
    }

 

注释掉的代码是因为在messaging-config.xml中没有了JMS相关的配置信息。

 

   修改JMSProxy.java文件

  

public void start() throws NamingException, JMSException
 {
    this.connectionFactory=(ConnectionFactory) SpringContext.getBean("JmsConnectionFactory");
             this.destination=(Destination) SpringContext.getBean("JmsDestination");
    //validate();
             //initializeJndiContext();
             //initializeConnectionFactory();
             //initializeDestination();
 }

   public void start() throws NamingException, JMSException
    {
    	this.connectionFactory=(ConnectionFactory) SpringContext.getBean("JmsConnectionFactory");
                this.destination=(Destination) SpringContext.getBean("JmsDestination");
    	//validate();
                //initializeJndiContext();
                //initializeConnectionFactory();
                //initializeDestination();
    }

 

SpringContext的getBean方法的作用是根据spring配置的beanID实例化相关的bean信息。附件中给我了SpringContext的源代码。JmsConnectionFactory为jms的连接工厂，JmsDestination是jms的消息主题Topic

 

下面是spring的jms相关bean的配置

 

<!-- JMS连接工厂 brokerURL方式 例如ActiveMQ-->
<bean id="JmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="${jms.activemq_url}"></property>
</bean>

<!--JMS Topic目的地 例如 ActiveMQ-->
<bean id="JmsDestination" class="org.apache.activemq.command.ActiveMQTopic">
    <constructor-arg index="0" value="${jms.activemq_topic}"></constructor-arg>
</bean>

<!-- JMS模板 -->
<bean id="JmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="JmsConnectionFactory"/>
    <property name="defaultDestination" ref="JmsDestination"/>
</bean>

	<!-- JMS连接工厂 brokerURL方式 例如ActiveMQ-->
	<bean id="JmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="${jms.activemq_url}"></property>
	</bean>
		
	<!--JMS Topic目的地 例如 ActiveMQ-->
	<bean id="JmsDestination" class="org.apache.activemq.command.ActiveMQTopic">
		<constructor-arg index="0" value="${jms.activemq_topic}"></constructor-arg>
	</bean>
	
	<!-- JMS模板 -->
	<bean id="JmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="JmsConnectionFactory"/>
		<property name="defaultDestination" ref="JmsDestination"/>
	</bean>

 

 下面是messaging-config.xml文件中JMS的配置信息。

<!-- JMS消息目标的配置 -->
<destination id="scanfile">
           <adapter ref="jms" />
           <channels>
                     <channel ref="my-polling-amf" />
                     <channel ref="my-streaming-amf" />
            </channels>
</destination>

<!-- JMS消息目标的配置 -->
<destination id="scanfile">
           <adapter ref="jms" />
           <channels>
                     <channel ref="my-polling-amf" />
                     <channel ref="my-streaming-amf" />
            </channels>
</destination>

 

 Ok，到此为止，已经整合完毕，整合后context.xml文件就不需要了。

附件给我了我修改后的flex-messaging-core.jar和SpringContext的源码。到目前为止Blazeds的配置已经很简单了，但是还有一种更好的方案就是org.springframework.flex，该组件主要作用是Blazeds和Spring的整合，在以后的文章中我会继续向大家介绍这个组件的使用方法。

 

    本片介绍了activemq的实现方法，如果是weblogic服务器则可以使用weblogic自带的jms服务，spring配置weblogic信息，可以参考我的下一篇文章，Spring整合Blazeds实现Weblogic JMS消息服务