Spring Cloud Stream Rabbit Binder，单消息源，具有分布在数据中心的云代工实例

Question

我正在使用Spring Cloud stream发布者将分区的Rabbit MQ队列设置为30个分区。消费者部署在Cloud-oundry中。

这需要30个云铸造中的消费者应用程序实例，我想将这些实例分布到2个数据中心。所以我在一个数据中心启动了15个实例，在第二个数据中心启动了其他15个实例

我期望每个实例连接到0-29分区（一个分区得到一个实例），但2个实例（每个数据中心各一个）连接到0到14个分区（0-14连接了2个实例）。15到29没有任何消费者。

有什么方法可以实现我的期望吗？

在cloud foundry的两个数据中心部署中，实例索引似乎都自动设置为0到14。是否有任何方法可以控制实例索引分配！？

Answer 1

设置Spring。云流动instanceIndex到不同的值在这里会有所帮助，例如spring。云流动instanceIndex=第二个数据中心中的$CF\u INSTANCE\u索引15。我使用这里提到的EnvironmentPostProcessor尝试了下面的解决方案，它成功了

public class EnvironmentPostProcessor1 implements EnvironmentPostProcessor {

    @Override
    public void postProcessEnvironment(ConfigurableEnvironment environment, SpringApplication application) {

            String cfInstanceIndex=environment.getProperty("CF_INSTANCE_INDEX");        
            if(cfInstanceIndex != null ){       
                ExpressionParser expressionParser = new SpelExpressionParser();
                Expression expression = expressionParser.parseExpression("15"+ " + " +cfInstanceIndex);
                Integer result =  (Integer) expression.getValue();
                System.setProperty("spring.cloud.stream.bindings.input.consumer.instanceIndex",result.toString()); 

            }


    }