具有嵌入式ActiveMQ Broker的Spring Boot WebSocket

具有嵌入式ActiveMQ Broker的Spring Boot WebSocket

我找到了解决方案。我的问题是EnableWebSocketMessageBroker批注和ActiveMQ Broker的缺少部署

删除application.yml并将WebSocketConfig类更改为

package com.example.websocket;import org.apache.activemq.broker.BrokerService;import org.apache.activemq.broker.jmx.ManagementContext;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.messaging.simp.config.MessageBrokerRegistry;import org.springframework.web.socket.config.annotation.EnableWebSocket;import org.springframework.web.socket.config.annotation.StompEndpointRegistry;import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurationSupport;@Configuration@EnableWebSocketpublic class WebSocketConfig extends WebSocketMessageBrokerConfigurationSupport {    @Override    public void configureMessageBroker(final MessageBrokerRegistry config) {        config.enableStompBrokerRelay("/topic") //        .setRelayHost("localhost") //        .setRelayPort(61613);        config.setApplicationDestinationPrefixes("/app");    }    @Override    public void registerStompEndpoints(final StompEndpointRegistry registry) {        registry.addEndpoint("/websocket").withSockJS();    }    @Bean(initMethod = "start", destroyMethod = "stop")    public BrokerService broker() throws Exception {        final BrokerService broker = new BrokerService();        broker.addConnector("stomp://localhost:61613");        broker.setPersistent(false);        final ManagementContext managementContext = new ManagementContext();        managementContext.setCreateConnector(true);        broker.setManagementContext(managementContext);        return broker;    }}

为我工作。