WebSockets JSR 356 Spring 集成 @ServerEndpoint

Question

问题：@ServerEndpoint class 中的@Autowired beans 为空

如何确保下面的这个 WebSocketController class 将被注入 beans，即如何让它由 Spring 管理？我可以连接到 websocket 所以它可以工作但是 gameService 在 WebSocketController class 实例中总是空的，所以我认为它是由 tomcat 以某种方式创建的而不是 Spring.

我正在使用 Spring 启动。我只需要弄清楚如何将 bean 注入到这个 websocket 控制器中 class.

WebSocketControllerclass

@Component
@ServerEndpoint("/sock")
public class WebSocketController {

    @Autowired
    private GameService gameService;

    private static Set<Session> clients = Collections.synchronizedSet(new HashSet<Session>());

    @OnMessage
    public void handleMessage(Session session, String message) throws IOException {

        session.getBasicRemote().sendText(
                "Reversed: " + new StringBuilder(message).reverse());
    }

    @OnOpen
    public void onOpen(Session session) {
        clients.add(session);
        System.out.println("New client @"+session.getId());
        if (gameService == null) System.out.println("game service null");
    }

    @OnClose
    public void onClose(Session session) {
        clients.remove(session);
        System.out.println("Client disconnected @" + session.getId());
    }
}

GameService 接口和实现

public interface GameService {
    List<Character> getCharacters();
}

@Service
public class GameServiceMockImpl implements GameService {

    @Override
    public List<Character> getCharacters() {
        List<Character> list = new ArrayList<>();
        list.add(new Character("aaa","1.png",100));
        list.add(new Character("aaa","2.jpg",100));
        list.add(new Character("aaa","3.jpg",100));
        return list;
    }
}

申请class

@SpringBootApplication
public class App  {

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

    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }

}

编辑：

使用 Spring 4 WebSockets 根本不起作用，我什至无法通过浏览器连接。

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/myHandler");
    }

    @Bean
    public WebSocketHandler myHandler() {
        return new MyHandler();
    }

}


public class MyHandler extends TextWebSocketHandler {

    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) {
        System.out.println(message.getPayload());
    }

}

Answer 1

您正在尝试集成 Spring 和 Java WebSocket API。由 @Component 注释的 class 注册到 spring bean 并且其实例由 spring 管理，但是如果 class 由 @ServerEndpoint 注释它注册到服务器端 WebSocket 端点，每次相应端点的 WebSocket 连接到服务器时，它的实例都由 JWA 实现创建和管理。我们不能同时使用这两个注释。

或者你可以使用CDI注入（你的服务器应该也支持）

@ServerEndpoint("/sock")
public class WebSocketController {

    @Inject
    private GameService gameService;

或查看 this 文档，Spring 4 支持 WebSocket

Answer 2

也许这篇文章可以帮助：

https://spring.io/blog/2013/05/23/spring-framework-4-0-m1-websocket-support

您可以使用依赖项（spring 版本 > 4）

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-websocket</artifactId>
    <version>${spring.version}</version>
</dependency>

然后就

@ServerEndpoint(value = "/echo", configurator = SpringConfigurator.class)
public class WebSocketEndpoint {

    @Inject
    private BroadcastService broadcaster;

WebSockets JSR 356 Spring 集成 @ServerEndpoint

WebSockets JSR 356 Spring integration @ServerEndpoint

spring

tomcat

spring-mvc

jsr

websocket