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


#user  nobody;
worker_processes  1;

#error_log  logs/error.log;
#error_log  logs/error.log  notice;
#error_log  logs/error.log  info;

#pid        logs/nginx.pid;


events {
    worker_connections  1024;
}


http {
    include       mime.types;
    default_type  application/octet-stream;

    #log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
    #                  '$status $body_bytes_sent "$http_referer" '
    #                  '"$http_user_agent" "$http_x_forwarded_for"';

    #access_log  logs/access.log  main;

    sendfile        on;
    #tcp_nopush     on;

    #keepalive_timeout  0;
    keepalive_timeout  65;

    #gzip  on;

    
    server
{
listen 80;
server_name product.zmall.com;
proxy_redirect off;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;

location / {
proxy_pass http://127.0.0.1:8000/product-serv/;
}
}

server
{
listen 80;
server_name user.zmall.com;
proxy_redirect off;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
client_max_body_size 0; 
chunked_transfer_encoding on;
location / {
proxy_pass http://127.0.0.1:8000/user-serv/;
}
}
    

}

3.动静分离

server
{
listen 80;
server_name images.zmall.com;

location / {
    root  html;
    index index.html;
}
}

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

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

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

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

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

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

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

二、集成SpringSession

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

1.引入依赖

<!--redis-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!--spring session-->
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
<!--commons-pool2-->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
</dependency>

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

spring:
  session:
    redis:
      flush-mode: on_save
      namespace: session.zmall
      cleanup-cron: 0 * * * * *
    store-type: redis
    timeout: 1800
  redis:
    host: localhost
    port: 6379
    password: 123456
    jedis:
      pool:
        max-active: 100
        max-wait: 10
        max-idle: 10
        min-idle: 10
    database: 0

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

package com.wh.user.service.impl;

import com.alibaba.nacos.common.utils.MD5Utils;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.wh.user.pojo.User;
import com.wh.user.mapper.UserMapper;
import com.wh.user.service.IUserService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.wh.user.utils.JsonResponseBody;
import com.wh.user.utils.JsonResponseStatus;
import com.wh.user.vo.UserVo;
import dto.UserDto;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.util.DigestUtils;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.UUID;

/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author baomidou
 * @since 2024-02-21
 */
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {

/**
 * 登录
 * @param userVo
 * @return
 */
    @Override
    public JsonResponseBody<?> userLogin(UserVo userVo) {
        //通过传递过来的用户名去数据库中查询对应的对象
        User user = this.getOne(new QueryWrapper<User>().eq("loginName", userVo.getLoginName()));
        //做密码判断【数据库的密码是经过加密的】
        //将用户传递过来的密码加密
        String userpwd = DigestUtils.md5DigestAsHex(userVo.getPassword().getBytes());
        //加密之后与数据库中的用户密码进行对比
        if(!userpwd.equals(user.getPassword())){
            //如果密码不匹配，则提示相关错误信息
            return JsonResponseBody.other(JsonResponseStatus.LOGIN_NO_EQUALS);
        }
        //如果登录成功，就进行属性复制
        UserDto userDto = new UserDto();
        //属性复制
        BeanUtils.copyProperties(user,userDto);
        return JsonResponseBody.success();
    }

}

package com.wh.user.controller;

import com.wh.user.service.IUserService;
import com.wh.user.utils.JsonResponseBody;
import com.wh.user.vo.UserVo;
import dto.UserDto;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * <p>
 *  前端控制器
 * </p>
 *
 * @author baomidou
 * @since 2024-02-21
 */
@RestController
public class UserController {
    @Autowired
    private IUserService userService;
    @Autowired
    private HttpServletRequest request;
    /**
     * 用户登陆功能实现
     * @return
     */
    @RequestMapping("/userLogin")
    public JsonResponseBody<?> userLogin(UserVo userVo){
        //设置当前用户的登录信息
        request.getSession().setAttribute("user",userVo);
        //调用登录的方法
        JsonResponseBody<?> user = userService.userLogin(userVo);
        return user;
    }
}

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

@Autowired
    private IProductService productService;
    @Autowired
    private HttpServletRequest request;
    /**
     * 首页跳转
     * @param model
     * @return
     */
    @RequestMapping("/index.html")
    public String index(Model model){
        //获取当前用户的登录信息
        UserDto user = (UserDto)request.getSession().getAttribute("user");
        //按照商品的销量降序排序获取销量排名Top5的商品
        List<Product> products = productService.list(new QueryWrapper<Product>()
                .orderByDesc("hot")
                .last("limit 4"));
        model.addAttribute("top4",products);
        model.addAttribute("user",user);
        return "Index";
    }

4.前端显示

<div class="soubg">
<div class="sou">
        <span class="fr">
        <span class="fl">你好，
                <#if user??>
                    ${user.loginName}
                    <#else><a href="Login.html">请登录</a>
                </#if>
                &nbsp; <a href="Regist.html" style="color:#ff4e00;">免费注册</a>&nbsp; </span>
            <span class="fl">|&nbsp;关注我们：</span>
            <span class="s_sh"><a href="#" class="sh1">新浪</a><a href="#" class="sh2">微信</a></span>
            <span class="fr">|&nbsp;<a href="#">手机版&nbsp;<img src="images/s_tel.png" align="absmiddle" /></a></span>
        </span>
    </div>
</div>

三、集成sentinel

1.导入pom依赖

到网关中

<!-- sentinel -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>

2.在application文件中进行配置

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

3.浏览器访问sentinel

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

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

四、集成seata

1.下载seata

下载地址http://Release v1.3.0 · apache/incubator-seata · GitHub Release 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配置：
store.mode=db    #修改存储方式为db
...
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true   #修改数据库名
store.db.user=root      #修改数据库账号
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
参数说明
-h nacos注册中心IP地址，默认是localhost
-p nacos注册中心端口，默认是8848
-g nacos配置中心分组，默认是SEATA_GROUP
-t nacos配置中心namespace命名空间名称，默认是''，即public默认命名空间
-u nacos注册中心账号
-w nacos注册中心密码

执行成功后可以打开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
registry {
    type = "nacos"                     #这里使用nacos为注册中心，将type修改成nacos
    nacos {
        application = "seata-server"   #注册的服务名
        serverAddr = "127.0.0.1:8848"  #nacos注册中心地址及端口
        group = "SEATA_GROUP" #服务注册分组
        namespace = ""        #namespace是服务注册时的命名空间，可不填，不填默认public
        cluster = "default"   #默认即可
        username = "nacos"    #nacos的登录账号
        password = "nacos"    #nacos的登录密码
    }
}
config {
    type = "nacos"
    nacos {
        serverAddr = "127.0.0.1:8848"
        namespace = ""
        group = "SEATA_GROUP"
        username = "nacos"
        password = "nacos"
    }
}
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记录事务日志要用到的表。
CREATE TABLE `undo_log`
(
`id` BIGINT(20) NOT NULL AUTO_INCREMENT,
`branch_id` BIGINT(20) NOT NULL,
`xid` VARCHAR(100) NOT NULL,
`context` VARCHAR(128) NOT NULL,
`rollback_info` LONGBLOB NOT NULL,
`log_status` INT(11) NOT NULL,
`log_created` DATETIME NOT NULL,
`log_modified` DATETIME NOT NULL,
`ext` VARCHAR(100) DEFAULT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE = INNODB
AUTO_INCREMENT = 1
DEFAULT CHARSET = utf8;
2.添加配置

①DataSourceProxyConfig
package com.zking.zmall.config;

import com.alibaba.druid.pool.DruidDataSource;
import io.seata.rm.datasource.DataSourceProxy;
import io.seata.rm.datasource.xa.DataSourceProxyXA;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import javax.sql.DataSource;

@Configuration
public class DataSourceProxyConfig {
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DruidDataSource druidDataSource() {
        return new DruidDataSource();
    }

    @Primary
    @Bean("dataSourceProxy")
    public DataSource dataSource(DruidDataSource druidDataSource) {
        //AT模式
        return new DataSourceProxy(druidDataSource);
        //XA模式
        //return new DataSourceProxyXA(druidDataSource);
    }
}
在启动类（使用到SeaTa）上排除DataSource数据源自动配置类
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
②application.yml

在需要进行分布式事务的各个微服务中的application.yml数据源更新成阿里巴巴的DruidDataSource
#type连接池类型 DBCP,C3P0,Hikari,Druid,默认为Hikari
    type: com.alibaba.druid.pool.DruidDataSource
③registry.conf

在微服务模块中的resources目录下添加seata的配置文件 registry.conf，该配置文件来自于seata-server/conf目录下的配置文件。
registry {
    type = "nacos"
    nacos {
        serverAddr = "localhost"
        namespace = "public"
        cluster = "default"
    }
}
config {
    type = "nacos"
    nacos {
        serverAddr = "localhost"
        namespace = "public"
        cluster = "default"
    }
}
③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去进行配置。
spring:
  application:
    name: service-product
  cloud:
    nacos:
      config:
        server-addr: localhost:8848 # nacos的服务端地址
        namespace: public
        group: SEATA_GROUP
    alibaba:
      seata:
        tx-service-group: my_test_tx_group
注意：一定要加一个配置

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
        </dependency>

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

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

原文地址：https://blog.csdn.net/m0_74315688/article/details/136262223

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：面试数据库篇（mysql）- 02定位慢查询和分析
下一篇：汽车后视镜反射率检测仪厂家

leetcode289:生命游戏
根据，简称为，是英国数学家约翰·何顿·康威在 1970 年发明的细胞自动机。给定一个包含m × n个格子的面板，每一个格子都可以看成是一个细胞。每个细胞都具有一个初始状态：1即为（live），或0即为
阅读更多2024-10-20
MongoDB数据恢复
注意：两个MongoDB的版本要一致，本文使用的是mongo:4.2.24。先把K8S上面的MongoDB 容器停止（可以把副本改成0）。1、将容器挂载MongoDB的数据目录备份到本地。经常是数据文
阅读更多2024-10-20
C#中实现事务
C#中实现事务
阅读更多2024-10-20
【LeetCode每日一题】——560.和为 K 的子数组
给你一个整数数组 nums 和一个整数 k ，请你统计并返回该数组中和为 k 的子数组的个数。子数组是数组中元素的连续非空序列。
阅读更多2024-10-20
「漏洞复现」满客宝智慧食堂系统 selectUserByOrgId 未授权访问漏洞
请勿利用文章内的相关技术从事非法测试，由于传播、利用此文所提供的信息而造成的任何直接或者间接的后果及损失，均由使用者本人负责，作者不为此承担任何责任。工具来自网络，安全性自测，如有侵权请联系删除。本次
阅读更多2024-10-20
React面试题目（从基本到高级）
React前端面试常见题目涵盖了React的基础概念、组件、状态管理、生命周期、性能优化等多个方面。
阅读更多2024-10-20
12.个人博客系统（Java项目基于spring和vue）
1 在校学习的学生，可用于日常学习使用或是毕业设计使用 2 毕业一到两年的开发人员，用于锻炼自己的独立功能模块设计能力，增强代码编写能力。 3 亦可以部署为商化项目使用。 4 需要完整资料及源码
阅读更多2024-10-20
YoloV8改进策略：注意力改进|DeBiFormer，可变形双级路由注意力|引入DeBiLevelRoutingAttention注意力模块（全网首发）
本次改进的核心在于将DeBiLevelRoutingAttention模块嵌入到YoloV8的主干网络中，具体位置是在SPPF（Spatial Pyramid Pooling Fast）模块之后。这一
阅读更多2024-10-20
word取消自动单词首字母大写
情况说明：在word输入单词后首字母会自动变成大写取消单词首字母大写步骤：（1）点击菜单栏文件（2）点击“更多”——>“选项”（3）点击“校对”——>“自动更正选项”（4）取消“句首字母大
阅读更多2024-10-20
web前端网页用户注册页面
【代码】web前端网页用户注册页面。
阅读更多2024-10-20

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

🥳🥳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完成动静分离

二、集成SpringSession

三、集成sentinel