ストアファクトリー API

A StoreFactory を選択します セッションデータがどこに保存されるか および どの EventStore がイベントを配布するか。 ストレージとイベントの同期は 独立していますので、バックエンドを自由に組み合わせることができます。

---

MemoryStoreFactory

MemoryStoreFactory()

を使用してファクトリを作成します インメモリストレージ とデフォルトの MemoryEventStore。 に使用します シングルノード または 非分散 構成。

StoreFactory sf = new MemoryStoreFactory();
// インメモリストレージ + ローカル専用イベント

---

MemoryStoreFactory(EventStore eventStore)

を使用してファクトリを作成します インメモリストレージ と カスタム EventStore で分散同期を行います。

EventStore es = new KafkaEventStore(...);
StoreFactory sf = new MemoryStoreFactory(es);
// ローカルストレージ + 分散イベント（Kafka）

---

HazelcastStoreFactory

HazelcastStoreFactory(HazelcastInstance hazelcastClient)

を使用してファクトリを作成します Hazelcast ストレージ とデフォルトの HazelcastEventStore.

HazelcastInstance hz = Hazelcast.newHazelcastInstance();
StoreFactory sf = new HazelcastStoreFactory(hz);
// ストレージとイベントの両方を Hazelcast 経由で

---

HazelcastStoreFactory(HazelcastInstance hazelcastClient, EventStore eventStore)

を使用してファクトリを作成します Hazelcast ストレージ と カスタム EventStore バックエンド。

HazelcastInstance hz = Hazelcast.newHazelcastInstance();
EventStore es = new RedisStreamEventStore(...);
StoreFactory sf = new HazelcastStoreFactory(hz, es);
// ストレージは Hazelcast、イベントは Redis Streams

---

RedisStoreFactory

RedisStoreFactory(RedissonClient redissonClient)

を使用してファクトリを作成します Redis ストレージ とデフォルトの RedissonPubSubEventStore （Redis Pub/Sub）。

RedissonClient redis = Redisson.create();
StoreFactory sf = new RedisStoreFactory(redis);
// Redis ストレージ + Redis Pub/Sub イベント

---

RedisStoreFactory(RedissonClient redissonClient, EventStore eventStore)

を使用してファクトリを作成します Redis ストレージ と カスタム EventStore.

RedissonClient redis = Redisson.create();
EventStore es = new NatsEventStore(...);
StoreFactory sf = new RedisStoreFactory(redis, es);
// Redis マップ + イベントは NATS

---

ストレージとイベントバックエンドの組み合わせ

ストレージ（StoreFactory)	イベント（EventStore)	例
メモリ	Kafka	new MemoryStoreFactory(new KafkaEventStore(...))
Redis	NATS	new RedisStoreFactory(redis, new NatsEventStore(...))
Hazelcast	Redis Streams	new HazelcastStoreFactory(hz, new RedisStreamEventStore(...))
メモリ	メモリ	new MemoryStoreFactory()
Hazelcast	Kafka	new HazelcastStoreFactory(hz, new KafkaEventStore(...))

---

最小限のサーバー使用例

Configuration cfg = new Configuration();
// その他の設定
cfg.setStoreFactory(new HazelcastStoreFactory(hz, new KafkaEventStore(...)));
SocketIOServer server = new SocketIOServer(cfg);
server.start();

---

コンセプトの要約

StoreFactory どこにセッションごとのデータが保存されるかを決定します。 EventStore サーバー間でイベントがどのように伝播するかを決定します。 両方とも 設定可能で差し替え可能です。アプリケーションコードを変更することなく。