分布式Hbernate search

分散式Hbernate Searchは、複数のノードRead/Writeをサポートしています。ネットで完全紹介の文章を見つけました。原文の接続
http://aredko.blogspot.com/2009/12/distributed-hibernate-search-with.html（fanqiangが必要）
分散式Hbernate SearchとAache Tomcat 6、ActiveMQとSpring.今日は私の経験を皆様に共有して、Master/slave(s)方式で分散式Hbernate Searchを配置してActiveMQ、Springを統合します。アプリケーション額容器はApache Tomcat 6です。
どうやって仕事をしますか
-Hibernate SearchサポートJMS back-endとmaster/slaave(s)インデックスを使って分散配置します。
−materは、暴露インデックスをネットワークを介して共有する（例えば、NFSを介して。。）
-slavie(s)materのインデックスをローカルにコピーします。
バージョン
-Apache Tomcat 6.0.20
-Hibernate Search 3.1.1 GA
-Apache ActiveMQ 5.3.0
-Spring 2.56
-XBen-Spring 3.6
${local.index.dir}-directory to store master index
${master.index.dir}-directory to copy master index to，it's shared network location for replication with slate(s)
Materインデックスの配置
Materの配置はやや複雑です。以下は配置属性の説明です。
$(local.index.dir)-mater索引を格納するディレクトリ
$(mater.index.dir)-materインデックスのターゲットディレクトリをコピーし、ネットワークを介してslaave(s)にコピーします。
まず、簡単のために、ActiveMQ仲介を同じサーバで実行します。したがって、私たちはWEB-INF/activemq.xmlファイルに簡単な組み込み仲介構成を使用します。

<beans
 xmlns="http://www.springframework.org/schema/beans"
 xmlns:amq="http://activemq.apache.org/schema/core"
 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-2.0.xsd
 http://activemq.apache.org/schema/core
 http://activemq.apache.org/schema/core/activemq-core.xsd">

 <amq:broker brokerName="HibernateSearchBroker">
     <amq:managementContext>
         <amq:managementContext createConnector="false"/>
     </amq:managementContext>

     <amq:transportConnectors>
         <amq:transportConnector uri="tcp://localhost:61616" /> 
     </amq:transportConnectors>
  </amq:broker>

  <amq:queue name="queue/hibernatesearch" physicalName="hibernateSearchQueue" />
</beans>

次に、ウェブアプリMEAT-INF/context.xmlにJNDIリソース（JMS Connection FactoryとQuene）を配置する必要がある。

<!-- ActiveMQ ConnectionFactory -->
<Resource
name="jms/ConnectionFactory"
auth="Container"
type="org.apache.activemq.ActiveMQConnectionFactory"
description="JMS Connection Factory"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
brokerURL="tcp://0.0.0.0:61616?trace=true"
brokerName="HibernateSearchBroker" />

<!-- ActiveMQ HibernateSearch queue -->
<Resource
name="queue/hibernatesearch"
auth="Container" type="org.apache.activemq.command.ActiveMQQueue"
description="Hibernate search queue"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
physicalName="hibernateSearchQueue" />

次に、Hbernate.cfg.xmlファイルにHibernate Searchを配置します。

<property name="hibernate.search.default.directory_provider">org.hibernate.search.store.FSMasterDirectoryProvider</property>
<property name="hibernate.search.default.indexBase">${local.index.dir}</property>
<property name="hibernate.search.default.sourceBase">${master.index.dir}</property>
<property name="hibernate.search.default.refresh">60</property>

マスターとslaaveの間のコードの重要な違いは、マスターにはAbstractJMSHibernetSearch Controllerを実装するサブクラスがモニターとして含まれる必要があります。

import javax.jms.MessageListener;

import org.hibernate.Session;
import org.hibernate.search.backend.impl.jms.AbstractJMSHibernateSearchController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class JMSHibernateSearchController
 extends AbstractJMSHibernateSearchController
     implements MessageListener {

 @Override
 protected void cleanSessionIfNeeded(Session session) {
    // clean session here ...     
 }

 @Override
 protected Session getSession() {
    // return new session here ...     
 }
}

最後にSpringのプロファイルaplication Contact.xmlファイルに、以下の構成を追加します。

<bean id="broker" class="org.apache.activemq.xbean.BrokerFactoryBean">
 <property name="config" value="WEB-INF/activemq.xml" />
 <property name="start" value="true" />
</bean>  

<bean name="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
 <property name="jndiName" value="java:comp/env/jms/ConnectionFactory" />
</bean>

<bean name="jmsHibernateSearchQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
 <property name="jndiName" value="java:comp/env/queue/hibernatesearch" />

<bean id="hibernateSearchController" class="<your implementation of AbstractJMSHibernateSearchController>" />

<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer" depends-on="broker">
 <property name="connectionFactory" ref="jmsConnectionFactory"/>
 <property name="destination" ref="jmsHibernateSearchQueue"/>
 <property name="messageListener" ref="hibernateSearchController" />
</bean>

With those configrations in place Hbernate Search master is ready to run.
正しく配置したら、Hibernate Search masterが動作します。
Slave索引の設定
Slave(s)の配置はもっと簡単で、設定属性の説明です。
${server}-ActiveMQ仲介サーバを実行する
ドル{lcoal.index.dir}-ローカルインデックスを格納するディレクトリ(masterのコピー)
${mater.index.share}-materインデックスをマウントするネットワーク共有ディレクトリ。
まず、私たちはサイトアプリケーションMeAT-INF/context.xml（Tocmat）にJNDIリソース（JMS Connection FactoryとQuene）を配置する必要があります。

...
<!-- ActiveMQ ConnectionFactory -->
<Resource
name="jms/ConnectionFactory"
auth="Container"
type="org.apache.activemq.ActiveMQConnectionFactory"
description="JMS Connection Factory"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
brokerURL="tcp://${server}:61616?trace=true"
brokerName="HibernateSearchBroker" />

<!-- ActiveMQ HibernateSearch queue -->
<Resource
name="queue/hibernatesearch"
auth="Container" type="org.apache.activemq.command.ActiveMQQueue"
description="Hibernate search queue"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
physicalName="hibernateSearchQueue" />
...

これからはhibernate.cfg.xmlにHbernate Searchを配置する必要があります。

<property name="hibernate.search.default.directory_provider">org.hibernate.search.store.FSSlaveDirectoryProvider</property>
<property name="hibernate.search.default.indexBase">${local.index.dir}</property>
<property name="hibernate.search.default.sourceBase">${master.index.share}</property>
<property name="hibernate.search.default.refresh">60</property>
<property name="hibernate.search.worker.backend">jms</property>
<property name="hibernate.search.worker.jms.connection_factory">java:comp/env/jms/ConnectionFactory</property>
<property name="hibernate.search.worker.jms.queue">java:comp/env/queue/hibernatesearch</property>
<property name="hibernate.search.worker.jndi.java.naming.factory.initial">org.apache.activemq.jndi.ActiveMQInitialContextFactory</property>

設定はこれで終了します
JUnitテストについての余談を言います。唯一の問題はSpring JNDI templatesを使ってJNDIを模擬することです。例えば、

<bean name="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="java:comp/env/jms/ConnectionFactory" />
    <property name="jndiTemplate">
        <bean class="org.springframework.mock.jndi.ExpectedLookupTemplate">
            <constructor-arg index="0" value="java:comp/env/jms/ConnectionFactory" />
            <constructor-arg index="1">
                <bean class="org.apache.activemq.ActiveMQConnectionFactory">
                    <property name="brokerURL">
                        <value>tcp://0.0.0.0:61616</value>
                    </property>
                </bean>
            </constructor-arg>
        </bean>
    </property>
</bean>

<bean name="jmsHibernateSearchQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="java:comp/env/queue/hibernatesearch" />
    <property name="jndiTemplate">
       <bean class="org.springframework.mock.jndi.ExpectedLookupTemplate">
           <constructor-arg index="0" value="java:comp/env/queue/hibernatesearch" />
           <constructor-arg index="1">
               <bean id="jmsHibernateSearchQueue"   class="org.apache.activemq.command.ActiveMQQueue">
                   <constructor-arg value="queue/hibernateSearchQueue"/>
               </bean>               
           </constructor-arg>
       </bean>
    </property>
</bean>