forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
kaiyu
2021-07-05 9cb298004c7ca4c75ad5faf0234531aa21c99c5c 
 screen-api/src/main/java/com/moral/api/websocket/SingleDeviceServer.java


@@ -1,11 +1,18 @@


package com.moral.api.websocket;




import com.moral.api.entity.Device;


import com.moral.api.entity.Sensor;


import com.moral.constant.RedisConstants;


import lombok.Data;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Component;


import org.springframework.web.bind.annotation.PathVariable;




import javax.websocket.*;


import javax.websocket.server.PathParam;


import javax.websocket.server.ServerEndpoint;


import java.util.List;


import java.util.Map;


import java.util.concurrent.CopyOnWriteArraySet;




/**


@@ -17,6 +24,7 @@


 **/


@ServerEndpoint("/singleDevice/{mac}")


@Component


@Data


public class SingleDeviceServer {




    //线程安全集合，用于存放server对象


@@ -26,10 +34,15 @@




    private String mac;




    public static RedisTemplate redisTemplate;




    private  Map<String,Device> devicesInfo;




    @OnOpen


    public void onOpen(Session session, @PathParam("mac") String mac) throws Exception {


        this.session = session;


        this.mac = mac;


        this.devicesInfo = redisTemplate.opsForHash().entries(RedisConstants.DEVICE_INFO);


        sockets.add(this);


        System.out.println(mac);


    }