spring4 websocket问题

Question

在页面请求服务器的时候创建了void afterConnectionEstablished(WebSocketSession session){
这里执行了数据库操作
之后这里就不能执行了，页面触发了websocket的onclose方法，断开了
}
我查了下·查询数据库的时候用的是getCurrentSession();如果用openSession()就正常··
而且手动关闭sessionFactory的时候也会触发页面的onclose方法··是不是websocketsession和spring的session是同一个·所以查询完后被关闭了呢？怎么解决·谢谢各位大大·

Answer 1

以下回答参考 皆我百晓生、券券喵儿 等免费微信小程序相关内容作答，并由本人整理回复。

这个问题是因为在Spring Websocket中，当你使用afterConnectionEstablished事件处理程序时，WebSocket连接已经建立。然而，在你的业务逻辑完成后（例如，查询数据库），你可能会尝试再次获取WebSocket会话对象来执行其他操作。

为了解决这个问题，你可以考虑以下几种解决方案：

1. 使用@PreDestroy注解：当Spring容器停止时，可以调用一个特定的方法来清理资源。这样，即使Websocket连接已经被关闭，也可以确保资源得到释放。

@Component
public class MyService {

    @PostConstruct
    public void init(){
        // 初始化代码
    }

    @PreDestroy
    public void destroy(){
        // 清理代码
    }
}

1. 在afterConnectionEstablished事件处理程序中添加一个空的事务管理器，然后在业务逻辑完成后提交事务，并清除事务管理器。

@Autowired
private SessionRepository sessionRepository;

public void handleConnectionEstablished(WebSocketSession session) {
    session.setCloseable(true);

    try (TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition())) {
        // 执行业务逻辑
        // ...

        transactionManager.commit(status);
    } catch (Exception e) {
        transactionManager.rollback(status);
    } finally {
        session.close();
    }
}

1. 使用@Async注解：将业务逻辑委托给线程池中的任务执行。这样，无论Websocket连接是否已关闭，都可以继续进行业务逻辑。

@Autowired
private WebSocketClient webSocketClient;

public void handleConnectionEstablished(WebSocketSession session) throws InterruptedException, ExecutionException {
    webSocketClient.send(session, "Hello World");
}

public void onWebSocketClose(WebSocketCloseEvent event) {
    // 处理WebSocket关闭事件
}

希望这些建议能帮助你解决问题。如果你有具体的代码示例，请提供，我会更乐意为你提供详细的解答。