Web在线聊天室(10) --- 插入消息

Posted 2022-12-13 满眼*星辰

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Web在线聊天室(10) --- 插入消息相关的知识，希望对你有一定的参考价值。

插入消息

消息格式


	"userId": 1,
	"nickName": "蔡徐坤",
	"channelId": 1,
	"content": "这是消息正文"

服务器端onMessage方法

    @OnMessage
    public void onMessage(Session session, String message) 
        // 1.遍历保存的所有session，每个都发送消息
        MessageCenter.sendMessage(message);
        // 2.消息还要保存在数据库，
        // （1）反序列化json字符串为message对象
        Message msg = Util.deserialize(message, Message.class);
        // （2）message设置接收消息的时间
//        msg.setSendTime(new Date());
        // （3）插入数据库
        int n = MessageDao.insert(msg);

        System.out.println("接收到的消息：" + message);

操作数据库插入方法

    /**
     * 往数据库插入消息信息
     */
    public static int insert(Message msg) 
        Connection connection = null;
        PreparedStatement statement = null;
        try 
            connection = Util.getConnection();
            String sql = "insert into message values(null,?,?,?,?)";
            statement = connection.prepareStatement(sql);
            statement.setInt(1,msg.getUserId());
            statement.setInt(2,msg.getChannelId());
            statement.setString(3,msg.getContent());
            statement.setTimestamp(4, new Timestamp(System.currentTimeMillis()));
            int result = statement.executeUpdate();
            return result;
        catch (Exception e) 
            throw new AppException("保存消息出错", e);
        finally 
            Util.close(connection,statement);