• 【技术分享】使用nginx完成动静分离➕集成SpringSession➕集成sentinel➕集成seata

    🥳🥳Welcome 的Huihui's Code World ! !🥳🥳

    接下来看看由辉辉所写的关于技术点的相关分享吧

    目录

    🥳🥳Welcome 的Huihui's Code World ! !🥳🥳

    一、 使用nginx完成动静分离

    1.下载nginx

    2.进入conf目录，并修改nginx.conf配置文件

    3.动静分离

    4.将静态文件放置再nginx中

    5.运行nginx根目录下的nginx.exe启动nginx

    6.修改项目中静态资源的路径

    二、 集成SpringSession

    1.引入依赖

    2.在需要使用到springsession的模块做以下配置

    3.编写代码完成登录功能

    4.前端显示

    三、 集成sentinel

    1.导入pom依赖

    2.在application文件中进行配置

    3.浏览器访问sentinel

    四、集成seata

    1.下载seata

    2.修改配置文件及初始化

    ①seata-server-1.4.0.zip​​​​​​​

    ②修改file.conf

    ③创建数据库Seata并初始化数据表

    3.启动seata服务

    4.使用Seata实现事务控制

    1.初始化数据表

    2.添加配置

    ①DataSourceProxyConfig

    ②application.yml

    ③registry.conf

    ③bootstrap.yaml

    一、 使用nginx完成动静分离

    1.下载nginx

    2.进入conf目录，并修改nginx.conf配置文件

    其中也可以完成反向代理的功能

    1.  
    2. #user  nobody;
    3. worker_processes  1;
    4.  
    5. #error_log  logs/error.log;
    6. #error_log  logs/error.log  notice;
    7. #error_log  logs/error.log  info;
    8.  
    9. #pid        logs/nginx.pid;
    10.  
    11.  
    12. events {
    13.     worker_connections  1024;
    14. }
    15.  
    16.  
    17. http {
    18.     include       mime.types;
    19.     default_type  application/octet-stream;
    20.  
    21.     #log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
    22.     #                  '$status $body_bytes_sent "$http_referer" '
    23.     #                  '"$http_user_agent" "$http_x_forwarded_for"';
    24.  
    25.     #access_log  logs/access.log  main;
    26.  
    27.     sendfile        on;
    28.     #tcp_nopush     on;
    29.  
    30.     #keepalive_timeout  0;
    31.     keepalive_timeout  65;
    32.  
    33.     #gzip  on;
    34.  
    35.     
    36.     server
    37. 	{
    38. 		listen 80;
    39. 		server_name product.zmall.com;
    40. 		proxy_redirect off;
    41. 		proxy_set_header Host $host;
    42. 		proxy_set_header X-Real-IP $remote_addr;
    43. 		proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
    44. 		
    45. 		location / {
    46. 			proxy_pass http://127.0.0.1:8000/product-serv/;
    47. 		}
    48. 	}
    49.  
    50. 	server
    51. 	{
    52. 		listen 80;
    53. 		server_name user.zmall.com;
    54. 		proxy_redirect off;
    55. 		proxy_set_header Host $host;
    56. 		proxy_set_header X-Real-IP $remote_addr;
    57. 		proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
    58. 		client_max_body_size 0; 
    59. 		chunked_transfer_encoding on;
    60. 		location / {
    61. 			proxy_pass http://127.0.0.1:8000/user-serv/;
    62. 		}
    63. 	}
    64.     
    65.  
    66. }

    3.动静分离

    1. server
    2. 	{
    3. 		listen 80;
    4. 		server_name images.zmall.com;
    5. 		
    6. 		location / {
    7. 		    root  html;
    8. 		    index index.html;
    9. 		}
    10. 	}

    4.将静态文件放置再nginx中

    5.运行nginx根目录下的nginx.exe启动nginx

    6.修改项目中静态资源的路径

    我使用了一个公共的文件，再里面使用了一个base标签，这样其他页面引用这个文件就可以用到其中的静态资源了。

    1. <#assign ctx>
    2. ${springMacroRequestContext.contextPath}/
    4. <base href="http:images.zmall.com/"/>

    这里的域名也需要做一个域名映射

    C:\Windows\System32\drivers\etc\hosts

    二、 集成SpringSession

    使用其来完成登录成功之后，在首页显示当前用户信息【跨服务】

    1.引入依赖

    2. <dependency>
    3. 	<groupId>org.springframework.bootgroupId>
    4. 	<artifactId>spring-boot-starter-data-redisartifactId>
    5. dependency>
    7. <dependency>
    8. 	<groupId>org.springframework.sessiongroupId>
    9. 	<artifactId>spring-session-data-redisartifactId>
    10. dependency>
    12. <dependency>
    13.     <groupId>org.apache.commonsgroupId>
    14.     <artifactId>commons-pool2artifactId>
    15. dependency>

    2.在需要使用到springsession的模块做以下配置

    1. spring:
    2.   session:
    3.     redis:
    4.       flush-mode: on_save
    5.       namespace: session.zmall
    6.       cleanup-cron: 0 * * * * *
    7.     store-type: redis
    8.     timeout: 1800
    9.   redis:
    10.     host: localhost
    11.     port: 6379
    12.     password: 123456
    13.     jedis:
    14.       pool:
    15.         max-active: 100
    16.         max-wait: 10
    17.         max-idle: 10
    18.         min-idle: 10
    19.     database: 0

    3.编写代码完成登录功能

    1. package com.wh.user.service.impl;
    2.  
    3. import com.alibaba.nacos.common.utils.MD5Utils;
    4. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
    5. import com.wh.user.pojo.User;
    6. import com.wh.user.mapper.UserMapper;
    7. import com.wh.user.service.IUserService;
    8. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
    9. import com.wh.user.utils.JsonResponseBody;
    10. import com.wh.user.utils.JsonResponseStatus;
    11. import com.wh.user.vo.UserVo;
    12. import dto.UserDto;
    13. import org.springframework.beans.BeanUtils;
    14. import org.springframework.stereotype.Service;
    15. import org.springframework.util.DigestUtils;
    16.  
    17. import javax.servlet.http.HttpServletRequest;
    18. import javax.servlet.http.HttpServletResponse;
    19. import javax.servlet.http.HttpSession;
    20. import java.nio.charset.StandardCharsets;
    21. import java.security.MessageDigest;
    22. import java.security.NoSuchAlgorithmException;
    23. import java.util.UUID;
    24.  
    25. /**
    26.  * 
    27.  *  服务实现类
    28.  * 
    29.  *
    30.  * @author baomidou
    31.  * @since 2024-02-21
    32.  */
    33. @Service
    34. public class UserServiceImpl extends ServiceImpl implements IUserService {
    35.  
    36. /**
    37.  * 登录
    38.  * @param userVo
    39.  * @return
    40.  */
    41.     @Override
    42.     public JsonResponseBody userLogin(UserVo userVo) {
    43.         //通过传递过来的用户名去数据库中查询对应的对象
    44.         User user = this.getOne(new QueryWrapper().eq("loginName", userVo.getLoginName()));
    45.         //做密码判断【数据库的密码是经过加密的】
    46.         //将用户传递过来的密码加密
    47.         String userpwd = DigestUtils.md5DigestAsHex(userVo.getPassword().getBytes());
    48.         //加密之后与数据库中的用户密码进行对比
    49.         if(!userpwd.equals(user.getPassword())){
    50.             //如果密码不匹配，则提示相关错误信息
    51.             return JsonResponseBody.other(JsonResponseStatus.LOGIN_NO_EQUALS);
    52.         }
    53.         //如果登录成功，就进行属性复制
    54.         UserDto userDto = new UserDto();
    55.         //属性复制
    56.         BeanUtils.copyProperties(user,userDto);
    57.         return JsonResponseBody.success();
    58.     }
    59.  
    60. }
    1. package com.wh.user.controller;
    2.  
    3. import com.wh.user.service.IUserService;
    4. import com.wh.user.utils.JsonResponseBody;
    5. import com.wh.user.vo.UserVo;
    6. import dto.UserDto;
    7. import org.springframework.beans.BeanUtils;
    8. import org.springframework.beans.factory.annotation.Autowired;
    9. import org.springframework.web.bind.annotation.RequestMapping;
    10. import org.springframework.web.bind.annotation.ResponseBody;
    11. import org.springframework.web.bind.annotation.RestController;
    12.  
    13. import javax.servlet.http.HttpServletRequest;
    14. import javax.servlet.http.HttpServletResponse;
    15.  
    16. /**
    17.  * 
    18.  *  前端控制器
    19.  * 
    20.  *
    21.  * @author baomidou
    22.  * @since 2024-02-21
    23.  */
    24. @RestController
    25. public class UserController {
    26.     @Autowired
    27.     private IUserService userService;
    28.     @Autowired
    29.     private HttpServletRequest request;
    30.     /**
    31.      * 用户登陆功能实现
    32.      * @return
    33.      */
    34.     @RequestMapping("/userLogin")
    35.     public JsonResponseBody userLogin(UserVo userVo){
    36.         //设置当前用户的登录信息
    37.         request.getSession().setAttribute("user",userVo);
    38.         //调用登录的方法
    39.         JsonResponseBody user = userService.userLogin(userVo);
    40.         return user;
    41.     }
    42. }

    在跳首页的controller方法中获取当前登录用户的session信息

    1. @Autowired
    2.     private IProductService productService;
    3.     @Autowired
    4.     private HttpServletRequest request;
    5.     /**
    6.      * 首页跳转
    7.      * @param model
    8.      * @return
    9.      */
    10.     @RequestMapping("/index.html")
    11.     public String index(Model model){
    12.         //获取当前用户的登录信息
    13.         UserDto user = (UserDto)request.getSession().getAttribute("user");
    14.         //按照商品的销量降序排序获取销量排名Top5的商品
    15.         List products = productService.list(new QueryWrapper()
    16.                 .orderByDesc("hot")
    17.                 .last("limit 4"));
    18.         model.addAttribute("top4",products);
    19.         model.addAttribute("user",user);
    20.         return "Index";
    21.     }

    4.前端显示

    1. "soubg">
    2. 	
      "sou">
    3.         "fr">
    4.         	"fl">你好，
    5.                 <#if user??>
    6.                     ${user.loginName}
    7.                     <#else>"Login.html">请登录
    8.                 if>
    9.                   "Regist.html" style="color:#ff4e00;">免费注册  
    10.             "fl">| 关注我们：
    11.             "s_sh">"#" class="sh1">新浪"#" class="sh2">微信
    12.             "fr">| "#">手机版 "images/s_tel.png" align="absmiddle" />
    13.         
    14.

三、 集成sentinel

1.导入pom依赖

到网关中

  2.         <dependency>
  3.             <groupId>com.alibaba.cloudgroupId>
  4.             <artifactId>spring-cloud-starter-alibaba-sentinelartifactId>
  5.         dependency>

2.在application文件中进行配置

  1. sentinel:
  2.       transport:
  3.         port: 9998 #跟控制台交流的端口,随意指定一个未使用的端口即可
  4.         dashboard: localhost:9999 # 指定控制台服务的地址
  5.       eager: true #当服务启动时是否与sentinel建立连接
  6.       web-context-unify: false # 关闭URL PATH聚合

3.浏览器访问sentinel

在此之前需要启动sentinel的那个jar包

  1. # 直接使用jar命令启动项目(控制台本身是一个SpringBoot项目)
  2. java -Dserver.port=9999 -Dcsp.sentinel.dashboard.server=localhost:9999 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard-1.8.4.jar

四、集成seata

1.下载seata

下载地址icon-default.png?t=N7T8http://Release v1.3.0 · apache/incubator-seata · GitHubRelease v1.3.0 · apache/incubator-seata · GitHub

2.修改配置文件及初始化

①seata-server-1.4.0.zip

将下载得到的seata-server-1.4.0.zip（非源码包）压缩包进行解压

  • 配置seata-1.4.0.zip（源码包）

修改seata-1.4.0中script/config-center目录中的config.txt配置：

  1. store.mode=db    #修改存储方式为db
  2. ...
  3. store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true   #修改数据库名
  4. store.db.user=root      #修改数据库账号
  5. store.db.password=1234  #修改数据库密码
  • 初始化Seata配置到Nacos中

在seata-1.4.0\script\config-center\nacos目录中右键选择git bash here，运行git命令窗口。并输入以下命令：

sh nacos-config.sh -h localhost -p 8848 -g SEATA_GROUP -u nacos -w nacos
参数说明
-hnacos注册中心IP地址，默认是localhost
-pnacos注册中心端口，默认是8848
-gnacos配置中心分组，默认是SEATA_GROUP
-tnacos配置中心namespace命名空间名称，默认是''，即public默认命名空间
-unacos注册中心账号
-wnacos注册中心密码

执行成功后可以打开Nacos的控制台，在配置列表中，可以看到初始化了很多Group为SEATA_GROUP 的配置。

②修改file.conf

将mode=“type”修改成mode="db" 2.设置数据库名、用户账号及密码

③创建数据库Seata并初始化数据表

解压seata-1.4.0源码包，并进入到seata-1.4.0\script\server\db目录，复制运行mysql.sql脚本完成seata服务端数据库初始化工作。【记得先创建一个数据库：seata】

④修改registry.conf

  1. registry {
  2.     type = "nacos"                     #这里使用nacos为注册中心，将type修改成nacos
  3.     nacos {
  4.         application = "seata-server"   #注册的服务名
  5.         serverAddr = "127.0.0.1:8848"  #nacos注册中心地址及端口
  6.         group = "SEATA_GROUP" #服务注册分组
  7.         namespace = ""        #namespace是服务注册时的命名空间，可不填，不填默认public
  8.         cluster = "default"   #默认即可
  9.         username = "nacos"    #nacos的登录账号
  10.         password = "nacos"    #nacos的登录密码
  11.     }
  12. }
  13. config {
  14.     type = "nacos"
  15.     nacos {
  16.         serverAddr = "127.0.0.1:8848"
  17.         namespace = ""
  18.         group = "SEATA_GROUP"
  19.         username = "nacos"
  20.         password = "nacos"
  21.     }
  22. }

registry：指定注册中心，将seata-server注册到指定位置 config： 指定配置中心

3.启动seata服务

直接进入seata服务的seata\bin目录下，双击运行seata-server.bat文件即可。或者使用以下命令方式运行：

cd bin
seata-server.bat -p 9000 -m file
seata-server.bat -h ip地址 -p 9000 -m file

-p 9000:指定监听端口，默认为8091

-m file: 模式

启动后在 Nacos 的服务列表下面可以看到一个seata的服务。

4.使用Seata实现事务控制

1.初始化数据表

进入源码包seata-1.4.0\script\client\at\db目录，复制并运行数据库脚本完成undo_log表创建，这是Seata记录事务日志要用到的表。

  1. CREATE TABLE `undo_log`
  2. (
  3. `id` BIGINT(20) NOT NULL AUTO_INCREMENT,
  4. `branch_id` BIGINT(20) NOT NULL,
  5. `xid` VARCHAR(100) NOT NULL,
  6. `context` VARCHAR(128) NOT NULL,
  7. `rollback_info` LONGBLOB NOT NULL,
  8. `log_status` INT(11) NOT NULL,
  9. `log_created` DATETIME NOT NULL,
  10. `log_modified` DATETIME NOT NULL,
  11. `ext` VARCHAR(100) DEFAULT NULL,
  12. PRIMARY KEY (`id`),
  13. UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
  14. ) ENGINE = INNODB
  15. AUTO_INCREMENT = 1
  16. DEFAULT CHARSET = utf8;

2.添加配置

①DataSourceProxyConfig
  1. package com.zking.zmall.config;
  2.  
  3. import com.alibaba.druid.pool.DruidDataSource;
  4. import io.seata.rm.datasource.DataSourceProxy;
  5. import io.seata.rm.datasource.xa.DataSourceProxyXA;
  6. import org.springframework.boot.context.properties.ConfigurationProperties;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  9. import org.springframework.context.annotation.Primary;
  10.  
  11. import javax.sql.DataSource;
  12.  
  13. @Configuration
  14. public class DataSourceProxyConfig {
  15.     @Bean
  16.     @ConfigurationProperties(prefix = "spring.datasource")
  17.     public DruidDataSource druidDataSource() {
  18.         return new DruidDataSource();
  19.     }
  20.  
  21.     @Primary
  22.     @Bean("dataSourceProxy")
  23.     public DataSource dataSource(DruidDataSource druidDataSource) {
  24.         //AT模式
  25.         return new DataSourceProxy(druidDataSource);
  26.         //XA模式
  27.         //return new DataSourceProxyXA(druidDataSource);
  28.     }
  29. }

在启动类（使用到SeaTa）上排除DataSource数据源自动配置类

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
②application.yml

在需要进行分布式事务的各个微服务中的application.yml数据源更新成阿里巴巴的DruidDataSource

  1. #type连接池类型 DBCP,C3P0,Hikari,Druid,默认为Hikari
  2.     type: com.alibaba.druid.pool.DruidDataSource
③registry.conf

在微服务模块中的resources目录下添加seata的配置文件 registry.conf，该配置文件来自于seata-server/conf目录下的配置文件。

  1. registry {
  2.     type = "nacos"
  3.     nacos {
  4.         serverAddr = "localhost"
  5.         namespace = "public"
  6.         cluster = "default"
  7.     }
  8. }
  9. config {
  10.     type = "nacos"
  11.     nacos {
  12.         serverAddr = "localhost"
  13.         namespace = "public"
  14.         cluster = "default"
  15.     }
  16. }
③bootstrap.yaml

请注意spring.cloud.alibaba.seata.tx-service-group=my_test_txgroup配置。这里的my_test_tx_group名称必须与seata源码包中的config.txt配置文件中的名字一致。重要，重要，重要！！！

请打开seata源码包目录seata-1.4.0\script\config-center\下的config.txt去进行配置。

  1. spring:
  2.   application:
  3.     name: service-product
  4.   cloud:
  5.     nacos:
  6.       config:
  7.         server-addr: localhost:8848 # nacos的服务端地址
  8.         namespace: public
  9.         group: SEATA_GROUP
  10.     alibaba:
  11.       seata:
  12.         tx-service-group: my_test_tx_group

注意：一定要加一个配置

  2.         <dependency>
  3.             <groupId>org.springframework.cloudgroupId>
  4.             <artifactId>spring-cloud-starter-bootstrapartifactId>
  5.         dependency>

好啦，今天的分享就到这了，希望能够帮到你呢！😊😊 

  • 相关阅读:
    【C#设计模式】单例模式
    Android 内存泄漏分析思路和案例剖析
    什么是响应式设计？响应式设计的基本原理是什么？如何兼容低版本的 IE？
    java计算机毕业设计网上宠物售卖平台源代码+数据库+系统+lw文档
    从零到上亿用户，我是如何一步步优化MySQL数据库的？（建议收藏）
    CCF ChinaSoft 2023 论坛巡礼｜软件测试产教研融合论坛
    vue如何使用深度选择器？
    【Spring Boot 源码学习】OnClassCondition 详解
    OpenCascade模型解析-详细分解模型结构
    【目标】新学期计划与目标
  • 原文地址：https://blog.csdn.net/m0_74315688/article/details/136262223