Spring 教程
- Spring 教程
- Spring 模块
- Spring 示例
- spring 创建应用
- Spring IoC容器
- Spring 依赖注入
- Spring 自动装配
- Spring Dependency注入
- Spring AOP
- Spring JdbcTemplate
- Spring ORM框架
- Spring SPEL表达式
- Spring MVC
- Spring MVC表单
- Spring MVC CRUD
- Spring MVC验证
- Spring MVC Tiles
- Spring Remoting
- Spring JAXB
- Spring Java Mail
- Spring Struts集成
- Spring security
- Spring Angular CRUD
Spring和JMS集成
要将spring与JMS集成，您需要创建两个应用程序。
JMS接收器应用程序 JMS Sender应用程序
要使用spring创建JMS应用程序，我们使用Apache的 Active MQ Server 创建队列。
让我们看看集成spring应用程序的简单步骤。使用JMS:
必需的Jar文件
1、您需要添加 spring core ， spring misc ， spring aop ， spring j2ee 和 spring持久性内核 jar文件。
下载spring的所有jar文件，包括aop，mvc，j2ee，remoting，oxm等。
2、添加 activemqall5。 9.jar 文件位于activemq目录中。
在ActiveMQ Server中创建队列
下载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/网址访问activemq服务器的管理控制台。
现在，单击 队列链接，在文本字段中写入 myqueue ，然后单击创建按钮
JMS接收器应用程序
让我们看一下将spring应用程序与JMS集成的简单步骤:
MyMessageListener.java TestListener.java applicationContext.xml
1)MyMessageListener.java
package com.nhooo;
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
package com.nhooo;
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.nhooo.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应用程序
让我们看一下创建JMS Sender应用程序的文件:
MyMessageSender.java TestJmsSender.java applicationContext.xml
1)MyMessageListener.java
package com.nhooo;
import javax.jms.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import 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 {
return session.createTextMessage(message);
}
});
}
}
2)TestJmsSender.java
package com.nhooo;
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"></constructor-arg> <property name="defaultDestinationName" value="myqueue"></property> </bean> <context:component-scan base-package="com.nhooo"></context:component-scan> </beans>