搭建Spring Boot2.X集成Hibernate5項目,並集成傳統SSH老項目的安全認證組件,以Spring Boot方式開發項目並集成到老系統
highlight: an-old-hope theme: cyanosis
持續創作,加速成長!這是我參與「掘金日新計劃 · 10 月更文挑戰」的第9天,點擊查看活動詳情
場景
由於老項目(SSH架構)需要新添加功能模塊,習慣了Spring Boot快速開發,突然使用XML那一套東西,不是不可以,但是不爽,故想使用Spring Boot方式開發新項目集成到老系統。
同時,記錄、分享在搭建、集成方面遇到的問題。
可行性分析
1.能否集成?
傳統項目(SSH架構)那一套就是XML的配置,Spring Boot則是將XML簡化,也無非類似,且新Spring Boot項目核心是提供接口被調用。故只要能保證開發的Spring Boot項目能成功集成到SSH老系統即可。
2.安全如何認證?
老項目存在權限認證組件,新開發的Spring Boot項目肯定得做集成,由老系統的認證組件進行安全認證。老系統的安全認證組件是非SpringBoot開發,但是以Jar的形式提供使用,最大問題在於相關配置文件中的對象的初始化以及兼容性問題需要考慮。
3.如何進行 ?
由於老系統使用Hibernate,所以首先就需要搭建Spring Boot集成Hibernate項目。
Hibernate沒有Spring Boot的相關啟動器,做集成稍顯麻煩,但是萬變不離其中,畢竟Spring Boot都是從xml轉變過來的。
其次在搭建好的環境基礎上引入老系統的安全認證組件進行測試。
搭建Spring Boot集成Hibernate5項目
添加依賴
JPA的默認實現是Hibernate,直接引入spring-boot-starter-data-jpa
啟動器即可。
bash
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
Entity
創建一個User對象,與數據庫數據表映射。
java
@Entity
@Data
@Table(name="user")
public class User {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
private String name;
private Integer age;
}
Dao
注意:低版本的Hibernate(應該是5以下)使用sessionFactory
對象獲取會話對象,高版本使用的是EntityManagerFactory
對象。由於老項目肯定使用sessionFactory
對象,所以集成測試也使用sessionFactory
對象,此時sessionFactory是有警告。
```java
public interface IUserDao {
/**
* @description: 保存用户
**/
void saveUser(User user);
User getUser(Integer id);
}
@Repository public class UserDaoImpl implements IUserDao { @Autowired private SessionFactory sessionFactory;
Session getCurrentSession() {
return sessionFactory.getCurrentSession();
}
@Override
public void saveUser(User user) {
getCurrentSession().save(user);
}
@Override
public User getUser(Integer id) {
return getCurrentSession().get(User.class, id);
}
}
高版本中這樣獲取會話對象:
java
@Autowired
private EntityManagerFactory entityManagerFactory;
Session getCurrentSession() {
return entityManagerFactory.unwrap(SessionFactory.class).getCurrentSession();
}
```
Service
```java public interface UserService {
void mySave(User user);
User getUser(Integer id);
}
@Transactional(rollbackFor = Exception.class) @Service public class UserServiceImpl implements UserService {
@Autowired
private IUserDao userDao;
@Override
public void mySave(User user) {
userDao.saveUser(user);
}
@Override
public User getUser(Integer id) {
return userDao.getUser(id);
}
} ```
Controller
```java @RestController @RequestMapping("/test") public class Controller {
@Autowired
private UserService userService;
/**
* 添加
*/
@RequestMapping("/insert")
public String insert() {
User user = new User();
user.setName("小白");
user.setAge(22);
userService.mySave(user);
return "success";
}
/**
* 查詢
*/
@RequestMapping("/get")
public User getUser(Integer id) {
return userService.getUser(id);
}
} ```
配置application.properties
```java server.port=8888
----------------------數據庫配置------------------------------
spring.datasource.url=jdbc:mysql://localhost:3306/demo?characterEncoding=utf-8 spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.username=root spring.datasource.password=123456 ```
啟動類
排除HibernateJpa相關的自動配置,進行手動配置,故需排除HibernateJpaAutoConfiguration
自動配置類,否則報錯如下:
java
org.springframework.orm.jpa.EntityManagerHolder cannot be cast to org.springframework.orm.hibernate5.SessionHolder
```java @SpringBootApplication(exclude = {HibernateJpaAutoConfiguration.class}) public class DemoApplication extends SpringBootServletInitializer {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
} ```
配置Hibernate
手動配置配置會話工廠與配置事務管理器,具體代碼參考如下: ```java @Configuration public class HibernateConfig {
@Autowired
private DataSource dataSource;
/**
* 配置會話工廠
*/
@Bean(name = "sessionFactory")
// @Bean(name="entityManagerFactory") public SessionFactory sessionFactoryBean() throws IOException { LocalSessionFactoryBean sessionFactoryBean = new LocalSessionFactoryBean(); // 設置數據源 sessionFactoryBean.setDataSource(dataSource); // entity包路徑 sessionFactoryBean.setPackagesToScan("cn.ybzy.demo.entity"); // 配置hibernate屬性 Properties properties = new Properties(); // sql方言 properties.setProperty("hibernate.dialect", "org.hibernate.dialect.MySQL5Dialect"); // 自動創建|更新|驗證數據庫表結構 properties.setProperty("hibernate.hbm2ddl.auto", "update"); // 輸出sql到控制枱 properties.setProperty("hibernate.show_sql", "true"); // 打印漂亮的sql properties.setProperty("hibernate.format_sql", "true"); properties.setProperty("hibernate.current_session_context_class", "org.springframework.orm.hibernate5.SpringSessionContext"); sessionFactoryBean.setHibernateProperties(properties); sessionFactoryBean.afterPropertiesSet(); SessionFactory sessionFactory = sessionFactoryBean.getObject();
return sessionFactory;
}
/**
* 配置事務管理器
*/
@Bean(name = "transactionManager")
public HibernateTransactionManager transactionManager(SessionFactory sessionFactory) {
HibernateTransactionManager transactionManager = new HibernateTransactionManager();
// 設置 sessionFactory
transactionManager.setSessionFactory(sessionFactory);
return transactionManager;
}
/**
* 創建攔截器,配置事務攔截方式
* 指定事務管理器和設置事務屬性
*
* @return
*/
// @Bean // public TransactionInterceptor transactionInterceptors(HibernateTransactionManager transactionManager) { // TransactionInterceptor transInterceptor = new TransactionInterceptor(); // // 設置事務管理器 // transInterceptor.setTransactionManager(transactionManager); // // 設置方法事務屬性 // Properties props = new Properties(); // props.setProperty("save", "PROPAGATION_REQUIRED"); // props.setProperty("update", "PROPAGATION_REQUIRED"); // props.setProperty("delete", "PROPAGATION_REQUIRED"); // props.setProperty("find", "PROPAGATION_REQUIRED,readOnly"); // props.setProperty("get", "PROPAGATION_REQUIRED,readOnly"); // transInterceptor.setTransactionAttributes(props); // return transInterceptor; // } // // / // * AOP攔截配置 // * 創建一個自動代理Bean的對象 // / // @Bean // public BeanNameAutoProxyCreator beanNameAutoProxyCreator() { // BeanNameAutoProxyCreator beanNameAutoProxyCreator = new BeanNameAutoProxyCreator(); // // 設置應該自動被代理包裝的 bean 的名稱 // beanNameAutoProxyCreator.setBeanNames("*ServiceImpl"); // // 設置常用攔截器 // beanNameAutoProxyCreator.setInterceptorNames("transactionInterceptor"); // return beanNameAutoProxyCreator; // }
} ```
進行測試
1.執行新增測試 2.執行查詢測試 3.執行新增異常事務回滾測試 ```java Whitelabel Error Page This application has no explicit mapping for /error, so you are seeing this as a fallback.
Mon Aug 15 14:44:05 CST 2022
There was an unexpected error (type=Internal Server Error, status=500).
/ by zero
java.lang.ArithmeticException: / by zero
at cn.ybzy.demo.service.impl.MyUserServiceImpl.saveUser(MyUserServiceImpl.java:25)
at cn.ybzy.demo.service.impl.MyUserServiceImpl$$FastClassBySpringCGLIB$$f77af9f1.invoke(
集成安全認證組件
集成分析
由於添加的安全認證組件涉及到了2個xml配置文件 ```java spring-shiro.xml
spring-datasource-jedis.xml ```
xml文件裏面創建的Bean需要通過Spring Boot的方式添加到容器中
解決方案:
1.使用@ImportResource註解將原生配置文件引入,進行自動配置其中定義的Bean
2.參考xml中的配置,將xml配置轉換成類配置
開始集成
這裏使用第一種方案。由於引入組件中定義了一些對象,如service類 Dao類,這些對象需要加入到Spring容器中,所以使用@ComponentScan(basePackages = {"com.XX"})
方式進行掃描
java
@ImportResource(locations = {"classpath:spring-shiro.xml","classpath:spring-datasource-jedis.xml"})
@ComponentScan(basePackages = {"com.XXX"})
@SpringBootApplication
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
}
啟動報錯
```java Description:
Field sessionFactory in com.zhunda.base.dao.impl.UserDaoImpl required a bean of type 'org.hibernate.SessionFactory' that could not be found.
The injection point has the following annotations: - @org.springframework.beans.factory.annotation.Autowired(required=true)
Action:
Consider defining a bean of type 'org.hibernate.SessionFactory' in your configuration. ``` 原因如下:
進行Spring掃描時,發現老項目Dao層中的需要SessionFactory對象,畢竟需要該對象操作數據庫,但是此刻配置HibernateConfig對象未生效,故找不到
解決方案:將@ComponentScan(basePackages = {"com.XXX"})
從啟動類移動到HibernateConfig
類
```java
@Configuration
@ComponentScan(basePackages = {"com.XXX"})
public class HibernateConfig {
}
再次出現異常:
java
Caused by: org.springframework.context.annotation.ConflictingBeanDefinitionException: Annotation-specified bean name 'userDaoImpl' for bean class [com.zhunda.base.dao.impl.UserDaoImpl] conflicts with existing, non-compatible bean definition of same name and class [cn.ybzy.demo.repository.impl.UserDaoImpl]
```
原因:
認證組件中定義有UserDaoImpl類與新項目中定義的測試UserDaoImpl類衝突,故將Spring Boot項目中的相關的測試對象,如UserDaoImpl改個名稱
```java public interface IMyUserDao {
/**
* @description: 保存用户
**/
void saveUser(User user);
}
@Repository public class MyUserDaoImpl implements IMyUserDao { @Autowired private SessionFactory sessionFactory;
Session getCurrentSession() {
return sessionFactory.getCurrentSession();
}
@Override
public void saveUser(User user) {
getCurrentSession().save(user);
}
}
啟動成功
java
2022-08-05 14:49:52.611 INFO 3048 --- [ restartedMain] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8888 (http) with context path ''
2022-08-05 14:49:52.613 INFO 3048 --- [ restartedMain] o.s.s.quartz.SchedulerFactoryBean : Starting Quartz Scheduler now
2022-08-05 14:49:52.613 INFO 3048 --- [ restartedMain] org.quartz.core.QuartzScheduler : Scheduler quartzScheduler_$_NON_CLUSTERED started.
2022-08-05 14:49:52.626 INFO 3048 --- [ restartedMain] s.a.ScheduledAnnotationBeanPostProcessor : No TaskScheduler/ScheduledExecutorService bean found for scheduled processing
2022-08-05 14:49:52.635 INFO 3048 --- [ restartedMain] cn.ybzy.demo.DemoApplication : Started DemoApplication in 7.301 seconds (JVM running for 8.798)
```
測試驗證
接着測試權限認證是否正常。由於認證組件使用Shiro,故此處Shiro報錯,集成認證組件出現異常
java
org.apache.shiro.UnavailableSecurityManagerException: No SecurityManager accessible to the calling code, either bound to the org.apache.shiro.util.ThreadContext or as a vm static singleton. This is an invalid application configuration.
經過一番折騰,在配置delegatingFilterProxy對象即可解決
```java
@ImportResource(locations = {"classpath:spring-shiro.xml","classpath:spring-datasource-jedis.xml"})
@SpringBootApplication
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
@Bean
public ShiroFilterFactoryBean delegatingFilterProxy(@Qualifier("shiroFilter") ShiroFilterFactoryBean shiroFilterFactoryBean) {
return shiroFilterFactoryBean;
}
}
啟動項目,執行測試,成功攔截
![在這裏插入圖片描述](http://p3-juejin.byteimg.com/tos-cn-i-k3u1fbpfcp/e338726a81d445aeb15e7e28128c2522~tplv-k3u1fbpfcp-zoom-1.image)
訪問登錄接口,得到安全組件設置的cookie值:
java
set-cookie SSO-SESSIONID=eb22cc107b094fb2ae5884a8df7923f4; Path=/; HttpOnly; SameSite=lax
```
將cookie值添加到集成項目對應的瀏覽器中
執行新增操作
執行查詢操作
執行事務操作
java
@Override
public void mySave(User user) {
userDao.saveUser(user);
int a=1/0;
}
程序異常,同時數據庫事務生效。
使用JPA功能
Dao
創建相關接口繼承CrudRepository
對象
java
@Repository
public interface IUserRepository extends CrudRepository<User, Integer> {}
Service
```java @Transactional(rollbackFor = Exception.class) @Service public class UserServiceImpl implements UserService {
@Autowired
private IUserDao userDao;
@Autowired
private IUserRepository userRepository;
@Override
public void saveUser(User user) {
// userDao.saveUser(user); userRepository.save(user); int a = 1 / 0; }
@Override
public User getUser(Integer id) {
// return userDao.getUser(id);
Optional
配置application.properties
```java server.port=8888
----------------------數據庫配置------------------------------
spring.datasource.url=jdbc:mysql://localhost:3306/demo?characterEncoding=utf-8 spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.username=root spring.datasource.password=123456
----------------------JPA配置------------------------------
數據庫類型
spring.jpa.database=MySQL
打印sql語句
spring.jpa.show-sql=true
生成SQL表
spring.jpa.generate-ddl=true
自動修改表結構
spring.jpa.hibernate.ddl-auto=update ```
啟動項目
啟動報錯: ```java Description:
Field userRepository in cn.ybzy.demo.service.impl.UserServiceImpl required a bean named 'entityManagerFactory' that could not be found.
The injection point has the following annotations: - @org.springframework.beans.factory.annotation.Autowired(required=true)
Action:
Consider defining a bean named 'entityManagerFactory' in your configuration. ```
默認情況下,JPA通過名稱entityManagerFactory
搜索sessionFactory
手動設置:方法上添加 @Bean(name="entityManagerFactory")
自動設置:方法名字一定要是entityManagerFactory
Hibernate配置
```java /* * 配置會話工廠 / // @Bean(name = "sessionFactory") @Bean(name="entityManagerFactory") public SessionFactory sessionFactoryBean() throws IOException { LocalSessionFactoryBean sessionFactoryBean = new LocalSessionFactoryBean(); // 設置數據源 sessionFactoryBean.setDataSource(dataSource); // entity包路徑 sessionFactoryBean.setPackagesToScan("cn.ybzy.demo.entity"); // 配置hibernate屬性 Properties properties = new Properties(); // sql方言 properties.setProperty("hibernate.dialect", "org.hibernate.dialect.MySQL5Dialect"); // 自動創建|更新|驗證數據庫表結構 properties.setProperty("hibernate.hbm2ddl.auto", "update"); // 輸出sql到控制枱 properties.setProperty("hibernate.show_sql", "true"); // 打印漂亮的sql properties.setProperty("hibernate.format_sql", "true"); properties.setProperty("hibernate.current_session_context_class", "org.springframework.orm.hibernate5.SpringSessionContext"); sessionFactoryBean.setHibernateProperties(properties); sessionFactoryBean.afterPropertiesSet(); SessionFactory sessionFactory = sessionFactoryBean.getObject();
return sessionFactory;
}
```
獲取會話
在JPA中通常使用EntityManagerFactory
對象獲取會話。
```java
@Autowired
private EntityManagerFactory entityManagerFactory;
Session getCurrentSession() {
return entityManagerFactory.unwrap(SessionFactory.class).getCurrentSession();
}
```
執行測試
最後進行測試,JPA功能正常。