部署Spring云数据流本地服务器

Question

作为初学者，我试着按照《手动安装入门》中描述的步骤进行操作。

我可以下载并启动Spring Cloud数据流本地服务器和Spring Cloud数据流shell。

然后我继续部署流

Welcome to the Spring Cloud Data Flow shell. For assistance hit TAB or type "help".
dataflow:>app register --name http --type source --uri maven://org.springframework.cloud.stream.app:http-source-rabbit:1.2.0.RELEASE
Successfully registered application 'source:http'
dataflow:>app register --name log --type sink --uri maven://org.springframework.cloud.stream.app:log-sink-rabbit:1.1.0.RELEASE
Successfully registered application 'sink:log'

然后我尝试创建一个流:

dataflow:>stream create --name httptest --definition "http --server.port=9000 | log" --deploy
Created new stream 'httptest'
Deployment request has been sent

然后发送一些数据，结果失败：

dataflow:>http post --target http://localhost:9000 --data "hello world"
> POST (text/plain) http://localhost:9000 hello world
> 500 INTERNAL_SERVER_ERROR
> 500 INTERNAL_SERVER_ERROR
{
  "exception" : "org.springframework.messaging.MessageHandlingException",
  "path" : "/",
  "error" : "Internal Server Error",
  "message" : "error occurred in message handler [org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@20eacb00]; nested exception is org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused (Connection refused)",
  "timestamp" : 1546968872545,
  "status" : 500
}
Error sending data 'hello world' to 'http://localhost:9000'

我可以从日志应用程序的日志文件中看到，有些地方出错了。但是作为一个初学者，我真的不知道如何继续或解决这个问题。

有什么想法吗？

Answer 1

查看此错误：

消息处理程序出错[org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint@20eacb00]; 嵌套异常为org.springframework.amqp.AmqpConnectException:java.net.ConnectException:连接被拒绝（连接被拒绝）

您似乎没有在本地运行RabbitMQ。在部署流时，如果您现在启动RabbitMQ实例，应用程序将自动恢复并连接到它。然后您将看到应用程序的成功部署，POST最终也会工作。

消息代理是 Spring Cloud 流的要求。这就是事件驱动的微服务通过发布-订阅语义相互通信的方式。更多详情请见春云流参考指南。

如果你想知道SCDF的作用，这里有一些背景：

SCDF仅仅是一个编排服务。当SCDF的本地实现部署流时，流中的应用程序作为独立的Java进程产生。它们是Spring Boot应用程序。开始时，它们试图用底层绑定器实现库自动配置类路径。在您的示例中，您注册的应用程序与rabbit-binder捆绑在一起，因为它们没有配置为连接到外部RabbitMQ集群，所以应用程序将尝试连接到默认的连接属性(即“localhost”和默认的“port”)。

您可以选择RabbitMQ或Kafka，也可以定制任何开箱即用的应用程序以与其他绑定器实现通信。

这里有一个在SCDF使用Apache Kafka作为binder实现的例子。