Spring 与 JMS 集成

17 Mar 2025 | 阅读 2 分钟

要将 Spring 与 JMS 集成，您需要创建两个应用程序。

JMS 接收应用程序
JMS 发送应用程序

要使用 Spring 创建 JMS 应用程序，我们使用 Apache 的 Active MQ 服务器 来创建队列。

让我们看看将 Spring 应用程序与 JMS 集成的简单步骤

所需的 Jar 文件

1) 您需要添加 spring core、spring misc、spring aop、spring j2ee 和 spring persistence core jar 文件。

下载 Spring 的所有 jar 文件，包括 aop、mvc、j2ee、remoting、oxm 等。

2) 添加位于 activemq 目录中的 activemqall5.9.jar 文件。

在 ActiveMQ 服务器中创建队列

下载 Active MQ 服务器下载 Active MQ

双击位于 apache-activemq-5.9.1-bin\apache-activemq-5.9.1\bin\win64 或 win32 目录中的 activemq.bat 文件。

现在将打开 activemq 服务器控制台。

通过 https://:8161/admin/ url 访问 activemq 服务器的管理控制台。

现在，单击 Queues 链接，在文本框中写入 myqueue，然后单击创建按钮。

1) JMS 接收应用程序

让我们看看将 Spring 应用程序与 JMS 集成的简单步骤

MyMessageListener.java
TestListener.java
applicationContext.xml

1) MyMessageListener.java

package com.javatpoint;
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.javatpoint;
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://:61616" />

<bean id="listener" class="com.javatpoint.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>

2) JMS 发送应用程序

让我们看看创建 JMS 发送应用程序的文件

MyMessageSender.java
TestJmsSender.java
applicationContext.xml

1) MyMessageListener.java

package com.javatpoint;
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.javatpoint;
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://: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.javatpoint"></context:component-scan>

</beans>

下载 JMS 接收示例（使用 Myeclipse IDE 开发）
下载 JMS 发送示例（使用 Myeclipse IDE 开发）

下一主题Spring 和 Jaxb 集成示例

我们提供所有技术（如 Java 教程、Android、Java 框架）的教程和面试问题

联系信息

G-13, 2nd Floor, Sec-3, Noida, UP, 201301, India

hr@tpointtech.com

+91-9599086977

关注我们

Python

Java

.Net Framework

AI, ML and Data Science

Cloud Technology

B.Tech and MCA

Web Technology

PHP

Software Testing

Technical Interview

Java Interview

Python

Web Interview

Database Interview

B.Tech / MCA

Important Interview

Software Testing Interview

Company Interviews

Online Compilers

Multiple Choice Questions

Spring 教程

IDE 中的 Spring

依赖注入

Spring JdbcTemplate

Spring AOP

Spring ORM

SPEL

Spring MVC

MVC 表单标签库

MVC 应用

Spring MVC 验证

MVC Tiles

Spring Remoting

Spring OXM

Spring Java Mail

Spring Web

Spring Security 教程

Spring 面试

Spring 测验

Spring Boot

Spring + Angular

其他

Spring 与 JMS 集成

所需的 Jar 文件

在 ActiveMQ 服务器中创建队列

1) JMS 接收应用程序

2) JMS 发送应用程序

相关帖子

Spring Remoting

Http Invoker

Spring 与 RMI

Burlap

Hessian

订阅 Tpoint Tech

联系信息

关注我们

教程

面试题

在线编译器