connection netty

build.gradle

@@ -31,6 +31,7 @@ allprojects {
         set('cglibVersion', "3.3.0")
         set('okhttpVersion', "4.9.3")
         set('jacksonVersion', "2.13.1")
+        set('nettyVersion', "4.1.72.Final")
         set('lombokVersion', "1.18.22")
         set('junitJupiterVersion', "5.8.1")
     }

concept-connection-loadbalance/concept-connection-loadbalance-core/src/main/java/com/github/linyuzai/connection/loadbalance/core/concept/AbstractConnectionLoadBalanceConcept.java

@@ -332,7 +332,7 @@ public T addMessageFactories(Collection<? extends MessageFactory> factories) {
             return (T) this;
         }
 
-        public void preBuild() {
+        protected void preBuild() {
             if (connectionServerProvider == null) {
                 throw new ConnectionLoadBalanceException("ConnectionServerProvider is null");
             }

concept-connection-loadbalance/concept-connection-loadbalance-netty/build.gradle

@@ -0,0 +1,28 @@
+plugins {
+    id 'java'
+}
+
+apply from: '../version.gradle'
+
+group 'com.github.linyuzai'
+version "${conceptConnectionLoadbalanceVersion}"
+sourceCompatibility = '1.8'
+
+repositories {
+    mavenCentral()
+}
+
+dependencies {
+    compileOnly project(path: ':concept-connection-loadbalance:concept-connection-loadbalance-core', configuration: 'default')
+
+    compileOnly "io.netty:netty-all:${nettyVersion}"
+
+    compileOnly "org.projectlombok:lombok:${lombokVersion}"
+    annotationProcessor "org.projectlombok:lombok:${lombokVersion}"
+    testImplementation "org.junit.jupiter:junit-jupiter-api:${junitJupiterVersion}"
+    testRuntimeOnly "org.junit.jupiter:junit-jupiter-engine:${junitJupiterVersion}"
+}
+
+test {
+    useJUnitPlatform()
+}

concept-connection-loadbalance/concept-connection-loadbalance-netty/src/main/java/com/github/linyuzai/connection/loadbalance/netty/concept/NettyLoadBalanceConcept.java

@@ -0,0 +1,4 @@
+package com.github.linyuzai.connection.loadbalance.netty.concept;
+
+public class NettyLoadBalanceConcept {
+}

concept-connection-loadbalance/concept-connection-loadbalance-spring-boot-starter/build.gradle

@@ -0,0 +1,33 @@
+plugins {
+    id 'java'
+}
+
+apply from: '../version.gradle'
+
+group 'com.github.linyuzai'
+version "${conceptConnectionLoadbalanceVersion}"
+sourceCompatibility = '1.8'
+
+repositories {
+    mavenCentral()
+}
+
+dependencies {
+
+    compileOnly project(':concept-connection-loadbalance:concept-connection-loadbalance-core')
+    compileOnly project(':concept-connection-loadbalance:concept-connection-loadbalance-discovery')
+    compileOnly project(':concept-connection-loadbalance:concept-connection-loadbalance-websocket')
+
+    compileOnly "org.springframework.boot:spring-boot-starter:${springBootVersion}"
+    compileOnly "org.springframework.cloud:spring-cloud-starter:${springCloudVersion}"
+    compileOnly "org.projectlombok:lombok:${lombokVersion}"
+    annotationProcessor "org.projectlombok:lombok:${lombokVersion}"
+    testImplementation "org.junit.jupiter:junit-jupiter-api:${junitJupiterVersion}"
+    testRuntimeOnly "org.junit.jupiter:junit-jupiter-engine:${junitJupiterVersion}"
+}
+
+test {
+    useJUnitPlatform()
+}
+
+//apply from: '../publish.gradle'

concept-connection-loadbalance/concept-connection-loadbalance-spring-boot-starter/src/main/java/com/github/linyuzai/connection/loadbalance/autoconfigure/websocket/ApplicationConnectionEventPublisher.java

@@ -0,0 +1,17 @@
+package com.github.linyuzai.connection.loadbalance.autoconfigure.websocket;
+
+import com.github.linyuzai.connection.loadbalance.core.event.DefaultConnectionEventPublisher;
+import lombok.AllArgsConstructor;
+import org.springframework.context.ApplicationEventPublisher;
+
+@AllArgsConstructor
+public class ApplicationConnectionEventPublisher extends DefaultConnectionEventPublisher {
+
+    private ApplicationEventPublisher publisher;
+
+    @Override
+    public void publish(Object event) {
+        super.publish(event);
+        publisher.publishEvent(event);
+    }
+}

concept-connection-loadbalance/concept-connection-loadbalance-spring-boot-starter/src/main/java/com/github/linyuzai/connection/loadbalance/autoconfigure/websocket/EnableWebSocketLoadBalanceConcept.java

@@ -0,0 +1,14 @@
+package com.github.linyuzai.connection.loadbalance.autoconfigure.websocket;
+
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+@Target(ElementType.TYPE)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Inherited
+@Import({WebSocketDiscoveryConfiguration.class, WebSocketLoadBalanceConfiguration.class})
+public @interface EnableWebSocketLoadBalanceConcept {
+
+}

concept-connection-loadbalance/concept-connection-loadbalance-spring-boot-starter/src/main/java/com/github/linyuzai/connection/loadbalance/autoconfigure/websocket/WebSocketDiscoveryConfiguration.java

@@ -0,0 +1,21 @@
+package com.github.linyuzai.connection.loadbalance.autoconfigure.websocket;
+
+import com.github.linyuzai.connection.loadbalance.core.server.ConnectionServerProvider;
+import com.github.linyuzai.connection.loadbalance.discovery.DiscoveryConnectionServerProvider;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.cloud.client.discovery.DiscoveryClient;
+import org.springframework.cloud.client.serviceregistry.Registration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration(proxyBeanMethods = false)
+@ConditionalOnClass({DiscoveryClient.class, Registration.class})
+public class WebSocketDiscoveryConfiguration {
+
+    @Bean
+    @ConditionalOnMissingBean
+    public ConnectionServerProvider connectionServerProvider(DiscoveryClient client, Registration registration) {
+        return new DiscoveryConnectionServerProvider(client, registration);
+    }
+}

concept-connection-loadbalance/concept-connection-loadbalance-spring-boot-starter/src/main/java/com/github/linyuzai/connection/loadbalance/autoconfigure/websocket/WebSocketLoadBalanceConfiguration.java

@@ -0,0 +1,51 @@
+package com.github.linyuzai.connection.loadbalance.autoconfigure.websocket;
+
+import com.github.linyuzai.connection.loadbalance.core.concept.ConnectionFactory;
+import com.github.linyuzai.connection.loadbalance.core.event.ConnectionEventPublisher;
+import com.github.linyuzai.connection.loadbalance.core.message.MessageFactory;
+import com.github.linyuzai.connection.loadbalance.core.proxy.ConnectionProxy;
+import com.github.linyuzai.connection.loadbalance.core.select.ConnectionSelector;
+import com.github.linyuzai.connection.loadbalance.core.server.ConnectionServerProvider;
+import com.github.linyuzai.connection.loadbalance.websocket.concept.WebSocketLoadBalanceConcept;
+import com.github.linyuzai.connection.loadbalance.websocket.proxy.WebSocketConnectionProxy;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.List;
+
+@Configuration(proxyBeanMethods = false)
+public class WebSocketLoadBalanceConfiguration {
+
+    @Bean
+    @ConditionalOnMissingBean
+    public ConnectionProxy connectionProxy() {
+        return new WebSocketConnectionProxy();
+    }
+
+    @Bean
+    @ConditionalOnMissingBean
+    public ConnectionEventPublisher connectionEventPublisher(ApplicationEventPublisher publisher) {
+        return new ApplicationConnectionEventPublisher(publisher);
+    }
+
+    @Bean
+    @ConditionalOnMissingBean
+    public WebSocketLoadBalanceConcept webSocketLoadBalanceConcept(
+            ConnectionServerProvider provider,
+            ConnectionProxy proxy,
+            List<ConnectionFactory> connectionFactories,
+            List<ConnectionSelector> connectionSelectors,
+            List<MessageFactory> messageFactories,
+            ConnectionEventPublisher publisher) {
+        return new WebSocketLoadBalanceConcept.Builder()
+                .connectionServerProvider(provider)
+                .connectionProxy(proxy)
+                .addConnectionFactories(connectionFactories)
+                .addConnectionSelectors(connectionSelectors)
+                .addMessageFactories(messageFactories)
+                .eventPublisher(publisher)
+                .build();
+    }
+}

settings.gradle

@@ -2,7 +2,9 @@ rootProject.name = 'concept'
 include 'concept-connection-loadbalance'
 include 'concept-connection-loadbalance:concept-connection-loadbalance-core'
 include 'concept-connection-loadbalance:concept-connection-loadbalance-discovery'
+include 'concept-connection-loadbalance:concept-connection-loadbalance-netty'
 include 'concept-connection-loadbalance:concept-connection-loadbalance-websocket'
+include 'concept-connection-loadbalance:concept-connection-loadbalance-spring-boot-starter'
 include 'concept-download'
 include 'concept-download:concept-download-core'
 include 'concept-download:concept-download-source-okhttp'