问题标签 [spring-cloud-bus]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
rabbitmq - Spring Cloud Bus 网络中断后无法恢复
我有一个使用 RabbitMQ binder 的 Spring Cloud Stream 应用程序，基于 Spring Boot1.5和 Spring Cloud构建Edgware.SR4。由于某种原因，Spring Cloud Bus 无法从持续至少 30 秒的网络中断中恢复（持续时间可能取决于您的环境）。如果网络中断时间足以让 RabbitMQ 删除独占队列，则应用程序能够重新声明匿名队列。这似乎是与系统修补/重启 RabbitMQ 服务器相一致的重复事件。
通过连接到远程 RabbitMQ 服务器并断开笔记本电脑上的网络连接，我复制了此示例应用程序中的错误。output.txt包含测试的整个标准输出。
以下是事件概要：
声明 springCloudBus 匿名队列：
springCloudBus 匿名队列消费者初始化：
网络连接中断：
网络连接恢复：
尝试从 springCloudBus 匿名队列中读取的消费者异常：
最后一个“RESOURCE_LOCKED”异常
反复出现的错误：
spring-cloud-config - oscloud.stream.binding.Binding 服务：创建生产者绑定失败
我正在尝试在集群环境中构建 spring config 客户端，为此我正在使用kafka它来连接客户端。我的客户端项目与本地kafka服务器一起使用，但是当我尝试连接到我的远程kafka服务器应用程序时，请不要启动并抛出以下错误，
在pom.xml,
java - 删除对象时的微服务通信
我们的应用程序由微服务组成。在我这边，在删除某个东西之前，它可能会在另一个微服务中使用。因此，我需要询问另一个微服务，该东西在您身边使用。为此，我使用 spring-cloud-event-bus 发送一个事件，我需要等到响应到来，所以我无法返回任何响应 tu UI。另外，我可以在侦听器类中进行响应。如何将消息转发给控制器。我该如何管理这个过程。
我有一个想法，但我认为这是不明智的，当删除请求到来时，我将事件发送到另一个微服务，我正在等待响应。我将其他微服务的响应保存到 mongodb 中，对象的 id 将被删除。顺便说一句，控制器检查数据库以获取响应
spring - 如何在执行器/总线刷新请求中使用弹簧云总线指示配置文件
我的环境：
- 弹簧云：Finchley.SR2
- spring-cloud-starter-bus-amqp 或 spring-cloud.starter-bus-roketmq
- spring-cloud-config-server / 客户端
有两个项目 - 配置服务器和客户端名为网关（spring.application.name）。我在开发配置文件中对其进行测试，客户端（网关）将在我以下时正确刷新：
- 请求/执行器/总线刷新
- 请求/执行器/总线刷新/**
- 请求/执行器/总线刷新/网关
- 请求/执行器/总线刷新/网关：**
现在我想明确指出网关中的配置文件，例如“/actuator/bus-refresh/Gateway:devel”或其他格式，我该怎么办？
java - 如何使用 Spring Cloud Bus 使用不受配置服务器控制的数据刷新应用程序实例？
我正在尝试在我的微服务应用程序中将 Spring Cloud Bus 与 Kafka 一起使用，实际上我可以使用它，但只有由 Spring Cloud 配置服务器控制的数据才会被刷新！
我在我的配置服务器上使用 jdbc 后端，为了模拟我的需要，我在属性表旁边的一项服务中更改属性文件中的一些值，并再次调用/monintor端点（这里提到第 4.3 节https://www.baeldung.com/spring-cloud-bus）；结果，只有来自属性表的数据被更改。
这是我的配置服务器的 yml 文件
这些分别是我的一个 Miscroservices 及其属性文件的 yml 文件
这是来自休息控制器的快照
我错过了什么？为什么属性文件中的值没有改变？希望我可以使用 Spring Cloud Bus 和 Kafka 来刷新这些外部数据。
apache-kafka - Spring Cloud Bus 事件（ RemoteApplicationEvent ）未发布到 Kafka
我正在使用 spring cloud bus 将事件发布到 kafka，以便另一个实例可以监听相同的事件。事件被触发但未发布到 kafka 。我正在使用带有 spring cloud stream 的 spring cloud bus。
版本：Spring Boot：2.0，Spring Cloud Bus：2.0.0，Spring Cloud Stream：2.0.1
应用程序.yml：
pom.xml
发布活动：
事件类别：
事件监听器：
spring-amqp - 重启rabbitmq后Spring cloud bus（AMQP）不重新创建队列
使用带有 Spring Boot 2.0.3 版本的 Spring Cloud Bus 时，我们在日志中看到以下异常
基于谷歌，我们看到了这张 JIRA 票
https://github.com/spring-projects/spring-amqp/issues/818
Spring cloud bus 应该重新创建这个匿名队列。看起来这个问题在最新版本的 spring AMQP 基于这张票
https://jira.spring.io/browse/AMQP-834
但我的问题是我们如何在不升级这个库的情况下解决这个问题？
spring-cloud - 自动更新不尊重更改的项目
我正在设置“ spring-cloud-config-monitor ”，所以当我得到一个 gitlab webhook 时，它会自动更新我的项目。
我正在测试两个项目“ monitoring-service ”和“ config-server ”，但是当推送回调到达 gitlab 时，警告说“ monitoring-service ”项目中的文件已更改，“ config-server ”也令人耳目一新避免这种行为？
spring-cloud - Spring Cloud 配置返回旧配置
我正在使用 spring cloud config 和 spring cloud bus。我从我的 git 存储库（托管在 bitbucket 中）设置了一个 webhook，以在发生推送时通知配置服务器。为了降低吞吐量并使用最少的缓存，我将刷新率设置为 2 分钟：
现在，当我推送到存储库时，配置服务器会通过 webhook 收到通知并向客户端发送消息。客户端再次向服务器请求配置，但由于刷新率设置为两分钟，并且通知链更快，配置服务器返回之前的配置。
有没有办法取消 webhook 上的刷新率（对 /monitor 的请求）？也许其他方法可以克服这个问题？
spring-cloud - io.grpc.StatusRuntimeException：PERMISSION_DENIED：用户无权执行此操作
我尝试实现spring cloud config+的简单示例spring cloud bus。
所以我已经实施
- 客户端服务器应用程序
- 配置服务器应用程序
在单独的存储库中，我放置了application.properties文件。
看起来服务器端的一切都是正确的。但是在客户端我在应用程序启动时看到错误：
基于stacktrace，我认为这个问题与权限有关。为了解决这个问题，我授予了owner权限：
但由于某种原因它没有帮助。
让我分享我的代码库：
application.properties文件为空。
build.gradle.kts：
应用：
示例控制器：
我想说，尽管启动时抛出异常，但应用程序部分工作。当我创建时，我会GET localhost:8080/message从位于 github 存储库的文件中看到值。但是，如果我在存储库中更改此文件，则GET`localhost:8080/message 将返回旧值。
我的代码有什么问题？如何解决？