`
一流涌进
  • 浏览: 5371 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

jave如何实现将上海宝付数据库数据存到内存

阅读更多


由代码可以看到,SimpleSession 实现了和 Serializable,下面再看一下 ValidatingSession 接口

// IntelliJ API Decompiler stub source generated from a class file

// Implementation of methods is not available

package org.apache.shiro.session.mgt;

public interface ValidatingSession extends org.apache.shiro.session.Session {

boolean isValid();

void validate() throws org.apache.shiro.session.InvalidSessionException;

}

可以看到,ValidatingSession 接口继承了 org.apache.shiro.session.Session 接口,下面再看看 org.apache.shiro.session.Session 接口

// IntelliJ API Decompiler stub source generated from a class file

// Implementation of methods is not available

package org.apache.shiro.session;

public interface Session {

java.io.Serializable getId();

java.util.Date getStartTimestamp();

java.util.Date getLastAccessTime();

long getTimeout() throws org.apache.shiro.session.InvalidSessionException;

void setTimeout(long l) throws org.apache.shiro.session.InvalidSessionException;

java.lang.String getHost();

void touch() throws org.apache.shiro.session.InvalidSessionException;

void stop() throws org.apache.shiro.session.InvalidSessionException;

java.util.Collection<java.lang.Object> getAttributeKeys() throws org.apache.shiro.session.InvalidSessionException;

java.lang.Object getAttribute(java.lang.Object o) throws org.apache.shiro.session.InvalidSessionException;

void setAttribute(java.lang.Object o, java.lang.Object o1) throws org.apache.shiro.session.InvalidSessionException;

java.lang.Object removeAttribute(java.lang.Object o) throws org.apache.shiro.session.InvalidSessionException;

}

有上述代码可以看到,SimpleSession 对象是一个比较复杂的对象,既有很多个属性,又有多个复杂方法,如果直接使用Jackson工具转化为 json 格式字符串存入数据库,最终是无法解析出来的

我的解决方案是:

存储方案
1.1 将对象序列化到内存中,并生成一个字节数据
1.2 将1.1中得到的字节数组转化为 base64 位的字符串
1.3 将1.2中得到的字符串存入数据库即可
读取方案
2.1 从数据库中读取 base64 加密后的字符串
2.2 将2.1中的加密字符串解密成字节数组
2.3 将2.3中的字节数组反序列化
具体实现

我这里借助 org.apache.commons.lang3.SerializationUtils 工具类来实现,序列化功能代码如下:

package com.lixiaohao.test.springshiro.util;

import org.apache.commons.lang3.SerializationUtils;

import org.apache.shiro.codec.Base64;

import org.apache.shiro.session.Session;

import java.io.Serializable;

/**

@program: shiroTest

@description:

@author: xiaohao.li

@create: 2018-07-30 14:55
**/

public class SerializeUtils extends SerializationUtils {

public static String serializeToString(Serializable obj) {

try {

byte[] value = serialize(obj);

return Base64.encodeToString(value);

} catch (Exception e) {

throw new RuntimeException("serialize session error", e);

}

}

public static Session deserializeFromString(String base64) {

try {

byte[] objectData = Base64.decode(base64);

return deserialize(objectData);

} catch (Exception e) {

throw new RuntimeException("deserialize session error", e);

}

}

}

session管理功能如下:

package com.lixiaohao.test.springshiro.session;

import com.lixiaohao.test.springshiro.dao.SessionModelDao;

import com.lixiaohao.test.springshiro.dao.UserDao;

import com.lixiaohao.test.springshiro.model.SessionModel;

import com.lixiaohao.test.springshiro.model.User;

import com.lixiaohao.test.springshiro.util.JsonUtils;

import com.lixiaohao.test.springshiro.util.SerializeUtils;

import org.apache.shiro.session.Session;

import org.apache.shiro.session.mgt.SimpleSession;

import org.apache.shiro.session.mgt.eis.CachingSessionDAO;

import org.springframework.beans.factory.annotation.Autowired;

import java.io.Serializable;

import com.lixiaohao.test.springshiro.util.StringUtils;

/**

@program: shiroTest

@description:

@author: xiaohao.li

@create: 2018-07-26 12:40
**/

public class UserCacheSessionDao extends CachingSessionDAO{

private final String PRINCIPALS_SESSION_KEY = "org.apache.shiro.subject.support.DefaultSubjectContext_PRINCIPALS_SESSION_KEY";

@Autowired

private SessionModelDao sessionModelDao;

@Autowired

private UserDao userDao;

protected void doUpdate(Session session) {

}

protected void doDelete(Session session) {

if ( session == null ) {

throw new NullPointerException(" session argument can not be null ");

}

String sessionId = (String)session.getId();

if ( StringUtils.isEmpty(sessionId) ) {

throw new NullPointerException(" property sessionId can not be null in session argument ");

}

sessionModelDao.delete(sessionId);

}

protected Serializable doCreate(Session session) {

if ( session == null ) {

throw new NullPointerException(" session argument can not be null ");

}

String sessionId = (String) generateSessionId(session);

assignSessionId(session,sessionId);

storeSession(session);

return sessionId;

}

private void storeSession(Session session){

String sessionId = (String) session.getId();

SessionModel sessionModel = new SessionModel();

sessionModel.setSessionId(sessionId);

sessionModel.setStatus(1);

//将对象序列化

String sessionStr = SerializeUtils.serializeToString((SimpleSession)session);

sessionModel.setSessionStr(sessionStr);

Object principals = session.getAttribute(PRINCIPALS_SESSION_KEY);

if ( principals != null ) {

User user = userDao.findByUserName((String) principals);

sessionModel.setValue(JsonUtils.objectToJson(user));

}

System.out.println("保存session -------->> "+JsonUtils.objectToJson(sessionModel));

sessionModelDao.insert(sessionModel);

}

protected Session doReadSession(Serializable sessionId) {

if ( sessionId == null ) {

throw new NullPointerException(" sessionId argument can not be null. ");

}

String id = (String) sessionId;

SessionModel sessionMode = sessionModelDao.findBySessionId(id);

if ( sessionMode == null ) {

return null;

}

java.lang.String sessionStr = sessionMode.getSessionStr();

//反序列化对象

Session session = SerializeUtils.deserializeFromString(sessionStr);

return session;

}

}
分享到:
评论

相关推荐

    java多个数据库实现数据同步

    本文将深入探讨如何使用Java来实现多个数据库之间的数据同步。 首先,我们需要理解数据同步的含义。数据同步是指在两个或多个数据库之间,当某个数据库中的数据发生改变时,这些变化能够被实时或者近实时地反映到...

    java实现上传图片存入到数据库

    在Java编程中,将图片上传并存储到数据库是一项常见的任务,尤其在开发Web应用时。这一过程涉及到文件处理、数据库操作以及可能的图像处理。以下是对这个主题的详细阐述: 首先,我们需要理解基本的文件上传流程。...

    Java实现数据库迁移同步

    数据库迁移是指将数据从一个数据库系统迁移到另一个数据库系统的过程,或者在同一系统中不同版本之间进行数据转移。这通常涉及到数据的抽取、转换和加载(ETL)过程,以及确保数据的一致性和完整性。 Java作为广泛...

    Java导出Oracle数据库数据

    exp 命令用于将 Oracle 数据库数据导出到文件中,而 imp 命令用于将数据从文件中导入到 Oracle 数据库中。这些命令可以在命令行中使用,例如,在 Windows 中,可以打开命令行窗口,输入 exp 用户名/密码@标识 file=d...

    Java实现从excel中批量导入数据到数据库

    Java实现从excel中批量高效导入数据到数据库中,包括图片的导入存储,读取图片显示在jsp页面等,需要下载JspSmartUpload.jar和jxl.jar两个jar包,将两个包导入项目才能运行

    JAVA串口助手接收数据并解析数据存入MySQL数据库中

    在本文中,我们将深入探讨如何使用Java开发一个串口助手应用程序,该程序能接收来自串行端口的数据并将其解析后存储到MySQL数据库中。首先,我们需要了解串口通信的基本概念,然后学习Java如何处理串口输入,接着是...

    java实现数据库容灾备份

    结合提供的标题"java实现数据库容灾备份"和描述"可以集成定时任务去实时备份或者定期备份,欢迎一起讨论",我们将详细介绍如何利用Java编写程序来自动化数据库的备份过程,并讨论相关技术要点。 首先,数据库备份是...

    java保存文件到数据库

    在Java编程中,将文件保存到数据库是一种常见的需求,特别是在处理图像、文档和其他非结构化数据时。这个过程涉及到将文件转换为二进制数据,然后将这些数据存储到数据库的特定字段中,通常是一个BLOB(Binary Large...

    java实现文本数据读取到数据库表

    将本地硬盘中的文本数据读取到mysql的数据库表中。 1. 文件保存在本地目录下,按照固定的格式保存,每一行对应着数据库中的一条记录,属性用空格隔开。 2. 创建数据库表,字段需要和文本文件的数据逐列对应。 3. ...

    java iText 实现从数据库中导出数据到已有的PDF模板

    在IT领域,它被广泛用于生成报告、发票、证书等,特别是在需要将数据动态地从数据库填充到预定义模板的情况。在这个场景中,"java iText 实现从数据库中导出数据到已有的PDF模板"是一个常见的需求,它涉及到多个关键...

    Java建立数据库连接并实现数据库查询.rar

    Java建立数据库连接并实现数据库查询,初学者通过本Java源代码,了解如何加载驱动器,获取连接,定义SQL查询语句,获取Statement对象,执行查询、遍历ResultSet、获取数据、在控制台输出数据,关闭连接等。

    JAVA内存数据库使用demo

    Java内存数据库,通常指的是那些将数据存储在内存中,而非磁盘上的数据库系统。这种数据库因为数据读写速度快,响应时间短,适用于处理大量实时数据的场景,如高速缓存、实时分析等。本示例将围绕如何在Java中使用...

    websocket实现前端页面动态刷新数据库中数据

    - 当检测到数据库有新数据时,后端通过已经建立的WebSocket连接,将更新的消息推送给前端。 - 前端页面接收到WebSocket消息后,刷新显示最新的数据库内容,无需手动刷新整个页面。 总结来说,这个项目通过...

    Java实现数据库数据导出到excel,内有数据连接jar包

    在Java编程环境中,将数据库中的数据导出到Excel文件是一项常见的任务,特别是在数据分析、报表生成或数据备份等场景。这个项目提供了完整的解决方案,包括必要的jar包支持数据连接。以下是关于这个主题的一些关键...

    java连接数据库并且向数据库插入数据

    在Java编程中,连接数据库并插入数据是一项基本且重要的任务,尤其在开发Web应用程序时,如JSP(JavaServer Pages)和Servlet结合MySQL数据库的场景。在这个过程中,开发者需要掌握如何配置数据库连接、编写SQL语句...

    数据库管理系统(java实现)

    数据库系统原理实验 数据库管理系统 javase java 大学数据库实验 主要利用JAVA序列化和反序列化 注解挺全的,DBMS, 文件存储表、库,根据sql语句实现建表,建库 可以建立索引(B+树) 可以做笛卡尔积(hash) 自然...

    JAVA实现数据库数据导入导出到Excel(POI)所需jar包

    最后,通过JDBC连接执行SQL插入语句,将数据写入数据库。 2. **所需Jar包:** - **Apache POI:** 包含处理Excel的核心库,如poi-ooxml-schemas、poi-ooxml、poi-ooxml-lite、poi等。这些jar包提供了解析和操作...

    很实用的端口接收数据并存储到数据库中的程序

    这个文件可能包含了服务器端监听端口、接收数据、解析数据以及将数据插入数据库的完整流程。通过对这个示例的学习,开发者可以更好地理解如何在实际项目中实现类似的功能。 总之,通过端口接收数据并存储到数据库是...

    Java反射泛型,实现数据库的动态增删改查等功能

    本文将详细介绍如何结合这两种技术实现在Java中对MySQL、SQL Server或Oracle数据库进行动态的增删改查操作。 首先,Java反射机制允许我们在运行时检查类、接口、字段和方法的信息,甚至可以动态调用方法和修改字段...

Global site tag (gtag.js) - Google Analytics