APIGateway для обработки веб-сокета и маршрутизации его к соответствующему микросервису с использованием Spring Boot 3.3 ⇐ JAVA

[Anonymous]

У меня есть микросервисное приложение, в котором APIGateway принимает все входящие запросы и перенаправляет их на соответствующий микросервис после выполнения некоторых проверок. Все работает нормально, пока я не использую запросы http/https. Но недавно я реализовал мобильное приложение, в котором мне нужна опция чата, для этого мы реализовали флаттер-приложение и микросервис для обработки запроса. Если я вызываю службу напрямую, она работает отлично, но когда я регистрирую свой новый микросервис в APIGateway, чтобы все запросы поступали через APIGateway, он начинает давать сбой.
Файл APIGateway application.yml
Файл APIGateway application.yml
APIGateway application.yml h2>
server:
port: 8090

spring:
application:
name: application-name
cloud:
kubernetes:
enabled: true
loadbalancer:
mode: SERVICE
discovery:
all-namespaces: true
gateway:
globalcors:
corsConfigurations:
'[/**]':
allowedOrigins: "*"
allowedMethods: "*"
allowedHeaders: "*"
discovery:
locator:
enabled: true
routes:
- id: coreservice-service
uri: lb://coreservice-service
predicates:
- Path=/hb/api/core/**
filters:
- AuthenticationFilter
- id: coreservice-service
uri: lb://coreservice-service
predicates:
- Path=/resources/**
filters:
- AuthenticationFilter
- id: authenticator-service
uri: lb://authenticator-service
predicates:
- Path=/hb/api/oauth/**
filters:
- AuthenticationFilter
- id: btchatstream-service
uri: lb://btchatstream-service
predicates:
- Path=/chat/**
filters:
- RewritePath=/ws/(?.*), /${segment}

profiles:
active: ${profile:prod}
webflux:
static-path-pattern: "/resources/**"

servlet:
multipart:
enabled: true
file-size-threshold: 2MB
max-file-size: 10MB
max-request-size: 12MB

APIGateway pom.xml

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0

org.springframework.boot
spring-boot-starter-parent
3.3.1


com.bot.apigateway
hb_ApiGateway
0.0.1-SNAPSHOT
hb_ApiGateway
Application-name














17
2023.0.2



org.springframework.cloud
spring-cloud-starter-netflix-eureka-client



org.springframework.boot
spring-boot-starter-test
test


io.projectreactor
reactor-test
test



org.springframework.cloud
spring-cloud-starter-gateway



org.springframework.cloud
spring-cloud-starter-kubernetes-client-all




org.springframework.boot
spring-boot-starter-reactor-netty




com.fasterxml.jackson.core
jackson-databind




io.jsonwebtoken
jjwt-api
0.11.5




io.jsonwebtoken
jjwt-impl
0.11.5




io.jsonwebtoken
jjwt-jackson
0.11.5






org.springframework.cloud
spring-cloud-dependencies
${spring-cloud.version}
pom
import







org.springframework.boot
spring-boot-maven-plugin


hiringbel_apigateway




Конфигурация микросервиса
@Configuration
@EnableWebSocketMessageBroker
public class ChatConfiguration implements WebSocketMessageBrokerConfigurer {

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/chat");
registry.addEndpoint("/chat")
.setAllowedOrigins("*")
.withSockJS();
}

@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
config.enableSimpleBroker("/topic");
config.setApplicationDestinationPrefixes("/app");
}
}

Файл микросервиса pom.xml

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0

org.springframework.boot
spring-boot-starter-parent
3.2.1


com.bot.chatstream
btchatstream
0.0.1-SNAPSHOT
btchatstream
Chat stream for text, audio, and video

17
2023.0.2



org.springframework.boot
spring-boot-starter-web


org.springframework.boot
spring-boot-starter-websocket




org.springframework.boot
spring-boot-starter-security
3.3.0



org.springframework.boot
spring-boot-devtools
runtime
true


org.projectlombok
lombok
true


org.springframework.boot
spring-boot-starter-test
test


org.springframework.boot
spring-boot-starter-webflux



org.springframework.cloud
spring-cloud-starter-netflix-eureka-client
4.1.2







org.springframework.cloud
spring-cloud-dependencies
${spring-cloud.version}
pom
import







org.springframework.boot
spring-boot-maven-plugin



org.projectlombok
lombok





btchatstream




После вызова службы через APIGateway
например. ws://192.168.1.100:8090/chat
Я становлюсь ниже исключения
io.netty.handler.codec.http.websocketx.WebSocketClientHandshakeException: Invalid handshake response getStatus: 403
at io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker13.verify(WebSocketClientHandshaker13.java:312) ~[netty-codec-http-4.1.111.Final.jar:4.1.111.Final]
at io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker.finishHandshake(WebSocketClientHandshaker.java:364) ~[netty-codec-http-4.1.111.Final.jar:4.1.111.Final]
at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:121) ~[reactor-netty-http-1.1.20.jar:1.1.20]
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:114) ~[reactor-netty-core-1.1.20.jar:1.1.20]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) ~[netty-codec-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346) ~[netty-codec-4.1.111.Final.jar:4.1.111.Final]
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318) ~[netty-codec-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1407) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.111.Final.jar:4.1.111.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994) ~[netty-common-4.1.111.Final.jar:4.1.111.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.111.Final.jar:4.1.111.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.111.Final.jar:4.1.111.Final]
at java.base/java.lang.Thread.run(Thread.java:842) ~[na:na]

2024-06-22T10:33:00.217+05:30 WARN 46116 --- [apigateway-hiringbell-service] [ctor-http-nio-9] reactor.netty.channel.FluxReceive : [e813645b-1, L:/127.0.0.1:61159 ! R:localhost/127.0.0.1:5050] An exception has been observed post termination, use DEBUG level to see the full stack: io.netty.handler.codec.http.websocketx.WebSocketClientHandshakeException: Connection prematurely closed BEFORE opening handshake is complete.
2024-06-22T10:33:05.388+05:30 WARN 46116 --- [apigateway-hiringbell-service] [tor-http-nio-10] r.netty.http.client.HttpClientConnect : [8392f56b-1, L:/127.0.0.1:61245 - R:localhost/127.0.0.1:5050] The connection observed an error


Подробнее здесь: https://stackoverflow.com/questions/786 ... -using-spr