在我们的集群中，我们有四个节点组成：
- 2 个种子节点（后端）
- 1 名工人
- 1 个 IIS 上的 webapi
集群已加入、启动并运行；当我向 webapi 发送 POST 时，：
- IIS 加入集群
- API 接收帖子并使用 Tell 发送消息
- 消息被处理了两三次！
- 仅发生在 IIS 加入时发送的消息，以下消息工作正常
这是我的 IIS 配置：
<akka>
<hocon>
<![CDATA[
akka.loglevel = INFO
akka.log-config-on-start = off
akka.stdout-loglevel = INFO
akka.actor {
provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"
deployment {
/TheProcess {
router = round-robin-group
routees.paths = ["/user/TheProcess"] # path of routee on each node
# nr-of-instances = 3 # max number of total routees
cluster {
enabled = on
allow-local-routees = off
use-role = TheProcess
}
}
}
debug {
receive = on
autoreceive = on
lifecycle = on
event-stream = on
unhandled = on
}
}
akka.remote {
helios.tcp {
# transport-class = "Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote"
# applied-adapters = []
# transport-protocol = tcp
# public-hostname = "localhost"
# 0 or 46001-46010
port = 0
hostname = "localhost"
}
log-remote-lifecyclo-events = DEBUG
}
akka.cluster {
seed-nodes = [
"akka.tcp://ActorSystem@localhost:2551",
"akka.tcp://ActorSystem@localhost:2552"
]
roles = [TheSend]
# auto-down-unreachable-after = 10s
# how often should the node send out gossip information?
# gossip-interval = 1s
# discard incoming gossip messages if not handled within this duration
# gossip-time-to-live = 2s
}
# http://getakka.net/docs/persistence/at-least-once-delivery
akka.persistence.at-least-once-delivery.redeliver-interval = 300s
# akka.persistence.at-least-once-delivery.redelivery-burst-limit =
# akka.persistence.at-least-once-delivery.warn-after-number-of-unconfirmed-attempts =
akka.persistence.at-least-once-delivery.max-unconfirmed-messages = 1000000
akka.persistence.journal.plugin = "akka.persistence.journal.sql-server"
akka.persistence.journal.publish-plugin-commands = on
akka.persistence.journal.sql-server {
class = "Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.SqlServer"
plugin-dispatcher = "akka.actor.default-dispatcher"
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string-name = "AkkaPersistence"
refresh-interval = 1s
connection-timeout = 30s
timestamp-provider = "Akka.Persistence.Sql.Common.Journal.DefaultTimestampProvider, Akka.Persistence.Sql.Common"
metadata-table-name = Metadata
}
akka.persistence.snapshot-store.plugin = ""akka.persistence.snapshot-store.sql-server""
akka.persistence.snapshot-store.sql-server {
class = "Akka.Persistence.SqlServer.Snapshot.SqlServerSnapshotStore, Akka.Persistence.SqlServer"
plugin-dispatcher = ""akka.actor.default-dispatcher""
connection-string-name = "AkkaPersistence"
schema-name = dbo
table-name = SnapshotStore
auto-initialize = on
}
]]>
</hocon>
这是我的后端配置：
<hocon>
<![CDATA[
akka.loglevel = INFO
akka.log-config-on-start = on
akka.stdout-loglevel = INFO
akka.actor {
provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"
debug {
receive = on
autoreceive = on
lifecycle = on
event-stream = on
unhandled = on
}
}
akka.remote {
helios.tcp {
# transport-class = "Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote"
# applied-adapters = []
# transport-protocol = tcp
# public-hostname = "localhost"
#
# seed-node ports 2551 and 2552
# non-seed-node port 0 or 46001-46010
port = 2551
hostname = "localhost"
}
log-remote-lifecyclo-events = INFO
}
akka.cluster {
seed-nodes = [
"akka.tcp://ActorSystem@localhost:2551",
"akka.tcp://ActorSystem@localhost:2552"
]
roles = [TheProcess]
# auto-down-unreachable-after = 10s
}
]]>
</hocon>
我认为问题与 akka 持久性有关，问题可能是什么？