企业集成模式实践——用actviemq集成.net应用系统

最近，在企业集成方面，做了一些技术尝试，用activemq来集成java与.net系统。

1.首先，搭建主数据管理系统

主界面如下：

3.在spring的配置文件中配置名为testTopic的队列：

<!-- 配置JMS连接工厂 --> 
      
<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop"> 
            <property name="connectionFactory"> 
               <bean class="org.apache.activemq.spring.ActiveMQConnectionFactory">
                    <property name="brokerURL" value="tcp://localhost:61616"/>                  
               </bean>
               </property>    
               <!--  <property name="maxConncetions"  value="1"/>-->
        </bean>
             <!--   <bean id ="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
                    <property name="brokerURL" value="tcp://localhost:61616"/>                  
               </bean>--> 


       <bean id="SendMessage" class="test.SendMessage">
           <property name="jmsTemplate" ref="jmsTemplate"/>
           <property name="topicName" value="testTopic"/>                            
       </bean> 
      <!--   <bean id="Listener" class="test.Listener">
            <constructor-arg ref="jmsTemplate"/>     
            <constructor-arg value="testTopic" />
              				
       </bean> -->
        <!-- 配置JMS模版 --> 
      <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> 
             <property name="connectionFactory" ref="jmsFactory"/> 
              <property name="defaultDestination" ref="testTopic"/> 
             <property name="explicitQosEnabled" value="true"/>
             <property name="deliveryMode" value="1" />
        </bean> 
        <bean id="testTopic" class="org.apache.activemq.command.ActiveMQTopic">
            <constructor-arg value="testTopic" />          
        </bean>

4.发送消息：

package test;


import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.Topic;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class SendMessage {
	
	private JmsTemplate jmsTemplate;
	
	private String topicName;
	
	private Topic testTopic;
	
	public void setJmsTemplate(JmsTemplate jmsTemplate){
		this.jmsTemplate = jmsTemplate;
	}
	public void setTopicName(String topicName) {
		this.topicName = topicName;
	}	

	public void sendMessage(final Map message) throws JMSException,InterruptedException{
		 
		if(testTopic==null){
			System.out.println(jmsTemplate);
			ConnectionFactory cf =jmsTemplate.getConnectionFactory();
			Connection conn = cf.createConnection();
			Session sess = conn.createSession(false,Session.AUTO_ACKNOWLEDGE);
			testTopic = sess.createTopic(topicName);
		}
		jmsTemplate.send(testTopic, new MessageCreator(){
			@Override
			public Message createMessage(Session session) throws JMSException {
				MapMessage mapMess = session.createMapMessage();
				Set temp = message.entrySet();
				Iterator temp2 = temp.iterator();
				while(temp2.hasNext()){
					Entry entry = (Entry)temp2.next();										
					mapMess.setObject((String)entry.getKey(), entry.getValue());
				}
				return mapMess;
			}
		});
		
	}
	/**
	 * 测试
	 * @param args
	 */
	public static void main(String[] args) {
	}

}

5.接收消息：

package test;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.Topic;

import org.springframework.jms.JmsException;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.listener.DefaultMessageListenerContainer;

public class Listener  implements MessageListener{

	private JmsTemplate jmsTemplate;
	
	private String topicName;
	
	public Listener(JmsTemplate jmsTemplate,String topicName){
		this.jmsTemplate = jmsTemplate;
		this.topicName = topicName;
		Topic topic;
		try{
			topic = this.jmsTemplate.getConnectionFactory().createConnection()
					.createSession(false, Session.AUTO_ACKNOWLEDGE)
					.createTopic(topicName);
			DefaultMessageListenerContainer dc = new DefaultMessageListenerContainer();
			dc.setPubSubDomain(true);
			dc.setDestination(topic);
			dc.setConnectionFactory(this.jmsTemplate.getConnectionFactory());
			dc.setPubSubNoLocal(false);
			dc.setMessageListener(this);
			dc.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
			dc.initialize();
			dc.start();
		}catch(JMSException e){
			e.printStackTrace();
		}
	}
	@Override
	public void onMessage(Message arg0) {
		// TODO Auto-generated method stub
		System.out.println("收到的消息："+arg0);
		MapMessage map = (MapMessage) arg0;
		try {
			System.out.println(map.getObject("Name"));
		} catch (JMSException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}

6.点击消息同步，执行SendMessage：

7.在.net中进行接收监听，点击订阅消息：