lizexing1
lizexing1
2018-02-25 12:19
采纳率: 0%
浏览 1.3k

使用activeMQ监听,调用mapper时为null怎么解决,请大神帮忙看看

spring文件配置如下:
<?xml version="1.0" encoding="UTF-8"?>
xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util-4.0.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.1.xsd
http://www.springframework.org/schema/jms">

<context:annotation-config/>
<context:component-scan base-package="com.lizx" />

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

<!-- 定义事务管理器 -->
<bean id="transactionManager"
    class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource" />
</bean>

<!-- 定义事务策略 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
    <tx:attributes>
        <!--所有以query开头的方法都是只读的 -->
        <tx:method name="query*" read-only="true" />
        <tx:method name="get*" read-only="true" />
        <!--其他方法使用默认事务策略 -->
        <tx:method name="delete*" propagation="REQUIRED" read-only="false"/>
        <tx:method name="edit*" propagation="REQUIRED" read-only="false"/>
        <tx:method name="add*" propagation="REQUIRED" read-only="false"/>
    </tx:attributes>
</tx:advice>

<aop:config>
    <!--pointcut元素定义一个切入点,execution中的第一个星号 用以匹配方法的返回类型,
        这里星号表明匹配所有返回类型。 com.bw.service.*.*(..)表明匹配com.bw.service包下的所有类的所有 
        方法 -->
    <aop:pointcut id="myPointcut" expression="execution(* com.lizx.app.service.*.*(..))" />
    <!--将定义好的事务处理策略应用到上述的切入点 -->
    <aop:advisor advice-ref="txAdvice" pointcut-ref="myPointcut" />
</aop:config>

 <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource"></property>
     <property name="configLocation" value="classpath:conf/SqlMapConfig.xml"></property>
     <property name="typeAliasesPackage" value="com.lizx.app"></property>
</bean>

  <!-- 自动扫描所有的Mapper接口与文件 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="com.lizx.app.mapper"></property>
</bean>

<import resource="classpath*:conf/spring-ActiveMQ.xml" />

activemq配置如下:
<?xml version="1.0" encoding="UTF-8"?>
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:amq="http://activemq.apache.org/schema/core"
xmlns:jms="http://www.springframework.org/schema/jms"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.1.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.1.xsd
http://www.springframework.org/schema/jms
http://www.springframework.org/schema/jms/spring-jms-4.1.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core-5.12.1.xsd">

 <mvc:annotation-driven />  
 <amq:connectionFactory     id="amqConnectionFactory"
        brokerURL="tcp://127.0.0.1:61616" userName="admin" password="admin" />

 <!-- 配置JMS连接工长 -->
<bean id="connectionFactory"
   class="org.springframework.jms.connection.CachingConnectionFactory">
    <constructor-arg ref="amqConnectionFactory" />
    <property name="sessionCacheSize" value="100" />
</bean>
 <!-- 定义消息队列(Queue) -->
<bean id="demoQueueDestination" class="org.apache.activemq.command.ActiveMQQueue">
    <!-- 设置消息队列的名字 -->
    <constructor-arg>
        <value>Jaycekon</value>
    </constructor-arg>
</bean>

 <!-- 配置JMS模板(Queue),Spring提供的JMS工具类,它发送、接收消息。 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="defaultDestination" ref="demoQueueDestination" />
    <property name="receiveTimeout" value="10000" />
    <!-- true是topic,false是queue,默认是false,此处显示写出false -->
    <property name="pubSubDomain" value="false" />
</bean>
   <!-- 配置消息队列监听者(Queue) -->
<bean id="queueMessageListener" class="com.lizx.app.MQListener" />
<bean id="queueListenerContainer"
      class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="destination" ref="demoQueueDestination" />
    <property name="messageListener" ref="queueMessageListener" />
</bean>

在监听中使用为null时的情况
图片说明
在其它地方调用,不为null时的情况:
图片说明

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 邀请回答

5条回答 默认 最新

  • sas303
    sas303 2018-02-25 12:25


    去掉,让spring 扫描注解。
    原因是xml 的声明和注解冲突了吧

    点赞 评论
  • lhm1524
    lhm1524 2018-02-25 13:02

    MQListener在XML里面声明,那么appmaper也必须在xml中注入

    点赞 评论
  • devmiao
    devmiao 2018-02-25 15:50
    点赞 评论
  • xionglangs
    编程爱好者熊浪 2018-02-27 06:42

    1、确定你的MQListener是否存在com.lizx包下面。
    2、确定你的MQListener在调用的时候spring的Application对象已经添加到servlet容器里面,并且servlet容器已经初始化成功。

    点赞 评论
  • KimmKing
    kimmking 2018-03-05 03:28

    我怀疑是多个不同applicationContext造成的。

    点赞 评论

相关推荐