微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Akka不会加载application.conf

如何解决Akka不会加载application.conf

我正在尝试设置其他akka.http.parsing.max-chunk-size

我的application.conf位于src / resources /中,如下所示:

akka.http {
   parsing {
       max-chunk-size=20m
   }
}

我在主体中使用以下代码来设置系统:

val conf = ConfigFactory.load()
implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer() 
implicit val executionContext = system.dispatcher

但是,当尝试发出较大的get请求时,我仍然收到此错误

akka.http.scaladsl.model.EntityStreamException: HTTP chunk size exceeds the configured limit of 1048576 bytes

编辑:我已经尝试根据得到的答案重定位文件,但是仍然出现相同的错误。我的程序结构如下:

├── main
│   ├── resources
│   │   └── application.conf
│   └── scala
│       ├── program
│       │   ├── BackTester.scala
│       │   ├── Main.scala
│       │   └── StrategyExecutor.scala
│       ├── strategies
│       │   ├── BollingerBandStrategy.scala
│       │   ├── CrossingSMAStrategy.scala
│       │   ├── RSIStrategy.scala
│       │   ├── stochasticStrategy.scala
│       │   └── TradingStrategies.scala
│       └── util
│           ├── Interval.scala
│           ├── JsonParser.scala
│           ├── Time.scala
│           ├── barseries
│           │   └── barSeriesBuilder.scala
│           └── requests
│               └── Fetcher.scala
└── test
    └── scala

解决方法

我查看了官方网站,看起来配置正确( https://doc.akka.io/docs/akka-http/current/configuration.html )。我会将特定的应用程序放入application.conf文件中。像下面的示例一样。

routersDemo {
  akka {
    actor.deployment {
      /poolMaster2 {
        router = round-robin-pool
        nr-of-instances = 5
      }

      /groupMaster2 {
        router = round-robin-group
        routees {
          paths = ["/user/slave_1","/user/slave_2","/user/slave_3","/user/slave_4","/user/slave_5"]
        }
      }
    }
  }
}

然后在ConfigFactory上调用它

    val system = ActorSystem("routersDemo",ConfigFactory.load().getConfig("routersDemo"))

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。