whyclxw
2024-11-25 4fc7909358cc62231c81b8e871749fc1b3fa69bd
src/main/java/com/whyc/webSocket/DevLineSocket.java
@@ -2,6 +2,7 @@
import com.whyc.config.WebSocketConfig;
import com.whyc.dto.Response;
import com.whyc.pojo.db_user.UserInf;
import com.whyc.service.DevInfService;
import com.whyc.service.UserInfService;
import org.springframework.beans.factory.annotation.Autowired;
@@ -15,7 +16,7 @@
import java.util.Map;
/**
 * 账号重复登录检查
 * 左侧列表
 */
@Component
@ServerEndpoint(value = "/lineSocket",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
@@ -36,15 +37,15 @@
    @OnOpen
    public void onOpen(Session session, EndpointConfig config){
        this.httpSession = (HttpSession) config.getUserProperties().get("httpSession");
        //UserInf user = (UserInf) this.httpSession.getAttribute("user");
        //final int userId = user.getUid();
        final int userId = 101;
        UserInf user = (UserInf) this.httpSession.getAttribute("user");
        final int userId = user.getUid();
        //final int userId = 101;
        Thread thread = new Thread() {
            @Override
            public void run() {
                try {
                    while (!currentThread().isInterrupted()) {
                        Response res = dinfService.getLine(userId);
                        Response res = dinfService.getDevType(userId);
                        session.getBasicRemote().sendObject(res);
                        sleep(4000);
                    }