如何在分布式环境中同步solr索引库和缓存信息
1 <!-- 真正可以产生Connection的ConnectionFactory,由对应的 JMS服务厂商提供 -->2 <bean>
3 <property name="brokerURL" value="tcp://192.168.136.139:61616"/>
4 </bean>
5 <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->
6 <bean
7 >
8 <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->
9 <property name="targetConnectionFactory" ref="targetConnectionFactory"/>
10 </bean>
11
12 <!-- 生产者 -->
13 <!-- Spring提供的JMS工具类,它可以进行消息发送、接收等 -->
14 <bean>
15 <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->
16 <property name="connectionFactory" ref="connectionFactory"/>
17 </bean>
18 <!--这个是队列目的地:(俩种配置方式)
19 一、点对点模式:需要一个生产者发送消息到队列版块(Queue)中,只能有一个消费者从该队列(Queue)中接受该消息。
20 【生产者发送消息时,消费者不需要处于运行状态】。
21 二、发布订阅模式:需要一个生产者发送消息到主题版块(Topic)中,可以有多个消费者订阅该版块来接受消息。
22 【生产者发送消息时,消费者必须处于运行状态,而且只能接受运行之后的消息】。
23 -->
24 <!-- 点对点模式 -->
25 <!-- <bean>
26 <constructor-arg>
27 <value>test-queue</value>
28 </constructor-arg>
29 </bean> -->
30 <!-- 发布订阅模式 -->
31 <bean>
32 <constructor-arg value="test-topic"/>
33 </bean>
34
35
36 <!-- 消费者 -->
37 <!-- 配置自定义消息监听器 -->
38 <bean></bean>
39 <!-- 配置MessageListenerContainer -->
40 <bean
41 >
42 <property name="connectionFactory" ref="connectionFactory"/>
43 <property name="destination" ref="testTopic"/> <!-- 这儿注意生产者使用的是那种模式并且用哪个队列来发送消息的 -->
44 <property name="messageListener" ref="myMessageListener"/>
45 </bean>
页:
[1]