Spring-Cloud-Stream集成测试，如何确保应用资源不被使用

Question

  @Test
  public void echoTransformTest() {
    try (ConfigurableApplicationContext context =
        new SpringApplicationBuilder(
              TestChannelBinderConfiguration.getCompleteConfiguration(DataflowApplication.class))
            .properties(new Properties())
            .run("--spring.cloud.function.definition=echo")) {
      InputDestination source = context.getBean(InputDestination.class);
      OutputDestination target = context.getBean(OutputDestination.class);

      GenericMessage<byte[]> inputMessage = new GenericMessage<>("hello".getBytes());

      source.send(inputMessage);
      assertThat(target.receive().getPayload()).isEqualTo("hello".getBytes());
    }
  }

Answer 1

我通过以下操作解决了这个问题：

SpringBootTest(properties = {"spring.cloud.stream.function.definition=reverse"})
@Import(TestChannelBinderConfiguration.class)
public class EchoTransformerTest {

  @Autowired private InputDestination input;

  @Autowired private OutputDestination output;

  @Test
  public void testTransformer() {
    this.input.send(new GenericMessage<byte[]>("hello".getBytes()));
    assertThat(output.receive().getPayload()).isEqualTo("olleh".getBytes());
  }
}

并将application.yml添加到test/resources中，这样可以确保我们不会读取src/resources应用程序属性。

另一种方法是显式定义@testpropertysource(locations=“test.yml”）