search

turms-im / turms

🕊️ The world's most advanced open source instant messaging engine for 100K~10M concurrent users https://turms-im.github.io/docs
Apache License 2.0
1.73k stars 267 forks source link

Run it with idea，can't start it #1478

Closed nikohpng closed 3 months ago

nikohpng commented 3 months ago

Question

I run it in windows with idea, but I can't start gateway.

Is there a document that can explain how to run it?

Configure

I pull from lastest develop branch，configure only modify redis and mongodb uri like this

gateway application.yml

turms:
  cluster:
    connection:
      client:
        ssl:
          enabled: false # Enable SSL if needed
          enabled-protocols: TLSv1.2,TLSv1.3
          key-store: classpath:keystore-test.p12 # keytool -genkeypair -keyalg RSA -keysize 2048 -validity 3650 -alias turms -keystore keystore-test.p12 -storetype PKCS12 -storepass imturms
          key-store-type: PKCS12
          key-store-password: imturms
          key-alias: turms
      server:
        ssl:
          enabled: false # Enable SSL if needed
          enabled-protocols: TLSv1.2,TLSv1.3
          key-store: classpath:keystore-test.p12 # keytool -genkeypair -keyalg RSA -keysize 2048 -validity 3650 -alias turms -keystore keystore-test.p12 -storetype PKCS12 -storepass imturms
          key-store-type: PKCS12
          key-store-password: imturms
          key-alias: turms
  gateway:
    websocket:
      enabled: true
      port: 10510
      ssl:
        enabled: false # Enable SSL if needed. Make sure to mutate HTTP requests to HTTPS requests, or Netty will throw NotSslRecordException
        enabled-protocols: TLSv1.2,TLSv1.3
        key-store: classpath:keystore-test.p12 # keytool -genkeypair -keyalg RSA -keysize 2048 -validity 3650 -alias turms -keystore keystore-test.p12 -storetype PKCS12 -storepass imturms
        key-store-type: PKCS12
        key-store-password: imturms
        key-alias: turms
    tcp:
      port: 11510
      ssl:
        enabled: false # Enable SSL if needed
        enabled-protocols: TLSv1.2,TLSv1.3
        key-store: classpath:keystore-test.p12 # keytool -genkeypair -keyalg RSA -keysize 2048 -validity 3650 -alias turms -keystore keystore-test.p12 -storetype PKCS12 -storepass imturms
        key-store-type: PKCS12
        key-store-password: imturms
        key-alias: turms
    udp:
      # Disable UDP currently until clients support UDP
      enabled: false
      port: 12510

# Spring configuration
spring:
  profiles:
    active: dev
  autoconfigure:
    exclude:
      - org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration
      - org.springframework.boot.autoconfigure.mongo.MongoReactiveAutoConfiguration
      - org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration
      - org.springframework.boot.autoconfigure.data.redis.RedisReactiveAutoConfiguration
  netty:
    leak-detection: simple

gateway application-dev.yaml

spring:
  netty:
    leak-detection: paranoid

############################### Turms ###############################

turms:
  cluster:
    connection:
      server:
        port-auto-increment: true
    shared-config:
      mongo:
        uri: mongodb://192.168.31.10:27017/turms-config-dev
  gateway:
    admin-api:
      debug:
        enabled: true
    client-api:
      logging:
        heartbeat-sample-rate: 1
        included-notification-categories:
          - category: all
      return-reason-for-server-error: true
    fake:
      enabled: true
    mongo:
      admin:
        uri: mongodb://192.168.31.10:27017/turms-dev
      user:
        uri: mongodb://192.168.31.10:27017/turms-dev
    redis:
      session:
        uri-list: redis://192.168.31.10
      location:
        uri-list: redis://192.168.31.10
      user-id-blocklist:
        uri: redis://192.168.31.10
      ip-blocklist:
        uri: redis://192.168.31.10
  logging:
    console:
      enabled: true
  plugin:
    js:
      debug:
        enabled: true

Error log

D:\Env\Java\jdk-21.0.3\bin\java.exe -XX:TieredStopAtLevel=1 -Dspring.output.ansi.enabled=always -Dcom.sun.management.jmxremote -Dspring.jmx.enabled=true -Dspring.liveBeansView.mbeanDomain -Dspring.application.admin.enabled=true "-Dmanagement.endpoints.jmx.exposure.include=*" -javaagent:D:\Install\IDE\ideaIU-2024.1.3.win\lib\idea_rt.jar=31239:D:\Install\IDE\ideaIU-2024.1.3.win\bin -Dfile.encoding=UTF-8 -Dsun.stdout.encoding=UTF-8 -Dsun.stderr.encoding=UTF-8 -classpath D:\WorkSpace\Im\turms\turms-gateway\target\classes;D:\WorkSpace\Im\turms\turms-server-common\target\classes;C:\Users\heping\.m2\repository\org\springframework\boot\spring-boot-starter\3.2.4\spring-boot-starter-3.2.4.jar;C:\Users\heping\.m2\repository\org\springframework\boot\spring-boot\3.2.4\spring-boot-3.2.4.jar;C:\Users\heping\.m2\repository\org\springframework\spring-context\6.1.5\spring-context-6.1.5.jar;C:\Users\heping\.m2\repository\org\springframework\spring-aop\6.1.5\spring-aop-6.1.5.jar;C:\Users\heping\.m2\repository\org\springframework\spring-beans\6.1.5\spring-beans-6.1.5.jar;C:\Users\heping\.m2\repository\org\springframework\spring-expression\6.1.5\spring-expression-6.1.5.jar;C:\Users\heping\.m2\repository\org\springframework\boot\spring-boot-autoconfigure\3.2.4\spring-boot-autoconfigure-3.2.4.jar;C:\Users\heping\.m2\repository\jakarta\annotation\jakarta.annotation-api\2.1.1\jakarta.annotation-api-2.1.1.jar;C:\Users\heping\.m2\repository\org\springframework\spring-core\6.1.5\spring-core-6.1.5.jar;C:\Users\heping\.m2\repository\org\springframework\spring-jcl\6.1.5\spring-jcl-6.1.5.jar;C:\Users\heping\.m2\repository\org\yaml\snakeyaml\2.2\snakeyaml-2.2.jar;C:\Users\heping\.m2\repository\io\projectreactor\netty\reactor-netty\1.1.17\reactor-netty-1.1.17.jar;C:\Users\heping\.m2\repository\io\projectreactor\netty\reactor-netty-core\1.1.17\reactor-netty-core-1.1.17.jar;C:\Users\heping\.m2\repository\io\netty\netty-handler-proxy\4.1.107.Final\netty-handler-proxy-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-codec-socks\4.1.107.Final\netty-codec-socks-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-resolver-dns\4.1.107.Final\netty-resolver-dns-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-codec-dns\4.1.107.Final\netty-codec-dns-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-resolver-dns-native-macos\4.1.107.Final\netty-resolver-dns-native-macos-4.1.107.Final-osx-x86_64.jar;C:\Users\heping\.m2\repository\io\netty\netty-resolver-dns-classes-macos\4.1.107.Final\netty-resolver-dns-classes-macos-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-transport-native-epoll\4.1.107.Final\netty-transport-native-epoll-4.1.107.Final-linux-x86_64.jar;C:\Users\heping\.m2\repository\io\netty\netty-transport-classes-epoll\4.1.107.Final\netty-transport-classes-epoll-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\projectreactor\netty\reactor-netty-http\1.1.17\reactor-netty-http-1.1.17.jar;C:\Users\heping\.m2\repository\io\netty\netty-codec-http\4.1.107.Final\netty-codec-http-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-codec-http2\4.1.107.Final\netty-codec-http2-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\swagger\core\v3\swagger-core-jakarta\2.2.20\swagger-core-jakarta-2.2.20.jar;C:\Users\heping\.m2\repository\org\apache\commons\commons-lang3\3.13.0\commons-lang3-3.13.0.jar;C:\Users\heping\.m2\repository\org\slf4j\slf4j-api\2.0.12\slf4j-api-2.0.12.jar;C:\Users\heping\.m2\repository\io\swagger\core\v3\swagger-annotations-jakarta\2.2.20\swagger-annotations-jakarta-2.2.20.jar;C:\Users\heping\.m2\repository\io\swagger\core\v3\swagger-models-jakarta\2.2.20\swagger-models-jakarta-2.2.20.jar;C:\Users\heping\.m2\repository\jakarta\xml\bind\jakarta.xml.bind-api\4.0.2\jakarta.xml.bind-api-4.0.2.jar;C:\Users\heping\.m2\repository\jakarta\activation\jakarta.activation-api\2.1.3\jakarta.activation-api-2.1.3.jar;C:\Users\heping\.m2\repository\com\fasterxml\jackson\core\jackson-annotations\2.15.4\jackson-annotations-2.15.4.jar;C:\Users\heping\.m2\repository\org\webjars\swagger-ui\5.11.10\swagger-ui-5.11.10.jar;C:\Users\heping\.m2\repository\org\webjars\webjars-locator-core\0.55\webjars-locator-core-0.55.jar;C:\Users\heping\.m2\repository\io\github\classgraph\classgraph\4.8.149\classgraph-4.8.149.jar;C:\Users\heping\.m2\repository\org\mongodb\bson\4.11.1\bson-4.11.1.jar;C:\Users\heping\.m2\repository\org\mongodb\mongodb-driver-core\4.11.1\mongodb-driver-core-4.11.1.jar;C:\Users\heping\.m2\repository\org\mongodb\bson-record-codec\4.11.1\bson-record-codec-4.11.1.jar;C:\Users\heping\.m2\repository\org\mongodb\mongodb-driver-reactivestreams\4.11.1\mongodb-driver-reactivestreams-4.11.1.jar;C:\Users\heping\.m2\repository\org\reactivestreams\reactive-streams\1.0.4\reactive-streams-1.0.4.jar;C:\Users\heping\.m2\repository\io\projectreactor\reactor-core\3.6.4\reactor-core-3.6.4.jar;C:\Users\heping\.m2\repository\io\lettuce\lettuce-core\6.3.2.RELEASE\lettuce-core-6.3.2.RELEASE.jar;C:\Users\heping\.m2\repository\io\netty\netty-common\4.1.107.Final\netty-common-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-handler\4.1.107.Final\netty-handler-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-transport-native-unix-common\4.1.107.Final\netty-transport-native-unix-common-4.1.107.Final.jar;C:\Users\heping\.m2\repository\com\github\ben-manes\caffeine\caffeine\3.1.8\caffeine-3.1.8.jar;C:\Users\heping\.m2\repository\org\checkerframework\checker-qual\3.37.0\checker-qual-3.37.0.jar;C:\Users\heping\.m2\repository\com\google\errorprone\error_prone_annotations\2.21.1\error_prone_annotations-2.21.1.jar;C:\Users\heping\.m2\repository\org\eclipse\collections\eclipse-collections-api\11.1.0\eclipse-collections-api-11.1.0.jar;C:\Users\heping\.m2\repository\org\eclipse\collections\eclipse-collections\11.1.0\eclipse-collections-11.1.0.jar;C:\Users\heping\.m2\repository\com\fasterxml\jackson\module\jackson-module-parameter-names\2.15.4\jackson-module-parameter-names-2.15.4.jar;C:\Users\heping\.m2\repository\org\jctools\jctools-core\4.0.3\jctools-core-4.0.3.jar;C:\Users\heping\.m2\repository\com\google\protobuf\protobuf-java\4.27.0\protobuf-java-4.27.0.jar;C:\Users\heping\.m2\repository\io\projectreactor\addons\reactor-extra\3.5.1\reactor-extra-3.5.1.jar;C:\Users\heping\.m2\repository\io\micrometer\micrometer-registry-prometheus\1.12.4\micrometer-registry-prometheus-1.12.4.jar;C:\Users\heping\.m2\repository\io\micrometer\micrometer-core\1.12.4\micrometer-core-1.12.4.jar;C:\Users\heping\.m2\repository\io\micrometer\micrometer-commons\1.12.4\micrometer-commons-1.12.4.jar;C:\Users\heping\.m2\repository\io\micrometer\micrometer-observation\1.12.4\micrometer-observation-1.12.4.jar;C:\Users\heping\.m2\repository\org\hdrhistogram\HdrHistogram\2.1.12\HdrHistogram-2.1.12.jar;C:\Users\heping\.m2\repository\org\latencyutils\LatencyUtils\2.0.3\LatencyUtils-2.0.3.jar;C:\Users\heping\.m2\repository\io\prometheus\simpleclient_common\0.16.0\simpleclient_common-0.16.0.jar;C:\Users\heping\.m2\repository\io\prometheus\simpleclient\0.16.0\simpleclient-0.16.0.jar;C:\Users\heping\.m2\repository\io\prometheus\simpleclient_tracer_otel\0.16.0\simpleclient_tracer_otel-0.16.0.jar;C:\Users\heping\.m2\repository\io\prometheus\simpleclient_tracer_common\0.16.0\simpleclient_tracer_common-0.16.0.jar;C:\Users\heping\.m2\repository\io\prometheus\simpleclient_tracer_otel_agent\0.16.0\simpleclient_tracer_otel_agent-0.16.0.jar;C:\Users\heping\.m2\repository\jakarta\validation\jakarta.validation-api\3.0.2\jakarta.validation-api-3.0.2.jar;C:\Users\heping\.m2\repository\io\netty\netty-codec-haproxy\4.1.107.Final\netty-codec-haproxy-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-buffer\4.1.107.Final\netty-buffer-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-transport\4.1.107.Final\netty-transport-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-resolver\4.1.107.Final\netty-resolver-4.1.107.Final.jar;C:\Users\heping\.m2\repository\io\netty\netty-codec\4.1.107.Final\netty-codec-4.1.107.Final.jar;C:\Users\heping\.m2\repository\com\fasterxml\jackson\core\jackson-core\2.15.4\jackson-core-2.15.4.jar;C:\Users\heping\.m2\repository\com\fasterxml\jackson\core\jackson-databind\2.15.4\jackson-databind-2.15.4.jar;C:\Users\heping\.m2\repository\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.15.4\jackson-datatype-jsr310-2.15.4.jar;C:\Users\heping\.m2\repository\com\fasterxml\jackson\dataformat\jackson-dataformat-yaml\2.15.4\jackson-dataformat-yaml-2.15.4.jar;C:\Users\heping\.m2\repository\org\projectlombok\lombok\1.18.30\lombok-1.18.30.jar im.turms.gateway.TurmsGatewayApplication
2024-06-12 09:04:16.523  INFO G dczczehr                     main im.turms.gateway.TurmsGatewayApplication : Starting TurmsGatewayApplication using Java 21.0.3 with PID 6692 (D:\WorkSpace\Im\turms\turms-gateway\target\classes started by heping in D:\WorkSpace\Im\turms)
2024-06-12 09:04:16.541  INFO G dczczehr                     main im.turms.gateway.TurmsGatewayApplication : The following 1 profile is active: "dev"
2024-06-12 09:04:16.736  WARN G dczczehr                     main      o.s.c.a.AnnotationBeanNameGenerator : Support for convention-based stereotype names is deprecated and will be removed in a future version of the framework. Please annotate the 'value' attribute in @im.turms.server.common.access.admin.web.annotation.RestController with @AliasFor(annotation=Component.class) to declare an explicit alias for @Component's 'value' attribute.
2024-06-12 09:04:18.208  WARN G dczczehr                     main      i.t.s.c.i.c.TurmsApplicationContext : The property "spring.config.location" is empty
2024-06-12 09:04:18.374  WARN G dczczehr                     main      i.t.s.c.i.c.TurmsApplicationContext : Could not find the file (git.properties), fall back to the default version 0.0.0 in non-production environments. Fix it by running "mvn compile"
2024-06-12 09:04:18.375  INFO G dczczehr                     main      i.t.s.c.i.c.TurmsApplicationContext : The local node with the build properties {version=0.0.0, commitId=, buildTime=} is running in a non-production environment
2024-06-12 09:04:19.376  INFO G dczczehr                     main             i.t.s.c.i.h.CpuHealthChecker : The CPU has become healthy. The current CPU load is: 0.0
2024-06-12 09:04:19.381  WARN G dczczehr                     main          i.t.s.c.i.h.MemoryHealthChecker : The max available memory (15342MB) is larger than the total of the available direct memory (3836MB), the max heap memory (4038MB), and the estimated max non-heap memory (256MB), which indicates that some memory will never be used by the server
2024-06-12 09:04:19.391  INFO G dczczehr                     main                       i.t.s.c.i.c.n.Node : The local node version is: 0.0.0
2024-06-12 09:04:19.575  WARN G dczczehr                     main         i.t.s.c.i.c.s.c.ConnectionServer : Failed to bind on the port: 7510. Trying to bind on the next port: 7511
reactor.netty.ChannelBindException: Failed to bind on [0.0.0.0:7510]

    suppressed: java.lang.Exception: #block terminated with an error
        at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:146)
        at reactor.core.publisher.Mono.block(Mono.java:1807)
        at reactor.netty.transport.ServerTransport.bindNow(ServerTransport.java:149)
        at im.turms.server.common.infra.cluster.service.connection.ConnectionServer.blockUntilConnect(ConnectionServer.java:99)
        at im.turms.server.common.infra.cluster.service.connection.ConnectionService.setupServer(ConnectionService.java:246)
        at im.turms.server.common.infra.cluster.service.connection.ConnectionService.<init>(ConnectionService.java:149)
        at im.turms.server.common.infra.cluster.node.Node.<init>(Node.java:147)
        at im.turms.server.common.infra.cluster.ClusterConfig.node(ClusterConfig.java:49)
        at im.turms.server.common.infra.cluster.ClusterConfig$$SpringCGLIB$$0.CGLIB$node$0(<generated>)
        at im.turms.server.common.infra.cluster.ClusterConfig$$SpringCGLIB$$FastClass$$1.invoke(<generated>)
        at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:258)
        at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:331)
        at im.turms.server.common.infra.cluster.ClusterConfig$$SpringCGLIB$$0.node(<generated>)
        at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
        at java.lang.reflect.Method.invoke(Method.java:580)
        at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:140)
        at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:644)
        at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:636)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1335)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1165)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
        at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:326)
        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:324)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
        at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:254)
        at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1443)
        at org.springframework.context.annotation.ContextAnnotationAutowireCandidateResolver$1.getTarget(ContextAnnotationAutowireCandidateResolver.java:103)
        at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:701)
        at im.turms.server.common.infra.cluster.node.Node$$SpringCGLIB$$0.getSharedProperties(<generated>)
        at im.turms.server.common.infra.property.TurmsPropertiesManager.getGlobalProperties(TurmsPropertiesManager.java:96)
        at im.turms.gateway.access.admin.throttle.AdminApiRateLimitingManager.<init>(AdminApiRateLimitingManager.java:36)
        at jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:62)
        at java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:502)
        at java.lang.reflect.Constructor.newInstance(Constructor.java:486)
        at org.springframework.beans.BeanUtils.instantiateClass(BeanUtils.java:208)
        at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:111)
        at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:315)
        at org.springframework.beans.factory.support.ConstructorResolver.autowireConstructor(ConstructorResolver.java:306)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.autowireConstructor(AbstractAutowireCapableBeanFactory.java:1355)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1192)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
        at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:326)
        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:324)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
        at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:975)
        at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:962)
        at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:624)
        at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754)
        at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:456)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:334)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:1354)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:1343)
        at im.turms.server.common.BaseTurmsApplication.bootstrap(BaseTurmsApplication.java:53)
        at im.turms.gateway.TurmsGatewayApplication.main(TurmsGatewayApplication.java:42)

2024-06-12 09:04:19.605  INFO G dczczehr                     main         i.t.s.c.i.c.s.c.ConnectionServer : The local node server started on: 0.0.0.0:7511
2024-06-12 09:04:19.806  INFO G dczczehr                     main                org.mongodb.driver.client : MongoClient with metadata {"driver": {"name": "mongo-java-driver|reactive-streams", "version": "4.11.1"}, "os": {"type": "Windows", "name": "Windows 11", "architecture": "amd64", "version": "10.0"}, "platform": "Java/Oracle Corporation/21.0.3+7-LTS-152"} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=null, transportSettings=NettyTransportSettings{eventLoopGroup=io.netty.channel.nio.NioEventLoopGroup@7e3236d, socketChannelClass=class io.netty.channel.socket.nio.NioSocketChannel, allocator=PooledByteBufAllocator(directByDefault: true), sslContext=null}, streamFactoryFactory=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DocumentCodecProvider{}, MapCodecProvider{}, IterableCodecProvider{}, Jsr310CodecProvider{}, BsonCodecProvider{}, im.turms.server.common.storage.mongo.codec.MongoCodecProvider@38a4e2b0]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[192.168.31.10:27017], srvServiceName=mongodb, mode=SINGLE, requiredClusterType=UNKNOWN, requiredReplicaSetName='null', serverSelector='null', clusterListeners='[im.turms.server.common.storage.mongo.MongoContext$1@14c99bf6]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=false, invalidHostNameAllowed=false, context=null}, applicationName='null', compressorList=[], uuidRepresentation=UNSPECIFIED, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null}
2024-06-12 09:04:19.851  INFO G dczczehr                     cluster-ClusterId{value='66696493421dd76345833161', description='null'}-192.168.31.10:27017               org.mongodb.driver.cluster : Monitor thread successfully connected to server with description ServerDescription{address=192.168.31.10:27017, type=SHARD_ROUTER, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=21, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=43731799}
2024-06-12 09:04:20.001  INFO G dczczehr                     mongo-event-loop-10-3       i.t.s.c.s.m.o.TurmsMongoOperations : Indexed the collection "leader": {"renewDate": 1}
2024-06-12 09:04:20.006  INFO G dczczehr                     mongo-event-loop-10-3       i.t.s.c.s.m.o.TurmsMongoOperations : Indexed the collection "member": {"_id.nodeId": 1}, {"status.lastHeartbeatDate": 1}
2024-06-12 09:04:20.015  INFO G dczczehr                     mongo-event-loop-10-3       i.t.s.c.s.m.o.TurmsMongoOperations : Enabled sharding the database: "turms-config-dev"
2024-06-12 09:04:20.061  INFO G dczczehr                     main    i.t.s.c.i.c.s.c.SharedPropertyService : Fetching shared properties
2024-06-12 09:04:20.170  INFO G dczczehr                     mongo-event-loop-10-3    i.t.s.c.i.c.s.c.SharedPropertyService : Fetched shared properties
2024-06-12 09:04:20.199  INFO G dczczehr                     main         i.t.s.c.i.c.s.d.DiscoveryService : A new member has been added: Member(key=Member.Key(clusterId=turms, nodeId=pmbgnxiy), zone=, name=pmbgnxiy, nodeVersion=0.0.0, nodeType=SERVICE, isSeed=false, registrationDate=Wed Jun 12 09:03:56 UTC 2024, isLeaderEligible=true, priority=0, memberHost=192.168.31.116, memberPort=7510, adminApiAddress=http://192.168.31.116:8510, wsAddress=null, tcpAddress=null, udpAddress=null, status=Member.MemberStatus(hasJoinedCluster=true, isHealthy=true, isActive=true, lastHeartbeatDate=Wed Jun 12 09:04:16 UTC 2024))
2024-06-12 09:04:20.200  INFO G dczczehr                     main         i.t.s.c.i.c.s.d.DiscoveryService : A new member has been added: Member(key=Member.Key(clusterId=turms, nodeId=dczczehr), zone=, name=dczczehr, nodeVersion=0.0.0, nodeType=GATEWAY, isSeed=false, registrationDate=Wed Jun 12 09:04:20 UTC 2024, isLeaderEligible=false, priority=0, memberHost=192.168.31.116, memberPort=7511, adminApiAddress=http://192.168.31.116:9510, wsAddress=ws://192.168.31.116:10510, tcpAddress=192.168.31.116:11510, udpAddress=null, status=Member.MemberStatus(hasJoinedCluster=false, isHealthy=true, isActive=true, lastHeartbeatDate=Wed Jun 12 09:04:20 UTC 2024))
2024-06-12 09:04:20.200  INFO G dczczehr                     main   i.t.s.c.i.c.s.d.LocalNodeStatusManager : Registering the local node as a member
2024-06-12 09:04:20.226  INFO G dczczehr                     mongo-event-loop-10-6   i.t.s.c.i.c.s.d.LocalNodeStatusManager : Registered the local node as a member
2024-06-12 09:04:20.741  INFO G dczczehr                     main                org.mongodb.driver.client : MongoClient with metadata {"driver": {"name": "mongo-java-driver|reactive-streams", "version": "4.11.1"}, "os": {"type": "Windows", "name": "Windows 11", "architecture": "amd64", "version": "10.0"}, "platform": "Java/Oracle Corporation/21.0.3+7-LTS-152"} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=null, transportSettings=NettyTransportSettings{eventLoopGroup=io.netty.channel.nio.NioEventLoopGroup@478530cb, socketChannelClass=class io.netty.channel.socket.nio.NioSocketChannel, allocator=PooledByteBufAllocator(directByDefault: true), sslContext=null}, streamFactoryFactory=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DocumentCodecProvider{}, MapCodecProvider{}, IterableCodecProvider{}, Jsr310CodecProvider{}, BsonCodecProvider{}, im.turms.server.common.storage.mongo.codec.MongoCodecProvider@38a4e2b0]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[192.168.31.10:27017], srvServiceName=mongodb, mode=SINGLE, requiredClusterType=UNKNOWN, requiredReplicaSetName='null', serverSelector='null', clusterListeners='[im.turms.server.common.storage.mongo.MongoContext$1@5be7b749]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=false, invalidHostNameAllowed=false, context=null}, applicationName='null', compressorList=[], uuidRepresentation=UNSPECIFIED, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null}
2024-06-12 09:04:20.749  INFO G dczczehr                     cluster-ClusterId{value='66696494421dd76345833162', description='null'}-192.168.31.10:27017               org.mongodb.driver.cluster : Monitor thread successfully connected to server with description ServerDescription{address=192.168.31.10:27017, type=SHARD_ROUTER, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=21, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=5158900}
2024-06-12 09:04:20.861  INFO G dczczehr                     main    i.t.s.c.d.b.m.BlocklistServiceManager : Starting resetting and synchronizing blocked clients
2024-06-12 09:04:20.874  INFO G dczczehr                     lettuce-nioEventLoop-19-1    i.t.s.c.d.b.m.BlocklistServiceManager : Reset and synchronized blocked clients
2024-06-12 09:04:20.875  INFO G dczczehr                     main    i.t.s.c.d.b.m.BlocklistServiceManager : Starting resetting and synchronizing blocked clients
2024-06-12 09:04:20.879  INFO G dczczehr                     lettuce-nioEventLoop-22-1    i.t.s.c.d.b.m.BlocklistServiceManager : Reset and synchronized blocked clients
2024-06-12 09:04:20.937  INFO G dczczehr                     main      i.t.g.a.c.t.TcpUserSessionAssembler : TCP server started on: 0:0:0:0:0:0:0:0:11510
2024-06-12 09:04:21.033  INFO G dczczehr                     main  t.g.a.c.w.WebSocketUserSessionAssembler : WebSocket server started on: 0:0:0:0:0:0:0:0:10510
2024-06-12 09:04:21.044  INFO G dczczehr                     main       i.t.s.c.d.a.s.BaseAdminRoleService : Loading all admin roles
2024-06-12 09:04:21.064  INFO G dczczehr                     main       i.t.s.c.d.a.s.BaseAdminRoleService : Loaded all admin roles
2024-06-12 09:04:21.071  INFO G dczczehr                     main           i.t.s.c.d.a.s.BaseAdminService : Loading all admins
2024-06-12 09:04:21.075  INFO G dczczehr                     turms-node-connection-server-worker-7-1        i.t.s.c.i.c.s.c.ConnectionService : [Server] Connected to the member
2024-06-12 09:04:21.087  INFO G dczczehr                     main           i.t.s.c.d.a.s.BaseAdminService : Loaded all admins
2024-06-12 09:04:21.107  INFO G dczczehr                     main            i.t.g.i.f.ClientFakingManager : Preparing clients
2024-06-12 09:04:21.110  INFO G dczczehr 7265123672759927483 turms-node-connection-server-worker-7-1        i.t.s.c.i.c.s.c.ConnectionService : [Server] Completed the opening handshake with the member: pmbgnxiy[192.168.31.116:7510]
2024-06-12 09:04:21.183  WARN G dczczehr                     main           i.t.s.c.d.d.a.a.s.DebugService : API debug is enabled
2024-06-12 09:04:21.723  WARN G dczczehr                     main s.c.a.AnnotationConfigApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'outboundMessageManager' defined in file [D:\WorkSpace\Im\turms\turms-server-common\target\classes\im\turms\server\common\infra\message\OutboundMessageManager.class]: Unsatisfied dependency expressed through constructor parameter 2: No qualifying bean of type 'im.turms.server.common.infra.logging.BaseNotificationLoggingManager' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {}
2024-06-12 09:04:21.753  INFO G dczczehr                     main  s.b.a.l.ConditionEvaluationReportLogger : 

Error starting ApplicationContext. To display the condition evaluation report re-run your application with 'debug' enabled.
2024-06-12 09:04:21.808 ERROR G dczczehr                     main   o.s.b.d.LoggingFailureAnalysisReporter : 

***************************
APPLICATION FAILED TO START
***************************

Description:

Parameter 2 of constructor in im.turms.server.common.infra.message.OutboundMessageManager required a bean of type 'im.turms.server.common.infra.logging.BaseNotificationLoggingManager' that could not be found.

Action:

Consider defining a bean of type 'im.turms.server.common.infra.logging.BaseNotificationLoggingManager' in your configuration.

Process finished with exit code 1
JamesChenX commented 3 months ago

Thanks for pointing it out. It occurs because I forgot to commit a new file, and you can pull the latest code on develop or master to fix it.

lovemianhuatang commented 3 months ago

@JamesChenX 类似的错误

2024-06-22 16:50:21.798  WARN G efazdrer                     main          i.t.s.c.i.h.MemoryHealthChecker : The max available memory (31129MB) is larger than the total of the available direct memory (7782MB), the max heap memory (8192MB), and the estimated max non-heap memory (256MB), which indicates that some memory will never be used by the server
2024-06-22 16:50:21.801  INFO G efazdrer                     main                       i.t.s.c.i.c.n.Node : The local node version is: 0.0.0
2024-06-22 16:50:21.801  WARN G efazdrer                     turms-health-checker-1-1          i.t.s.c.i.h.MemoryHealthChecker : Used system memory: 32687MB/32768MB; Used available memory: 98MB/31129MB; Used direct memory: 5MB/7782MB/8192MB; Used heap memory: 47MB/8192MB; Used non-heap memory: 46MB
2024-06-22 16:50:21.857  WARN G efazdrer                     main         i.t.s.c.i.c.s.c.ConnectionServer : Failed to bind on the port: 7510. Trying to bind on the next port: 7511
reactor.netty.ChannelBindException: Failed to bind on [0.0.0.0:7510]

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoCreate] :
    reactor.core.publisher.Mono.create(Mono.java:203)
    reactor.netty.transport.ServerTransport.bind(ServerTransport.java:91)
Error has been observed at the following site(s):
    *__Mono.create ⇢ at reactor.netty.transport.ServerTransport.bind(ServerTransport.java:91)
Original Stack Trace:
    suppressed: java.lang.Exception: #block terminated with an error
        at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:146)
        at reactor.core.publisher.Mono.block(Mono.java:1807)
        at reactor.netty.transport.ServerTransport.bindNow(ServerTransport.java:149)
        at im.turms.server.common.infra.cluster.service.connection.ConnectionServer.blockUntilConnect(ConnectionServer.java:99)
        at im.turms.server.common.infra.cluster.service.connection.ConnectionService.setupServer(ConnectionService.java:246)
        at im.turms.server.common.infra.cluster.service.connection.ConnectionService.<init>(ConnectionService.java:149)
        at im.turms.server.common.infra.cluster.node.Node.<init>(Node.java:147)
        at im.turms.server.common.infra.cluster.ClusterConfig.node(ClusterConfig.java:49)
        at im.turms.server.common.infra.cluster.ClusterConfig$$SpringCGLIB$$0.CGLIB$node$0(<generated>)
        at im.turms.server.common.infra.cluster.ClusterConfig$$SpringCGLIB$$FastClass$$1.invoke(<generated>)
        at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:258)
        at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:331)
        at im.turms.server.common.infra.cluster.ClusterConfig$$SpringCGLIB$$0.node(<generated>)
        at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
        at java.lang.reflect.Method.invoke(Method.java:580)
        at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:140)
        at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:644)
        at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:636)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1335)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1165)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
        at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:326)
        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:324)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
        at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:254)
        at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1443)
        at org.springframework.context.annotation.ContextAnnotationAutowireCandidateResolver$1.getTarget(ContextAnnotationAutowireCandidateResolver.java:103)
        at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:701)
        at im.turms.server.common.infra.cluster.node.Node$$SpringCGLIB$$0.getSharedProperties(<generated>)
        at im.turms.server.common.infra.property.TurmsPropertiesManager.getGlobalProperties(TurmsPropertiesManager.java:96)
        at im.turms.gateway.access.admin.throttle.AdminApiRateLimitingManager.<init>(AdminApiRateLimitingManager.java:36)
        at jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:62)
        at java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:502)
        at java.lang.reflect.Constructor.newInstance(Constructor.java:486)
        at org.springframework.beans.BeanUtils.instantiateClass(BeanUtils.java:208)
        at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:111)
        at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:315)
        at org.springframework.beans.factory.support.ConstructorResolver.autowireConstructor(ConstructorResolver.java:306)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.autowireConstructor(AbstractAutowireCapableBeanFactory.java:1355)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1192)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
        at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:326)
        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:324)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
        at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:975)
        at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:962)
        at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:624)
        at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754)
        at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:456)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:334)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:1354)
        at org.springframework.boot.SpringApplication.run(SpringApplication.java:1343)
        at im.turms.server.common.BaseTurmsApplication.bootstrap(BaseTurmsApplication.java:53)
        at im.turms.gateway.TurmsGatewayApplication.main(TurmsGatewayApplication.java:42)

2024-06-22 16:50:21.858  INFO G efazdrer                     main         i.t.s.c.i.c.s.c.ConnectionServer : The local node server started on: 0.0.0.0:7511
2024-06-22 16:50:21.922  INFO G efazdrer                     main                org.mongodb.driver.client : MongoClient with metadata {"driver": {"name": "mongo-java-driver|reactive-streams", "version": "4.11.1"}, "os": {"type": "Darwin", "name": "Mac OS X", "architecture": "aarch64", "version": "14.5"}, "platform": "Java/Oracle Corporation/21.0.2+13-58"} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=null, transportSettings=NettyTransportSettings{eventLoopGroup=io.netty.channel.nio.NioEventLoopGroup@72ce812e, socketChannelClass=class io.netty.channel.socket.nio.NioSocketChannel, allocator=PooledByteBufAllocator(directByDefault: true), sslContext=null}, streamFactoryFactory=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DocumentCodecProvider{}, MapCodecProvider{}, IterableCodecProvider{}, Jsr310CodecProvider{}, BsonCodecProvider{}, im.turms.server.common.storage.mongo.codec.MongoCodecProvider@373afd6c]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[localhost:27017], srvServiceName=mongodb, mode=SINGLE, requiredClusterType=UNKNOWN, requiredReplicaSetName='null', serverSelector='null', clusterListeners='[im.turms.server.common.storage.mongo.MongoContext$1@521441d5]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=false, invalidHostNameAllowed=false, context=null}, applicationName='null', compressorList=[], uuidRepresentation=UNSPECIFIED, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null}
2024-06-22 16:50:21.940  INFO G efazdrer                     cluster-ClusterId{value='667700cd34e1d623af9406f2', description='null'}-localhost:27017               org.mongodb.driver.cluster : Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=SHARD_ROUTER, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=16729416}
2024-06-22 16:50:22.003  INFO G efazdrer                     mongo-event-loop-10-3       i.t.s.c.s.m.o.TurmsMongoOperations : Indexed the collection "leader": {"renewDate": 1}
2024-06-22 16:50:22.006  INFO G efazdrer                     mongo-event-loop-10-3       i.t.s.c.s.m.o.TurmsMongoOperations : Indexed the collection "member": {"_id.nodeId": 1}, {"status.lastHeartbeatDate": 1}
2024-06-22 16:50:22.010  INFO G efazdrer                     mongo-event-loop-10-3       i.t.s.c.s.m.o.TurmsMongoOperations : Enabled sharding the database: "turms-config-dev"
2024-06-22 16:50:22.030  INFO G efazdrer                     main    i.t.s.c.i.c.s.c.SharedPropertyService : Fetching shared properties
2024-06-22 16:50:22.078  INFO G efazdrer                     mongo-event-loop-10-4    i.t.s.c.i.c.s.c.SharedPropertyService : Fetched shared properties
2024-06-22 16:50:22.093  INFO G efazdrer                     main         i.t.s.c.i.c.s.d.DiscoveryService : A new member has been added: Member(key=Member.Key(clusterId=turms, nodeId=hfpztyju), zone=, name=hfpztyju, nodeVersion=0.0.0, nodeType=SERVICE, isSeed=false, registrationDate=Sat Jun 22 16:49:29 UTC 2024, isLeaderEligible=true, priority=0, memberHost=192.168.31.53, memberPort=7510, adminApiAddress=http://192.168.31.53:8510, wsAddress=null, tcpAddress=null, udpAddress=null, status=Member.MemberStatus(hasJoinedCluster=true, isHealthy=true, isActive=true, lastHeartbeatDate=Sat Jun 22 16:50:19 UTC 2024))
2024-06-22 16:50:22.093  INFO G efazdrer                     main        i.t.s.c.i.c.s.c.ConnectionService : [Client] Connecting to the member: {id=hfpztyju, host=192.168.31.53, port=7510}. Retry times: 0
2024-06-22 16:50:22.112 ERROR G efazdrer                     main  i.n.r.d.DnsServerAddressStreamProviders : Unable to load io.netty.resolver.dns.macos.MacOSDnsServerAddressStreamProvider, fallback to system defaults. This may result in incorrect DNS resolutions on MacOS. Check whether you have a dependency on 'io.netty:netty-resolver-dns-native-macos'. Use DEBUG level to see the full stack: java.lang.UnsatisfiedLinkError: failed to load the required native library
2024-06-22 16:50:22.121  INFO G efazdrer                     main         i.t.s.c.i.c.s.d.DiscoveryService : A new member has been added: Member(key=Member.Key(clusterId=turms, nodeId=efazdrer), zone=, name=efazdrer, nodeVersion=0.0.0, nodeType=GATEWAY, isSeed=false, registrationDate=Sat Jun 22 16:50:22 UTC 2024, isLeaderEligible=false, priority=0, memberHost=192.168.31.53, memberPort=7511, adminApiAddress=http://192.168.31.53:9510, wsAddress=ws://192.168.31.53:10510, tcpAddress=192.168.31.53:11510, udpAddress=null, status=Member.MemberStatus(hasJoinedCluster=false, isHealthy=false, isActive=true, lastHeartbeatDate=Sat Jun 22 16:50:22 UTC 2024))
2024-06-22 16:50:22.121  INFO G efazdrer                     main   i.t.s.c.i.c.s.d.LocalNodeStatusManager : Registering the local node as a member
2024-06-22 16:50:22.135  INFO G efazdrer                     mongo-event-loop-10-6   i.t.s.c.i.c.s.d.LocalNodeStatusManager : Registered the local node as a member
2024-06-22 16:50:22.145  INFO G efazdrer                     turms-node-connection-client-io-2-1        i.t.s.c.i.c.s.c.ConnectionService : [Client] Connected to the member: {id=hfpztyju, host=192.168.31.53, port=7510}
2024-06-22 16:50:22.153  INFO G efazdrer                     turms-node-connection-client-io-2-1        i.t.s.c.i.c.s.c.ConnectionService : [Client] Sending an opening handshake request to the member: {id=hfpztyju, host=192.168.31.53, port=7510}
2024-06-22 16:50:22.171 ERROR G efazdrer                     turms-node-connection-client-io-2-1        i.t.s.c.i.c.s.c.ConnectionService : [Client] Failed to complete the opening handshake with the member: {id=hfpztyju, host=192.168.31.53, port=7510}. Closing connection to reconnect
java.lang.RuntimeException: Failure code: 3
    at im.turms.server.common.infra.cluster.service.connection.ConnectionService.lambda$connectMemberUntilSucceedOrRemoved0$7(ConnectionService.java:304)
    at reactor.core.publisher.LambdaMonoSubscriber.onNext(LambdaMonoSubscriber.java:171)
    at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:539)
    at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
    at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:539)
    at reactor.core.publisher.MonoMetricsFuseable$MetricsFuseableSubscriber.onNext(MonoMetricsFuseable.java:130)
    at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:539)
    at reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:99)
    at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.onNext(FluxTimeout.java:181)
    at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:539)
    at reactor.core.publisher.Operators$MonoInnerProducerBase.complete(Operators.java:2812)
    at reactor.core.publisher.SinkOneMulticast.tryEmitValue(SinkOneMulticast.java:66)
    at reactor.core.publisher.SinkOneSerialized.tryEmitValue(SinkOneSerialized.java:38)
    at im.turms.server.common.infra.cluster.service.rpc.RpcEndpoint.resolveRequest(RpcEndpoint.java:138)
    at im.turms.server.common.infra.cluster.service.rpc.RpcEndpoint.handleResponse(RpcEndpoint.java:126)
    at im.turms.server.common.infra.cluster.service.rpc.RpcService$1.onResponseReceived(RpcService.java:235)
    at im.turms.server.common.infra.cluster.service.rpc.RpcService$1.onDataReceived(RpcService.java:145)
    at im.turms.server.common.infra.cluster.service.connection.ConnectionService.lambda$onMemberConnectionAdded$14(ConnectionService.java:491)
    at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:185)
    at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:379)
    at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:426)
    at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:114)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
    at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
    at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
    at reactor.netty.channel.AbstractChannelMetricsHandler.channelRead(AbstractChannelMetricsHandler.java:148)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
    at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
    at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
    at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
    at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
    at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.172  INFO G efazdrer                     turms-node-connection-client-io-2-1        i.t.s.c.i.c.s.c.ConnectionService : [Client] The connection to the member {id=hfpztyju, host=192.168.31.53, port=7510} has been closed
2024-06-22 16:50:22.172  INFO G efazdrer                     turms-node-connection-client-io-2-1        i.t.s.c.i.c.s.c.ConnectionService : [Client] Try to reconnect the member {id=hfpztyju, host=192.168.31.53, port=7510} after 15000 millis
2024-06-22 16:50:22.339  INFO G efazdrer                     main                org.mongodb.driver.client : MongoClient with metadata {"driver": {"name": "mongo-java-driver|reactive-streams", "version": "4.11.1"}, "os": {"type": "Darwin", "name": "Mac OS X", "architecture": "aarch64", "version": "14.5"}, "platform": "Java/Oracle Corporation/21.0.2+13-58"} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=null, transportSettings=NettyTransportSettings{eventLoopGroup=io.netty.channel.nio.NioEventLoopGroup@56266bda, socketChannelClass=class io.netty.channel.socket.nio.NioSocketChannel, allocator=PooledByteBufAllocator(directByDefault: true), sslContext=null}, streamFactoryFactory=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DocumentCodecProvider{}, MapCodecProvider{}, IterableCodecProvider{}, Jsr310CodecProvider{}, BsonCodecProvider{}, im.turms.server.common.storage.mongo.codec.MongoCodecProvider@373afd6c]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[localhost:27017], srvServiceName=mongodb, mode=SINGLE, requiredClusterType=UNKNOWN, requiredReplicaSetName='null', serverSelector='null', clusterListeners='[im.turms.server.common.storage.mongo.MongoContext$1@18bb1b88]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=false, invalidHostNameAllowed=false, context=null}, applicationName='null', compressorList=[], uuidRepresentation=UNSPECIFIED, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null}
2024-06-22 16:50:22.343  INFO G efazdrer                     cluster-ClusterId{value='667700ce34e1d623af9406f3', description='null'}-localhost:27017               org.mongodb.driver.cluster : Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=SHARD_ROUTER, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=17, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=3156000}
2024-06-22 16:50:22.401  INFO G efazdrer                     main    i.t.s.c.d.b.m.BlocklistServiceManager : Starting resetting and synchronizing blocked clients
2024-06-22 16:50:22.411  INFO G efazdrer                     lettuce-nioEventLoop-19-1    i.t.s.c.d.b.m.BlocklistServiceManager : Reset and synchronized blocked clients
2024-06-22 16:50:22.411  INFO G efazdrer                     main    i.t.s.c.d.b.m.BlocklistServiceManager : Starting resetting and synchronizing blocked clients
2024-06-22 16:50:22.412  INFO G efazdrer                     lettuce-nioEventLoop-22-1    i.t.s.c.d.b.m.BlocklistServiceManager : Reset and synchronized blocked clients
2024-06-22 16:50:22.428  INFO G efazdrer                     main      i.t.g.a.c.t.TcpUserSessionAssembler : TCP server started on: 0:0:0:0:0:0:0:0:11510
2024-06-22 16:50:22.448  INFO G efazdrer                     main  t.g.a.c.w.WebSocketUserSessionAssembler : WebSocket server started on: 0:0:0:0:0:0:0:0:10510
2024-06-22 16:50:22.451  INFO G efazdrer                     main       i.t.s.c.d.a.s.BaseAdminRoleService : Loading all admin roles
2024-06-22 16:50:22.457  INFO G efazdrer                     main       i.t.s.c.d.a.s.BaseAdminRoleService : Loaded all admin roles
2024-06-22 16:50:22.459  INFO G efazdrer                     main           i.t.s.c.d.a.s.BaseAdminService : Loading all admins
2024-06-22 16:50:22.465  INFO G efazdrer                     main           i.t.s.c.d.a.s.BaseAdminService : Loaded all admins
2024-06-22 16:50:22.472  INFO G efazdrer                     main            i.t.g.i.f.ClientFakingManager : Preparing clients
2024-06-22 16:50:22.490  WARN G efazdrer                     main           i.t.s.c.d.d.a.a.s.DebugService : API debug is enabled
2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-5            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=103, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-4            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=102, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-6            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=104, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-3            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=101, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-2            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=100, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-1            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=109, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-9            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=107, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-8            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=106, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-7            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=105, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.582 ERROR G efazdrer                     turms-fake-client-nio-10            i.t.g.i.f.ClientFakingManager : Failed to establish the session: {user=108, device=DESKTOP}
java.io.IOException: Broken pipe
    at sun.nio.ch.SocketDispatcher.write0(native)

    suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Assembly trace from producer [reactor.core.publisher.MonoPeek] :
    reactor.core.publisher.Mono.doOnCancel(Mono.java:2688)
    reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
Error has been observed at the following site(s):
    *___Mono.doOnCancel ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:743)
    |_   Mono.doOnError ⇢ at reactor.netty.ReactorNetty$OutboundThen.<init>(ReactorNetty.java:744)
    *_________Mono.then ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.sendRequest(TurmsTcpClient.java:158)
    |_     Mono.flatMap ⇢ at im.turms.server.common.infra.client.TurmsTcpClient.login(TurmsTcpClient.java:115)
    *________Mono.defer ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    *_________Mono.then ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:137)
    |_ Mono.doOnSuccess ⇢ at im.turms.gateway.infra.fake.ClientFakingManager.prepareClients(ClientFakingManager.java:138)
Original Stack Trace:
        at sun.nio.ch.SocketDispatcher.write0(native)
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:62)
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:137)
        at sun.nio.ch.IOUtil.write(IOUtil.java:81)
        at sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:542)
        at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:415)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:355)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:935)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:921)
        at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:907)
        at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125)
        at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:939)
        at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:957)
        at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:982)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:950)
        at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:1000)
        at io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1025)
        at io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:306)
        at reactor.netty.channel.ChannelOperations.lambda$sendObject$2(ChannelOperations.java:321)
        at reactor.netty.FutureMono$DeferredFutureMono.subscribe(FutureMono.java:100)
        at reactor.core.publisher.Mono.subscribe(Mono.java:4568)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265)
        at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
        at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)
        at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)
        at reactor.core.publisher.SerializedSubscriber.onComplete(SerializedSubscriber.java:146)
        at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onComplete(FluxRetryWhen.java:204)
        at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)
        at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277)
        at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:177)
        at reactor.netty.resources.NewConnectionProvider$NewConnectionObserver.onStateChange(NewConnectionProvider.java:205)
        at reactor.netty.channel.ChannelOperationsHandler.channelActive(ChannelOperationsHandler.java:62)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:260)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.AbstractChannelHandlerContext.fireChannelActive(AbstractChannelHandlerContext.java:231)
        at io.netty.channel.DefaultChannelPipeline$HeadContext.channelActive(DefaultChannelPipeline.java:1398)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:258)
        at io.netty.channel.AbstractChannelHandlerContext.invokeChannelActive(AbstractChannelHandlerContext.java:238)
        at io.netty.channel.DefaultChannelPipeline.fireChannelActive(DefaultChannelPipeline.java:895)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:306)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:1583)

2024-06-22 16:50:22.583  INFO G efazdrer                     turms-fake-client-nio-10            i.t.g.i.f.ClientFakingManager : Prepared clients. Expected: 10. Prepared: 0
2024-06-22 16:50:22.583  INFO G efazdrer                     turms-fake-client-nio-10            i.t.g.i.f.ClientFakingManager : No available client to send random requests
2024-06-22 16:50:22.643  INFO G efazdrer                     main                i.t.s.c.i.p.PluginManager : All plugins are started
2024-06-22 16:50:22.643  INFO G efazdrer                     main im.turms.gateway.TurmsGatewayApplication : Started TurmsGatewayApplication in 2.14 seconds (process running for 2.53)
2024-06-22 16:50:25.140  WARN G efazdrer                     turms-health-checker-1-1          i.t.s.c.i.h.MemoryHealthChecker : Used system memory: 32682MB/32768MB; Used available memory: 215MB/31129MB; Used direct memory: 81MB/7782MB/8192MB; Used heap memory: 56MB/8192MB; Used non-heap memory: 78MB
2024-06-22 16:50:25.566  INFO G efazdrer  698782499061669836 turms-admin-http-worker-31-1 : |192.168.31.53|54984711-2|2024-06-22 16:50:25.552|getMetrics|{names=[jvm.gc.max.data.size, system.memory.total, system.cpu.usage, system.memory.free, jvm.gc.memory.promoted, jvm.memory.used, user.logged_in, jvm.classes.unloaded, jvm.threads.peak, jvm.gc.pause, turms.client.request, disk.free, jvm.buffer.total.capacity, jvm.buffer.memory.used, jvm.classes.loaded, disk.total, jvm.memory.committed, system.memory.swap.free, http.server.requests, user.online, process.cpu.usage, system.memory.swap.total, rpc.request, jvm.gc.live.data.size, jvm.threads.live, jvm.gc.memory.allocated, jvm.threads.daemon, jvm.memory.max, jvm.buffer.count], returnDescription=false, returnAvailableTags=false}|TRUE|10|
2024-06-22 16:50:25.651  INFO G efazdrer 4931689535366882901 turms-admin-http-worker-31-1 : |192.168.31.53|54984711-4|2024-06-22 16:50:25.650|getMetrics|{names=[system.cpu.usage, disk.free, system.memory.free, system.memory.total, disk.total], returnDescription=false, returnAvailableTags=false}|TRUE|0|
2024-06-22 16:50:28.145  WARN G efazdrer                     turms-health-checker-1-1          i.t.s.c.i.h.MemoryHealthChecker : Used system memory: 32640MB/32768MB; Used available memory: 247MB/31129MB; Used direct memory: 84MB/7782MB/8192MB; Used heap memory: 84MB/8192MB; Used non-heap memory: 78MB
2024-06-22 16:50:31.104  INFO G efazdrer                     turms-mongo-change-watcher-1         i.t.s.c.i.c.s.d.DiscoveryService : The leader has changed to: Leader(clusterId=turms, nodeId=hfpztyju, renewDate=Sat Jun 22 16:50:29 UTC 2024, generation=1)
2024-06-22 16:50:31.150  WARN G efazdrer                     turms-health-checker-1-1          i.t.s.c.i.h.MemoryHealthChecker : Used system memory: 32681MB/32768MB; Used available memory: 267MB/31129MB; Used direct memory: 84MB/7782MB/8192MB; Used heap memory: 104MB/8192MB; Used non-heap memory: 78MB