-
Notifications
You must be signed in to change notification settings - Fork 1
Four nodes demo
ingted edited this page Sep 26, 2020
·
1 revision
USAGE: FAkkaSeed.exe [--help] [--windowsize <winsz>] [--majoritynodecount <mnc>] [--transportmanagerport <port>]
[--seedport <port> <pubSeedPort>] [--seedhostnametype <hostname> <pubHostname>]
[--hostname <string>] [--pubhostname <string>] [--persistdb <string>] [--persistdbuid <string>]
[--persistdbpwd <string>]
OPTIONS:
--windowsize <winsz> specify a initial candidate recommandation waiting time period
--majoritynodecount <mnc>
specify a reasonable initial seednode number, at should be at least more then half of the
node number
--transportmanagerport <port>
--seedport <port> <pubSeedPort>
--seedhostnametype <hostname> <pubHostname>
--hostname <string> --pubhostname <string>
--persistdb <string> --persistdbuid <string>
--persistdbpwd <string>
--help display this list of options.
myIP: 192.168.123.113
petabridge.cmd{
# default IP address used to listen for incoming petabridge.cmd client connections
# should be a safe default as it listens on "all network interfaces".
host = "0.0.0.0"
# default port number used to listen for incoming petabridge.cmd client connections
port = 9110
# when true, logs all loaded palettes on startup
log-palettes-on-startup = on
}
akka {
stdout-loglevel = DEBUG
loglevel = DEBUG
#log-config-on-start = on
loggers = ["Akka.Logger.NLog.NLogLogger, Akka.Logger.NLog"]
debug {
receive = on
autoreceive = on
lifecycle = on
event-stream = on
unhandled = on
}
actor {
# debug.unhandled = on
provider = cluster
inbox {
inbox-size = 100000
}
}
remote {
dot-netty.tcp {
#byte-order = "little-endian"
public-hostname = "192.168.123.113"
hostname = "0.0.0.0"
public-port = 9000
port = 9000
}
}
cluster {
auto-down-unreachable-after = off
roles = ["petabridge.cmd", "ShardNode", "singletonRole"]
sharding {
role = "ShardNode"
# journal-plugin-id = "akka.persistence.journal.inmem"
# snapshot-plugin-id = "akka.persistence.snapshot-store.inmem"
journal-plugin-id = "akka.persistence.journal.sharding"
snapshot-plugin-id = "akka.persistence.snapshot-store.sharding"
}
#seed-nodes = [ "akka.tcp://cluster-system@localhost:8081", "akka.tcp://cluster-system@localhost:8082" ]
}
persistence{
query.journal.sql {
max-buffer-size = 10000
}
journal {
plugin = "akka.persistence.journal.sql-server"
sql-server {
class = "Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Persistence.SqlServer"
connection-string = "Persist Security Info=False;User ID=sa;Password=/'],lp123/'],lp123;Initial Catalog=AkkaPersistence;Server=10.28.112.93"
# default SQL commands timeout
connection-timeout = 30s
schema-name = dbo
table-name = journal
metadata-table-name = metadata
auto-initialize = off
event-adapters {
json-adapter = "Sessionrapper+EventAdapter, mdcf"
#"Nrk.Oddjob.Upload.PersistenceUtils+EventAdapter, Upload"
}
event-adapter-bindings {
# to journal
"System.Object, mscorlib" = json-adapter
# from journal
"Newtonsoft.Json.Linq.JObject, Newtonsoft.Json" = [json-adapter]
}
}
sharding {
connection-string = "Persist Security Info=False;User ID=sa;Password=/'],lp123/'],lp123;Initial Catalog=AkkaPersistence;Server=10.28.112.93"
auto-initialize = on
plugin-dispatcher = "akka.actor.default-dispatcher"
class = "Akka.Persistence.SqlServer.Journal.SqlServerJournal,
Akka.Persistence.SqlServer"
connection-timeout = 30s
schema-name = dbo
table-name = journal
timestamp-provider = "Akka.Persistence.Sql.Common.Journal.DefaultTimestampProvider,
Akka.Persistence.Sql.Common"
metadata-table-name = metadata
}
}
snapshot-store {
plugin = "akka.persistence.snapshot-store.sql-server"
sql-server {
class = "Akka.Persistence.SqlServer.Snapshot.SqlServerSnapshotStore, Akka.Persistence.SqlServer"
serializer = hyperion
connection-string = "Persist Security Info=False;User ID=sa;Password=/'],lp123/'],lp123;Initial Catalog=AkkaPersistence;Server=10.28.112.93"
# default SQL commands timeout
connection-timeout = 30s
schema-name = dbo
table-name = snapshot
auto-initialize = off
}
sharding {
class = "Akka.Persistence.SqlServer.Snapshot.SqlServerSnapshotStore,
Akka.Persistence.SqlServer"
plugin-dispatcher = "akka.actor.default-dispatcher"
connection-string = "Persist Security Info=False;User ID=sa;Password=/'],lp123/'],lp123;Initial Catalog=AkkaPersistence;Server=10.28.112.93"
connection-timeout = 30s
schema-name = dbo
table-name = ShardingSnapshotStore
auto-initialize = on
}
}
}
extensions = ["Akka.Cluster.Tools.PublishSubscribe.DistributedPubSubExtensionProvider,Akka.Cluster.Tools"]
}
[DEBUG][9/26/2020 3:14:55 PM][Thread 0001][EventStream] StandardOutLogger started
[INFO][9/26/2020 3:14:56 PM][Thread 0005][akka://cluster-system/system/log1-NLogLogger] NLogLogger started
[DEBUG][9/26/2020 3:14:56 PM][Thread 0001][EventStream(cluster-system)] Logger log1-NLogLogger [NLogLogger] started
[DEBUG][9/26/2020 3:14:56 PM][Thread 0001][EventStream(cluster-system)] StandardOutLogger being removed
9/26/2020 11:15:56 PM
9/26/2020 11:14:56 PM
setWaitCandidateBase: not ifOnlyVillage
reset timer from 60000.000000 to 59984.376800
<null>
seq []
seq []
192.168.123.113 tell 192.168.123.114: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
192.168.123.113 tell 192.168.123.114: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
192.168.123.113
192.168.123.113 tell 192.168.123.111: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
msg from 192.168.123.113: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
tell 192.168.123.114: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
msg from msg from 192.168.123.114:
192.168.123.113 tell 192.168.123.112: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
192.168.123.113 tell 192.168.123.111: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
192.168.123.113 tell 192.168.123.112: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
Recommand
(("45f28e0b-9d91-4275-9dc6-76972576c10c",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:53 PM,
"192.168.123.114")192.168.123.111: Recommand
(("188bd413-7c18-46ec-b0d2-84c75a2d65a1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:54 PM,
"192.168.123.111")
no need to make in advance: 9/26/2020 11:14:56 PM
no need to make in advance:
192.168.123.113 tell 192.168.123.113: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
no need to make in advance: 9/26/2020 11:14:56 PM
192.168.123.113 tell 192.168.123.111: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
9/26/2020 11:14:56 PM
192.168.123.113 tell 192.168.123.113: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
msg from 192.168.123.113: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
192.168.123.113 tell 192.168.123.113: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
no need to make in advance: 9/26/2020 11:14:56 PM
192.168.123.113 tell 192.168.123.112: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
msg from 192.168.123.113: Recommand
(("8fc56182-d2e3-4a88-b4d9-bc6f1c424dd1",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:56 PM,
"192.168.123.113")
no need to make in advance: 9/26/2020 11:14:56 PM
msg from 192.168.123.112: Recommand
(("f45a52e2-facf-499a-add1-f1a7e384ed59",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:57 PM,
"192.168.123.112")
no need to make in advance: 9/26/2020 11:14:56 PM
msg from 192.168.123.112: Recommand
(("f45a52e2-facf-499a-add1-f1a7e384ed59",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:57 PM,
"192.168.123.112")
no need to make in advance: 9/26/2020 11:14:56 PM
msg from 192.168.123.112: Recommand
(("f45a52e2-facf-499a-add1-f1a7e384ed59",
akka.tcp://[email protected]:9000), 9/26/2020 11:14:57 PM,
"192.168.123.112")
no need to make in advance: 9/26/2020 11:14:56 PM
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
<null>
seq []
seq []
msg from 192.168.123.114: Elect
(akka.tcp://[email protected]:9000,
akka.tcp://[email protected]:9000)
electCnt.Keys.Count: 1, selfList.Length: 1
msg from 192.168.123.111: Elect
(akka.tcp://[email protected]:9000,
akka.tcp://[email protected]:9000)
electCnt.Keys.Count: 1, selfList.Length: 2
transMgr.SendToAllPeersAsyncTCP
msg from 192.168.123.113: Elect
(akka.tcp://[email protected]:9000,
akka.tcp://[email protected]:9000)
electCnt.Keys.Count: 1, selfList.Length: 3
192.168.123.113 first join with election akka.tcp://[email protected]:9000
setWaitCandidateBase: ifOnlyVillage
msg from 192.168.123.113: Elect
(akka.tcp://[email protected]:9000,
akka.tcp://[email protected]:9000)
electCnt.Keys.Count: 1, selfList.Length: 3
192.168.123.113 first join with election akka.tcp://[email protected]:9000
setWaitCandidateBase: ifOnlyVillage
<null>
seq []
seq []
akka.tcp://[email protected]:9000
seq
[Member(address = akka.tcp://[email protected]:9000, Uid=398268763 status = Up, role=[ShardNode,singletonRole,petabridge.cmd], upNumber=2);
Member(address = akka.tcp://[email protected]:9000, Uid=950451485 status = Up, role=[ShardNode,singletonRole,petabridge.cmd], upNumber=1);
Member(address = akka.tcp://[email protected]:9000, Uid=440661357 status = Up, role=[ShardNode,singletonRole,petabridge.cmd], upNumber=3);
Member(address = akka.tcp://[email protected]:9000, Uid=830781675 status = Up, role=[ShardNode,singletonRole,petabridge.cmd], upNumber=4)]
seq []
akka.tcp://[email protected]:9000
seq
[Member(address = akka.tcp://[email protected]:9000, Uid=398268763 status = Up, role=[ShardNode,singletonRole,petabridge.cmd], upNumber=2);
Member(address = akka.tcp://[email protected]:9000, Uid=950451485 status = Up, role=[ShardNode,singletonRole,petabridge.cmd], upNumber=1);
Member(address = akka.tcp://[email protected]:9000, Uid=440661357 status = Up, role=[ShardNode,singletonRole,petabridge.cmd], upNumber=3);
Member(address = akka.tcp://[email protected]:9000, Uid=830781675 status = Up, role=[ShardNode,singletonRole,petabridge.cmd], upNumber=4)]
seq []