Bean在Spring boot中不会被覆盖

Question

遵循本教程，我正在尝试编写并测试一个使用了spring-cloud和azure函数的应用程序。https://github.com/markusgulden/aws-tutorials/tree/master/spring-cloud-function/spring-cloud-function-azure/src/main/java/de/margul/awstutorials/springcloudfunction/azure

我正在尝试编写一个测试用例并覆盖bean。下面是包含函数和处理程序Bean函数的应用程序类。

@SpringBootApplication
@ComponentScan(basePackages = { "com.package" })

public class DataFunctions extends AzureSpringBootRequestHandler<GenericMessage<Optional<String>>, Data> {

@FunctionName("addData")
public HttpResponseMessage addDataRun(
        @HttpTrigger(name = "add", methods = {
                HttpMethod.POST }, authLevel = AuthorizationLevel.FUNCTION) HttpRequestMessage<Optional<String>> request,
        final ExecutionContext context) throws JsonParseException, JsonMappingException, IOException {
    context.getLogger().info("Java HTTP trigger processed a POST request.");

    try {
        handleRequest(new GenericMessage<Optional<String>>(request.getBody()), context);
    } catch (ServiceException ex) {
        ErrorMessage em = new ErrorMessage();
        return request.createResponseBuilder(handleException(ex, em)).body(em).build();
    }
    return request.createResponseBuilder(HttpStatus.CREATED).build();
}

@Autowired
MyService mService;

@Bean
public Consumer<GenericMessage<Optional<String>>> addData() {
    ObjectMapper mapper = new ObjectMapper();
    return req -> {
        SomeModel fp = null;
        try {
            fp = mapper.readValue(req.getPayload().get(), SomeModel.class);
        } catch (Exception e) {
            throw new ServiceException(e);
        }

        mService.addData(fp);
    };
}

}

我想通过覆盖上面的bean来进行测试。

Cosmosdb弹簧配置

@Configuration
@EnableDocumentDbRepositories
public class CosmosDBConfig extends AbstractDocumentDbConfiguration {

    @Value("${cosmosdb.collection.endpoint}")
    private String uri;

    @Value("${cosmosdb.collection.key}")
    private String key;

    @Value("${cosmosdb.collection.dbname}")
    private String dbName;

    @Value("${cosmosdb.connect.directly}")
    private Boolean connectDirectly;

    @Override
    public DocumentDBConfig getConfig() {
        ConnectionPolicy cp = ConnectionPolicy.GetDefault();
        if (connectDirectly) {
            cp.setConnectionMode(ConnectionMode.DirectHttps);
        } else {
            cp.setConnectionMode(ConnectionMode.Gateway);
        }
        return DocumentDBConfig.builder(uri, key, dbName).connectionPolicy(cp).build();
    }
}

以下是配置

@TestConfiguration
@PropertySource(value = "classpath:application.properties", encoding = "UTF-8")
@Profile("test")
@Import({DataFunctions.class})
public class TestConfig {

    @Bean(name="addData")
    @Primary
    public Consumer<GenericMessage<Optional<String>>> addData() {
        return req -> {
            System.out.println("data mock");
        };
    }

    @Bean
    @Primary
    public DocumentDBConfig getConfig() {
        return Mockito.mock(DocumentDBConfig.class);
    }
}

最后一个测试类

@RunWith(SpringRunner.class)
//@SpringBootTest //Enabling this gives initialization error.
@ActiveProfiles("test")
public class TempTest {

    @InjectMocks
    DataFunctions func;

    @Mock
    MyService mService;

    @Before
    public void setup() {
        MockitoAnnotations.initMocks(this);
    }

    private Optional<String> createRequestString(final String res) throws IOException {
        InputStream iStream = TempTest.class.getResourceAsStream(res);
        String charset="UTF-8";
        try (BufferedReader br = new BufferedReader(new InputStreamReader(iStream, charset))) {
            return Optional.of(br.lines().collect(Collectors.joining(System.lineSeparator())));
        }
    }

    @Test
    public void testHttpPostTriggerJava() throws Exception {
        @SuppressWarnings("unchecked")
        final HttpRequestMessage<Optional<String>> req = mock(HttpRequestMessage.class);
        final Optional<String> queryBody = createRequestString("/test-data.json");
        doNothing().when(mService).addData(Mockito.any(SomeModel.class));
        doReturn(queryBody).when(req).getBody();

        doAnswer(new Answer<HttpResponseMessage.Builder>() {
            @Override
            public HttpResponseMessage.Builder answer(InvocationOnMock invocation) {
                HttpStatus status = (HttpStatus) invocation.getArguments()[0];
                return new HttpResponseMessageMock.HttpResponseMessageBuilderMock().status(status);
            }
        }).when(req).createResponseBuilder(any(HttpStatus.class));

        final ExecutionContext context = mock(ExecutionContext.class);
        doReturn(Logger.getGlobal()).when(context).getLogger();
        doReturn("addData").when(context).getFunctionName();

        // Invoke
        final HttpResponseMessage ret = func.addDataRun(req, context);

        // Verify
        assertEquals(ret.getStatus(), HttpStatus.CREATED);
    }
}

在本例中，从DataFunctions类调用实际的addData，而不是测试配置bean。此外，当数据库连接应该使用我的测试配置中的模拟bean时，也会创建数据库连接。有没有人能指出我的测试配置出了什么问题？

Answer 1

标记了cosmos db config加载的第一部分。

@Configuration
@EnableDocumentDbRepositories
@Profile("!test")
public class CosmosDBConfig extends AbstractDocumentDbConfiguration {
   ...
}

还必须在服务中将存储库bean标记为可选。

public class MyService {
    @Autowired(required = false)
    private MyRepository myRepo;
}

除了这个，我没有使用任何其他的弹簧启动配置。

@ActiveProfiles("test")
public class FunctionTest {
    ...
}

对于提供模拟版本的模拟处理程序的第二部分，我简单地将测试配置文件作为spring应用程序，如下所示。

@SpringBootApplication
@ComponentScan(basePackages = { "com.boeing.da.helix.utm.traffic" })
@Profile("test")
public class TestConfiguration {

    public static void main(final String[] args) {
        SpringApplication.run(TestConfiguration.class, args);
    }
    @Bean(name="addData")
    @Primary
    public Consumer<GenericMessage<Optional<String>>> addData() {
        return req -> {
            System.out.println("data mock");
        };
    }   
}

并在我的构造函数中使用了来自spring cloud中的azure函数库的这个构造函数。

public class AppFunctions
        extends AzureSpringBootRequestHandler<GenericMessage<Optional<String>>, List<Data>> {
    public AppFunctions(Class<?> configurationClass) {
        super(configurationClass);
    }
}

public AzureSpringBootRequestHandler(Class<?> configurationClass) {
    super(configurationClass);
}

希望这能帮助到别人。