问题标签 [spring-cloud-zookeeper]

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.

0 投票
0 回答
559 浏览

maven - Spring Boot ZooKeeper 客户端

我想使用 ZooKeeper 来通过 ZooKeeper 临时节点同步我的分布式服务。

想法如下 - 启动时拓扑中的每个节点都将创建 ZooKeeper 会话和临时节点。在节点重新启动或故障时,这些节点将消失。

我将使用 Spring Boot 来实现它。现在我怀疑使用什么项目和 Maven 依赖项来实现 ZooKeeper 客户端自动配置,能够在应用程序启动时创建 ZooKeeper 会话,能够从这个客户端创建 - ZooKeeper 临时节点并使用 ZooKeeper 事务。

现在我正在寻找Spring Cloud Zookeeper/但我不确定它是否适合这个目的。能否请您指出正确的 Spring Boot ZooKeeper 项目并展示如何实现我上面描述的小示例。

0 投票
1 回答
28 浏览

spring - 应用程序依赖项(其他应用程序)

我们需要使用 docker stack 部署我们的 4 个应用程序(3 个 spring boot 应用程序和 1 个 zookeper)。正如我们的 DevOps 人员告诉我们的那样,无法在 docker stack 中定义哪个应用程序将依赖于另一个应用程序,就像在 docker compose 中一样,所以我们作为开发人员需要在代码中解决它。

你能告诉我该怎么做或最好的方法是什么吗?我们的一个应用程序必须首先启动,因为该应用程序管理数据库(迁移等)。Next 可以在数据库准备好后启动其他应用程序。有任何想法吗?谢谢。

0 投票
1 回答
104 浏览

java - 在 Zookeeper 中创建没有 cmd 的 ZNode

我正在尝试通过 Zookeeper 实现配置管理。我从命令行创建了几个 ZNode:

  1. 创建/配置“”
  2. 创建 /config/mypocapp ""
  3. 创建 /config/mypocapp/name "John Doe"

name是我想在我的应用程序中访问的属性之一,名为mypocapp.

由于我们将在我们的应用程序中拥有很多属性,因此我们不能使用命令行来创建这样的每个属性。

有没有办法我们可以通过一些 UI 或直接在文件中创建 Zookeeper 中的属性(并将其导入 Zookeeper)。

我对动物园管理员完全陌生,在这个方向上没有得到任何帮助。请帮忙。

0 投票
1 回答
46 浏览

spring-cloud - 具有 Zookeeper 依赖项的 Spring Cloud 在第二个访问者中获取 NullException

我有一个名称为的应用程序

我用配置设置客户端

所以我可以用这个名字设置假客户端注释

现在我FeignClient第二次访问时收到 NullException。

我的 springcloud 版本是 Finchley.SR1

我将完整代码推送到github:https ://github.com/kanghouchao/sample-springcloud.git

我做错什么了?

0 投票
1 回答
1236 浏览

spring-integration - 如何使用 ZooKeeper 在 Spring Integration 中实现轮询器的分布式锁

Spring Integration 具有 ZooKeeper 支持,如https://docs.spring.io/spring-integration/reference/html/zookeeper.html中所述, 但是该文档非常模糊。

它建议在 bean 下面添加,但没有详细说明当节点被授予领导权时如何启动/停止轮询器。

我们是否有任何示例说明如何使用 Zookeeper 在任何时候确保以下轮询器在集群中只运行一次?

0 投票
2 回答
764 浏览

spring-integration - 如何使用 Zookeeper 和 Spring 集成负载平衡领导者

使用 spring 集成和 zookeeper,可以实现一个领导者来执行诸如轮询之类的活动。

但是,我们如何将领导者责任分配给集群中的所有节点以进行负载平衡?

给出下面的代码,一旦应用程序启动,我看到同一个节点正在维护领导角色并获取事件。我想将此活动分发到集群中的每个节点以更好地平衡负载。

有什么方法可以安排集群中的每个节点以循环方式获得领导权和撤销?

0 投票
1 回答
239 浏览

kubernetes - Kubernetes 检查 pod 是否失败

在我基于 Kubernetes 的集群中,我几乎没有基于 Java 的 dockerized 微服务,它们相互连接,因此每个人都相互发送和接收一些信息。我有 Kafka/Zookeeper 集群,它也再次连接到这个微服务。我需要一些程序,比如当我重新启动活动的 Kafka pod 时,另一个微服务应该理解它并重新启动自己。这个怎么做?请举一些例子yml。

0 投票
0 回答
125 浏览

java - Spring bean 为空,即使它正在另一个项目中填充

我有两个项目:A 和 B。我在项目 A 中创建了一个 bean,如下所示:

然后在项目 BI 中向 bean 添加数据,如下所示:

当我回到项目 AI 有这个类:

但是connectorRegistry这里是空的,即使我向它添加了数据并且我知道,通过查看 spring live bean 图,bean 是这样的依赖关系: SomeWorker ----> CON <----- SomeClass

因此,如果SomeClassSomeWorker都在同一个 bean 上,那么它不应该为空。我在这里想念什么?

编辑: 在我通过这样的主类A调用的项目中,也许它与问题有关:SomeWorkerSpringBoot

0 投票
1 回答
415 浏览

java - 如何在调试模式下跳过 Kafka 和 zookeeper 日志

使用 spring bootapplication.ymllogback.xml属性文件。

我尝试了以下application.yml属性,但它不起作用。

0 投票
1 回答
596 浏览

spring-cloud - 如何配置区域 Spring Cloud Zookeeper

我有一个 3 个前端应用程序和 3 个后端应用程序,假设 1 个虚拟机同时托管前端和后端应用程序,如下图所示,每个前端应用程序都使用由支持的发现客户端连接到后端动物园管理员。

在此处输入图像描述

现在我想创建网络关联或区域,以便 FE1 连接到 BE1(如果可用),如果 BE1 关闭连接到 BE2/BE3。这可以在 spring-cloud-zookeeper 中实现吗?

虽然这可以使用 eureka 来完成,但我更喜欢使用 zookeeper 来完成。


编辑

好的,在尤里卡中,我们可以设置区域字段,功能区可以根据从尤里卡为每个服务器检索的区域字段在客户端中进行区域关联。尽管功能区使用相同的 zonepreference 过滤器,但问题出在 zookeeper 中,但由于 zookeeper 不传递区域信息,它始终保持不变UNKNOWN,因此不应用区域过滤。

作为解决方法,我尝试在注册服务时将区域信息作为元数据传递,如下所示。

现在在客户端创建功能区配置,从元数据中检索区域信息作为过滤器,如下所示。

boostrap.yml

问题

现在的问题是我的自定义过滤器类没有被启用/使用,功能区仍在使用默认区域过滤器,如果我使用定义配置@RibbonClients

但是,如果我声明ribbon.NIWSServerListFilterClassName未应用过滤器,但在这种情况下我无法设置区域属性,则需要对区域属性进行硬编码。