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

• Session共享，JPA实现自动RESTful

---

学习内容：

1. Session共享
2. JPA实现自动RESTful

---

1. Session共享

1. 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数据都一致。

2. 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;}
     

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

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

4. 配置controller并且去掉https

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

         @Value("${server.port}")private String port;@PostMapping("/save")@ResponseBodypublic String saveName(String name, HttpSession session) {session.setAttribute("name", name);return port;}@GetMapping("get")@ResponseBodypublic 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
     

5. 使用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

1. 这里使用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
   

2. 同样引入必要的依赖

    <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方法。

3. 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 */@Deprecateddefault void deleteInBatch(Iterable<T> entities) {this.deleteAllInBatch(entities);}void deleteAllInBatch(Iterable<T> entities);void deleteAllByIdInBatch(Iterable<ID> ids);void deleteAllInBatch();
   

4. 定义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。

5. 利用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> {
     }