2

JPA Hibernate 実装で Spring JMS を使用していますが、同じレコードの挿入とインスタント読み取りで断続的な問題が発生しています。

ウェブ アプリケーション フロー:

-データは Web アプリケーション Web サービスにポストされ、データは Glassfish OpenMQ キュー (以下の STUInputQ) に送信されます。
-com.api.listener.backoffice.STUMessageListener は、STUInputQ キューを読み取り、Oracle Database に挿入してから、(新しいデータベースの主キーを含む) メッセージを別のキュー (以下の ArchiveQ) に送信します。
-com.api.listener.backoffice.StorableMessageListener は ArchiveQ キューを読み取り、com.api.listener.backoffice.STUMessageListener によって挿入されたデータベース レコードの主キーを使用してデータベースの読み取りを試みます。

問題：

場合によっては (約 18%)、StorableMessageListener の読み取り操作で、レコードが存在する場合でも null が返されます。挿入がシーケンスで生成された主キーを返しても、読み取りが発生する前に挿入コミットが処理されていないように思えます。データを挿入するメソッドとそれを読み取るメソッドの最後に unix タイムスタンプを配置しました。問題が発生した場合、unix タイムスタンプは同じであるため、コミットが最終的になる前に読み取りがメッセージを取得するように見えます.

一時的な解決策:

スレッドをスリープ状態にするためのロジックを追加しました。これにより、データベースの読み取りで null が取得されないようにします。スレッドのスリープが長期的な解決策であるとは本当に思いません。StorableMessageListener がトランザクションを読み取る前に、STUMessageListener がトランザクションをコミットできないように見える理由について何か考えはありますか?

依存関係:

hibernate-core.3.3.2.GA

hibernate-entitymanager-3.4.0.GA

春 3.0.6.RELEASE

Java 1.5

春の構成:

<?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:util="http://www.springframework.org/schema/util"
                xmlns:context="http://www.springframework.org/schema/context"
                xmlns:aop="http://www.springframework.org/schema/aop"
                xmlns:tx="http://www.springframework.org/schema/tx"
                xmlns:hz="http://www.hazelcast.com/schema/spring"
                xsi:schemaLocation="
                http://www.hazelcast.com/schema/spring
                http://www.hazelcast.com/schema/spring/hazelcast-spring-2.5.xsd
                http://www.springframework.org/schema/beans
                http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
                http://www.springframework.org/schema/util
                http://www.springframework.org/schema/util/spring-util-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/tx
                http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
                http://www.springframework.org/schema/aop
                http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">

                <!-- Generic -->
                <context:annotation-config />
                <context:component-scan base-package="myapp.api" />
                <aop:aspectj-autoproxy/>

                <!-- JPA -->
                <bean class="org.springframework.orm.jpa.support.PersistenceAnnotationBeanPostProcessor" />

                <tx:annotation-driven />

                <bean class="org.springframework.dao.annotation.PersistenceExceptionTranslationPostProcessor" />

                <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
                    <property name="dataSource" ref="dataSource" />
                    <property name="jpaVendorAdapter" ref="jpaVendorAdapter" />
                    <property name="persistenceUnitName" value="MyApp" />
                    <property name="jpaProperties">
                        <props>
                            <prop key="hibernate.use_sql_comments">true</prop>
                            <prop key="hibernate.generate_statistics">true</prop>
                            <prop key="hibernate.archive.autodetection">class</prop>
                            <prop key="hibernate.cache.use_second_level_cache">true</prop>
                            <prop key="hibernate.cache.provider_class">com.hazelcast.hibernate.provider.HazelcastCacheProvider</prop>
                            <prop key="hibernate.cache.use_query_cache">true</prop>
                            <prop key="hibernate.cache.use_minimal_puts">true</prop>
                        </props>
                    </property>
                </bean>


               <hz:hazelcast id="instance">
                    <hz:config>
                         //rest of Hazelast config maps here
                    </hz:config>
                </hz:hazelcast>

                <hz:hibernate-region-factory id="regionFactory" instance-ref="instance"/>

                <!-- Define JPA Provider Adapter -->
                <bean id="jpaVendorAdapter" class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
                    <property name="showSql" value="true" />
                    <property name="generateDdl" value="true" />
                    <property name="databasePlatform" value="org.hibernate.dialect.OracleDialect" />
                </bean>

                <bean id="dataSourceTarget" class="oracle.jdbc.pool.OracleDataSource" destroy-method="close">
                    <property name="URL" value="jdbc:oracle:thin:@server:1525:name" />
                    <property name="user" value="test" />
                    <property name="password" value="123" />
                    <property name="connectionCachingEnabled" value="true" />
                    <property name="connectionCacheProperties">
                        <props merge="default">
                            <prop key="MinLimit">5</prop>
                            <prop key="MaxLimit">50</prop>
                        </props>
                    </property>
                </bean>

                <bean id="dataSource" class="org.springframework.jdbc.datasource.LazyConnectionDataSourceProxy">
                    <property name="targetDataSource" ref="dataSourceTarget"/>
                </bean>


                <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
                    <property name="entityManagerFactory" ref="entityManagerFactory"/>
                    <property name="dataSource" ref="dataSource"/>
                </bean>

                <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="false"/>

                <bean id="genericDAO" class="myapp.api.dao.impl.GenericDAOImpl">
                    <constructor-arg>
                        <value>java.io.Serializable</value>
                    </constructor-arg>
                </bean>

                <bean id="springContextHolder" class="myapp.api.util.SpringContextHolder" factory-method="getInstance" />

        <bean id="executionInterceptor" class="myapp.api.listener.backoffice.ExecutionInterceptor" />

        <!-- JNDI-->
        <bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate"/>

        <!-- JMS -->
        <bean id="jmsQueueConnectionFactory"  class="org.springframework.jndi.JndiObjectFactoryBean">
            <property name="jndiTemplate">
                <ref bean="jndiTemplate"/>
            </property>
            <property name="jndiName" value="${jms.jndi.qconnectionfactory}">

            </property>
        </bean>
        <bean id="myJMSConnectionFactory" class="com.api.model.vo.backoffice.OpenMqConnectionFactoryBean">
            <property name="imqAddressList" value="${jms.imq.url}" />
            <property name="imqDefaultUsername" value="${jms.imq.user}" />
            <property name="imqDefaultPassword" value="${jms.imq.password}" />
            <property name="imqHost" value="${jms.imq.host}" />
            <property name="imqPort" value="${jms.imq.port}" />
        </bean>

        <bean id="stuMessageListener" class="com.api.listener.backoffice.STUMessageListener" />
        <bean id="storeListener" class="com.api.listener.backoffice.StorableMessageListener"/>

        <bean id="executionInterceptor" class="com.api.listener.backoffice.ExecutionInterceptor" />

        <bean id="stuJmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="jmsQueueConnectionFactory"/>
            <property name="destinationName" value="STUInputQ"/>
            <property name="sessionTransacted" value="false"/>
            <property name="messageListener" ref="stuMessageListener" />
            <property name="concurrentConsumers" value="5" />
            <property name="maxConcurrentConsumers" value="100" />
            <property name="receiveTimeout" value="30000" />
            <property name="cacheLevelName" value="CACHE_NONE" />

        </bean>
        <bean id="storeJmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="jmsQueueConnectionFactory"/>
            <property name="destinationName" value="ArchiveQ"/>
            <property name="sessionTransacted" value="false"/>
            <property name="messageListener" ref="storeListener" />
            <property name="concurrentConsumers" value="5" />
            <property name="maxConcurrentConsumers" value="100" />
            <property name="receiveTimeout" value="30000" />
            <property name="cacheLevelName" value="CACHE_NONE" />

        </bean>

 </beans>

持続性設定:

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="1.0" xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd">
  <persistence-unit name="com" transaction-type="RESOURCE_LOCAL">
  </persistence-unit>
</persistence>

レコードを挿入するクラス:

public class STUMessageListener implements javax.jms.MessageListener{
       @Autowired
       StoringService storingService;

       @Transactional
       public void onMessage(Message message) throws RuntimeException { 
           try {
                Object omsg = ((ObjectMessage) message).getObject();
                if (omsg instanceof StorableMessage) {
                     StorableMessage storableMessage = (StorableMessage) omsg;
                     //StorableMessage insert into Database
                     storingService.store(storableMessage); 

                   //jms logic here to send message to next queue (ArchiveQ)
           }
           catch (Throwable ex) {
                throw new RuntimeException(ex);
            }
   }

     @Service("storingService")
        public class StoringServiceImpl{

            @Autowired
            MessagesDAO messagesDAO;

            @Transactional
            public StorableMessage store(StorableMessage storableMessage) {
                messagesDAO.save(storableMessage);
            }

        }

    @Repository("messagesDAO")
    public class MessagesDAOImpl{
        private Class<T> type
        @PersistenceContext
        EntityManager entityManager;

        public void save(T object) {
           entityManager.persist(object);
        }

        public T findById(Serializable id) {
           return entityManager.find(type, id);
        }
    }

データベース レコードを読み取るクラス:

public class StorableMessageListener implements javax.jms.MessageListener {
    @Autowired
    MessageDAO messageDAO;

    @Transactional
    public void onMessage(Message message) throws RuntimeException {
          if (omsg instanceof StorableMessage) {
               //this is where null is returned for the Messages object 18% of the time
               //sleep thread by 1 second logic here helps eliminate the null Messages object
              //uses same MessageDAO as above 
              Messages msg = messageDAO.findById(storableMessage.getMessageKey());
          }
    }
4

1 に答える 1

0

挿入メソッドの注釈を次のように変更してみてください

@トランザクション (伝播 = 伝播.REQUIRES_NEW)

これにより、メソッドが終了するとすぐに挿入がコミットされます。

于 2013-05-24T10:47:25.957 に答える