Spring Boot WebSocket не отвечает - PullRequest
Новая
       12

Spring Boot WebSocket не отвечает

0 голосов
/ 15 июня 2019

У меня есть приложение Spring Boot, которое обрабатывает загрузку файлов и хранение данных. Я включил конфигурацию WebSocket, но WebSocket не работает. Мое приложение для Android выдает исключение, в котором говорится, что «путь к потоку пуст.

Класс обработчика 

import com.google.gson.Gson;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;

@Component
public class SocketHandler extends TextWebSocketHandler {

List sessions = new ArrayList<>();

@Override
public void handleTextMessage(WebSocketSession session, TextMessage message)
        throws InterruptedException, IOException {

    for(Object t : sessions) {
                WebSocketSession webSocketSession = (WebSocketSession) t;
        Map value = new Gson().fromJson(message.getPayload(), Map.class);
        webSocketSession.sendMessage(new TextMessage("Hello " + value.get("name") + " !"));
    }
}

@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
    //the messages will be broadcasted to all users.
    sessions.add(session);
}
}

Конфигурационный класс 

import com.labafrique.creporter.web.CReporterSpring.websocket.SocketHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Controller;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;

@Configuration
@EnableWebSocket
@Controller
public class WebSocketConfig implements WebSocketConfigurer {
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new SocketHandler(), "/t").setAllowedOrigins("*");
    }
}

Основной класс 

import com.labafrique.creporter.web.CReporterSpring.controller.property.FileStorageProperties;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;

@EnableJpaRepositories("com.labafrique.creporter.web.CReporterSpring.repository") 
@EntityScan("com.labafrique.creporter.web.CReporterSpring.model")
@ComponentScan(basePackages = {"com.labafrique.creporter.web.CReporterSpring.controller"})
@EnableConfigurationProperties({
        FileStorageProperties.class
}) 
@SpringBootApplication
public class CReporterSpringApplication {

    public static void main(String[] args) {
        SpringApplication.run(CReporterSpringApplication.class, args);
    }
}

Я пытался переместить класс в разные пакеты, но все равно ничего не получалось.

...