Project——智慧出行——module1--tf_producer——步骤5:PropertyUtil.scala

创建读取配置属性kafka.properties的工具类,object PropertyUtil

package utils

import java.util.Properties

// PropertyUtil读取配置文件的工具类
object PropertyUtil {
  // 1 import java.util.Properties
  val properties = new Properties
  // 4 异常处理,加try catch语句(ctrl Alt + t)
  try {

    // 2 加载配置文件,将其转换为输入流
    val inputStream = ClassLoader.getSystemResourceAsStream("kafka.properties")
    // 3 加载配置文件属性
    properties.load(inputStream)
  } catch {
    // 5
    case e: Exception => e.getStackTrace
  } finally {}

  // 6 封装一个方法用于快速获取“key-value”
  def getProperty(key: String): String = properties.getProperty(key)
}

猜你喜欢

转载自blog.csdn.net/qq_26416195/article/details/82148333