English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
Для интеграции spring с JMS вам нужно создать два приложения.
Приложение-получатель JMS Приложение JMS Sender
Чтобы интегрировать spring с JMS, мы используем Apache Active MQ Server Создание очереди.
Давайте посмотрим на простые шаги интеграции spring приложений. Использование JMS:
1、вам нужно добавить spring core , spring misc , spring aop , spring j2ee и ядро persistence spring jar файлы.
скачайте все jar файлы spring, включая aop, mvc, j2ee, remoting, oxm и т.д.
2、добавьте activemqall5.9.jar Файл находится в директории activemq.
Скачайте Active MQ сервер. Скачайте Active MQ
дважды щелкните activemq.bat Файл находится в директории apache-activemq-5.9.1-bin \ apache-activemq-5.9.1 \ bin \ win64 или win32.
Теперь откроется консоль сервера ActiveMQ.
через http://localhost:8161/admin/URL для доступа к консоли управления ActiveMQ сервера.
Теперь нажмите ссылка на очередьи в текстовом поле введите myqueue и затем нажмите кнопку создания
Давайте рассмотрим простые шаги по интеграции spring приложения с JMS:
MyMessageListener.java TestListener.java applicationContext.xml
1)MyMessageListener.java
пакет com.w3codebox;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
public class MyMessageListener implements MessageListener{
@Override
public void onMessage(Message m) {
TextMessage message=(TextMessage)m;
try{
System.out.println(message.getText());
}catch (Exception e) {e.printStackTrace();}
}
}
2)TestListener.java
пакет com.w3codebox;
import org.springframework.context.support.GenericXmlApplicationContext;
public class TestListener {
public static void main(String[] args) {
GenericXmlApplicationContext ctx = new GenericXmlApplicationContext();
ctx.load("classpath:applicationContext.xml");
ctx.refresh();
while(true){}
}
}
3)applicationContext.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:jms="http://www.springframework.org/schema/jms" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans" http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> p:brokerURL="tcp://localhost:61616" /> <bean id="listener" class="com.w3codebox.MyMessageListener"></bean> <jms:listener-container container-type="default" connection-factory="connectionFactory"> acknowledge="auto"> <jms:listener destination="myqueue" ref="listener" method="onMessage"></jms:listener> </jms:listener-container> </beans>
Давайте посмотрим на файлы для создания приложения JMS Sender:
MyMessageSender.java TestJmsSender.java applicationContext.xml
1)MyMessageListener.java
пакет com.w3codebox;
импорт javax.jms.*;
импорт org.springframework.beans.factory.annotation.Autowired;
импорт org.springframework.jms.core.JmsTemplate;
импорт org.springframework.jms.core.MessageCreator;
импорт org.springframework.stereotype.Component;
@Component("messageSender")
public class MyMessageSender {
@Autowired
private JmsTemplate jmsTemplate;
public void sendMessage(final String message) {
jmsTemplate.send(new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
возврат session.createTextMessage(message);
}
});
}
}
2)TestJmsSender.java
пакет com.w3codebox;
import org.springframework.context.support.GenericXmlApplicationContext;
public class TestJmsSender {
public static void main(String[] args) {
GenericXmlApplicationContext ctx = new GenericXmlApplicationContext();
ctx.load("classpath:applicationContext.xml");
ctx.refresh();
MyMessageSender sender = ctx.getBean("messageSender", MyMessageSender.class);
sender.sendMessage("hello jms3");
}
}
3)applicationContext.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:context="http://www.springframework.org/schema/context" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans" http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> p:brokerURL="tcp://localhost:61616" /> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <constructor-arg name="connectionFactory" ref="connectionFactory"> <property name="defaultDestinationName" value="myqueue"> </bean> </context:component-scan base-package="com.w3codebox"> </beans>