1.2.16

1.支持多集群客户端，服务端
2.支持统计用户在系统精准的使用时间

src/main/java/com/github/sseserver/local/LocalController.java

@@ -56,6 +56,9 @@ public void registerInstance() {
  }
  InetSocketAddress address = httpServer.getAddress();
  ServiceDiscoveryService discoveryService = discoverySupplier.get();
+ if (discoveryService == null) {
+ return;
+ }
  for (int i = 0, retry = 3; i < retry; i++) {
  try {
  discoveryService.registerInstance(address.getAddress().getHostAddress(), address.getPort());

src/main/java/com/github/sseserver/qos/Message.java

@@ -13,7 +13,7 @@ public interface Message extends Serializable {
  int FILTER_CHANNEL = (1 << 5);
 
  static String newId(String type, String serverId) {
- return type + "" + serverId + "-" + SnowflakeIdWorker.INSTANCE.nextId();
+ return type + serverId + "-" + SnowflakeIdWorker.INSTANCE.nextId();
  }
 
  String getListenerName();

src/main/java/com/github/sseserver/springboot/SseServerProperties.java

@@ -40,7 +40,6 @@ public enum ClusterRoleEnum {
  SseServerBeanDefinitionRegistrar.registerAtLeastOnce
  )),
  CLIENT(Arrays.asList(
- SseServerBeanDefinitionRegistrar.registerLocalMessageRepository,
  SseServerBeanDefinitionRegistrar.registerClusterConnectionService,
  SseServerBeanDefinitionRegistrar.registerClusterMessageRepository,
  SseServerBeanDefinitionRegistrar.registerServiceDiscoveryService,

src/test/resources/application.yaml

@@ -13,6 +13,13 @@ spring:
  sse-server:
  remote:
  enabled: true
+ cluster:
+ c1:
+ role: client
+ redis:
+ redis-connection-factory-bean-name: c1redis
+ c2:
+ role: server
 
  redis:
  host: localhost