java - Spring JMS 监听器容器未完全停止-6ren

java - Spring JMS 监听器容器未完全停止

转载作者：太空宇宙更新时间：2023-11-04 06:07:48

我在 JMS 监听器容器方面遇到了奇怪的问题。如果我停止监听器容器，一半消息仍会传递到应用程序并由监听器处理。这是我的部署描述符:

  <servlet>
        <servlet-name>mvc-dispatcher</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <load-on-startup>1</load-on-startup>
    </servlet>

    <servlet-mapping>
        <servlet-name>mvc-dispatcher</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>

    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>WEB-INF/jms-config.xml,WEB-INF/root-context.xml</param-value>      
    </context-param>

    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
</web-app>

这是我的 Spring 配置:

<context:component-scan base-package="com.con.*" />


    <bean   class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor" />


    <!-- Web methods environment mappings -->

    <bean id="webMethodProperties"
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="file:/opt/app/jboss/current/modules/com/con/commons/logconfiguration/main/webmethods.properties" />
    </bean> 


    <bean id="intialContext" class="javax.naming.InitialContext">
    <constructor-arg>

            <map>
                <entry key="java.naming.factory.initial" value="${java.naming.factory.initial}" />
                <entry key="java.naming.provider.url" value="${java.naming.provider.url}" />
                <entry key="com.webmethods.jms.naming.clientgroup" value="${com.webmethods.jms.naming.clientgroup}" />
            </map>

        </constructor-arg>
    </bean>
    <!-- JNDI Template for accessing Web Method resources -->
    <bean id="webMethodsJndiTemplate" class="org.springframework.jndi.JndiTemplate">
        <property name="environment">
            <map>
                <entry key="java.naming.factory.initial" value="${java.naming.factory.initial}" />
                <entry key="java.naming.provider.url" value="${java.naming.provider.url}" />
                <entry key="com.webmethods.jms.naming.clientgroup" value="${com.webmethods.jms.naming.clientgroup}" />
            </map>
        </property>
    </bean>
    <bean id="destinationResolver"
        class="org.springframework.jms.support.destination.JndiDestinationResolver">
        <property name="jndiTemplate" ref="webMethodsJndiTemplate" />
        <property name="cache" value="true" />
        <property name="fallbackToDynamicDestination" value="false" />
    </bean>

    <!-- Custom ConnectionFactory to customize ClientId -->
    <bean id="remoteJmsConnectionFactory"
        class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
        <property name="targetObject" ref="connectionFactoryHelper"/>
        <property name="targetMethod" value="createJmsConnectionFactory"/>
    </bean>

    <!-- JMS MDB Container which recieves messages from Vantage S -->

    <jms:listener-container container-type="default"
        connection-factory="remoteJmsConnectionFactory" destination-type="durableTopic"
        destination-resolver="destinationResolver" acknowledge="auto">
        <jms:listener destination="beconEventingJMSTopic" ref="beconListener" id="jmslistener"
            selector="${scrmessageselector}" subscription="${screventingsubscriber}"
            method="onMessage" />
    </jms:listener-container>

    <bean id="beconListener" class="com.con.jms.OMIListener"/>

</beans>

尝试在此处启动监听器

@Controller
public class StartJmsController {

    @Resource(name="jmslistener")
    private DefaultMessageListenerContainer beconListener;

    @RequestMapping("/startscrjms")
    public String hello(
            @RequestParam(value = "name", required = false, defaultValue = "World") String name,
            Model model) {

        beconListener.start();
        model.addAttribute("message", "JMS Listener started.");
        return "jmsmessage";
    }

}

在此处停止监听器。

@Controller

public class StopJmsController {

    @Resource(name="jmslistener")
    private DefaultMessageListenerContainer beconListener;

    @RequestMapping("/stopscrjms" ) 
    public String printWelcome(ModelMap model,  HttpSession session) {

        beconListener.stop(new Runnable() {
            public void run() {
                System.out.println("JMS Listener stopped.");
            }
        });

        model.addAttribute("message", "JMS Listener stopped.");
        return "jmsmessage";

    }

}

根上下文.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"
   xsi:schemaLocation="http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans.xsd">

  <!-- Empty -->

</beans>

pom.xml

   <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>WebMethodTopicSubscriber</groupId>
        <artifactId>OMISCRPayLoad</artifactId>
        <version>1.0</version>
        <packaging>war</packaging>
        <dependencies>
            <dependency>
                <groupId>com.wm.g11n</groupId>
                <artifactId>wm-g11nutils</artifactId>
                <version>8.2.2.4</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>com.webmethods.jms</groupId>
                <artifactId>wm-brokerclient</artifactId>
                <version>8.2.3</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>com.webmethods.jms</groupId>
                <artifactId>wm-jmsnaming</artifactId>
                <version>8.2.2</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>com.webmethods.jms</groupId>
                <artifactId>wm-jmsclient</artifactId>
                <version>8.2.2.0</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>antlr</groupId>
                <artifactId>antlr</artifactId>
                <version>2.7.7</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>aopalliance</groupId>
                <artifactId>aopalliance</artifactId>
                <version>1.0</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>commons-collections</groupId>
                <artifactId>commons-collections</artifactId>
                <version>3.2.1</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>commons-dbcp</groupId>
                <artifactId>commons-dbcp</artifactId>
                <version>1.4</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>commons-logging</groupId>
                <artifactId>commons-logging</artifactId>
                <version>1.1.1</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>commons-pool</groupId>
                <artifactId>commons-pool</artifactId>
                <version>1.6</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>dom4j</groupId>
                <artifactId>dom4j</artifactId>
                <version>1.6.1</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>com.logicblaze.fuse.liferay.dependencies</groupId>
                <artifactId>jms</artifactId>
                <version>fuse-4.1.2</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.quartz-scheduler</groupId>
                <artifactId>quartz</artifactId>
                <version>2.2.1</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-beans</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context-support</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-core</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-expression</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jdbc</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jms</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-orm</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-tx</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-web</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-webmvc</artifactId>
                <version>4.0.3.RELEASE</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>com.con.commons</groupId>
                <artifactId>Configuration</artifactId>
                <version>1.0</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
              <groupId>org.apache.logging.log4j</groupId>
              <artifactId>log4j-api</artifactId>
              <version>2.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-core</artifactId>
            <version>2.1</version>
        </dependency>   
            <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>javax.servlet-api</artifactId>
            <version>3.1.0</version>
             <scope>provided</scope>
        </dependency>
        </dependencies>

    <build>
         <sourceDirectory>src/main/java</sourceDirectory>
        <resources>
          <resource>
            <directory>src/main/java</directory>
            <filtering>true</filtering>
            <includes>
              <include>**/*.xml</include>          
            </includes>
          </resource>     
        </resources>

            <plugins>
                <plugin>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <version>3.1</version>
                    <configuration>
                        <source>1.6</source>
                        <target>1.6</target>
                    </configuration>
                </plugin>
                <plugin>
                    <artifactId>maven-war-plugin</artifactId>
                    <version>2.3</version>
                    <configuration>
                        <warSourceDirectory>WebContent</warSourceDirectory>
                        <failOnMissingWebXml>false</failOnMissingWebXml>
                    </configuration>
                </plugin>


          </plugins>
        </build>
    </project>

在博客中读到，这可能是错误“是您将容器加载到 Web 上下文(DispatcherServlet 的上下文)和根上下文(ContextLoaderListener 的上下文)中。这意味着您有 2 个容器，而您只停止 servlet 上下文中的一个”

问题类似Spring JMS Listener Container stop only half of listeners

但是答案中的修复并不清楚。

我该如何解决这个问题。？

最佳答案

在 web.xml 中将 Dispatcher Servlet 定义更改为以下内容。

    <servlet>
        <servlet-name>spring</servlet-name>
        <servlet-class>
            org.springframework.web.servlet.DispatcherServlet
        </servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
                <param-value>WEB-INF/jms-config.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>

并删除以下部分。

<context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>WEB-INF/jms-config.xml,WEB-INF/root-context.xml</param-value>      
</context-param>

<listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

根据用户评论更新

推荐的模式是为非 Web 内容和 Web 内容提供单独的上下文。但在您的情况下，根上下文中似乎没有任何内容，如果您的应用程序以这种方式工作，您可以跳过它。

将来，如果您需要根范围 - 假设您在应用中添加 ORM 支持 - 您始终可以将 ContextLoaderListener 条目与 contextConfigLocation 上下文参数一起保留在其中，其值仅作为您的根上下文配置文件名。

顺便说一句，即使您决定在应用程序中添加 ORM 支持，您也可以在 Web 上下文中执行此操作，并且应用程序应该可以正常工作，只是不建议这样做。

更新尝试这个。

    <servlet>
        <servlet-name>spring</servlet-name>
        <servlet-class>
            org.springframework.web.servlet.DispatcherServlet
        </servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
                <param-value>WEB-INF/jms-config.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>


<context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>WEB-INF/root-context.xml</param-value>      
</context-param>

<listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

关于java - Spring JMS 监听器容器未完全停止，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29092372/

文章推荐： Java构造函数困惑，什么去了哪里？

文章推荐： java - 为什么 AmazonS3Client 不使用我设置的代理？

文章推荐： python - Tkinter 常规语句不起作用

文章推荐： java代码死锁情况？

jms - JMS 生态系统中 JMS 代理的职责是什么？
我正在读这个 question和 corresponding answer并被答案第一行中的术语 JMS broker 弄糊涂了: MS (ActiveMQ is a JMS broker imple
jms - JMS 与响应式流有何不同？
我正在学习 API 中的 Reactive Streams，我对它与 JMS 之间的相似性感到震惊。在 JMS 中，我们也有异步处理、发布者和订阅者。我在进行这种等效时缺少什么观点？最佳答案 Rea
jms - JMS 规范或各种实现是否支持消息的传递确认？
假设生产者向 JMS 主题“新闻”发送一条消息。消费者 1 读取了消息，但消费者 2 处于离线状态，因此他还没有读取消息。是否有任何内置(针对规范或实现)的方式来通知生产者消费者 1 已阅读他的消息
jms - 什么是外国 JMS 提供者？ Weblogic 在 JMS 应用程序中的典型作用是什么？
目前我正在开发一个 JMS 应用程序。但我使用普通的 JMS API 和属性文件进行配置。我的应用程序在 Weblogic 中运行并连接到我客户端的 MQ 系列服务器。最近我知道我可以使用 Webl
jms - solace jms 是否实现了 JMS 2.0 规范？
我正在尝试使用 Solace 中可用的异步发送功能，但我打算使用 JMS 进行抽象，而不是直接使用 JCSMP 使用它。 JMS 2.0 支持异步发送以及其他新功能:http://www.oracle
jms - JavaEE 6 : How to inject JMS Resource in a standalone JMS client?
我无法获得 javax.jms.ConnectionFactory注入(inject)我的独立 JMS 客户端。我得到一个 java.lang.NullPointerException在 conne
java - 长期存在的 JMS session 。保持 JMS 连接/JMS session 总是打开不好的做法吗？
保持 JMS 连接/ session /消费者始终打开是一种不好的做法吗？代码草稿示例: // app startup code ConnectionFactory cf = (Connection
jms - 如何从 JMS 队列中删除消息？
我有几个作业，每个作业都有多条消息排队。每个作业的消息随机交错。如果用户决定取消作业，我想从队列中删除属于该作业的所有消息。我已经能够使用 browse() 找到所有要删除的消息，但一直无法弄清楚如何
jms - 将最后发送的消息发送给 jms 主题的新消费者
是否可以将主题配置为仅存储最后一条消息的副本并将其发送到新连接而不知道客户端标识符或其他信息？更新: 从 Shashi 提供的信息中，我发现这两页使用 retroactive consumer 描述
jms - 来自集群中分布式队列的所有 JMS 消息
目前正在使用 WebLogic 和分布式队列。我从文档中了解到，分布式队列允许您使用全局 JNDI 名称检索到集群中任何队列的连接。分布式队列为您提供的主要功能之一似乎是跨多个托管服务器的负载平衡连接
jms - 为 Camel JMS 生产者设置 ConnectionFactory : camel-jms Vs camel-sjms
再见，我的基本要求是有一个可以发送消息的路由，并将其放在 JMS 队列中。 camel 上下文在 JavaEE 6 容器中运行，即 JBoss AS 7.1.1，因此它是 HornetQ for JM
java - JMS 2.0 规范 - JMS 提供者如何检测 JMS 客户端对 Message 对象的更改？
我正在阅读 JMS 2.0 规范，其中提到(相关摘录下方)如果客户端尝试修改 Message 对象，则 JMS 提供程序可能会抛出异常。我的问题是 JMS 提供者如何知道客户端是否试图修改 Mess
java - Spring - JMS，在 JMS activemq 服务器启动/停止几次后，监听器服务器抛出 java.io.EOFException，然后不连接到正在运行的 JMS
我的 spring 上下文文件中有以下设置。 "PowerEventQueue" “${
jms - 从 JSP 连接到 JMS
我正在尝试使用 JSP 连接到 ActiveMQ。但是，当我运行该程序时，它给了我以下类型的异常: NoClassDefFoundError: javax/jms/Destination . 我不确定
jms - JMS 和 CORBA 的区别？
我刚看了CORBA和JMS，他们好像都是用来实现的代理架构/模式。我对他们有几个问题 1.他们之间的区别我还不是很清楚，谁能解释一下？ 2.CORBA 是否用于当今的 IT 解决方案？还是正在失去魅
jms - 关于 Mule JMS 队列配置的建议
我正在更新现有的 Mule 配置，任务是增强它以根据消息的某些属性将消息路由到不同的端点，因此最好对我手头的两个选项有一些利弊: 在消息上添加属性，使用“message-properties-tran
jms - jms 如何与 tibco 一起工作？
我有一个订阅 JMS 主题应用程序的 Java 应用程序，该应用程序偶尔会出现以下异常: javax.jms.JMSException: Connection has been terminated
jms - Camel 、JMS、CLIENT_ACKNOWLEDGE 模式
我知道 Camel 的 JMS 组件用于接收消息，使用 Springs DefaultMessageListenerContainer。它可以配置为使用 CLIENT_ACKNOWLEDGE 模式来确
jms - 创建 JMS 关联 ID
通常不鼓励使用从 JMS 提供者返回的消息 ID 作为相关 ID，将消息发布到队列中。人们如何为请求/响应架构生成相关 ID？最佳答案客户端可以使用唯一的 ID 标准，如 UUID生成新的 ID。
jms - MQ JMS setClientReconnectOptions 没有按预期工作？
我有一个简单的代码可以将 2 条消息放入队列中。 1) 我用两台服务器设置了 connectionNameList。 2) 这两个服务器是独立的，但有相同的队列管理器和定义相同名称的队列，例如“QMg

太空宇宙

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

java - Spring JMS 监听器容器未完全停止