在Finagle中记录远程主机

Question

我想在使用Finagle Client时将被叫远程主机记录到STDOUT.但据我所知,这是不可能的com.twitter.finagle.http.filter.LoggingFilter; 其#format(示例见下文)方法无法访问实际主机:

• request.remoteHost() 回报 0.0.0.0
• request.remoteAddress() 返回一个基本上包含上述IP的对象
• request.host()返回一个None对象

我的第一个猜测是,访问主机是不可能的,因为Finagle的客户端负载平衡在堆栈中发生得更深.

这是我使用的测试代码:

    LoggingFilter<Request> loggingFilter = new LoggingFilter<>(
            new Logger(this.getClass().getSimpleName(), java.util.logging.Logger.getLogger(this.getClass().getSimpleName())),

            new LogFormatter<Request, Response>() {
                @Override
                public String format(Request request, Response reply, Duration replyTime) {
                    return null;
                }

                @Override
                public String formatException(Request request, Throwable throwable, Duration replyTime) {
                    return null;
                }
            });

    Service<Request, Response> service = Http.client().newService("localhost:8090,localhost:8091");
    Future<Response> response = loggingFilter.andThen(service).apply(Request.apply("/profiles/me"));

Answer 1

发送请求的实际端点在负载均衡器中确定.因此,确实只能在负载平衡模块之后完成对远程主机的记录.

负载平衡器模块使参数Transporter.EndpointAddr可用.该参数包含实际地址.为了使用此参数,您应该在负载平衡模块之后将模块添加到HTTP客户端堆栈.

Scala中的一个例子:

创建日志记录过滤器:

class MyLoggingFilter(addr: Address) extends SimpleFilter[Request, Response] {
  override def apply(request: Request, service: Service[Request, Response]) = {
    println(s"Sending request to $addr")
    service(request)
  }
}

定义新模块

def endpointLoggerModule: Stackable[ServiceFactory[Request, Response]] =
  new Stack.Module1[Transporter.EndpointAddr, ServiceFactory[Request, Response]] {
    val role: Role = Role("EndpointLogger")
    val description = "Log remote address"
    def make(_addr: Transporter.EndpointAddr, 
             next: ServiceFactory[Request, Response]) = {
      val Transporter.EndpointAddr(addr) = _addr
      new MyLoggingFilter(addr).andThen(next)
    }
  }

在堆栈中使用此模块创建一个新的Http客户端:

val stackWithLogging = Http.client.stack
  .insertAfter(LoadBalancerFactory.role, endpointLoggerModule)
val service = Http.client.copy(stack = stackWithLogging)
  .newService("localhost:8090,localhost:8091")

然后,此创建的服务应记录发送请求的实际地址.

有关模块组成的更多信息,请参阅官方Finagle文档.