ActiveMQ整合Spring——发送消息

野性酷女 2022-05-27 09:56 256阅读 0赞

需要的jar包：

`<dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>4.1.3.RELEASE</version> </dependency>`

`<dependency>     <groupId>org.springframework</groupId>     <artifactId>spring-jms</artifactId>     <version>4.1.3.RELEASE</version>    </dependency>`

`<dependency>     <groupId>org.apache.activemq</groupId>     <artifactId>activemq-all</artifactId>     <version>5.11.2</version> </dependency>`

`新建spring-activemq.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" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	xmlns:context="http://www.springframework.org/schema/context"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans
         http://www.springframework.org/schema/beans/spring-beans.xsd 
         http://code.alibabatech.com/schema/dubbo 
         http://code.alibabatech.com/schema/dubbo/dubbo.xsd
         http://www.springframework.org/schema/context 
         http://www.springframework.org/schema/context/spring-context.xsd">
    
    	
    	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    		<property name="brokerURL" value="tcp://192.168.25.134:61616" />
    	</bean>
    	
    	<bean id="connectionFactory"
    		class="org.springframework.jms.connection.SingleConnectionFactory">
    		
    		<property name="targetConnectionFactory" ref="targetConnectionFactory" />
    	</bean>
    	
    	
    	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    		
    		<property name="connectionFactory" ref="connectionFactory" />
    	</bean>
    	
    	<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
    		<constructor-arg>
    			<value>spring-queue</value>
    		</constructor-arg>
    	</bean>
    	
    	<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
    		<constructor-arg value="topic" />
    	</bean>
    
    
    </beans>

在java代码中的具体应用：

@Autowired
    	private JmsTemplate jmsTemplate;
    	@Resource
    	private Destination topicDestination;//使用命名注入，使用topic消息形式
    
    
           @Override
    	public E3Result saveItemService(TbItem tbItem, String desc) {
    		//发送消息
    		final long itemId = 111；
    		jmsTemplate.send(topicDestination, new MessageCreator() {
    			
    			@Override
    			public Message createMessage(Session session) throws JMSException {
    				// TODO Auto-generated method stub
    				TextMessage createTextMessage = session.createTextMessage();
    				System.out.println(itemId);
    				createTextMessage.setText(itemId + "");
    				return createTextMessage;
    			}
    		});
    	}