websocket通过上下线更新数据库字段

目前就是通过websocket连接设备,通过设备是否连接或者是否接受消息来决定设备的上下线并更新到数据库里面去,要怎么实现啊

 //收到客户端消息后调用的方法


@OnMessage
public void onMessage(String message, Session session) {
    log.info("用户消息:"+userId+",报文:"+message);
    //可以群发消息
    //消息保存到数据库、redis
    if(StringUtils.isNotBlank(message)){
        try {
            //解析发送的报文
            JSONObject jsonObject = JSON.parseObject(message);
            //追加发送人(防止串改)
            jsonObject.put("fromUserId",this.userId);
            String toUserId=jsonObject.getString("toUserId");
            //传送给对应toUserId用户的websocket
            if(StringUtils.isNotBlank(toUserId)&&webSocketMap.containsKey(toUserId)){
                webSocketMap.get(toUserId).sendMessage(jsonObject.toJSONString());
            }else{
                log.error("请求的userId:"+toUserId+"不在该服务器上");
                //否则不在这个服务器上，发送到mysql或者redis
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

是要在这里添加业务逻辑层方法吗,是要调用哪些接口,怎么写,完全不会了

运行结果及报错内容

我的解答思路和尝试过的方法

我想要达到的结果

做个异步的设备状态存储。