春季-嵌入式代理和故障转移使用者的Activemq群集

环境

>现有一个具有专有集群方式的软件,应将其移至使用JMS的位置
>客户不想为安装和维护保养付费
邮件系统,因此只有在我可以嵌入整个邮件系统的情况下,才能使用它
传递到现有虚拟机中
>代理实例和使用者应位于同一JVM中.消费者
在故障转移情况下,它应该能够连接到远程代理,因为所有使用者(无论他们将在哪个JVM上运行)都应具有一个输入队列.
>如果消费者将直接方法调用用于
与当地经纪人沟通

示范项目

我使用ActiveMQ Maven Spring创建了一个非常简单的演示(日食)项目(整个项目位于http://www.woofiles.com/dl-279452-fOcsWkcm-activemq.zip).如果尝试尝试,请更改activemq的dataDirectory,因为到目前为止它是有线的绝对路径.

我尝试从春季开始创建一个经纪人,以及一组消费者.请参阅下面的Spring配置：

<?xml version="1.0" encoding="UTF-8"?>
<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"
    xmlns:p="http://www.springframework.org/schema/p" xmlns:task="http://www.springframework.org/schema/task"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-3.0.xsd">

    <bean id="propertyConfigurer"
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_FALLBACK" />
    </bean>
        <bean id="embeddedBroker" class="org.apache.activemq.broker.BrokerService"
            destroy-method="stop" init-method="start" >
            <property name="brokerName" value="conversion" />
            <property name="dataDirectory"
                value="c:\eclipseWithMaven\activemq\working\conversion" />
            <property name="schedulerSupport" value="false" />
            <property name="transportConnectorURIs">
                <list>
                    <value>tcp://127.0.0.1:600${idOfClusterNode}</value>
                </list>
            </property>
            <property name="managementContext">
                <bean class="org.apache.activemq.broker.jmx.ManagementContext">
                    <property name="connectorPort" value="201${idOfClusterNode}" />
                </bean>
            </property>
        </bean>

    <!-- depends-on see why at http://activemq.apache.org/vm-transport-reference.html -->
    <!--depends-on="embeddedBroker" -->
    <bean id="jmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory" depends-on="embeddedBroker">
        <property name="brokerURL">
            <value>failover:(vm:/conversion,tcp://127.0.0.1:6001,tcp://127.0.0.1:6002)</value>
        </property>
    </bean>
    <bean id="cachedConnectionFactory"
        class="org.springframework.jms.connection.CachingConnectionFactory"
        p:targetConnectionFactory-ref="jmsFactory" p:sessionCacheSize="10" />
    <bean id="container"
        class="org.springframework.jms.listener.SimpleMessageListenerContainer">
        <property name="concurrentConsumers" value="10" />
        <property name="connectionFactory" ref="cachedConnectionFactory" />
        <property name="messageListener" ref="conversion" />
        <property name="destination" ref="conversionInputQueue" />
    </bean>
    <bean id="conversionInputQueue" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg value="conversionInputQueue" />
    </bean>
    <bean id="conversion" class="activemq.Conversion"
        p:clusterId="${idOfClusterNode}" />
</beans>

我只是尝试使用spring&所使用的不同参数来启动activemq.ConversionDemo类的一两个实例. log4j配置.运行配置的环境条目如下所示：

>实例1：-DidOfClusterNode = 1 -DidOfOtherClusterNode = 2 -DlogFile = conversion1.log
>实例2：-DidOfClusterNode = 2 -DidOfOtherClusterNode = 1
-DlogFile = conversion2.log

如果我启动一个实例,那很好.如果两个正在运行,则会出现以下问题：

>第二个经纪人根本不会启动.它说它没有锁.很好,但是我想,它只是异步启动一个线程,并将控制权交还给spring.但似乎,它不会让春天继续.
> SimpleMessageListenerContainer似乎也握有控件
在春季,直到所有消费者都开始使用.

我想要的是

>我要满足以上要求
>我认为我必须异步启动经纪人和消费者,
我在春季用这个配置无法真正做到
>在代理之间实现真正的负载平衡会很好.看来,ActiveMQ仅准备进行故障转移.
>如果ActiveMQ无法满足我的需求,请推荐
其他免费解决方案.

如果您需要更多信息,请告诉我.

编辑

我认为ActiveMQ支持我的需求,我只需要了解“经纪人网络”.所以我想我必须有两个文件存储,以及两个经纪人的网络.

解决方法:

如果将2个代理指向同一文件存储,则第一个将获得锁定,第二个将锁定直到释放该锁定为止……这是一个shared file system master/slave的设置

如果您要进行主动/主动设置,则需要使用单独的文件存储并将它们连接在一起,作为network of brokers

标签：activemq,cluster-computing,spring
来源： https://codeday.me/bug/20191201/2083892.html