散布式Hibernate search详解
散布式Hibernate Search与Apache Tomcat6,ActiveMQ 和Spring.今天我将跟大家分享我的经验,以master/slave(s)方式配置散布式Hibernate Search并整合Apache ActiveMQ,Spring,利用程序额容器是Apache Tomcat 6。
怎么工作:
-Hibernate Search 支撑运用JMS back-end 和 master/slave(s) 索引进行散布式配置
- mater通过网络同享袒露索引 (例如通过NFS。。。)
- slave(s) 复制mater的索引到当地
版本
- Apache Tomcat 6.0.20
- Hibernate Search 3.1.1 GA
- Apache ActiveMQ 5.3.0
- Spring 2.5.6
- XBean-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 slave(s)
Mater索引的配置
Mater的配置稍显复杂。下列是配置属性注明
$(local.index.dir) - 存储mater索引的目录
$(master.index.dir) -拷贝mater索引的指标目录,通过网络定位供slave(s)复制。
首先,为了简略起见,我们将ActiveMQ中介运转在统一台服务器上。因而,我们在WEB-INF/activemq.xml文件中运用简略的嵌入式中介配置。
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://www.baidow.com/tupian/lupian/20190516/sjlro5f0zxe" xmlns:xsi="http://www.baidow.com/tupian/lupian/20190516/ppzcmma2qyf" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.baidow.com/tupian/lupian/20190516/mz22guycym5.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>
其次,需要在web application 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://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" />
接下来在Hibernate.cfg.xml文件中配置Hibernate Searc
<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>
Master和slave之间代码的一个重要区别是:master中必须包含实现 AbstractJMSHibernateSearchController 的子类作为监听器,例如
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的配置文件applicationContext.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 configurations in place Hibernate 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中配置Hibernate 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>
总结
以上就是本文对于散布式Hibernate search详解的全部内容,但愿对大家有所帮忙。感乐趣的朋友可以继续参阅本站:Hibernate实现乐观锁和悲观锁代码介绍、Hibernate中心思想与接口简介等,有什么题目可以随时留言,小编会及时回复大家的,谢谢朋友们对本站的支撑!
热门标签:dede模板 / destoon模板 / dedecms模版 / 织梦模板