【问题标题】:Akka Persistence: No Sufficient Working Example for JDBC MySQLAkka 持久性:没有足够的 JDBC MySQL 工作示例
【发布时间】:2020-11-20 05:08:29
【问题描述】:

我一直试图让我的 EventSourceBehavior 写入 MySQL,但出现以下错误,可能是什么问题?错误非常普遍,很难看出根本原因是什么。有没有办法测试我的 JDBC 是否通过 Akka、ex 连接等正确配置,谢谢

2020-11-20 00:48:57,999 WAR HikariConfig              slick.db - using dataSourceClassName and ignoring jdbcUrl.
2020-11-20 00:48:57,999 WAR HikariConfig              slick.db - using dataSourceClassName and ignoring jdbcUrl.
2020-11-20 00:48:58,002 INF HikariDataSource          slick.db - Starting...
2020-11-20 00:48:58,002 INF HikariDataSource          slick.db - Starting...
2020-11-20 00:48:58,041 INF HikariDataSource          slick.db - Start completed.
2020-11-20 00:48:58,042 INF HikariDataSource          slick.db - Start completed.
2020-11-20 00:49:18,293 ERR Main$                     Supervisor StopSupervisor saw failure: Exception during recovery from snapshot. PersistenceId [first]. Circuit Breaker Timed out.
akka.persistence.typed.internal.JournalFailureException: Exception during recovery from snapshot. PersistenceId [first]. Circuit Breaker Timed out.

应用程序.conf

akka {
  loglevel = DEBUG

  persistence {
    journal.plugin = "jdbc-journal"
    snapshot-store.plugin = "jdbc-snapshot-store"
  }
}

slick {
  profile = "slick.jdbc.MySQLProfile$"
  db {
    dataSourceClass = "slick.jdbc.DriverDataSource"
    driver = "com.mysql.cj.jdbc.Driver"
    url = "jdbc:mysql://localhost:3306/"
    user = nilu
    password = "password"
  }
}

【问题讨论】:

    标签: akka akka-persistence


    【解决方案1】:

    一般来说,使用 Akka Persistence JDBC,您需要指定要使用的数据库,而不仅仅是要连接的 DBMS(服务器)。因此,如果数据库名为 my_akka_persistence,则 JDBC URL 将类似于 jdbc:mysql://localhost:3306/my_akka_persistence

    【讨论】:

    • 也是这样,但是我还得分别设置主机和端口,由于某种原因,url 不够。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2019-02-10
    • 1970-01-01
    • 2023-03-03
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多