如何使用springXD发送http-client post请求

Question

我已经在我的本地实现了一个 restfull webservice 项目，我可以从 rest-client 发送请求，并且我也得到了响应。 下面是rest-client“发布请求”：

{"address":{"type1":"abc","email":"tata@gmail.com"}}

回复：

{"address":{"type1":"abc","email":"tata@gmail.com"}}

这些是标题。

Content-Type:application/json

下面是我本地的java项目API URL：

http://localhost:8080/test/test1

现在我正在尝试学习 spring XD 如何使用 spring XD 发送请求。我已经在本地安装了 Spring XD 和 RabbitMQ。

帮助我如何使用这些 json 请求从 Spring XD 发送 post 请求。

Answer 1

由于您使用的是 Spring，也许您可​​以使用 org.springframework.web.clientRestTemplate 类来请求您的 API：

RestTemplate restTemplate = new RestTemplate();
HttpEntity<MailContact> request = new HttpEntity<>(new MailContact("contact@mail.net"));
Contact contact = restTemplate.postForObject("http://localhost:8080/test/test1", request, Contact.class);

希望这会有所帮助。

Answer 2

使用httpMethod 属性...

--httpMethod=POST

和mappedRequestHeaders 添加您的自定义标题，但它将获得X- 前缀。您将需要使用自定义标头映射器自定义处理器以删除它。

Answer 3

让我们举个例子。如果您希望 SpringXD 成为 Web 服务客户端，从周一到周五的上午 8 点到下午 5 点每分钟都得到响应，并将结果转储到文件中， 请使用您的 xd-shell 运行以下命令

stream create --name my_rest_client --definition "trigger --cron='0 * 8-17 * * 1-5' | http-client --url='''http://localhost:8080/test/test1''' --replyTimeout=2000 --httpMethod=GET --outputType=text/plain | file" --deploy

trigger 模块将发送 '' char 作为默认请求，要更改此行为，您可以通过添加有效负载参数来定义确切的字符串，例如： 触发 --payload='yourRequestMessage' --cron='0 * 8-17 * * 1-5'