将自定义 RequestBody 从 POST 请求发送到 java 中的外部 GET 请求

Question

我正在使用多线程发布请求设置休息服务（在微服务场景中），我需要区分 RequestBody 交付，例如：

{obj0, obj1, obj2, obj3}

前三个 obj 是 kafka 队列上的正确转发器，但现在我想添加新的 obj (obj3) 并将他的交付分开以将其发送到另一个外部休息服务。 这个外部 GET 服务将接收 obj3（只是 2 个字符串）来评估他的 PathVariable 并触发一些其他算法。 我怎样才能达到这个结果？ 在我的 doExecute() 方法中，我有一些这样的代码：

for (String element : bodyElements) {
  String[] singleElement = element.split(",");

        if (obj1 || obj2 || obj3){
          ...do something;
          }else{
           ...forward obj3 to other REST service
          }

感谢任何帮助，谢谢！

Answer 1

我希望这能回答你的问题

HttpEntity body = new HttpEntity(postBody,headers);
new RestTemplate().exchange("http://service-url",HttpMethod.POST,body,String.class);

这只是一个rest模板的例子。如果你想做 GET 调用，只需将 HttpMethod.POST 替换为 HttpMethod.GET 并将正文传递为 null