Spring WebFlux Route总是返回404

Question

我正在做一个简单的项目，它使用Spring Boot 2和使用Kotlin的Spring WebFlux。我为我的处理函数编写了测试（在测试中，我使用Mockito模拟依赖项）。

然而，我的路由函数似乎不会触发处理程序，因为我的所有请求都返回HTTP 404 not FOUND（即使路由是正确的）。

我已经查看了各种其他项目，以了解这些测试应该如何编写（这里，这里），但问题仍然存在。

代码如下（也可以在GitHub上找到）：

用户路由测试

@ExtendWith(SpringExtension::class, MockitoExtension::class)
@Import(UserHandler::class)
@WebFluxTest
class UserRouterTest {

    @MockBean
    private lateinit var userService: UserService

    @Autowired
    private lateinit var userHandler: UserHandler

    @Test
    fun givenExistingCustomer_whenGetCustomerByID_thenCustomerFound() {
        val expectedCustomer = User("test", "test")
        val id = expectedCustomer.userID

        `when`(userService.getUserByID(id)).thenReturn(Optional.ofNullable(expectedCustomer))

        val router = UserRouter().userRoutes(userHandler)
        val client = WebTestClient.bindToRouterFunction(router).build()

        client.get()
                .uri("/users/$id")
                .accept(MediaType.ALL)
                .exchange()
                .expectStatus().isOk
                .expectHeader().contentType(MediaType.APPLICATION_JSON_UTF8)
                .expectBody(User::class.java)
    }
}

用户

@Entity
class User(var username : String, var password: String) {

    @Id
    val userID = UUID.randomUUID()
}

用户存储库

@Repository
interface UserRepository : JpaRepository<User, UUID>{
}

用户服务

@Service
class UserService(
        private val userRepository: UserRepository
) {
    fun getUserByID(id: UUID): Optional<User> {
        return Optional.of(
                try {
                    userRepository.getOne(id)
                } catch (e: EntityNotFoundException) {
                    User("test", "test")
                }
        )
    }

    fun addUser(user: User) {
        userRepository.save(user)
    }
}

用户处理程序

@Component
class UserHandler(
        private val userService: UserService
) {
    fun getUserWithID(request: ServerRequest): Mono<ServerResponse> {
        val id = try {
            UUID.fromString(request.pathVariable("userID"))
        } catch (e: IllegalArgumentException) {
            return ServerResponse.badRequest().syncBody("Invalid user id")
        }
        val user = userService.getUserByID(id).get()
        return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON_UTF8)
                .body(BodyInserters.fromObject(user))
    }
}

用户路由器

@Configuration
class UserRouter {
    @Bean
    fun userRoutes(userHandler: UserHandler) = router {
        contentType(MediaType.APPLICATION_JSON_UTF8).nest {
            GET("/users/{userID}", userHandler::getUserWithID)
            GET("") { ServerResponse.ok().build() }
        }
    }
}

编辑

要根据一个或多个查询参数的存在进行路由（无论它们的值如何），我们可以执行以下操作：User路由器

@Configuration
class UserRouter {
    @Bean
    fun userRoutes(userHandler: UserHandler) = router {

        GET("/users/{userID}", userHandler::getUserWithID)
        (GET("/users/")
                and queryParam("username") { true }
                and queryParam("password") { true }
                )
                .invoke(userHandler::getUsers)
    }
}

请注意，GET（“/users/？username={username}”，userHandler：：getUsersWithUsername）不起作用。

Answer 1

路由器的配置方式-contentType（MediaType.APPLICATION_JSON_UTF8）. est-将仅匹配具有此内容类型的请求，因此您必须删除contentType先决条件或更改测试以包含它

client.get()
                .uri("/users/$id")
                .accept(MediaType.ALL)
                .header("Content-Type", "application/json;charset=UTF-8")
                .exchange()
                .expectStatus().isOk
                .expectHeader().contentType(MediaType.APPLICATION_JSON_UTF8)
                .expectBody(User::class.java)