如何在spring云数据流中使用Rabbitmq绑定器

文章/答案/技术大牛

发布

1回答

Spring Cloud数据流部署到Cloud Foundry

spring-cloud-dataflow

我是spring云数据流的新手。我正在尝试建立一个简单的http源和rabbitmq汇流使用SCDF流，app.The流应该部署在OSCF (云计算)。部署后，流应该能够接收HTTP POST请求并将请求数据发送到RabbitMQ。到目前为止，我已经下载了数据流服务器使用下面的链接和推送到云铸造。我正在使用本地的Shall应用程序。https://dataflow.sp

浏览 28提问于2021-04-07得票数 0

1回答

Spring cloud数据流紧耦合

spring-cloud-stream、spring-cloud-dataflow

我正在使用Spring cloud stream和在spring cloud数据流中运行的RabbitMQ绑定器。我的问题是Spring Cloud Dataflow引入了与他的运行时以及与导入的批量应用程序(如FTP源、JDBC接收器)的紧密耦合。在数据流服务器中运行的流管道以及任务可以在不将其部署到数据流服务器</e

浏览 2提问于2018-12-14得票数 0

3回答

在Kubernetes上建立Spring数据流

apache-kafka、kubernetes、spring-cloud-dataflow

我是否需要自己在主服务器上安装Spring数据流实例，还是将其作为部署的一部分“自动”安装？我遵循了指南，尽管删除了MySQL的所有配置。也许这是必需的。

浏览 13提问于2016-11-20得票数 0

1回答

用于批量使用的spring云数据流只需要跳过吗？

spring-batch、spring-cloud、spring-cloud-dataflow

我想了解一下spring云数据流的体系结构。特别是使用它来编排纯粹的批处理管道。我已经在k8s中部署了所有组件，并且注意到我可以在没有中间件(Kafka / RabbitMQ)的情况下部署skipper组件，并通过服务器组件成功地运行批处理作业。当纯粹用于批处理作业或任务时，skipper (以及随后的Kafka/RabbitMQ中间件)是否是春季云数据流的必要部分？

浏览 0提问于2020-04-23得票数 0

回答已采纳

1回答

将RDBMS与同步

mysql、spring-boot、ldap、spring-cloud-dataflow

Ldap目录目前是主要的数据源，但其动机是在Ldap和RDBMS中同时拥有实时数据，因为我们计划使用RDBMS进行实时分析。 Option1:使用spring云数据流的思想。源spring引导应用程序，用于读取上次同步运行后更改的ldap数据。源应用程序将数据推送到队列中(目前为RabbitMQ)。接收器将是另一个直接从队列收集数据并将数据保存到RDBMS中的春季引导应用程序。我们将能够使用

浏览 0提问于2019-03-10得票数 0

1回答

使用RabbitMQ作为绑定器的Spring* cloud stream的Spring安全*

spring-boot、spring-security、rabbitmq、spring-cloud-stream、azure-spring-boot

我有一个启用了Spring cloud stream的Spring引导应用程序。此项目包含API端点和生产者/消费者流。在我们的例子中，RabbitMQ是绑定器。我们已经启用了Spring安全性，但它适用于API端点。我需要知道如何对来自RabbitMQ的流请求实施安全性。因为与此相关的用户上下文和其他服务都不会将其请求发布到队列中(我们的云流具有该队列的侦听器)，并且不会直接调用API

浏览 2提问于2021-05-18得票数 0

1回答

Google Pub/Sub上的Spring云数据流

spring、google-cloud-platform、spring-cloud-dataflow

我使用过spring cloud data flow、rabbitmq和kafka，但我想知道是否可以使用google pub/sub安装scdf。我不想创建一个流(新的应用程序，spring云流)，它的源或宿都是gcp，我想让google pub/sub over spring cloud数据流服务器作为一个中间消息传递代理。有什么建议吗？

浏览 1提问于2019-12-30得票数 1

1回答

卡夫卡->春云数据流(RabbitMQ)->卡夫卡

apache-kafka、spring-cloud-stream、spring-cloud-dataflow

我遇到的问题是使用(SCDF)通过环境将数据移动到正确的位置。情况如下：我有一个生产版的卡夫卡，我只能订阅(只读)。(3节点集群: node 1:9092，Node 2:9092，Node 3:9092)i有一个运行在Kubernetes集群中的SCDF实例，该集群使用RabbitMQ主干(全部在一台服务器上)i有一个节点卡夫卡服务器在查看SCDF时，我没有看到一种将Kafka定义为源并将其读入处理器(将是自定义的)并写入另一个Kafka实例的方法。

浏览 3提问于2021-06-03得票数 0

2回答

春天的云流漂流池--然后呢？

spring-cloud-stream、spring-cloud-dataflow

我创建了一个Spring，它使用了应用程序中的。我使用的是带有RabbitMQ绑定的。这将自动使用我的路由器表达式的结果创建RabbitMQ交换(类型:主题)。我认为下一步是为每个路由器结果创建新的数据流。但是，只能将配置为从队列中读取。当然，我可以手动创建队列并将它们绑定到自动创建的交换，但这就是我应该做的吗？或者，是否有一些我缺少的配置会导致队列自动创建和<e

浏览 0提问于2018-01-16得票数 1

回答已采纳

1回答

rabbitmq、spring-cloud、spring-cloud-stream、spring-cloud-dataflow

我想对它使用rabbit绑定器，但我缺少提供rabbitmq代理属性的语法。谁能帮帮我。 1.=myhost, spring.rabbitmq.username=user,spring.rabbitmq.password=pass, spring.rabbitmq.port=5672,sprin

浏览 1提问于2016-09-23得票数 2

回答已采纳

1回答

如何在Spring云数据流Kafka绑定器中维护kafka的租户数据隔离？

spring-cloud、spring-kafka、spring-cloud-stream、spring-cloud-dataflow

那么我们如何在使用spring云数据流的同时创建一个特定于宗旨的Kafka绑定器。

浏览 11提问于2021-06-03得票数 0

1回答

外部化Spring数据流Config - Spring服务器

spring-cloud-config、spring-cloud-dataflow

我有以下内容： spring.cloud.deployer.cloudfoundry.username=clouduser spring.cloud.deployer.cloudfoundry.pass

浏览 1提问于2016-08-19得票数 2

回答已采纳

1回答

针对大数据的微服务之间的通信

java、spring-integration、spring-cloud、microservices、spring-cloud-stream

我正在构建一个spring的基于云的微服务ML管道。我有一个数据摄取服务，它(当前)从SQL获取数据，这些数据需要由预测服务使用。一般的共识是写入应该使用基于异步消息的通信，使用kafka/rabbitmq。我是否应该使用API网关来调用启动管道的摄取？

浏览 0提问于2017-06-07得票数 1

2回答

Spring兔子源:如何拦截和丰富源中的消息

spring-cloud-dataflow

我已经成功地使用了一个典型的简单流来评估Spring：=接收器。对于部署，将有多个源输入到这个管道中，我可以使用数据流标签来完成这一工作。一切都很好。每个源都是不同的rabbitmq实例，并且由于处理器需要知道消息来自何处(因为它必须调用源系统以获得进一步的信息)，我想出的策略是用源系统的头部细节充实每条消息，这些信息随后透明地传递给处理器。现在，我精通Spring、Spring和Spri

浏览 6提问于2016-11-23得票数 0

1回答

春云流与RabbitMQ的连接

java、spring、rabbitmq、connection、spring-cloud-stream

有一个简单的Spring项目，我试图连接到RabbitMQ，它说它的，但它不起作用。我在密码里做错什么了吗？Application.propertiesspring.rabbitmq.port=5672spring.rabbitmq.password=guest spring</em

浏览 1提问于2020-04-18得票数 0

回答已采纳

1回答

在弹簧云环境中的分布式Rabbitmq

rabbitmq、spring-cloud、spring-amqp、netflix-eureka

我正在尝试使用以下组件建立一个基于当前spring云版本(主要是Netflix )的分布式系统使用Eureka和Config Server客户端的我的理解是，要使这样的特性起作用，就应该在服务中引入spring云总线客户端，这些服务将使用目前唯一受支持的实现，即rabbitmq服务器(实际的rabbitmq</e

浏览 2提问于2016-02-23得票数 7

1回答

Spring云流应用程序消息传递系统的可移植性

apache-kafka、rabbitmq、ibm-mq、spring-cloud、spring-cloud-stream

我正在使用IBM构建一个应用程序。所建议的构建它的架构是使用spring云流。我在许多文章中读到，您可以将spring云消息传递系统移植到其他系统。这意味着，我以后也可以将IBM更改为kafka，但可以在类路径上提供绑定器实现。那是什么意思？我使用rabbitmq构建了一个Spring应用程序，我在应用程序中使用的特性是belo，生

浏览 1提问于2018-11-25得票数 0

1回答

如何使用spring云流rabbitmq的当前交换和队列名

spring、stream、cloud、spring-rabbit

我正在将遗留的spring应用程序切换到spring启动。mq-test.topic.aa.mq-test 我对春云流的特性是这样的。<em

浏览 0提问于2019-05-30得票数 1

回答已采纳

2回答

spring数据流基本样例发布

spring-cloud-dataflow

我是spring云数据流的初学者，我从简单的教程开始：当我发现这个应用程序的时候，我真的不知道从哪里开始找问题。因此，我知道该事件被发送到rabbitMq，因为在rabbitMq仪表板中，我可以在消息率中看到它。当我部署流时，服务器会记录日志的本地路径，但这里没有记录任何内容。谢谢你的帮助

浏览 1提问于2018-02-20得票数 0

2回答

spring云流无法解析使用发布到RabbitMq的消息

rabbitmq、spring-cloud-stream

我有一个问题，在获取消息到春云流春启动应用程序。我使用rabbitMq作为消息引擎。消息生成器是一个非Spring引导应用程序，它使用发送消息。队列名称："audit.logging.rest“发现了两个问题：Issue1:，我注意到下面的方法只有在将方法参数作为对象时才会触发，因

浏览 4提问于2017-02-22得票数 1

回答已采纳

点击加载更多

Spring Cloud数据流部署到Cloud Foundry

Spring cloud数据流紧耦合

在Kubernetes上建立Spring数据流

用于批量使用的spring云数据流只需要跳过吗？

将RDBMS与同步

使用RabbitMQ作为绑定器的Spring* cloud stream的Spring安全*

Google Pub/Sub上的Spring云数据流

卡夫卡->春云数据流(RabbitMQ)->卡夫卡

春天的云流漂流池--然后呢？