问题标签 [twitter-finagle]

我需要同时启动两个Finagle ListeningServer因为我必须实现两个不同的扩展特性ListeningServer。

基本上，每个ListeningServer都是一个com.twitter.util.Awaitable，每当我必须实例化一个新的时，ListeningServer我都会使用Await.ready(myListeningServer).

现在我不确定 using是否是同时启动多个 sAwait.all()的正确选择。ListeningServer我会使用com.twitter.util.Future.collect()，但我有两个Awaitables。

def all(awaitables: Awaitable[_]*): Unit

完成所有操作后返回。

我正在使用 Scala 2.12 和 Twitter 20.3.0。

如何配置启用 tls 的 finagle Redis 客户端？

因为我们使用的函数只使用了redis-endpiont。

我是 twitter finagle API 的新手，在我们的代码的一部分中，我们在 Future 对象上调用 onFailure() 方法。在 onFailure() 内部，我们抛出了一个新异常。下面是代码：

对于上面的代码，我必须编写一个 Mockito Junit 来覆盖 onFailure() 调用中的代码。

提前致谢

我们的 scala/thrift 服务正在使用带有 java8 的 twitter finagle 2.12-18.10.0。该服务对于单个请求或少数请求运行良好，但是当我们尝试用很多请求访问该服务时，我们会收到很多请求

命中服务器的示例客户端（间歇性失败）

为什么服务器会随机关闭频道。可能的解决方法是什么

从文档中，finagle 给出了这个例子：

好的，所以当我为锁添加正确的 sql 时： SELECT GET_LOCK('foo',2) 这应该持有锁。对于这个测试，我有意删除了任何解锁——我希望它在第二次尝试获得锁时失败。

但是……对该代码的两次后续调用都有效——没有锁定失败，即使我引入延迟 >2 秒，旨在导致第二次锁定尝试超时。

为什么锁定行为似乎没有做任何事情？

我正在尝试执行 GET 请求并打印我返回的 JSON 响应。JSON 响应应如下所示。

这是我的代码：

现在，当我的客户端将请求发送到服务器时，我想打印 JSON，但我得到的格式是。有人可以指导我如何实现这一目标。

我正在一个使用 scala 和 twitter 服务器 finagle 的项目中工作。我们项目的需求有日志记录和跟踪。在搜索时，我遇到了 sleuth 和 zipkin。我能够集成 zipkin，因为我找到了 finagle 的库，但找不到任何与侦探相关的库。我查看了 sleuth 的文档，但它只与弹簧有关。所以我的问题是除了春天还有没有人使用侦探？可能吗？如果有人有，那么您能否提供文档或示例。

我发现很难找到有关 DTAB 解析器实际工作方式的文档。

从 Finagle 文档中：

以 $ 开头的路径称为“系统路径”，Finagle 会对其进行特殊处理。这用于指定具体的命名器。

显然，“inet”是那些“名称”之一，但我想知道预定义名称的完整列表，以及是否有办法定义新的名称（如果我想实现内部服务发现机制，例如）。

文档似乎非常稀缺。有什么建议吗？

显然有一种方法可以定义“名称”，据我所知，至少有：

我在哪里可以获得这些“名称”、完整集以及如何声明新名称的文档？

I have seen in many places that Finagle has service discovery and load balancing capabilities, but I cannot find any reference to actual detailed implementation.

How does Finagle client get the address of the Service Discovery?

How is such a service discovery implemented?

The documentation seems incomplete...

Thanks!