spring boot(学习笔记第十一课)

Session共享，JPA实现自动RESTful

学习内容：

Session共享
JPA实现自动RESTful

1. Session共享

Session共享面临问题
- spring boot默认将session保存在web server的内存里面，会产生什么问题呢。
  如上图所示，有nginx作为服务器前置负载均衡器的时候，第一次访问将session保存在web server 1中的内存中，但是第二次访问的时候，假如重新定向到web server 4的时候，将无法正确取得session。
- 使用redis解决问题
  
  使用redis之后，使每次web server的session数据都保存到唯一的redis的，这样重定向到那个web server，最后都会从redis的内存取得，所以每次取得和保存的session数据都一致。

Nginx负载均衡

创建nginx server 最好使用sudo -i。注意，这里使用VMware进行创建

cd /data
mkdir nginx
wget https://nginx.org/download/nginx-1.27.0.tar.gz
cd nginx-1.27.0
yum -y install pcre-devel openssl openssl-devel gd-devel gcc gcc-c++
./configure
make
make install

启动nginx server
- 如果有process占用80端口,通过ss -tulnp | grep :80命令确认。
- 如果有process占用80端口,通过ss -tulnp | grep :80命令确认。
- 之后定位到$pid，使用kill -9 $pid结束进行。注意，这里$pid意味需要替换的变量
尝试访问nginx server
http://192.168.12.130/ 注意，这里采用http，不能采用https，如何配置https在nginx中需要确认

修改nginx.conf配置文件

 upstream finlay.com{
      server 192.168.12.1:8080 weight=1;
      server 192.168.12.1:8081 weight=1;
    }
    #gzip  on;
    server {
        listen       80;
        server_name  localhost;
        #charset koi8-r;
        #access_log  logs/host.access.log  main;

        location / {
            proxy_pass http://finlay.com;
            proxy_redirect default;
        }

对spring boot应用加入session依赖
加入了这个依赖，spring boot应用程序自动 session数据保存到redis的数据库中。

 <dependency>
            <groupId>org.springframework.session</groupId>
            <artifactId>spring-session-data-redis</artifactId>
</dependency>

配置controller并且去掉https

配置controller，在controller中向session保存信息之后从session读取信息。

    @Value("${server.port}")
    private String port;

    @PostMapping("/save")
    @ResponseBody
    public String saveName(String name, HttpSession session) {
        session.setAttribute("name", name);
        return port;
    }

    @GetMapping("get")
    @ResponseBody
    public String getName(HttpSession session) {
        return port + ":" + session.getAttribute("name").toString();
    }

将https配置去掉，因为暂时nginx没有配置https。

#server.ssl.key-store=classpath:/key/httpskey.p12
#server.ssl.key-alias=hellohttps
#server.ssl.key-store-password=123456

分别启动8080和8081两个端口，模拟两个server，进行负载均衡处理server。

java -jar demo-0.0.1-SNAPSHOT.jar --server.port=8080
java -jar demo-0.0.1-SNAPSHOT.jar --server.port=8081

使用postman对nginx服务器进行模拟发送post请求和get请求。
- 发送post请求，对session上设置name的attribute。从结果是8080端口来看，这里是通过8080端口的服务器进行session情报的保存。
- 发送get请求，对session上设置name的attribute`。
  
  可以看到当nginx将请求post的save请求上对session进行设置后，8081端口的上get请求，能够马上去的到同样的值，保证服务器端的前置负载均衡器将请求重定向到另一个服务器，取得到的session情报一致。

2. JPA实现自动RESTful

这里使用postgresql进行实验，对数据源进行配置。

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.url=jdbc:postgresql://127.0.0.1:5432/springboot
spring.datasource.username=finlay
spring.datasource.password=123456
spring.jpa.database=postgresql
spring.jpa.properties.show-sql=true
spring.jpa.properties.hibernate.hbm2ddl.auto=update
spring.datasource.driver-class-name=org.postgresql.Driver
spring.jpa.database-platform=org.hibernate.dialect.PostgreSQLDialect

同样引入必要的依赖

 <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.9</version>
 </dependency>
 <dependency>
            <groupId>org.postgresql</groupId>
            <artifactId>postgresql</artifactId>
            <scope>runtime</scope>
</dependency>
<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-rest</artifactId>
</dependency>

注意这里加入了spring-boot-starter-data-rest，可以在后面看到，这里不需要在定义自己的controller代码，spring-boot-starter-data-rest可以自动生成自己的RESTful方法。

JpaRepository提供的默认方法
JpaRepository本身提供了好多方法。尝试查看下代码。

@NoRepositoryBean
public interface JpaRepository<T, ID> extends ListCrudRepository<T, ID>, ListPagingAndSortingRepository<T, ID>, QueryByExampleExecutor<T> {
    void flush();
    <S extends T> S saveAndFlush(S entity);
    <S extends T> List<S> saveAllAndFlush(Iterable<S> entities);
    /** @deprecated */
    @Deprecated
    default void deleteInBatch(Iterable<T> entities) {
        this.deleteAllInBatch(entities);
    }
    void deleteAllInBatch(Iterable<T> entities);
    void deleteAllByIdInBatch(Iterable<ID> ids);
    void deleteAllInBatch();

定义Entity类和创建BookReposity

定义Entity类 Book

@Data
@Entity(name = "book")
public class Book{
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;
    private String name;
    private String author;
}

继承JpaRepository<T, ID>，生成自己的interface。

	public interface BookDao extends JpaRepository<Book,Integer> {
	}

其余的代码需不需要，spring boot会自动生成books (默认的，book表名加上s)，作为默认的RESTful API的path。

利用postman进行访问
- 利用post books进行请求，保存book的Entity对象。
- 查看数据库的保存情况。
- 看到增加的Entity，spring boot也给出了访问的url，进一步使用GET进行访问。
- 对books发出POST请求，findAll所有的记录。
- 对book特定id发出PUT请求，修改该记录。
- 对于上面的默认path(url)可以进行修改
- 修改整个集合的path配置。
  - path
  - collectionResourceRel
  - itemResourceRel
```
@RepositoryRestResource(path = "my_books",
        collectionResourceRel = "my_books",
        itemResourceRel = "my_book")
public interface BookDao extends JpaRepository<Book, Integer> {
}
```