无法在GKE集群上的spring-boot中使STOMP工作/连接

Question

我正在尝试让我的应用程序在GKE中运行。我正在使用来自cloudamqp的RabbitMQ实例。我通过AMQP将此实例用于我的微服务之间的所有内部消息传递。

现在我想使用stompRelay通过SockJS上的STOMP向浏览器发送消息。当我在本地（在我的开发机器上）连接到实例时，一切都像魅力一样。消息被发送和确认，...

当我将应用程序移动到生产（GKE）时，所有AMQP队列都能正常工作，但是我无法让STOMP使用中继...当我使用simpleBroker时，一切正常。

我很确定代码是正确的，因为它可以从我的开发PC正常工作。我认为这与GKE防火墙拦截有关。

我已经尝试通过允许TCP 61613,61614上的所有输入/输出流量在gce上为防火墙添加额外的规则。

错误

o.s.m.s.s.StompBrokerRelayMessageHandler : TCP connection failure in session _system_: No CONNECTED frame received in 60000 ms.
r.io.net.impl.netty.tcp.NettyTcpClient   : CLOSED: [id: 0x5d96aa8d, /10.20.6.78:47136 :> xxxxxxxxxx.rmq.cloudamqp.com/35.195.232.78:61613]

我的dockerfile

FROM openjdk:8-jre-alpine

RUN apk add --no-cache tzdata
ENV TZ Europe/Brussels

ENV SPRING_PROFILES_ACTIVE production

WORKDIR /app
ADD target/application.jar /app/application.jar

EXPOSE 8080

CMD ["java", "-jar", "application.jar"]

我的中继配置

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableStompBrokerRelay("/topic", "/queue")
                .setRelayHost(relayHost)
                .setRelayPort(relayPort)
                .setSystemLogin(relayLogin)
                .setSystemPasscode(relayPasscode)
                .setVirtualHost(relayVHost)
                .setClientLogin(relayLogin)
                .setClientPasscode(relayPasscode);
    }

我一直在努力奋斗2天，试图让这个运行起来......

有没有人在Spring上使用外部rabbitMQ在GKE上运行STOMP？

Answer 1

再次查看配置后，我发现了一个拼写错误导致连接到RabbitMQ的问题。

@Value("${app.stomp.username:guest}")
private String relayLogin;

但配置是

app:
  stomp:
    user: xxxxxxxx