1

我使用 Ratpack 和 Groovy 创建了一个 API。我想要一个 POST API，这样数据应该被处理并存储在 2 个 cassandra 数据库中，比如 table-A 和 table-B。现在我在我的 Ratpack.groovy 中有这个，因此每当需要推送数据时我都必须调用这两个 API：

prefix("A") {
    post {  registry.get(PostEndpointA).handle(context) }
}
prefix("B") {
    post {  registry.get(PostEndpointB).handle(context) }
}

我想要一个像这样的单个 POST API 调用，以便通过单个 API 调用可以将请求一起委托给两个端点：

prefix("post") {
    post {  registry.get(PostEndpointA).handle(context) }
    post {  registry.get(PostEndpointB).handle(context) }
}

或者，我想要这个：

prefix("post") {
        post {  registry.get(PostEndpoint).handle(context) }
}

在 PostEndpoint 中，我可以像这样执行这两个操作：

saveJsonAsA(context)
            .promiseSingle()
            .then { ItemA updatedItem ->
                context.response.headers
                    .add(HttpHeaderNames.LOCATION, "/item/api/A")
                context.response.status(HttpResponseStatus.CREATED.code())
                    .send()
            }
saveJsonAsB(context)
            .promiseSingle()
            .then { ItemB updatedItem ->
                context.response.headers
                    .add(HttpHeaderNames.LOCATION, "/item/api/B")
                context.response.status(HttpResponseStatus.CREATED.code())
                    .send()
            }

在这两种情况下，该项目仅添加到表 A 而不是 B 或之前在代码中编写的任何内容。

注意ItemA和ItemB本质上是同一个DB，只是主键不同，方便2种方式的GET。知道如何在 Ratpack 中执行此操作吗？

4

2 回答 2

1

如果我正确理解这一点，您可以尝试做类似的事情：

@Grab('io.ratpack:ratpack-groovy:1.3.3')

import static ratpack.groovy.Groovy.ratpack

import ratpack.http.Status
import ratpack.exec.Promise
import com.google.common.reflect.TypeToken

class ServiceA {
  Promise<String> save(json) {
    Promise.value(json)
  }
}

class ServiceB {
  Promise<String> save(json) {
    Promise.value(json)
  }
}

ratpack {
  bindings {
    bindInstance new ServiceA()
    bindInstance new ServiceB()
  }
  handlers {
    post(':name') { // parameterize on path token
      def name = pathTokens.get('name') // extract token
      def service = null
      switch(name) {
        case 'A':
          service = get(ServiceA) // extract appropriate service
          break
        case 'B':
          service = get(ServiceB) // extract appropriate service
          break
      }

      parse(new TypeToken<Map<String, Object>>(){})
        .flatMap(service.&save) // save your extracted item
        .then {
          response.headers.add('Location', "/item/api/$name")
          response.status(Status.of(201))
          response.send()
        }
    }
  }
}

示例卷发看起来像这样

$ curl -X POST -H'Content-Type: application/json' -d '{"foo":"bar"}' -v localh ost:5050/A

< HTTP/1.1 201 Created
< Location: /item/api/A
< content-length: 0
< connection: keep-alive

$ curl -X POST -H'Content-Type: application/json' -d '{"foo":"bar"}' -v localh ost:5050/B

< HTTP/1.1 201 Created
< Location: /item/api/B
< content-length: 0
< connection: keep-alive

根据您发布的大量问题，我建议您注册 Ratpack 社区 slack 频道https://slack-signup.ratpack.io/

于 2016-06-06T17:49:51.017 回答
0

我们使用 rxJava 来做到这一点： Single .zip( service.add(cv1), service.add(cv2), (a, b) -> new Object[] { a, b } ) .blockingGet(); 我们将它包装在一个 Promise 中并处理块中的数组then。

于 2017-03-12T16:00:16.970 回答