Scala+Spray环境下Prometheus指标转换及服务启动问题求助

一、将Seq[MetricSnapshot]转换为Prometheus标准文本格式 #

不用手动拼接格式，Prometheus官方Java客户端提供了现成的格式化工具，直接借助io.prometheus.client.exporter.common.TextFormat类即可处理。

步骤1：确认依赖 #

确保项目引入兼容Scala的Prometheus客户端依赖：

libraryDependencies += "io.prometheus" % "simpleclient" % "0.16.0"
libraryDependencies += "io.prometheus" % "simpleclient_common" % "0.16.0"

步骤2：代码实现 #

如果你的Seq[MetricSnapshot]来自defaultRegistry，可直接通过官方API生成标准格式：

import io.prometheus.client.CollectorRegistry
import io.prometheus.client.exporter.common.TextFormat
import java.io.StringWriter

val defaultRegistry = CollectorRegistry.defaultRegistry
val writer = new StringWriter()
// 直接将注册表指标写入Writer，生成Prometheus标准格式
TextFormat.write004(writer, defaultRegistry.metricFamilySamples())
val prometheusText = writer.toString()

这段代码会自动生成带HELP、TYPE注释，以及符合规范的指标行文本。

如果必须基于自定义的Seq[MetricSnapshot]处理，可参考TextFormat源码逻辑手动拼接：

1. 先输出指标的帮助注释：# HELP <指标名> <描述文本>
2. 再输出指标类型注释：# TYPE <指标名> <类型>（如gauge、counter）
3. 遍历快照拼接指标行：<指标名>{<标签键="标签值">} <指标数值>，注意标签值需转义双引号，数值要符合浮点数/整数格式

二、启动HTTPServer后服务直接终止的排查与解决 #

服务无报错终止，核心原因多为线程模型问题：

• Prometheus HTTPServer默认是守护线程：主线程完成初始化后若没有阻塞逻辑，JVM会因无存活非守护线程直接退出。解决方法：将HTTPServer的线程设为非守护线程，或在主线程添加Thread.currentThread().join()这类阻塞逻辑。
• Spray服务未正确阻塞主线程：检查Spray的Http().bindAndHandle返回的Future是否被正确等待，避免主线程提前结束。
• 排查JVM退出触发点：启动时添加JVM参数-XX:+PrintExitOnError，可直接查看导致JVM退出的具体原因。

三、替代方案：用Spray自有路由暴露指标 #

既然打算用自有HTTP路由返回指标，可跳过单独启动Prometheus HTTPServer的步骤，直接在Spray路由中添加/metrics端点：

import spray.routing.SimpleRoutingApp
import java.io.StringWriter

object SprayPrometheusApp extends SimpleRoutingApp {
  def main(args: Array[String]): Unit = {
    startServer("0.0.0.0", 8080) {
      path("metrics") {
        get {
          val registry = CollectorRegistry.defaultRegistry
          val writer = new StringWriter()
          TextFormat.write004(writer, registry.metricFamilySamples())
          complete(writer.toString())
        }
      } ~
      // 你的其他业务路由
      path("health") {
        complete("OK")
      }
    }
  }
}

这种方式复用Spray的HTTP服务，避免了额外启动Server的线程冲突问题，更贴合你的需求。

内容的提问来源于stack exchange，提问作者Дима Шестаев