|
对于最新的稳定版本，请使用 spring-cloud-stream 4.3.0！ |
测试
Spring Cloud Stream 支持在不连接到消息传递系统的情况下测试您的微服务应用程序。
Spring Integration 测试活页夹
Spring Cloud Stream 附带了一个测试绑定器，您可以使用它来测试各种应用程序组件，而无需实际的实际绑定器实现或消息代理。
该测试绑定器充当单元测试和集成测试之间的桥梁，并基于 Spring Integration 框架作为 JVM 内消息代理，本质上为您提供两全其美的体验 - 一个没有网络的真正绑定器。
测试活页夹配置
要启用 Spring Integration 测试绑定器，您需要将其添加为依赖项，并使用@EnableTestBinder.
添加所需的依赖项
以下是所需 Maven POM 条目的示例。
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-test-binder</artifactId>
<scope>test</scope>
</dependency>或者对于 build.gradle.kts
testImplementation("org.springframework.cloud:spring-cloud-stream-test-binder")测试活页夹用法
现在，您可以将微服务作为简单的单元测试进行测试。
要启用测试绑定器，请使用@EnableTestBinder.
@SpringBootTest
public class SampleStreamTests {
@Autowired
private InputDestination input;
@Autowired
private OutputDestination output;
@Test
public void testEmptyConfiguration() {
this.input.send(new GenericMessage<byte[]>("hello".getBytes()));
assertThat(output.receive().getPayload()).isEqualTo("HELLO".getBytes());
}
@SpringBootApplication
@EnableTestBinder
public static class SampleConfiguration {
@Bean
public Function<String, String> uppercase() {
return v -> v.toUpperCase();
}
}
}如果您需要更多控制或想要在同一测试套件中测试多个配置 您还可以执行以下作：
@EnableAutoConfiguration
public static class MyTestConfiguration {
@Bean
public Function<String, String> uppercase() {
return v -> v.toUpperCase();
}
}
. . .
@Test
public void sampleTest() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
MyTestConfiguration.class))
.run("--spring.cloud.function.definition=uppercase")) {
InputDestination source = context.getBean(InputDestination.class);
OutputDestination target = context.getBean(OutputDestination.class);
source.send(new GenericMessage<byte[]>("hello".getBytes()));
assertThat(target.receive().getPayload()).isEqualTo("HELLO".getBytes());
}
}对于您有多个绑定和/或多个输入和输出的情况，或者只是想明确
您要发送或接收的目的地，send()和receive()方法InputDestination和OutputDestination被覆盖，以允许您提供输入和输出目标的名称。
请考虑以下示例：
@EnableAutoConfiguration
public static class SampleFunctionConfiguration {
@Bean
public Function<String, String> uppercase() {
return value -> value.toUpperCase();
}
@Bean
public Function<String, String> reverse() {
return value -> new StringBuilder(value).reverse().toString();
}
}和实际测试
@Test
public void testMultipleFunctions() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
SampleFunctionConfiguration.class))
.run("--spring.cloud.function.definition=uppercase;reverse")) {
InputDestination inputDestination = context.getBean(InputDestination.class);
OutputDestination outputDestination = context.getBean(OutputDestination.class);
Message<byte[]> inputMessage = MessageBuilder.withPayload("Hello".getBytes()).build();
inputDestination.send(inputMessage, "uppercase-in-0");
inputDestination.send(inputMessage, "reverse-in-0");
Message<byte[]> outputMessage = outputDestination.receive(0, "uppercase-out-0");
assertThat(outputMessage.getPayload()).isEqualTo("HELLO".getBytes());
outputMessage = outputDestination.receive(0, "reverse-out-0");
assertThat(outputMessage.getPayload()).isEqualTo("olleH".getBytes());
}
}对于具有其他映射属性（例如destination您应该使用这些名称。例如，考虑不同版本的
前面的测试，其中我们显式映射了uppercasefunction 设置为myInput和myOutput绑定名称：
@Test
public void testMultipleFunctions() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
SampleFunctionConfiguration.class))
.run(
"--spring.cloud.function.definition=uppercase;reverse",
"--spring.cloud.stream.bindings.uppercase-in-0.destination=myInput",
"--spring.cloud.stream.bindings.uppercase-out-0.destination=myOutput"
)) {
InputDestination inputDestination = context.getBean(InputDestination.class);
OutputDestination outputDestination = context.getBean(OutputDestination.class);
Message<byte[]> inputMessage = MessageBuilder.withPayload("Hello".getBytes()).build();
inputDestination.send(inputMessage, "myInput");
inputDestination.send(inputMessage, "reverse-in-0");
Message<byte[]> outputMessage = outputDestination.receive(0, "myOutput");
assertThat(outputMessage.getPayload()).isEqualTo("HELLO".getBytes());
outputMessage = outputDestination.receive(0, "reverse-out-0");
assertThat(outputMessage.getPayload()).isEqualTo("olleH".getBytes());
}
}测试 Binder 和 PollableMessageSource
Spring Integration Test Binder 还允许您在使用PollableMessageSource（有关更多详细信息，请参阅 [使用轮询的消费者]）。
不过，需要理解的重要一点是，民意调查不是事件驱动的，而且PollableMessageSource是一种策略，它公开了生成（轮询）消息（单数）的作。
轮询的频率或使用的线程数或轮询的位置（消息队列或文件系统）完全取决于您;
换句话说，您有责任配置轮询器或线程或消息的实际源。幸运的是，Spring 有很多抽象来配置它。
让我们看一下例子：
@Test
public void samplePollingTest() {
ApplicationContext context = new SpringApplicationBuilder(SamplePolledConfiguration.class)
.web(WebApplicationType.NONE)
.run("--spring.jmx.enabled=false", "--spring.cloud.stream.pollable-source=myDestination");
OutputDestination destination = context.getBean(OutputDestination.class);
System.out.println("Message 1: " + new String(destination.receive().getPayload()));
System.out.println("Message 2: " + new String(destination.receive().getPayload()));
System.out.println("Message 3: " + new String(destination.receive().getPayload()));
}
@EnableTestBinder
@EnableAutoConfiguration
public static class SamplePolledConfiguration {
@Bean
public ApplicationRunner poller(PollableMessageSource polledMessageSource, StreamBridge output, TaskExecutor taskScheduler) {
return args -> {
taskScheduler.execute(() -> {
for (int i = 0; i < 3; i++) {
try {
if (!polledMessageSource.poll(m -> {
String newPayload = ((String) m.getPayload()).toUpperCase();
output.send("myOutput", newPayload);
})) {
Thread.sleep(2000);
}
}
catch (Exception e) {
// handle failure
}
}
});
};
}
}上面（非常基本的）示例将在 2 秒的间隔内生成 3 条消息，将它们发送到Source此活页夹发送到哪个OutputDestination我们检索它们的地方（对于任何断言）。
目前，它打印以下内容：
Message 1: POLLED DATA
Message 2: POLLED DATA
Message 3: POLLED DATA如您所见，数据是相同的。这是因为此绑定器定义了实际MessageSource- 来源
使用poll()操作。虽然对于大多数测试方案来说已经足够了，但在某些情况下，你可能需要
定义您自己的MessageSource.为此，只需配置一个类型为MessageSource在测试配置中提供您自己的
消息溯源的实现。
下面是示例：
@Bean
public MessageSource<?> source() {
return () -> new GenericMessage<>("My Own Data " + UUID.randomUUID());
}渲染以下输出;
Message 1: MY OWN DATA 1C180A91-E79F-494F-ABF4-BA3F993710DA
Message 2: MY OWN DATA D8F3A477-5547-41B4-9434-E69DA7616FEE
Message 3: MY OWN DATA 20BF2E64-7FF4-4CB6-A823-4053D30B5C74不要命名这个豆子messageSource因为它将与同名（不同类型）的 bean 发生冲突
由 Spring Boot 出于不相关的原因提供。 |