Spring5 （G筆記）

大綱
Spring 5 框架概述
Spring5 入門案例
IOC （概念和原理）
IOC （ BeanFactory 接口）
IOC 操作 Bean 管理（概念）
IOC 操作 Bean 管理（基于 xml 方式）
- 1 、基于 xml 方式創建對象
- 2 、基于 xml 方式注入屬性
  - 2.1 、第一種注入方式：使用 set 方法進行注入
  - 2.2 、第二種注入方式：使用有參數構造進行注入
- 3 、 p 名稱空間注入（了解）
IOC 操作 Bean 管理（ xml 注入其他類型屬性）
- 1 、字面量（null和特殊符號）
- 2 、注入屬性 - 外部 bean
- 3 、注入屬性 - 內部 bean
- 4 、注入屬性 - 級聯賦值
  - （ 1 ）第一種寫法
  - （ 2 ）第二種寫法
IOC 操作 Bean 管理（ xml 注入集合屬性）
- 1 、注入數組類型屬性 2 、注入 List 集合類型屬性 3 、注入 Map 集合類型屬性
- 4 、在集合里面設置對象類型值
- 5 、把集合注入部分提取出來
IOC 操作 Bean 管理（ FactoryBean ）
IOC 操作 Bean 管理（ bean 作用域）
IOC 操作 Bean 管理（ bean 生命周期）
IOC 操作 Bean 管理（ xml 自動裝配）
IOC 操作 Bean 管理 ( 外部屬性文件 )
- 1 、直接配置數據庫信息
- 2 、引入外部屬性文件配置數據庫連接池
IOC 操作 Bean 管理 ( 基于注解方式 )
- 1 、什么是注解
- 2 、 Spring 針對 Bean 管理中創建對象提供注解
- 3 、基于注解方式實現對象創建
- 4 、開啟組件掃描細節配置
- 5 、基于注解方式實現屬性注入
- 6 、完全注解開發(用配置類替代xml配置文件，詳細可見SpringBoot)
AOP （概念）
AOP （底層原理）
AOP （ JDK 動態代理）
AOP （術語）
AOP 操作（準備工作）
AOP 操作（ AspectJ 注解實現）（推薦）
AOP 操作（ AspectJ 配置文件實現）（）
JdbcTemplate( 概念和準備 )
JdbcTemplate 操作數據庫（添加）
JdbcTemplate 操作數據庫（修改和刪除）
JdbcTemplate 操作數據庫（查詢返回某個值）
JdbcTemplate 操作數據庫（查詢返回對象）
JdbcTemplate 操作數據庫（查詢返回集合）
JdbcTemplate 操作數據庫（批量操作）
- 2 、 JdbcTemplate 實現批量添加操作
- 3 、 JdbcTemplate 實現批量修改操作
- 4 、 JdbcTemplate 實現批量刪除操作
事務操作（事務概念）
事務操作（搭建事務操作環境）
事務操作（ Spring 事務管理介紹）
事務操作（注解聲明式事務管理）
事務操作（注解聲明式事務管理參數配置）
- 2 、 propagation ：事務傳播行為
- 3 、 ioslation ：事務隔離級別
- 4 、 timeout ：超時時間
- 5 、 readOnly ：是否只讀
- 6 、 rollbackFor ：回滾
- 7 、 noRollbackFor ：不回滾
事務操作（ XML 聲明式事務管理）
事務操作（完全注解聲明式事務管理）
Spring5 框架新功能
- 2 、Spring 5.0框架自帶了通用的日志封裝Log4j2
- 3 、 Spring5 框架核心容器支持 @Nullable 注解
- 4 、 Spring5 核心容器支持函數式風格 GenericApplicationContext
- 5 、 Spring5 支持整合 JUnit5
Spring5 框架新功能（ Webflux ）
- 1 、 SpringWebflux 介紹
- 2 、響應式編程（ Java 實現）
- 3 、響應式編程（ Reactor 實現）
- 4 、 SpringWebflux 執行流程和核心 API
- 5 、 SpringWebflux （基于注解編程模型）
- 6 、 SpringWebflux （基于函數式編程模型）
課程總結

大綱

1、Spring 框架概述
2、IOC 容器
（1）IOC 底層原理
（2）IOC 接口（BeanFactory） 
（3）IOC 操作 Bean 管理（基于 xml） 
（4）IOC 操作 Bean 管理（基于注解）
3、Aop
4、JdbcTemplate
5、事務管理
6、Spring5 新特性

Spring 5 框架概述

1 、Spring是輕量級的開源的JavaEE框架

2 、Spring可以解決企業應用開發的復雜性

3 、Spring有兩個核心部分：IOC和Aop
（ 1 ）IOC：控制反轉，把創建對象過程交給Spring進行管理
（ 2 ）Aop：面向切面，不修改源代碼進行功能增強

4 、Spring特點
（ 1 ）方便解耦，簡化開發
（ 2 ）Aop編程支持
（ 3 ）方便程序測試
（ 4 ）方便和其他框架進行整合
（ 5 ）方便進行事務操作
（ 6 ）降低API開發難度

5 、現在課程中，選取Spring版本 5.x

Spring5 入門案例

1 、下載 Spring
（ 1 ）使用Spring最新穩定版本 5.2.

（ 2 ）下載地址
https://repo.spring.io/release/org/springframework/spring/

2 、打開 idea 工具，創建普通 Java 工程

3 、導入 Spring5 相關 jar 包

4 、創建普通類，在這個類創建普通方法

public class User {
      public void add() {
      System.out.println("add......");
      }
}

5 、創建Spring配置文件，在配置文件配置創建的對象
（ 1 ）Spring配置文件使用xml格式（選擇Spring config）

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
[http://www.springframework.org/schema/beans/spring-beans.xsd">](http://www.springframework.org/schema/beans/spring-beans.xsd">)
    <!--配置User對象創建-->
    <bean id="user" class="com.yu.spring5.User"></bean>
</beans>

6 、進行測試代碼編寫

    @Test
    public void testAdd(){
        //1 加載spring配置文件
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");
        //2 獲取配置創建的對象
        User user = context.getBean("user", User.class);

        System.out.println(user);
        user.add();
    }

IOC （概念和原理）

1 、什么是IOC
（ 1 ）控制反轉，把對象創建和對象之間的調用過程，交給Spring進行管理
（ 2 ）使用IOC目的：為了耦合度降低
（ 3 ）做入門案例就是IOC實現

2 、IOC底層原理
（ 1 ）xml解析、工廠模式、反射

3 、畫圖講解IOC底層原理

IOC （ BeanFactory 接口）

1 、IOC思想基于IOC容器完成，IOC容器底層就是對象工廠

2 、Spring提供IOC容器實現兩種方式：（兩個接口）
（ 1 ）BeanFactory：IOC容器基本實現，是Spring內部的使用接口，不提供開發人員進行使用

加載配置文件時候不會創建對象，在獲取對象（使用）才去創建對象

（ 2 ）ApplicationContext：BeanFactory接口的子接口，提供更多更強大的功能，一般由開發人
員進行使用

加載配置文件時候就會把在配置文件對象進行創建

spring上下文：

應用上下文即是Spring容器的一種抽象化表述；而我們常見的ApplicationContext本質上說就是一個維護Bean定義以及對象之間協作關系的高級接口。額，聽起來是不是很抽象拗口？那你再讀一遍呢。。。這里，我們必須明確，Spring的核心是容器，而容器并不唯一，框架本身就提供了很多個容器的實現，大概分為兩種類型：一種是不常用的BeanFactory，這是最簡單的容器，只能提供基本的DI功能；還有一種就是繼承了BeanFactory后派生而來的應用上下文，其抽象接口也就是我們上面提到的的ApplicationContext，它能提供更多企業級的服務，例如解析配置文本信息等等，這也是應用上下文實例對象最常見的應用場景。有了上下文對象，我們就能向容器注冊需要Spring管理的對象了。對于上下文抽象接口，Spring也為我們提供了多種類型的容器實現，供我們在不同的應用場景選擇......

詳細參考地址：http://www.rzrgm.cn/chenbenbuyi/p/8166304.html

3 、ApplicationContext接口有實現類

IOC 操作 Bean 管理（概念）

1 、什么是 Bean 管理
（ 0 ）Bean管理指的是兩個操作
（ 1 ）Spring創建對象
（ 2 ）Spirng注入屬性

2 、Bean管理操作有兩種方式
（ 1 ）基于xml配置文件方式實現
（ 2 ）基于注解方式實現

IOC 操作 Bean 管理（基于 xml 方式）

1 、基于 xml 方式創建對象

    <!--配置User對象創建-->
    <bean id="user" class="com.yu.spring5.User"></bean>

（ 1 ）在spring配置文件中，使用bean標簽，標簽里面添加對應屬性，就可以實現對象創建
（ 2 ）在bean標簽有很多屬性，介紹常用的屬性

id屬性：唯一標識
class屬性：類全路徑（包類路徑）
name屬性（不常用）：和id類似，可以有特殊符號
（ 3 ）創建對象時候，默認也是執行無參數構造方法完成對象創建

2 、基于 xml 方式注入屬性

DI ：依賴注入，就是注入屬性

2.1 、第一種注入方式：使用 set 方法進行注入

（ 1 ）創建類，定義屬性和對應的set方法

/**
* 演示使用set方法進行注入屬性
*/
public class Book {
//創建屬性
private String bname;
private String bauthor;
//創建屬性對應的set方法
public void setBname(String bname) {
this.bname = bname;
}
public void setBauthor(String bauthor) {
this.bauthor = bauthor;
}
}

（ 2 ）在spring配置文件配置對象創建，配置屬性注入

<!-- 2 set方法注入屬性-->
<bean id="book" class="com.yu.spring5.Book">
<!--使用property完成屬性注入
name：類里面屬性名稱
value：向屬性注入的值
-->
<property name="bname" value="易筋經"></property>
<property name="bauthor" value="達摩老祖"></property>
</bean>

2.2 、第二種注入方式：使用有參數構造進行注入

（ 1 ）創建類，定義屬性，創建屬性對應有參數構造方法

/**
* 使用有參數構造注入
*/

public class Orders {
//屬性
private String oname;
private String address;
//有參數構造
public Orders(String oname,String address) {
this.oname = oname;
this.address = address;
}
}

（ 2 ）在spring配置文件中進行配置

<!-- 3 有參數構造注入屬性-->
<bean id="orders" class="com.yu.spring5.Orders">
<constructor-arg name="oname" value="電腦"></constructor-arg>
<constructor-arg name="address" value="China"></constructor-arg>
</bean>

除了使用name外，還可以使用索引index，如

<constructor-arg index="0" value="電腦"></constructor-arg>

0表示有參構造的第0個參數

3 、 p 名稱空間注入（了解）

只能用于set方法注入
（ 1 ）使用p名稱空間注入，可以簡化基于xml配置方式
第一步添加p名稱空間在配置文件中

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

第二步進行屬性注入，在bean標簽里面進行操作

<!--2 set方法注入屬性-->
<bean id="book" class="com.yu.spring5.Book" p:bname="九陽神功"p:bauthor="無名氏"></bean>

IOC 操作 Bean 管理（ xml 注入其他類型屬性）

1 、字面量（null和特殊符號）

（ 1 ）null值

        <!--null值-->
        <property name="address">
            <null/>
        </property>

（ 2 ）屬性值包含特殊符號

        <!--屬性值包含特殊符號
            方法1 把<>進行轉義 &lt; &gt;
            方法2 把帶特殊符號內容寫到CDATA
        -->
        <property name="address" >
            <value><![CDATA[<<上海>>]]></value>
        </property>

2 、注入屬性 - 外部 bean

（ 1 ）創建兩個類 service類和dao類
（ 2 ）在service調用dao里面的方法
（ 3 ）在spring配置文件中進行配置

public class UserService {
    //創建UserDao類型屬性，生成set方法
    private UserDao userDao;

    public void setUserDao(UserDao userDao) {
        this.userDao = userDao;
    }

    public void add(){

        System.out.println("UserService add ~~~~~~~");
//        //原始方式創建UserDao對象
//        UserDao userDao = new UserDaoImpl();
        userDao.update();
    }
}

UserDao略

    <!--1 service和dao對象創建-->
    <bean id="userService" class="com.yu.spring5.service.UserService">
        <!--注入userDao對象
            name屬性：類里面屬性名稱
            ref屬性：創建userDao對象bean標簽id值
        -->
        <property name="userDao" ref="userDaoImpl"></property>
    </bean>

    <bean id="userDaoImpl" class="com.yu.spring5.dao.UserDaoImpl"></bean>

3 、注入屬性 - 內部 bean

（ 1 ）一對多關系：部門和員工
一個部門有多個員工，一個員工屬于一個部門
部門是一，員工是多
（ 2 ）在實體類之間表示一對多關系，員工表示所屬部門，使用對象類型屬性進行表示

//部門類
public class Dept {
    private String dname;
    public void setDname(String dname) {
      this.dname = dname;
    }
}

//員工類
public class Emp {
      private String ename;
      private String gender;
      //員工屬于某一個部門，使用對象形式表示
      private Dept dept;
      public void setDept(Dept dept) {
           this.dept = dept;
      }
      public void setEname(String ename) {
          this.ename = ename;
      }
      public void setGender(String gender) {
          this.gender = gender;
      }
}

（ 3 ）在spring配置文件中進行配置

    <!--內部bean-->
    <bean id="emp" class="com.yu.spring5.bean.Emp">
        <!--設置兩個普通屬性-->
        <property name="ename" value="lucy"></property>
        <property name="gender" value="女"></property>
        <!--設置對象類型屬性-->
        <property name="dept">
            <bean id="dept" class="com.yu.spring5.bean.Dept">
                <property name="dname" value="安保部"></property>
            </bean>
        </property>
    </bean>

4 、注入屬性 - 級聯賦值

（ 1 ）第一種寫法

    <!--級聯賦值-->
    <bean id="emp" class="com.yu.spring5.bean.Emp">
        <!--設置兩個普通屬性-->
        <property name="ename" value="lucy"></property>
        <property name="gender" value="女"></property>
        <!--級聯賦值-->
        <property name="dept" ref="dept">
        </property>
    </bean>

    <bean id="dept" class="com.yu.spring5.bean.Dept">
        <property name="dname" value="財務部"></property>
    </bean>

（ 2 ）第二種寫法

注意：這種方法需要Emp中有dept的get方法

    <!--級聯賦值-->
    <bean id="emp" class="com.yu.spring5.bean.Emp">
        <!--設置兩個普通屬性-->
        <property name="ename" value="lucy"></property>
        <property name="gender" value="女"></property>
        <!--級聯賦值-->
        <property name="dept" ref="dept"></property>
        <property name="dept.dname" value="技術部"></property>

    </bean>

    <bean id="dept" class="com.yu.spring5.bean.Dept">
    </bean>

IOC 操作 Bean 管理（ xml 注入集合屬性）

1 、注入數組類型屬性 2 、注入 List 集合類型屬性 3 、注入 Map 集合類型屬性

（ 1 ）創建類，定義數組、list、map、set類型屬性，生成對應set方法

public class Stu {
//1 數組類型屬性
private String[] courses;
//2 list集合類型屬性
private List<String> list;
//3 map集合類型屬性
private Map<String,String> maps;
//4 set集合類型屬性
private Set<String> sets;

public void setSets(Set<String> sets) {
this.sets = sets;
}
public void setCourses(String[] courses) {
this.courses = courses;
}
public void setList(List<String> list) {
this.list = list;
}
public void setMaps(Map<String, String> maps) {
this.maps = maps;
}
}

（ 2 ）在spring配置文件進行配置

    <!-- 集合類型屬性注入-->
    <bean id="stu" class="com.yu.spring5.collectionType.Stu">
        <!--數組類型屬性注入-->
        <property name="cources">
            <array>
                <value>java</value>
                <value>數據庫</value>
            </array>
        </property>
        <!--List類型屬性注入-->
        <property name="list">
            <list>
                <value>張三</value>
                <value>小三</value>
            </list>
        </property>
        <!--map類型屬性注入-->
        <property name="maps">
            <map>
                <entry key="JAVA" value="java"></entry>
                <entry key="REDIS" value="redis"></entry>
            </map>
        </property>
        <!--set類型屬性注入-->
        <property name="sets">
            <set>
                <value>李四</value>
                <value>小四</value>
            </set>
        </property>
    </bean>

4 、在集合里面設置對象類型值

public class Stu {
    //學生所學多門課程
    private List<Course> coursesList;

    public void setCoursesList(List<Course> coursesList) {
        this.coursesList = coursesList;
    }
}

//課程類
public class Course {
    private String cname;//課程名稱

    public void setCname(String cname) {
        this.cname = cname;
    }
}

    <!-- 集合類型屬性注入-->
    <bean id="stu" class="com.yu.spring5.collectionType.Stu">
        <!--注入list集合類型，值是對象-->
        <property name="coursesList">
            <list>
                <ref bean="course1"></ref>
                <ref bean="course2"></ref>
            </list>
        </property>
    </bean>


    <!--創建多個course對象-->
    <bean id="course1" class="com.yu.spring5.collectionType.Course">
        <property name="cname" value="Spring"></property>
    </bean>
    <bean id="course2" class="com.yu.spring5.collectionType.Course">
        <property name="cname" value="SpringBoot"></property>
    </bean>

5 、把集合注入部分提取出來

（ 1 ）在spring配置文件中引入名稱空間 util

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:util="http://www.springframework.org/schema/util"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">

（ 2 ）使用util標簽完成list集合注入提取

    <!-- 1 提取list集合類型屬性注入-->
    <util:list id="bookList">
        <value>易筋經</value>
        <value>九陰真經</value>
        <value>九陽神功</value>
    </util:list>
    <!--2 提取list集合類型屬性注入使用-->
    <bean id="book" class="com.yu.spring5.collectionType.Book">
        <property name="list" ref="bookList"></property>
    </bean>

IOC 操作 Bean 管理（ FactoryBean ）

1 、 Spring 有兩種類型 bean ，一種普通 bean ，另外一種工廠 bean （ FactoryBean ）

2 、普通 bean ：在配置文件中定義 bean 類型就是返回類型

3 、工廠 bean ：在配置文件定義 bean 類型可以和返回類型不一樣
第一步創建類，讓這個類作為工廠bean，實現接口 FactoryBean
第二步實現接口里面的方法，在實現的方法中定義返回的bean類型

public class MyBean implements FactoryBean<Course> {
//定義返回bean
@Override
public Course getObject() throws Exception {
    Course course = new Course();
    course.setCname("abc");
    return course;
}
@Override
public Class<?> getObjectType() {
    return null;
}
@Override
public boolean isSingleton() {
    return false;
}
}

<bean id="myBean" class="com.yu.spring5.factoryBean.MyBean">
</bean>

    @Test
    public void testCollectionTest3(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean3.xml");
        Course course = context.getBean("myBean", Course.class);

        System.out.println(course);
    }

IOC 操作 Bean 管理（ bean 作用域）

1 、在 Spring 里面，設置創建 bean 實例是單實例還是多實例

單實例:確保一個類只有一個實例，自行提供這個實例并向整個系統提供這個實例。

2 、在 Spring 里面，默認情況下， bean 是單實例對象

3 、如何設置單實例還是多實例
（ 1 ）在spring配置文件bean標簽里面有屬性（scope）用于設置單實例還是多實例
（ 2 ）scope屬性值
第一個值默認值，singleton，表示是單實例對象
第二個值 prototype，表示是多實例對象

（ 3 ）singleton和prototype區別
第一 singleton單實例，prototype多實例
第二設置scope值是singleton時候，加載spring配置文件時候就會創建單實例對象
設置scope值是prototype時候，不是在加載spring配置文件時候創建對象，而是在調用
getBean方法時候創建多實例對象
scope還有兩個不常用的參數：request，session

IOC 操作 Bean 管理（ bean 生命周期）

1 、生命周期
（ 1 ）從對象創建到對象銷毀的過程

2 、 bean 生命周期
（ 1 ）通過構造器創建bean實例（無參數構造）
（ 2 ）為bean的屬性設置值和對其他bean引用（調用set方法）
（ 3 ）調用bean的初始化的方法（需要進行配置初始化的方法）
（ 4 ）bean可以使用了（對象獲取到了）
（ 5 ）當容器關閉時候，調用bean的銷毀的方法（需要進行配置銷毀的方法）

3 、演示 bean 生命周期

public class Orders {
    private String oname;
    //無參數構造
    public Orders() {
        System.out.println("第一步，執行無參構造創建bean實例");
    }

    public void setOname(String oname) {
        this.oname = oname;
        System.out.println("第二步，調用set方法設置屬性值");
    }
    //創建執行的初始化的方法
    public void initMethod(){
        System.out.println("第三步，執行初始化的方法");
    }
    //創建執行的銷毀的方法
    public void destroyMethod(){
        System.out.println("第五步，執行銷毀的方法");
    }
}

    <bean id="oders" class="com.yu.spring5.bean.Orders" init-method="initMethod" destroy-method="destroyMethod">
        <property name="oname" value="手機"></property>
    </bean>

    @Test
    public void testBean3(){
//        ApplicationContext context =
//                new ClassPathXmlApplicationContext("bean4.xml");
        ClassPathXmlApplicationContext context =
                new ClassPathXmlApplicationContext("bean4.xml");
        Orders oders = context.getBean("oders", Orders.class);
        System.out.println("第四步 獲取創建bean實例對象");
        System.out.println(oders);
        //手動讓bean實例銷毀
        context.close();

    }

4 、更完整：加上bean 的后置處理器， bean 生命周期有七步
（ 1 ）通過構造器創建bean實例（無參數構造）
（ 2 ）為bean的屬性設置值和對其他bean引用（調用set方法）
（ 3 ）把bean實例傳遞bean后置處理器的方法postProcessBeforeInitialization

（ 4 ）調用bean的初始化的方法（需要進行配置初始化的方法）

（ 5 ）把 bean 實例傳遞 bean 后置處理器的方法 postProcessAfterInitialization
（ 6 ）bean可以使用了（對象獲取到了）
（ 7 ）當容器關閉時候，調用bean的銷毀的方法（需要進行配置銷毀的方法）

5 、演示添加后置處理器效果
（ 1 ）創建類，實現接口BeanPostProcessor，創建后置處理器

public class MyBeanPost implements BeanPostProcessor{
    @Override
    public java.lang.Object postProcessBeforeInitialization(java.lang.Object bean, java.lang.String beanName) throws org.springframework.beans.BeansException {
        /* compiled code */
        System.out.println("在初始化之前執行的方法");
        return bean;
    }

    @Override
    public java.lang.Object postProcessAfterInitialization(java.lang.Object bean, java.lang.String beanName) throws org.springframework.beans.BeansException {
        /* compiled code */
        System.out.println("在初始化之后執行的方法");
        return bean;
    }

    <!--配置后置處理器-->
    <bean id="myBeanPost" class="com.yu.spring5.bean.MyBeanPost"></bean>

IOC 操作 Bean 管理（ xml 自動裝配）

1 、什么是自動裝配
（ 1 ）根據指定裝配規則（屬性名稱或者屬性類型），Spring自動將匹配的屬性值進行注入

2 、演示自動裝配過程
（ 1 ）根據屬性名稱自動注入

    <!--實現自動裝配
        bean標簽屬性autowire，配置自動裝配
        autowire屬性常用兩個值：
            byName根據屬性名注入  注入bean的id值和類屬性名稱
            byType根據屬性類型注入
    -->
    <bean id="emp" class="com.yu.spring5.autowire.Emp" autowire="byName" >
        <!--<property name="dept" ref="dept"></property>-->
    </bean>

    <bean id="dept" class="com.yu.spring5.autowire.Dept" >
    </bean>

（ 2 ）根據屬性類型自動注入

    <bean id="emp" class="com.yu.spring5.autowire.Emp" autowire="byType" >
        <!--<property name="dept" ref="dept"></property>-->
    </bean>

    <bean id="dept" class="com.yu.spring5.autowire.Dept" >
    </bean>

IOC 操作 Bean 管理 ( 外部屬性文件 )

1 、直接配置數據庫信息

（ 1 ）配置德魯伊連接池
（ 2 ）引入德魯伊連接池依賴jar包 druid-1.1.9.jar

    <!--直接配置連接池-->
    <!-- DruidDataSource dataSource = new DruidDataSource(); -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
        <property name="url" value="jdbc:mysql://localhost:3306/userDb"></property>
        <property name="username" value="root"></property>
        <property name="password" value="root"></property>
    </bean>

2 、引入外部屬性文件配置數據庫連接池

（ 1 ）創建外部屬性文件，properties格式文件，寫數據庫信息

prop.driverClass=com.mysql.jdbc.Driver
prop.url=jdbc:mysql://localhost:3306/userDb
prop.userName=root
prop.password=root

（ 2 ）把外部properties屬性文件引入到spring配置文件中

引入context名稱空間

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:util="http://www.springframework.org/schema/util"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

? 在spring配置文件使用標簽引入外部屬性文件

    <!--引入外部屬性文件-->
    <context:property-placeholder location="classpath:jdbc.properties"/>

    <!--配置連接池-->
    <!-- DruidDataSource dataSource = new DruidDataSource(); -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="${prop.driverClass}"></property>
        <property name="url" value="${prop.url}"></property>
        <property name="username" value="${prop.userName}"></property>
        <property name="password" value="${prop.password}"></property>
    </bean>

IOC 操作 Bean 管理 ( 基于注解方式 )

1 、什么是注解

（ 1 ）注解是代碼特殊標記，格式：@注解名稱(屬性名稱=屬性值, 屬性名稱=屬性值..)
（ 2 ）使用注解，注解作用在類上面，方法上面，屬性上面
（ 3 ）使用注解目的：簡化xml配置

2 、 Spring 針對 Bean 管理中創建對象提供注解

（ 1 ）@Component 普通組件
（ 2 ）@Service 用于業務邏輯（Service）層
（ 3 ）@Controller 用于Web層
（ 4 ）@Repository 用于Dao層

上面四個注解功能是一樣的，都可以用來創建bean實例

3 、基于注解方式實現對象創建

第一步引入依賴
spring-aop-5.2.6.RELEASE.jar
第二步開啟組件掃描
在bean1中添加

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!--開啟組件掃描
        1 如果掃描多個包，多個包使用逗號隔開
        2 掃描包上層目錄也可以實現掃描多個包
    -->
    <context:component-scan base-package="com.yu"></context:component-scan>
</beans>

第三步創建類，在類上面添加創建對象注解

//在注解里面value屬性值可以省略不寫
//若不寫，默認是類名稱，首字母小寫
//UserService --》userService

@Component(value = "userService")//<bean id="userService" class=".."/>
public class UserService {
    public void add(){
        System.out.println("service add·····");
    }
}

4 、開啟組件掃描細節配置

    <!--示例1
        use-default-filters="false" 表示現在不使用默認filter，自己配置filter
        context:include-filter， 設置掃描哪些內容（帶Controller注解的）
    -->
    <context:component-scan base-package="com.yu" use-default-filters="false">
        <context:include-filter type="annotation"
                                expression="org.springframework.stereotype.Controller"/>
    </context:component-scan>
    
    <!--示例2
        context:exclude-filter: 設置哪些內容不進行掃描
    -->
    <context:component-scan base-package="com.yu">
        <context:exclude-filter type="annotation"
                                expression="org.springframework.stereotype.Controller"/>
    </context:component-scan>

5 、基于注解方式實現屬性注入

前三個都是針對對象類型
（ 1 ）@Autowired：根據屬性類型進行自動裝配
第一步把service和dao對象創建，在service和dao類添加創建對象注解
第二步在service注入dao對象，在service類添加dao類型屬性，在屬性上面使用注解,不需要set方法
UserDao

@Repository
public class UserDaoImpl implements UserDao {

    @Override
    public void add() {
        System.out.println("dao add````");
    }
}

UserService

@Service
public class UserService {
    //定義dao類型屬性
    //不需要set方法
    //添加注入屬性注解
    @Autowired
    private UserDao userDao;

    public void add(){
        System.out.println("service add·····");
        userDao.add();
    }
}

（ 2 ）@Qualifier：根據名稱進行注入
這個@Qualifier注解的使用，和上面@Autowired一起使用

@Repository(value = "userDaoImpl1")
public class UserDaoImpl implements UserDao {

    @Override
    public void add() {
        System.out.println("dao add````");
    }
}

@Service
public class UserService {
    //定義dao類型屬性
    //不需要set方法
    //添加注入屬性注解
    @Autowired
    @Qualifier(value = "userDaoImpl1")//根據名稱進行注入
    private UserDao userDao;

    public void add(){
        System.out.println("service add·····");
        userDao.add();
    }
}

（ 3 ）@Resource：可以根據類型注入，可以根據名稱注入

import javax.annotation.Resource;


//@Resource //根據類型進行注入
@Resource(name = "userDaoImpl1") //根據名稱進行注入
private UserDao userDao;

（ 4 ）@Value：注入普通類型屬性

@Value(value = "abc")
private String name;

6 、完全注解開發(用配置類替代xml配置文件，詳細可見SpringBoot)

（ 1 ）創建配置類，替代xml配置文件
config.SpringConfig

@Configuration //作為配置類，替代xml配置文件
@ComponentScan(basePackages = {"com.yu"})
public class SpringConfig {

}

這樣就可以替代bean1.xml
（ 2 ）編寫測試類

    @Test
    public void testService(){
        ApplicationContext context =
                new AnnotationConfigApplicationContext(SpringConfig.class);
        UserService userService = context.getBean("userService", UserService.class);
        System.out.println(userService);
        userService.add();
    }

AOP （概念）

1 、什么是 AOP
（ 1 ）面向切面編程（方面），利用AOP可以對業務邏輯的各個部分進行隔離，從而使得
業務邏輯各部分之間的耦合度降低，提高程序的可重用性，同時提高了開發的效率。

（ 2 ）通俗描述：不通過修改源代碼方式，在主干功能里面添加新功能

（ 3 ）使用登錄例子說明AOP

AOP （底層原理）

1 、 AOP 底層使用動態代理
（ 1 ）有兩種情況動態代理
第一種有接口情況，使用 JDK 動態代理
? 創建接口實現類代理對象，增強類的方法

第二種沒有接口情況，使用 CGLIB 動態代理
? 創建子類的代理對象，增強類的方法

AOP （ JDK 動態代理）

1 、使用JDK動態代理，使用Proxy類里面的方法創建代理對象

（ 1 ）調用newProxyInstance方法

方法有三個參數：
第一參數，類加載器
第二參數，增強方法所在的類，這個類實現的接口，支持多個接口
第三參數，實現這個接口InvocationHandler，創建代理對象，寫增強的部分

2 、編寫 JDK 動態代理代碼
（ 1 ）創建接口，定義方法

package com.yu.spring5;

public interface UserDao {
    public int add(int a,int b);
    public String update(String id);
}

（ 2 ）創建接口實現類，實現方法

package com.yu.spring5;

public class UserDaoImpl implements UserDao {
    @Override
    public int add(int a, int b) {
        System.out.println("add方法執行了。。。");
        return a+b;
    }

    @Override
    public String update(String id) {
        System.out.println("update方法執行了。。。");
        return id;
    }
}

（ 3 ）使用Proxy類創建接口代理對象

package com.yu.spring5;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.util.Arrays;

public class JDKProxy {
    public static void main(String[] args){
        //創建接口實現類代理對象
        Class[] interfaces = {UserDao.class};
//        Proxy.newProxyInstance(JDKProxy.class.getClassLoader(), interfaces, new InvocationHandler() {
//            @Override
//            public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
//                return null;
//            }
//        });
        UserDaoImpl userDao = new UserDaoImpl();
        UserDao dao = (UserDao) Proxy.newProxyInstance(JDKProxy.class.getClassLoader(), interfaces, new UserDaoProxy(userDao));
        int result = dao.add(1, 2);
        System.out.println("result:"+result);
    }
}
//創建代理對象代碼
class UserDaoProxy implements InvocationHandler{
    //1 把創建的是誰的代理對象，的誰傳遞過來
    //有參構造傳遞
    private Object obj;
    public UserDaoProxy(Object obj){
        this.obj=obj;
    }

    //增強的邏輯
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        //方法之前
        System.out.println("方法之前執行..."+method.getName()+":傳遞的參數..."+ Arrays.toString(args));
        //被增強的方法執行
        Object res = method.invoke(obj, args);
        //方法之后
        System.out.println("方法執行之后..."+obj);

        return res;
    }
}

AOP （術語）

1 、連接點

2 、切入點

3 、通知（增強）

4 、切面

AOP 操作（準備工作）

1 、 Spring 框架一般都是基于 AspectJ 實現 AOP 操作
（ 1 ）AspectJ不是Spring組成部分，獨立AOP框架，一般把AspectJ和Spirng框架一起使
用，進行AOP操作

2 、基于 AspectJ 實現 AOP 操作
（ 1 ）基于xml配置文件實現
（ 2 ）基于注解方式實現（使用）

3 、在項目工程里面引入 AOP 相關依賴

spring-aspects-5.2.6.RELEASE.jar

4 、切入點表達式
（ 1 ）切入點表達式作用：知道對哪個類里面的哪個方法進行增強
（ 2 ）語法結構： execution([權限修飾符] [返回類型] [類全路徑] 方法名稱 )

舉例 1 ：對com.yu.dao.BookDao類里面的add進行增強
//* 任意修飾符 [返回類型]可以省略
execution(* com.yu.dao.BookDao.add(..))

舉例 2 ：對com.yu.dao.BookDao類里面的所有的方法進行增強
execution(* com.yu.dao.BookDao.* (..))

舉例 3 ：對com.yu.dao包里面所有類，類里面所有方法進行增強
execution(* com.yu.dao.. (..))

AOP 操作（ AspectJ 注解實現）（推薦）

1 、創建類，在類里面定義方法

package com.yu.spring5.aopanno;

import org.springframework.stereotype.Component;

//被增強的類
@Component
public class User {
    public void add(){
        System.out.println("add.....");
    }
}

2 、創建增強類（編寫增強邏輯）
（ 1 ）在增強類里面，創建方法，讓不同方法代表不同通知類型

package com.yu.spring5.aopanno;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

//增強的類
@Component
@Aspect//生成代理對象
public class UserProxy {
    //前置通知
    //@Before注解表示作為前置通知
    @Before(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void before(){
        System.out.println("before,.......");
    }
    //最終通知
    @After(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void after(){
        System.out.println("After,.......");
    }
    //后置通知（返回通知）
    //After是在方法之后執行，AfterReturning是返回值之后執行
    @AfterReturning(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void afterReturning(){
        System.out.println("AfterReturning,.......");
    }
    //異常通知
    @AfterThrowing(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void afterThrowing(){
        System.out.println("AfterThrowing,.......");
    }
    //環繞通知
    @Around(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
        System.out.println("環繞之前,.......");
        //被增強的方法執行
        proceedingJoinPoint.proceed();
        System.out.println("環繞之后,.......");
    }
}

3 、進行通知的配置
（ 1 ）在spring配置文件中，開啟注解掃描
bean1.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
    <!--開啟注解掃描-->
    <context:component-scan base-package="com.yu.spring5.aopanno"></context:component-scan>

    <!--開啟Aspect生成代理對象-->
    <aop:aspectj-autoproxy></aop:aspectj-autoproxy>
</beans>

（ 2 ）使用注解創建User和UserProxy對象

（ 3 ）在增強類上面添加注解 @Aspect

//增強的類

@Component
@Aspect //生成代理對象
public class UserProxy {

（ 4 ）在spring配置文件中開啟生成代理對象

<!-- 開啟Aspect生成代理對象-->
<aop:aspectj-autoproxy></aop:aspectj-autoproxy>

4 、配置不同類型的通知
（ 1 ）在增強類的里面，在作為通知方法上面添加通知類型注解，使用切入點表達式配置

（ 2 ）測試

package com.yu.spring5.test;

import com.yu.spring5.aopanno.User;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestAop {
    @Test
    public void testAopAnno(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");
        User user = context.getBean("user", User.class);
        user.add();
    }
}

5 、相同的切入點抽取

    //相同切入點抽取
    @Pointcut(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void pointdemo(){

    }
    //前置通知
    //@Before注解表示作為前置通知
    @Before(value = "pointdemo()")
    public void before(){
        System.out.println("before,.......");
    }

6 、有多個增強類多同一個方法進行增強，設置增強類優先級
（ 1 ）在增強類上面添加注解 @Order(數字類型值)，數字類型值越小優先級越高

@Component
@Aspect
@Order(1)
public class PersonProxy {
    //后置通知
    @Before(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void personBefore(){
        System.out.println("personBefore~~~~~");
    }
}

7 、完全使用注解開發
創建配置類，不需要創建xml配置文件
創建class: config.ConfigAop

package com.yu.spring5.config;

import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableAspectJAutoProxy;

@Configuration
@ComponentScan(basePackages = {"com.yu"})
@EnableAspectJAutoProxy(proxyTargetClass = true)
public class ConfigAop {
}

測試

    @Test
    public void testAopAnno(){
        ApplicationContext context =
                new AnnotationConfigApplicationContext(ConfigAop.class);
        User user = context.getBean("user", User.class);
        user.add();
    }

AOP 操作（ AspectJ 配置文件實現）（）

1 、創建兩個類，增強類和被增強類，創建方法

public class Book {
    public void buy(){
        System.out.println("buy......");
    }
}

public class BookProxy {
    public void before111(){
        System.out.println("before////");
    }
}

2 、在 spring 配置文件中創建兩個類對象

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
    <!--創建對象-->
    <bean id="book" class="com.yu.spring5.aopxml.Book"></bean>
    <bean id="bookProxy" class="com.yu.spring5.aopxml.BookProxy"></bean>

    <!--配置aop增強-->
    <aop:config>
        <!--切入點-->
        <aop:pointcut id="p" expression="execution(* com.yu.spring5.aopxml.Book.buy())"></aop:pointcut>    
        <!--配置切面-->
        <aop:aspect ref="bookProxy">
            <!--增強作用在具體的方法上-->
            <aop:before method="before111" pointcut-ref="p"/>
        </aop:aspect>
        
    </aop:config>
    

</beans>

3 、在 spring 配置文件中配置切入點

JdbcTemplate( 概念和準備 )

1 、什么是 JdbcTemplate
（ 1 ）Spring框架對JDBC進行封裝，使用JdbcTemplate方便實現對數據庫操作

2 、準備工作
（ 1 ）引入相關jar包

（ 2 ）在spring配置文件bean1.xml配置數據庫連接池

    <!-- 數據庫連接池 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close">
        <property name="url" value="jdbc:mysql:///user_db" />
        <property name="username" value="root" />
        <property name="password" value="root" />
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    </bean>

（ 3 ）bean1.xml中配置JdbcTemplate對象，注入DataSource

    <!--JdbcTemplate對象-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--注入dataSource-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

（ 4 ）創建service類，創建dao類，在dao注入jdbcTemplate對象

配置文件bean1.xml

<!-- 組件掃描 -->
<context:component-scan base-package="com.atguigu"></context:component-scan>

創建類：
? Service

package com.yu.spring5.service;

import com.yu.spring5.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class BookService {
    //注入dao
    @Autowired
    public BookDao bookDao;

}

? Dao

package com.yu.spring5.dao;

public interface BookDao {
}

package com.yu.spring5.dao;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository
public class BookDapImpl implements BookDao{
    //注入JdbcTemplate
    @Autowired
     private JdbcTemplate jdbcTemplate;
}

JdbcTemplate 操作數據庫（添加）

1 、對應數據庫創建實體類

package com.yu.spring5.entity;

public class Book{
    private String userId;
    private String username;
    private String ustatus;
//get和set略
}

2 、編寫 service 和 dao
BookService

    //添加方法
    public void addBook(Book book){
        bookDao.add(book);
    }

BookDao

    //添加方法
    void add(Book book);

（ 1 ）在dao進行數據庫添加操作
（ 2 ）調用JdbcTemplate對象里面update方法實現添加操作

? 有兩個參數
? 第一個參數：sql語句
? 第二個參數：可變參數，設置sql語句值

BookDaoImpl

@Repository
public class BookDapImpl implements BookDao{
    //注入JdbcTemplate
    @Autowired
     private JdbcTemplate jdbcTemplate;

    @Override
    public void add(Book book) {
        //1 創建sql語句
        String sql = "insert into t_book values(?,?,?)";
        //2 調用方法實現
        Object[] args = {book.getUserId(), book.getUsername(), book.getUstatus()};
        int update = jdbcTemplate.update(sql,args);
        System.out.println(update);
    }
}

3 、測試類

public class TestBook {
    @Test
    public void testJdbcTemplate(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");
        BookService bookService = context.getBean("bookService", BookService.class);

        Book book = new Book();
        book.setUserId("1");
        book.setUsername("Java");
        book.setUstatus("a");
        bookService.addBook(book);

    }
}

JdbcTemplate 操作數據庫（修改和刪除）

1 、修改

    @Override
    public void update(Book book) {
        String sql = "update t_book set username=?,ustatus=? where user_id=?";
        Object[] args = {book.getUsername(), book.getUstatus(), book.getUserId()};
        int update = jdbcTemplate.update(sql, args);
        System.out.println(update);
    }

2 、刪除

    @Override
    public void delete(int id) {
        String sql ="delete from t_book where user_id=?";
        int update = jdbcTemplate.update(sql, id);
        System.out.println(update);
    }

JdbcTemplate 操作數據庫（查詢返回某個值）

1 、查詢表里面有多少條記錄，返回是某個值
2 、使用 JdbcTemplate 實現查詢返回某個值代碼

? 有兩個參數
? 第一個參數：sql語句
? 第二個參數：返回類型Class

    @Override
    public int selectCount(){
        String sql = "select count(*) from t_book";
        Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
        return count;
    }

測試

        //查詢表記錄數
        System.out.println(bookService.findCount());

JdbcTemplate 操作數據庫（查詢返回對象）

1 、場景：查詢圖書詳情
2 、 JdbcTemplate 實現查詢返回對象

? 有三個參數
? 第一個參數：sql語句
? 第二個參數：RowMapper 是接口，針對返回不同類型數據，使用這個接口里面實現類完成
數據封裝
? 第三個參數：sql語句值

    @Override
    public Book findBookInfo(String id){
        String sql = "select * from t_book where user_id = ?";
        Book book1 = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<Book>(Book.class), id);
        return book1;
    }

JdbcTemplate 操作數據庫（查詢返回集合）

1 、場景：查詢圖書列表分頁 ...

2 、調用 JdbcTemplate 方法實現查詢返回集合

    //查詢返回集合
    @Override
    public List<Book> findAllBook() {
        String sql = "select * from t_book";
        List<Book> bookList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<Book>(Book.class));
        return bookList;
    }

測試

        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");
        BookService bookService = context.getBean("bookService", BookService.class);
        List<Book> all = bookService.findAll();
        System.out.println(all);

JdbcTemplate 操作數據庫（批量操作）

1 、批量操作：操作表里面多條記錄

2 、 JdbcTemplate 實現批量添加操作

? 有兩個參數
? 第一個參數：sql語句
? 第二個參數：List集合，添加多條記錄數據

    //批量添加
    @Override
    public void batchAddBook(List<Object[]> batchArgs) {
        String sql = "insert into t_book values(?,?,?)";
        int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
        System.out.println(Arrays.toString(ints));
    }

批量添加測試

        //批量添加 測試
        List<Object[]> batchArgs = new ArrayList<>();
        Object[] o1 ={"5","java","b"};
        Object[] o2 ={"6","c++","c"};
        Object[] o3 ={"7","mysql","d"};
        batchArgs.add(o1);
        batchArgs.add(o2);
        batchArgs.add(o3);
       
        bookService.batchAdd(batchArgs);

3 、 JdbcTemplate 實現批量修改操作

    @Override
    public void batchUpdateBook(List<Object[]> batchArgs) {
        String sql = "update t_book set username = ?,ustatus=? where user_id = ?";
        int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
        System.out.println(Arrays.toString(ints));
    }

        //批量修改 測試
        List<Object[]> batchArgs = new ArrayList<>();
        Object[] o1 ={"javaBatch","bBatch","5"};
        Object[] o2 ={"c++Batch","cBatch","6"};
        Object[] o3 ={"mysqlBatch","dBatch","7",};
        batchArgs.add(o1);
        batchArgs.add(o2);
        batchArgs.add(o3);

        bookService.batchUpdate(batchArgs);

4 、 JdbcTemplate 實現批量刪除操作

    @Override
    public void batchDeleteBook(List<Object[]> batchArgs) {
        String sql ="delete from t_book where user_id = ?";
        int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
        System.out.println(Arrays.toString(ints));
    }

        //批量刪除 測試
        List<Object[]> batchArgs = new ArrayList<>();
        Object[] o1 = {"6"};
        Object[] o2 = {"7"};
        batchArgs.add(o1);
        batchArgs.add(o2);

        bookService.batchDelete(batchArgs);

事務操作（事務概念）

1 、什么事務
（ 1 ）事務是數據庫操作最基本單元，邏輯上一組操作，要么都成功，如果有一個失敗所有操
作都失敗
（ 2 ）典型場景：銀行轉賬

lucy 轉賬 100 元給mary
lucy少 100 ，mary多 100

2 、事務四個特性（ ACID ）
（ 1 ）原子性
（ 2 ）一致性
（ 3 ）隔離性
（ 4 ）持久性

事務操作（搭建事務操作環境）

1 、創建數據庫表，添加記錄

2 、創建 service ，搭建 dao ，完成對象創建和注入關系
（ 1 ）service注入dao，在dao注入JdbcTemplate，在JdbcTemplate注入DataSource

@Service
public class UserService {
    //注入dao
    @Autowired
    private UserDao userDao;

    //轉賬
    public void accountMoney(){
        
        userDao.addMoney();
        int i = 10/0;
        userDao.reduceMoney();
    }
}

3 、在 dao 創建兩個方法：多錢和少錢的方法，在 service 創建方法（轉賬的方法）

@Repository
public class UserDaoImpl implements UserDao{
    @Autowired
    private JdbcTemplate jdbcTemplate;
    //lucy 轉賬100給mary
    @Override
    public void addMoney() {
        String sql = "update account set money = money-? where username = ?";
        jdbcTemplate.update(sql,100,"lucy");
    }

    @Override
    public void reduceMoney() {
        String sql = "update account set money = money+? where username = ?";
        jdbcTemplate.update(sql,100,"mary");
    }

}

4 、上面代碼，如果正常執行沒有問題的，但是如果代碼執行過程中出現異常，有問題

（ 1 ）上面問題如何解決呢？

使用事務進行解決

（ 2 ）事務操作過程

事務操作（ Spring 事務管理介紹）

1 、事務添加到 JavaEE 三層結構里面 Service 層（業務邏輯層）

2 、在 Spring 進行事務管理操作
（ 1 ）有兩種方式：編程式事務管理和聲明式事務管理（使用）

3 、聲明式事務管理
（ 1 ）基于注解方式（使用）
（ 2 ）基于xml配置文件方式

4 、在 Spring 進行聲明式事務管理，底層使用 AOP 原理

5 、 Spring 事務管理 API
（ 1 ）提供一個接口，代表事務管理器，這個接口針對不同的框架提供不同的實現類

事務操作（注解聲明式事務管理）

1 、在 spring 配置文件配置事務管理器

<!--創建事務管理器-->
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!--注入數據源-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

2 、在 spring 配置文件，開啟事務注解
（ 1 ）在spring配置文件引入名稱空間 tx

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
                             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

（ 2 ）開啟事務注解

    <!--開啟事務注解-->
    <tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>

3 、在 service 類上面（或者 service 類里面方法上面）添加事務注解
（ 1 ）@Transactional，這個注解添加到類上面，也可以添加方法上面
（ 2 ）如果把這個注解添加類上面，這個類里面所有的方法都添加事務
（ 3 ）如果把這個注解添加方法上面，為這個方法添加事務

@Service
@Transactional
public class UserService {

事務操作（注解聲明式事務管理參數配置）

1 、在 service 類上面添加注解 @Transactional ，在這個注解里面可以配置事務相關參數

2 、 propagation ：事務傳播行為

（ 1 ）多事務方法直接進行調用，這個過程中事務是如何進行管理的

@Service
@Transactional( propagation = Propagation.REQUIRED)
public class UserService {

3 、 ioslation ：事務隔離級別

（ 1 ）事務有特性成為隔離性，多事務操作之間不會產生影響。不考慮隔離性產生很多問題
（ 2 ）有三個讀問題：臟讀、不可重復讀、虛（幻）讀
（ 3 ）臟讀：一個未提交事務讀取到另一個未提交事務的數據

（ 4 ）不可重復讀：一個未提交事務讀取到另一提交事務修改數據

（ 5 ）虛讀：一個未提交事務讀取到另一提交事務添加數據

（ 6 ）解決：通過設置事務隔離級別，解決讀問題

mysql默認是REPEATABLE_READ

@Service
@Transactional(isolation = Isolation.REPEATABLE_READ)
public class UserService {

4 、 timeout ：超時時間

（ 1 ）事務需要在一定時間內進行提交，如果不提交進行回滾
（ 2 ）默認值是 - 1 ，設置時間以秒單位進行計算

5 、 readOnly ：是否只讀

（ 1 ）讀：查詢操作，寫：添加修改刪除操作
（ 2 ）readOnly默認值false，表示可以查詢，可以添加修改刪除操作
（ 3 ）設置readOnly值是true，設置成true之后，只能查詢

6 、 rollbackFor ：回滾

（ 1 ）設置出現哪些異常進行事務回滾

@Service
@Transactional(rollbackFor = Exception.class)
public class UserService {

7 、 noRollbackFor ：不回滾

（ 1 ）設置出現哪些異常不進行事務回滾

事務操作（ XML 聲明式事務管理）

1 、在 spring 配置文件中進行配置

第一步配置事務管理器
第二步配置通知
第三步配置切入點和切面

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
                             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
    <!--組件掃描    -->
    <context:component-scan base-package="com.yu"></context:component-scan>
    <!-- 數據庫連接池 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close">
        <property name="url" value="jdbc:mysql:///user_db" />
        <property name="username" value="root" />
        <property name="password" value="root" />
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    </bean>
    <!--JdbcTemplate對象-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--注入dataSource-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!--1 創建事務管理器-->
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!--注入數據源-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!--2 配置通知-->
    <tx:advice id="txadvice">
        <!--配置事務參數-->
        <tx:attributes>
            <!--指定哪種規則的方法上面添加事務-->
            <tx:method name="accountMoney" propagation="REQUIRED"/>
            <!--<tx:method name="account*"/>-->
        </tx:attributes>
    </tx:advice>
    <!--3 配置切入點和切面-->
    <aop:config>
        <!--配置切入點-->
        <aop:pointcut id="pt" expression="execution(* com.yu.spring5.service.UserService.*(..))"/>
        <!--配置切面-->
        <aop:advisor advice-ref="txadvice" pointcut-ref="pt"></aop:advisor>
    </aop:config>
</beans>

測試

public class TestBook {
    @Test
    public void testAccount(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean2.xml");
        UserService userService = context.getBean("userService", UserService.class);
        userService.accountMoney();
    }
}

事務操作（完全注解聲明式事務管理）

1 、創建配置類，使用配置類替代 xml 配置文件
在spring5下新建config.TxConfig

package com.yu.spring5.config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;

@Configuration//配置類
@ComponentScan(basePackages = "com.yu")//組件掃描
@EnableTransactionManagement//開啟事務
public class TxConfig {
    //創建數據庫連接池
    @Bean
    public DruidDataSource getDruidDataSource(){
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql:///user_db");
        dataSource.setUsername("root");
        dataSource.setPassword("root");

        return dataSource;
    }
    //創建JdbcTemplate對象
    @Bean
    public JdbcTemplate getJdbcTemplate(DataSource dataSource){
        //到ioc容器中根據類型找到dataSource
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        //注入dataSource
        jdbcTemplate.setDataSource(dataSource);

        return jdbcTemplate;
    }
    //創建事務管理器
    @Bean
    public DataSourceTransactionManager getDataSourceTransactionManager(DataSource dataSource){
        DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource);
        return transactionManager;
    }

}

測試

    @Test
    public void testAccount2(){
        ApplicationContext context =
                new AnnotationConfigApplicationContext(TxConfig.class);
        UserService userService = context.getBean("userService", UserService.class);
        userService.accountMoney();
    }

Spring5 框架新功能

1 、整個 Spring5 框架的代碼基于 Java8 ，運行時兼容 JDK9 ，許多不建議使用的類和方法在代碼庫中刪除

2 、Spring 5.0框架自帶了通用的日志封裝Log4j2

（ 1 ）Spring5已經移除Log4jConfigListener，官方建議使用Log4j2
（ 2 ）Spring5框架整合Log4j2
第一步引入jar包

第二步在src下創建log4j2.xml配置文件

<?xml version="1.0" encoding="UTF-8"?>
<!--日志級別以及優先級排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->
<!--Configuration后面的status用于設置log4j2自身內部的信息輸出，可以不設置，當設置成trace時，可以看到log4j2內部各種詳細輸出-->
<configuration status="INFO">
    <!--先定義所有的appender-->
    <appenders>
        <!--輸出日志信息到控制臺-->
        <console name="Console" target="SYSTEM_OUT">
            <!--控制日志輸出的格式-->
            <PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
        </console>
    </appenders>
    <!--然后定義logger，只有定義了logger并引入的appender，appender才會生效-->
    <!--root：用于指定項目的根日志，如果沒有單獨指定Logger，則會使用root作為默認的日志輸出-->
    <loggers>
        <root level="info">
            <appender-ref ref="Console"/>
        </root>
    </loggers>
</configuration>

手動日志輸出

package com.yu.spring5.test;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class UserLog {
    private static final Logger log = LoggerFactory.getLogger(UserLog.class);

    public static void main(String[] args){
        log.info("hello log4j2");
        log.warn("hello log4j2");
    }
}

3 、 Spring5 框架核心容器支持 @Nullable 注解

（ 1 ）@Nullable注解可以使用在方法上面，屬性上面，參數上面，表示方法返回可以為空，屬性值可以
為空，參數值可以為空

（ 2 ）注解用在方法上面，方法返回值可以為空

（ 3 ）注解使用在方法參數里面，方法參數可以為空

（ 4 ）注解使用在屬性上面，屬性值可以為空

4 、 Spring5 核心容器支持函數式風格 GenericApplicationContext

JAVA8中的Lambda理解使用
 在Java中如何使用lambda表達式中的Supplier 接口？

    //函數式風格創建對象，交給spring進行管理
    @Test
    public void testGenericApplicationContext(){
        // 1 創建GenericApplicationContext對象
        GenericApplicationContext context = new GenericApplicationContext();
        //2 調用context的方法對象注冊
        context.refresh();
        context.registerBean("user1",User.class,() -> new User());
        //3 獲取在spring注冊的對象
//        User user = (User) context.getBean("com.yu.spring5.test.User");
        User user = (User) context.getBean("user1");
        System.out.println(user);
    }

5 、 Spring5 支持整合 JUnit5

（ 1 ）整合JUnit4
第一步引入Spring相關針對測試依賴
spring-test-5.2.6.RELEASE.jar
第二步創建測試類，使用注解方式完成

package com.yu.spring5.test;

import com.yu.spring5.service.UserService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)//單元測試框架
@ContextConfiguration("classpath:bean1.xml")//加載配置文件
public class JTest4 {

    @Autowired
    private UserService userService;

    @Test
    public void test1(){
        userService.accountMoney();
    }
}

（ 2 ）Spring5整合JUnit5
第一步引入JUnit5的jar包

第二步創建測試類，使用注解完成

package com.yu.spring5.test;

import com.yu.spring5.service.UserService;

import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit.jupiter.SpringExtension;


@ExtendWith(SpringExtension.class)
@ContextConfiguration("classpath:bean1.xml")//加載配置文件
public class JTest5 {

    @Autowired
    private UserService userService;

    @Test
    public void test1(){
        userService.accountMoney();
    }
}

（ 3 ）使用一個復合注解替代上面兩個注解完成整合

@SpringJUnitConfig(locations = "classpath:bean1.xml")
public class JTest5 {

    @Autowired
    private UserService userService;

    @Test
    public void test1(){
        userService.accountMoney();
    }
}

Spring5 框架新功能（ Webflux ）

1 、 SpringWebflux 介紹

（ 1 ）是Spring5添加新的模塊，用于web開發的，功能和SpringMVC類似的，Webflux使用
當前一種比較流程響應式編程出現的框架。

（ 2 ）使用傳統web框架，比如SpringMVC，這些基于Servlet容器，Webflux是一種異步非阻
塞的框架，異步非阻塞的框架在Servlet3.1以后才支持，核心是基于Reactor的相關API實現
的。

（ 3 ）解釋什么是異步非阻塞

異步和同步
非阻塞和阻塞
** 上面都是針對對象不一樣

****** 異步和同步針對調用者，調用者發送請求，如果等著對方回應之后才去做其他事情就是同
步，如果發送請求之后不等著對方回應就去做其他事情就是異步

** 阻塞和非阻塞針對被調用者，被調用者受到請求之后，做完請求任務之后才給出反饋就是阻
塞，受到請求之后馬上給出反饋然后再去做事情就是非阻塞

（ 4 ）Webflux特點：
第一非阻塞式：在有限資源下，提高系統吞吐量和伸縮性，以Reactor為基礎實現響應式編程
第二函數式編程：Spring5框架基于java8，Webflux使用Java8函數式編程方式實現路由請求

（ 5 ）比較SpringMVC

第一兩個框架都可以使用注解方式，都運行在Tomet等容器中

第二 SpringMVC采用命令式編程，Webflux采用異步響應式編程

2 、響應式編程（ Java 實現）

（ 1 ）什么是響應式編程
響應式編程是一種面向數據流和變化傳播的編程范式。這意味著可以在編程語言中很方便
地表達靜態或動態的數據流，而相關的計算模型會自動將變化的值通過數據流進行傳播。
電子表格程序就是響應式編程的一個例子。單元格可以包含字面值或類似"=B1+C1"的公
式，而包含公式的單元格的值會依據其他單元格的值的變化而變化。

（ 2 ）Java8及其之前版本

提供的觀察者模式兩個類Observer和Observable

public class ObserverDemo extends Observable {

public static void main(String[] args) {
ObserverDemo observer = new ObserverDemo();
//添加觀察者
observer.addObserver((o,arg)->{
System.out.println("發生變化");
});
observer.addObserver((o,arg)->{
System.out.println("手動被觀察者通知，準備改變");
});
observer.setChanged(); //數據變化
observer.notifyObservers(); //通知
}
}

3 、響應式編程（ Reactor 實現）

（ 1 ）響應式編程操作中， Reactor 是滿足 Reactive 規范框架
（ 2 ） Reactor 有兩個核心類， Mono 和 Flux ，這兩個類實現接口 Publisher ，提供豐富操作
符。 Flux 對象實現發布者，返回 N 個元素； Mono 實現發布者，返回 0 或者 1 個元素
（ 3 ）Flux和Mono都是數據流的發布者，使用Flux和Mono都可以發出三種數據信號：
元素值，錯誤信號，完成信號，錯誤信號和完成信號都代表終止信號，終止信號用于告訴
訂閱者數據流結束了，錯誤信號終止數據流同時把錯誤信息傳遞給訂閱者

（ 4 ）代碼演示 Flux 和 Mono

第一步引入依賴

## <dependency>

## <groupId>io.projectreactor</groupId>

## <artifactId>reactor-core</artifactId>

## <version>3.1.5.RELEASE</version>

## </dependency>

第二步編程代碼

public static void main(String[] args) {
//just方法直接聲明
Flux.just( 1 , 2 , 3 , 4 );
Mono.just( 1 );
//其他的方法
Integer[] array = { 1 , 2 , 3 , 4 };
Flux.fromArray(array);

List<Integer> list = Arrays.asList(array);
Flux.fromIterable(list);

Stream<Integer> stream = list.stream();
Flux.fromStream(stream);
}

（ 5 ）三種信號特點

錯誤信號和完成信號都是終止信號，不能共存的
如果沒有發送任何元素值，而是直接發送錯誤或者完成信號，表示是空數據流
如果沒有錯誤信號，沒有完成信號，表示是無限數據流

（ 6 ）調用just或者其他方法只是聲明數據流，數據流并沒有發出，只有進行訂閱之后才會觸
發數據流，不訂閱什么都不會發生的

（ 7 ）操作符
***** 對數據流進行一道道操作，成為操作符，比如工廠流水線
第一 map 元素映射為新元素

第二 flatMap 元素映射為流
? 把每個元素轉換流，把轉換之后多個流合并大的流

4 、 SpringWebflux 執行流程和核心 API

SpringWebflux基于Reactor，默認使用容器是Netty，Netty是高性能的NIO框架，異步非阻
塞的框架
（ 1 ）Netty

NIO

（ 2 ）SpringWebflux執行過程和SpringMVC相似的

SpringWebflux核心控制器 DispatchHandler，實現接口WebHandler
接口WebHandler有一個方法

（ 3 ）SpringWebflux里面DispatcherHandler，負責請求的處理

HandlerMapping：請求查詢到處理的方法
HandlerAdapter：真正負責請求處理
HandlerResultHandler：響應結果處理

（ 4 ）SpringWebflux實現函數式編程，兩個接口：RouterFunction（路由處理）
和HandlerFunction（處理函數）

5 、 SpringWebflux （基于注解編程模型）

SpringWebflux實現方式有兩種：注解編程模型和函數式編程模型
使用注解編程模型方式，和之前SpringMVC使用相似的，只需要把相關依賴配置到項目中，
SpringBoot自動配置相關運行容器，默認情況下使用Netty服務器

第一步創建SpringBoot工程，引入Webflux依賴

第二步配置啟動端口號

第三步創建包和相關類
? 實體類

? 創建接口定義操作的方法

//用戶操作接口
public interface UserService {
//根據id查詢用戶
Mono<User> getUserById(int id);
//查詢所有用戶
Flux<User> getAllUser();
//添加用戶
Mono<Void> saveUserInfo(Mono<User> user);
}

? 接口實現類

public class UserServiceImpl implements UserService {
//創建map集合存儲數據
private final Map<Integer,User> users = new HashMap<>();
public UserServiceImpl() {
this.users.put( 1 ,new User("lucy","nan", 20 ));
this.users.put( 2 ,new User("mary","nv", 30 ));
this.users.put( 3 ,new User("jack","nv", 50 ));
}
//根據id查詢
@Override
public Mono<User> getUserById(int id) {
return Mono.justOrEmpty(this.users.get(id));
}
//查詢多個用戶
@Override
public Flux<User> getAllUser() {
return Flux.fromIterable(this.users.values());
}


//添加用戶
@Override
public Mono<Void> saveUserInfo(Mono<User> userMono) {
return userMono.doOnNext(person -> {
//向map集合里面放值
int id = users.size()+ 1 ;
users.put(id,person);
}).thenEmpty(Mono.empty());
}
}

? 創建controller

@RestController
public class UserController {
//注入service
@Autowired
private UserService userService;
//id查詢
@GetMapping("/user/{id}")
public Mono<User> geetUserId(@PathVariable int id) {
return userService.getUserById(id);
}
//查詢所有
@GetMapping("/user")
public Flux<User> getUsers() {
return userService.getAllUser();
}
//添加
@PostMapping("/saveuser")
public Mono<Void> saveUser(@RequestBody User user) {
Mono<User> userMono = Mono.just(user);
return userService.saveUserInfo(userMono);
}
}

? 說明
SpringMVC方式實現，同步阻塞的方式，基于SpringMVC+Servlet+Tomcat
SpringWebflux方式實現，異步非阻塞方式，基于SpringWebflux+Reactor+Netty

6 、 SpringWebflux （基于函數式編程模型）

（ 1 ）在使用函數式編程模型操作時候，需要自己初始化服務器
（ 2 ）基于函數式編程模型時候，有兩個核心接口：RouterFunction（實現路由功能，請求轉發
給對應的handler）和HandlerFunction（處理請求生成響應的函數）。核心任務定義兩個函數
式接口的實現并且啟動需要的服務器。
（ 3 ）SpringWebflux 請求和響應不再是 ServletRequest 和 ServletResponse，而是
ServerRequest和ServerResponse

第一步把注解編程模型工程復制一份，保留entity和service內容
第二步創建Handler（具體實現方法）

public class UserHandler {
private final UserService userService;
public UserHandler(UserService userService) {


this.userService = userService;
}
//根據id查詢
public Mono<ServerResponse> getUserById(ServerRequest request) {
//獲取id值
int userId = Integer.valueOf(request.pathVariable("id"));
//空值處理
Mono<ServerResponse> notFound = ServerResponse.notFound().build();
//調用service方法得到數據
Mono<User> userMono = this.userService.getUserById(userId);
//把userMono進行轉換返回
//使用Reactor操作符flatMap
return
userMono
.flatMap(person ->
ServerResponse.ok().contentType(MediaType.APPLICATION_JSON)
.body(fromObject(person)))
.switchIfEmpty(notFound);
}
//查詢所有
public Mono<ServerResponse> getAllUsers() {
//調用service得到結果
Flux<User> users = this.userService.getAllUser();
return
ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(users,User.cl
ass);
}
//添加
public Mono<ServerResponse> saveUser(ServerRequest request) {
//得到user對象
Mono<User> userMono = request.bodyToMono(User.class);
return
ServerResponse.ok().build(this.userService.saveUserInfo(userMono));
}

}

第三步初始化服務器，編寫Router
? 創建路由的方法

//1 創建Router路由
public RouterFunction<ServerResponse> routingFunction() {
//創建hanler對象
UserService userService = new UserServiceImpl();
UserHandler handler = new UserHandler(userService);
//設置路由
return RouterFunctions.route(

GET("/users/{id}").and(accept(APPLICATION_JSON)),handler::getUserById)
.andRoute(GET("/users").and(accept(APPLICATION_JSON)),handler::get
AllUsers);
}

? 創建服務器完成適配

//2 創建服務器完成適配
public void createReactorServer() {
//路由和handler適配
RouterFunction<ServerResponse> route = routingFunction();
HttpHandler httpHandler = toHttpHandler(route);
ReactorHttpHandlerAdapter adapter = new
ReactorHttpHandlerAdapter(httpHandler);
//創建服務器
HttpServer httpServer = HttpServer.create();
httpServer.handle(adapter).bindNow();
}

? 最終調用

public static void main(String[] args) throws Exception{
Server server = new Server();
server.createReactorServer();
System.out.println("enter to exit");
System.in.read();
}

（ 4 ）使用WebClient調用

public class Client {
public static void main(String[] args) {
//調用服務器地址
WebClient webClient = WebClient.create("http://127.0.0.1:5794");
//根據id查詢
String id = "1";
User userresult = webClient.get().uri("/users/{id}", id)
.accept(MediaType.APPLICATION_JSON).retrieve().bodyToMono(User
.class)
.block();
System.out.println(userresult.getName());

//查詢所有
Flux<User> results = webClient.get().uri("/users")
.accept(MediaType.APPLICATION_JSON).retrieve().bodyToFlux(User
.class);
results.map(stu -> stu.getName())
.buffer().doOnNext(System.out::println).blockFirst();
}
}

課程總結

1 、 Spring 框架概述
（ 1 ）輕量級開源JavaEE框架，為了解決企業復雜性，兩個核心組成：IOC 和AOP
（ 2 ）Spring5.2.6版本

2 、 IOC 容器

（ 1 ）IOC底層原理（工廠、反射等）
（ 2 ）IOC接口（BeanFactory）
（ 3 ）IOC操作Bean管理（基于xml）
（ 4 ）IOC操作Bean管理（基于注解）

3 、 Aop
（ 1 ）AOP底層原理：動態代理，有接口（JDK動態代理），沒有接口（CGLIB動態代理）
（ 2 ）術語：切入點、增強（通知）、切面
（ 3 ）基于AspectJ實現AOP操作

4 、 JdbcTemplate

（ 1 ）使用JdbcTemplate實現數據庫curd操作
（ 2 ）使用JdbcTemplate實現數據庫批量操作

5 、事務管理
（ 1 ）事務概念
（ 2 ）重要概念（傳播行為和隔離級別）
（ 3 ）基于注解實現聲明式事務管理
（ 4 ）完全注解方式實現聲明式事務管理

6 、 Spring5 新功能
（ 1 ）整合日志框架
（ 2 ）@Nullable注解
（ 3 ）函數式注冊對象
（ 4 ）整合JUnit5單元測試框架
（ 5 ）SpringWebflux使用

posted @ 2021-07-14 10:46 星空與滄海閱讀(185) 評論(0) 收藏舉報

刷新頁面返回頂部

星空與滄海