无法使用spring boot 2和Stomp连接到Amazon MQ

Question

我正在使用Spring boot 2、Stomp和Amazon MQ构建WebSocket应用程序。

但是，我无法连接到Amazon MQ broker。我收到Failed to connect: connection timed out错误。

我的WebSocket配置：

@Configuration
@RequiredArgsConstructor
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
private final ActiveMQProperties properties;
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/")
.setAllowedOrigins("*")
.withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableStompBrokerRelay("/topic")
.setAutoStartup(true)
.setRelayPort(61614)
.setRelayHost(properties.getBrokerUrl())
.setClientLogin(properties.getUser())
.setClientPasscode(properties.getPassword())
.setSystemLogin(properties.getUser())
.setSystemPasscode(properties.getPassword())
.setTcpClient(createClient());
}
private TcpOperations<byte[]> createClient(){
return new ReactorNettyTcpClient<>((client) -> client
//                .host(properties.getBrokerUrl())
//                .port(61614)
.addressSupplier(this::getAddress)
.secure(), new StompReactorNettyCodec());
}
private SocketAddress getAddress() {
try {
InetAddress address = InetAddress.getByName(properties.getBrokerUrl());
SocketAddress socketAddress = new InetSocketAddress(address, 61614);
return socketAddress;
} catch (UnknownHostException e) {
log.error(e);
}
return null;
}

记录

2020-03-27 16:21:19.419  WARN 49890 --- [ealth-indicator] o.s.boot.actuate.jms.JmsHealthIndicator  : Connection failed to start within 5 seconds and will be closed.
2020-03-27 16:21:39.156  INFO 49890 --- [ient-loop-nio-1] o.s.m.s.s.StompBrokerRelayMessageHandler : TCP connection failure in session _system_: Failed to connect: connection timed out: {my-aws-url}:61614
io.netty.channel.ConnectTimeoutException: connection timed out: {my-aws-url}:61614
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:261) ~[netty-transport-4.1.45.Final.jar:4.1.45.Final]
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) ~[netty-common-4.1.45.Final.jar:4.1.45.Final]
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170) ~[netty-common-4.1.45.Final.jar:4.1.45.Final]
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) ~[netty-common-4.1.45.Final.jar:4.1.45.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) ~[netty-common-4.1.45.Final.jar:4.1.45.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500) ~[netty-transport-4.1.45.Final.jar:4.1.45.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[netty-common-4.1.45.Final.jar:4.1.45.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.45.Final.jar:4.1.45.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.45.Final.jar:4.1.45.Final]
at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_241]
2020-03-27 16:21:39.156 DEBUG 49890 --- [ient-loop-nio-1] org.springframework.web.SimpLogging      : Cleaning up connection state for session _system_

Answer 1

我认为您在安全组/NACL中缺少一个允许端口61614上通信的条目。我还将使用traceroute检查客户端主机是否可以访问代理主机。解决这两个问题中的任何一个都应该解决问题。

Answer 2

需要为AWS MQ broker配置分配安全组。如果您没有选择任何安全组，它将使用默认的安全组。因此，您的IP必须添加到已使用的安全组中。然后您可以访问MQ管理UI或队列。