springboot中websocket使用案例

1.pom.xml引入jar包

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-websocket</artifactId>
            <version>2.5.2</version>
        </dependency>

2.新建websocker类

package net.supwit.websocket;



import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;


@ServerEndpoint("/videoSocket/{taskid}")
@Component
@Slf4j
public class VideoWebSocket {

    public volatile static Map<String, Set<Session>> clients = new ConcurrentHashMap<>();

    @OnOpen
    public void onOpen(@PathParam("taskid") String taskid, Ses