springboot第34集:ES 搜索,nginx

news2024/11/14 17:24:57
#用search after解决深分页性能问题
#第一页
GET /bank/_search
{
  "size": 10,
  "sort": [
    {
      "account_number": {
        "order": "asc"
      }
    }
  ]
}


#第二页
GET /bank/_search
{
  "size": 10,
  "sort": [
    {
      "account_number": {
        "order": "asc"
      }
    }
  ],
  "search_after" : [13]
}
# true\false 指定是否返回_source
GET /bank/_search?size=5
{
  "query": {
    "match_all": {}
  },
  "_source": true
}

#明确指定要返回的字段
GET /bank/_search
{
  "_source": ["address", "balance"]
}

#将两个字段排除在外
GET /bank/_search
{
  "_source": {
    "excludes": ["address", "balance"]
  }
}

全文检索完全匹配,必须包含分词后的所有词

GET /songs_v1/_search
{
  "query": {
    "match": {
      "lyrics": {
        "query": "All I need is someone who makes me wanna sing",
        "operator": "and"
      }
    }
  }
}
41a8200c113239bfdf791fb380f7ea15.png
image.png
014ac62a0e0fa930db3e7482a0e9faa9.png
image.png
647982e9df460a96f37d692310d67b37.png
image.png
f867676d1addd5a1706b67419b62aff7.png
image.png
7473ed768065c2547c2cc55b21db42b4.png
image.png

https://www.elastic.co/cn/downloads/elasticsearch

c251b34a26a7abf9ed6302e92ae3a5f0.png
image.png

1) 前台启动:bin/elasticsearch

2) 后台启动:bin/elasticsearch -d

1) 前台停止:ctrl+c

(2) 后台停止:kill -9 elasticsearch的进程号

  • 创建用户命令

adduser elasticsearch
  • 修改用户密码

passwd elasticsearch
  • 将es解压目录的所有者授予此用户

chown -R elasticsearch elasticsearch-7.8.0
  • 切换至elasticsearch用户

su elasticsearch
  • 进入es安装目录,运行启动脚本

/usr/local/elasticsearch-7.8.0/bin/elasticsearch -d

On this node:

⁃ Create an enrollment token with bin/elasticsearch-create-enrollment-token -s node.

⁃ Uncomment the transport.host setting at the end of config/elasticsearch.yml.

⁃ Restart Elasticsearch.

• On other nodes:

⁃ Start Elasticsearch with bin/elasticsearch --enrollment-token <token>, using the enrollment token that you generated.

https://www.elastic.co/cn/kibana

288fd92c3d3e32ead17f7069d1cb29ed.png
image.png
a71cc360bec62baec4d9b0ebd1c3856b.png
image.png
import http from '@/utils/request'//axios 拦截器
// 导出
export function exportData(params) {
  return http({
    url: '/customs/reimburse/export',
    method: 'post',
    params,
    responseType: 'arraybuffer', // 一定要加这一配置,否则导出文件打不开
  })
}
let res = await exportData({ ids: 5 })
  let href = window.URL.createObjectURL(new Blob([res],
  { type: 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet' }))
  const downloadElement = document.createElement('a')
  downloadElement.href = href
  downloadElement.download = '导出报表.xlsx' //下载后文件名
  document.body.appendChild(downloadElement)
  downloadElement.click() //点击下载
  document.body.removeChild(downloadElement) //下载完成移除元素
  window.URL.revokeObjectURL(href) //释放掉blob对象
import { saveAs } from 'file-saver';

axios({
  method: 'post',
  url: '接口地址',
  responseType: 'blob' // 必须,此内容会告知后端返回数据为blob,否则会得到string内容
}).then(response => {
    saveAs(new Blob([response.data], { type: 'application/octet-stream' }),`download.xlsx`)
}).catch((error) => {

});
download() {
        const data = {  }// 要发送到后台的数据
        axios({ 
          method: 'get',
          url: '/downFile/file', // 请求地址
          data: data, // 参数
          responseType: 'blob' //  表明返回服务器返回的数据类型  这里注意    要加上responseType
        })
          .then((res) => { // 处理返回的文件流
            // 注意 返回的res 无需做任何处理,有时在用框架封装的请求之后会出    现返回response.text() 等情况导致文件流下载失败。
            const blob = new Blob([content])
            const fileName = 'down.xls'
            const alink = document.createElement('a')
            alink.download = fileName
            alink.style.display = 'none'
            alink.href = URL.createObjectURL(blob)   // 这里是将文件流    转化为一个文件地址
            document.body.appendChild(alink)
            alink.click()
            URL.revokeObjectURL(alink.href) // 释放URL 对象
            document.body.removeChild(alink)
        })
      }

首先需要导入的插件有:

npm install element-plus[1] --save,//elementplus的组件库(这个可用可不用,我用的是组件的按钮所以需要使用到他)
npm install xlsx --save//xlsx的插件

当一张表的数据达到几千万时,查询一次所花的时间会变长。业界公认MySQL单表容量在 1千万 以下是最佳状态,因为这时它的BTREE索引树高在3~5之间。

数据切分可以分为:垂直切分水平切分

一、垂直切分

垂直切分又可以分为: 垂直分库垂直分表

1、垂直分库

概念 就是根据业务耦合性,将关联度低的不同表存储在不同的数据库。做法与大系统拆分为多个小系统类似,按业务分类进行独立划分。与"微服务治理"的做法相似,

每个微服务使用单独的一个数据库。

如图:

b238f32dc7325fa0afea4912eaccce43.jpeg

说明

一开始我们是单体服务,所以只有一个数据库,所有的表都在这个库里。

后来因为业务需求,单体服务变成微服务治理。所以将之前的一个商品库,拆分成多个数据库。每个微服务对于一个数据库。

2、垂直分表

概念 把一个表的多个字段分别拆成多个表,一般按字段的冷热拆分,热字段一个表,冷字段一个表。从而提升了数据库性能。

如图:

fd145e8e44aef61a674b6e63c1e8e779.jpeg

说明

一开始商品表中包含商品的所有字段,但是我们发现:

1.商品详情和商品属性字段较长2.商品列表的时候我们是不需要显示商品详情和商品属性信息,只有在点进商品商品的时候才会展示商品详情信息

所以可以考虑把商品详情和商品属性单独切分一张表,提高查询效率。

3、垂直切分优缺点

优点

- 解决业务系统层面的耦合,业务清晰
- 与微服务的治理类似,也能对不同业务的数据进行分级管理、维护、监控、扩展等
- 高并发场景下,垂直切分一定程度的提升IO、数据库连接数、单机硬件资源的瓶颈

缺点

- 分库后无法Join,只能通过接口聚合方式解决,提升了开发的复杂度
- 分库后分布式事务处理复杂
- 依然存在单表数据量过大的问题(需要水平切分)

二、水平切分

当一个应用难以再细粒度的垂直切分或切分后数据量行数巨大,存在单库读写、存储性能瓶颈,这时候就需要进行水平切分了。

水平切分也可以分为:水平分库水平分表

1、水平分库

水平分库的原因

上面虽然已经把商品库分成3个库,但是随着业务的增加一个订单库也出现QPS过高,数据库响应速度来不及,一般mysql单机也就1000左右的QPS,如果超过1000就要考虑分库。

如图

271c8484284c4589e80d6d68c88d7ffb.jpeg

2、水平分表

概念 一般我们一张表的数据不要超过1千万,如果表数据超过1千万,并且还在不断增加数据,那就可以考虑分表。

如图

3e7625d063e81bb68e991d44b0536607.jpeg

3、水平切分优缺点

优点

- 不存在单库数据量过大、高并发的性能瓶颈,提升系统稳定性和负载能力
- 应用端改造较小,不需要拆分业务模块

缺点

- 跨分片的事务一致性难以保证
- 跨库的Join关联查询性能较差
- 数据多次扩展难度和维护量极大

三、数据分片规则

我们我们考虑去水平切分表,将一张表水平切分成多张表,这就涉及到数据分片的规则,比较常见的有:Hash取模分表数值Range分表一致性Hash算法分表

1、Hash取模分表

概念 一般采用Hash取模的切分方式,例如:假设按goods_id分4张表。(goods_id%4 取整确定表)

530a7519de627405006f552bd45e696b.jpeg

优点

- 数据分片相对比较均匀,不容易出现热点和并发访问的瓶颈。

缺点

- 后期分片集群扩容时,需要迁移旧的数据很难。
- 容易面临跨分片查询的复杂问题。比如上例中,如果频繁用到的查询条件中不带goods_id时,将会导致无法定位数据库,从而需要同时向4个库发起查询,
再在内存中合并数据,取最小集返回给应用,分库反而成为拖累。

2、数值Range分表

概念 按照时间区间或ID区间来切分。例如:将goods_id为11000的记录分到第一个表,10012000的分到第二个表,以此类推。

如图

4cb692a72a9d49d2aa5057255ea54f5c.jpeg

优点

- 单表大小可控
- 天然便于水平扩展,后期如果想对整个分片集群扩容时,只需要添加节点即可,无需对其他分片的数据进行迁移
- 使用分片字段进行范围查找时,连续分片可快速定位分片进行快速查询,有效避免跨分片查询的问题。

缺点

- 热点数据成为性能瓶颈。
例如按时间字段分片,有些分片存储最近时间段内的数据,可能会被频繁的读写,而有些分片存储的历史数据,则很少被查询

3、一致性Hash算法

一致性Hash算法能很好的解决因为Hash取模而产生的分片集群扩容时,需要迁移旧的数据的难题

1、分布式事务问题

使用分布式事务中间件解决,具体是通过最终一致性还是强一致性分布式事务,看业务需求

2、跨节点关联查询 Join 问题

切分之前,我们可以通过Join来完成。而切分之后,数据可能分布在不同的节点上,此时Join带来的问题就比较麻烦了,考虑到性能,尽量避免使用Join查询。

表,会引入新的的问题

1、分布式事务问题

使用分布式事务中间件解决,具体是通过最终一致性还是强一致性分布式事务,看业务需求,这里就不多说。

2、跨节点关联查询 Join 问题

切分之前,我们可以通过Join来完成。而切分之后,数据可能分布在不同的节点上,此时Join带来的问题就比较麻烦了,考虑到性能,尽量避免使用Join查询。

解决这个问题的一些方法:

全局表

全局表,也可看做是 "数据字典表",就是系统中所有模块都可能依赖的一些表,为了避免跨库Join查询,可以将 这类表在每个数据库中都保存一份。这些数据通常

很少会进行修改,所以也不担心一致性的问题。

字段冗余

利用空间换时间,为了性能而避免join查询。例:订单表保存userId时候,也将userName冗余保存一份,这样查询订单详情时就不需要再去查询"买家user表"了。

数据组装

在系统层面,分两次查询。第一次查询的结果集中找出关联数据id,然后根据id发起第二次请求得到关联数据。最后将获得到的数据进行字段拼装。

3、跨节点分页、排序、函数问题

跨节点多库进行查询时,会出现Limit分页、Order by排序等问题。分页需要按照指定字段进行排序,当排序字段就是分片字段时,通过分片规则就比较容易定位到指定的分片;

当排序字段非分片字段时,就变得比较复杂了。需要先在不同的分片节点中将数据进行排序并返回,然后将不同分片返回的结果集进行汇总和再次排序,最终返回给用户。

4、全局主键避重问题

如果都用主键自增肯定不合理,如果用UUID那么无法做到根据主键排序,所以我们可以考虑通过雪花ID来作为数据库的主键

微信扫一扫功能开发前期准备

# 1、微信开放平台介绍(申请里面的网站应用需要企业资料)
    微信开放平台网站:https://open.weixin.qq.com/

# 2、什么是appid、appsecret、授权码code
    appid和appsecret是 资源所有者向申请人分配的一个id和秘钥
    code是授权凭证,A->B 发起授权,想获取授权用户信息,那a必须携带授权码,才可以向B获取授权信息
    (你要从我这里拿东西出去,就必须带身份证)

#   3、先仔细阅读下微信开放平台 官方给出的微信登录开发指南:
    https://developers.weixin.qq.com/doc/oplatform/Website_App/WeChat_Login/Wechat_Login.html
ea6246d2a9f4d58a94d3d6af47692da6.png
image.png
48f95aaa007c6f7a68023b9ba480db36.png
image.png

微信开放平台注册并登录:

由于创建网站应用需要企业认证,而且进行微信验证 需要 交300块钱给腾讯,对于个人开发者来说成本过高,所以只能采用别人的或者自己花钱申请。

f24c2a07a5dedd61a166e772a2ee8924.png
image.png
92bf02d8db622261eb3fdc2ee4d4aac5.png
image.png

微信授权一键登录,授权URL获取

简介:获取微信开放平台扫码链接url地址

#  增加结果工具类,JsonData;  增加application.properties配置
#  微信开放平台配置
      wxopen.appid=
      wxopen.appsecret=
      #重定向url
      wxopen.redirect_url=http://test/pub/api/v1/wechat/user/callback1

application.properties

# 微信相关配置:
# 公众号
wxpay.appid=wx5beXXXXX7cdd40c
wxpay.appsecret=55480123XXXXXXXXb382fe548215e9
# 微信开放平台配置
wxopen.appid=wx025XXXXX9a2d5b
wxopen.appsecret=f5b6730c59XXXXXXX5aeb8948a9f3
# 重定向url 重定向到首页,并根据code拿到token,从而获取微信扫码用户的登录信息
# 这个域名是别人认证过的,只能拿来做个参考,不能自己回调
wxopen.redirect_url=http://XXXX.cn/XXXX/wechat/user/callback
public class WeChatConfig {

    // 微信开放平台二维码连接
    // 待填充参数:appid=%s    redirect_uri=%s     state=%s
    private final static String OPEN_QRCODE_URL = "https://open.weixin.qq.com/connect/qrconnect?appid=%s&redirect_uri=%s&response_type=code&scope=snsapi_login&state=%s#wechat_redirect";

    // 微信开放平台获取access_token地址
    // 待填充参数:appid=%s    secret=%s     code=%s
    private final static String OPEN_ACCESS_TOKEN_URL="https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code";

    // 获取用户信息
    // 待填充参数:access_token=%s    openid=%s
    private final static String OPEN_USER_INFO_URL ="https://api.weixin.qq.com/sns/userinfo?access_token=%s&openid=%s&lang=zh_CN";

    @Value("${wxpay.appid}")
    private String appid;// 微信appid

    @Value("${wxpay.appsecret}")
    private String appsecret;// 微信秘钥

    @Value("${wxopen.appid}")
    private String openAppid;// 开放平台appid

    @Value("${wxopen.appsecret}")
    private String openAppsecret;// 开放平台秘钥

    @Value("${wxopen.redirect_url}")
    private String openRedirectUrl;// 开放平台回调地址

    public static String getOpenUserInfoUrl() {
        return OPEN_USER_INFO_URL;
    }

    public static String getOpenAccessTokenUrl() {
        return OPEN_ACCESS_TOKEN_URL;
    }

    public static String getOpenQrcodeUrl() {
        return OPEN_QRCODE_URL;
    }
@ResponseBody
    @GetMapping("/login_url")
    @CrossOrigin
    public JsonData weChatloginUrl(
        @RequestParam(value = "state", required = true) String state) throws UnsupportedEncodingException {
        /**
         * state :
         * 用于保持请求和回调的状态,授权请求后原样带回给第三方。该参数可用于防
         * 止csrf攻击(跨站请求伪造攻击),建议第三方带上该参数,可设置为简单的随
         * 机数加session进行校验,例如:state=3d6be0a4035d839573b04816624a415e
         */
        // 获取开放平台重定向地址
        String redirectUrl = weChatConfig.getOpenRedirectUrl();
        // 微信开放平台文档规定,需要先对回调的url使用urlEncode对链接进行编码处理
        String callbackUrl = URLEncoder.encode(redirectUrl, "GBK");
        // 为扫码链接qrcodeUrl填充参数 appid=%s redirect_uri=%s state=%s 到 OPEN_QRCODE_URL
        String qrcodeUrl = String.format(weChatConfig.getOpenQrcodeUrl(), 
                                         weChatConfig.getOpenAppid(), callbackUrl, state);
        // 构建json对象返回
        return JsonData.buildSuccess(qrcodeUrl);
    }

UserMapper.java

/**
 * @Auther: csp1999
 * @Date: 2020/08/28/14:31
 * @Description: User Mapper
 */
@Repository
public interface UserMapper {

    // 保存微信登录用户基本信息
    Integer saveUser(@Param("user") User user);

    // 根据openid 查询
    User findByUserOpenid(String openid);

    // 根据主键id 查询
    User findByUserId(Integer id);

    // 更新微信用户基本信息
    void updateUser(@Param("user") User user);
}
@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private WeChatConfig weChatConfig;

    @Autowired
    private UserMapper userMapper;

    /**
     * 通过code并附带appId appSecret 向微信方索取access_token
     * 并通过 access_token 获得用户基本信息(昵称,地址,头像等) 保存数据到数据库
     * @param code
     * @return
     */
    @Override
    public User saveWeChatUser(String code) {
        // 通过 code 获取 access_tokenURL
        String accessTokenUrl = String.format(
                WeChatConfig.getOpenAccessTokenUrl(),
                weChatConfig.getOpenAppid(),
                weChatConfig.getOpenAppsecret(),
                code);

        // 通过 access_tokenURL 向微信开放平台发送请求, 获取access_token
        Map<String, Object> baseMap = HTTPUtils.doGet(accessTokenUrl);

        if (baseMap == null || baseMap.isEmpty()) {
            return null;
        }

        // 拿到 accessToken
        String accessToken = (String) baseMap.get("access_token");
        String openId = (String) baseMap.get("openid");

        // 通过accessToken 得到向微信开放平台发送 用于获取用户基本信息的请求的url
        String userInfoUrl = String.format(WeChatConfig.getOpenUserInfoUrl(), accessToken, openId);

        // 获取access_token
        Map<String, Object> baseUserMap = HTTPUtils.doGet(userInfoUrl);

        if (baseUserMap == null || baseUserMap.isEmpty()) {
            return null;
        }
        // 拿到用户基本信息
        String nickname = (String) baseUserMap.get("nickname");// 微信用户名
        System.out.println(baseUserMap.get("sex"));
        Double sexTemp = (Double) baseUserMap.get("sex");// 微信用户性别
        System.out.println(sexTemp);
        int sex = sexTemp.intValue();// Double => Integer
        String province = (String) baseUserMap.get("province");// 微信用户所在省
        String city = (String) baseUserMap.get("city");// 微信用户所在市
        String country = (String) baseUserMap.get("country");// 微信用户所在国家
        String headimgurl = (String) baseUserMap.get("headimgurl");// 微信用户头像

        StringBuilder builder = new 
            StringBuilder(country).append("||").append(province).append("||").append(city);
        String finalAddress = builder.toString();

        try {
            //解决中文乱码
            nickname = new String(nickname.getBytes("ISO-8859-1"), "UTF-8");
            finalAddress = new String(finalAddress.getBytes("ISO-8859-1"), "UTF-8");

        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        User user = new User();
        user.setName(nickname).setHeadImg(headimgurl).setCity(finalAddress)
            .setOpenid(openId).setSex(sex).setCreateTime(new Date());

        User findUser = userMapper.findByUserOpenid(openId);
        if (findUser != null) { //如果数据库中已经有该微信用户信息,更新微信用户最新基本信息,并直接返回即可
            userMapper.updateUser(user);
            return user;
        }// 否则继续往下执行

        userMapper.saveUser(user);// 保存用户信息
        return user;
    }
}

通过扫码登录跳转页面携带的参数code而获取封装有user信息的token

@GetMapping("/user/callback")
 public String weChatUserCallback(@RequestParam(value = "code", required = true) String code,
                                  String state, // 根据实际情况而定可用作保存当前页面地址
                                  RedirectAttributes redirectAttributes){
     User user = userService.saveWeChatUser(code);
     System.out.println("user:"+user);
     redirectAttributes.addFlashAttribute("user",user);
     String token = null;
     if (user != null){
         // jwt 生成 token
         token = JWTUtils.createJsonWebToken(user);
         redirectAttributes.addFlashAttribute("token",token);
         redirectAttributes.addFlashAttribute("state",token);
         return "redirect:/test/test03?token="+token;// 将token 拼接于url ,便于拦截器过滤
     }else{
         return "redirect:/error/error";
     }
 }

微信网页扫码支付简介

#   1、扫码支付文档:https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=2_2

#   2、名称理解
        appid:公众号唯一标识
        appsecret:公众号的秘钥

        mch_id:商户号,申请微信支付的时候分配的
        key:支付交易过程生成签名的秘钥,设置路径 
            微信商户平台(pay.weixin.qq.com)-->账户中心-->账户设置-->API安全-->密钥设置
            
#   3、和微信支付交互方式
        1、post方式提交
        2、xml格式的协议
        3、签名算法MD5
        
        4、交互业务规则 先判断协议字段返回,再判断业务返回,最后判断交易状态
        5、接口交易单位为 分
        6、交易类型:JSAPI--公众号支付、NATIVE--原生扫码支付、APP--app支付

微信支付业务流程说明:

(1)商户后台系统根据用户选购的商品生成订单。

(2)用户确认支付后调用微信支付【统一下单API】生成预支付交易;

(3)微信支付系统收到请求后生成预支付交易单,并返回交易会话的二维码链接code_url。

(4)商户后台系统根据返回的code_url生成二维码。

(5)用户打开微信“扫一扫”扫描二维码,微信客户端将扫码内容发送到微信支付系统。

(6)微信支付系统收到客户端请求,验证链接有效性后发起用户支付,要求用户授权。

(7)用户在微信客户端输入密码,确认支付后,微信客户端提交授权。

(8)微信支付系统根据用户授权完成支付交易。

(9)微信支付系统完成支付交易后给微信客户端返回交易结果,并将交易结果通过短信、微信消息提示用户。微信客户端展示支付交易结果页面。

(10)微信支付系统通过发送异步消息通知商户后台系统支付结果。商户后台系统需回复接收情况,通知微信后台系统不再发送该单的支付通知。

(11)未收到支付通知的情况,商户后台系统调用【查询订单API】。

(12)商户确认订单已支付后给用户发货。

微信扫码支付之统一下单接口开发之订单增删改查

统一下单微信官方文档:https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=9_1

c1f76cebb86a2c4db99d5933b60d7d16.png
image.png
DROP TABLE IF EXISTS `video_order`;

CREATE TABLE `video_order` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `openid` varchar(32) DEFAULT NULL COMMENT '用户标示',
  `out_trade_no` varchar(64) DEFAULT NULL COMMENT '订单唯一标识',
  `state` int(11) DEFAULT NULL COMMENT '0表示未支付,1表示已支付',
  `create_time` datetime DEFAULT NULL COMMENT '订单生成时间',
  `notify_time` datetime DEFAULT NULL COMMENT '支付回调时间',
  `total_fee` int(11) DEFAULT NULL COMMENT '支付金额,单位分',
  `nickname` varchar(32) DEFAULT NULL COMMENT '微信昵称',
  `head_img` varchar(128) DEFAULT NULL COMMENT '微信头像',
  `video_id` int(11) DEFAULT NULL COMMENT '视频主键',
  `video_title` varchar(128) DEFAULT NULL COMMENT '视频名称',
  `video_img` varchar(256) DEFAULT NULL COMMENT '视频图片',
  `user_id` int(11) DEFAULT NULL COMMENT '用户id',
  `ip` varchar(64) DEFAULT NULL COMMENT '用户ip地址',
  `del` int(5) DEFAULT '0' COMMENT '0表示未删除,1表示已经删除',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

LOCK TABLES `video_order` WRITE;
public class CommonUtils {

    // 生成 uuid, 即用来标识一笔单,也用做 nonce_str
    public static String generateUUID() {
        return UUID.randomUUID().toString().replaceAll("-", "")// 去掉默认自带的 - 分隔符
                .substring(0, 32);// 截取 32 位
    }

    // MD5 加密工具类
    public static String getMD5String(String data) {
        try {
            // 获取MD5 加密实例
            MessageDigest md = MessageDigest.getInstance("MD5");
            // 获得数组对象
            byte[] array = md.digest(data.getBytes("UTF-8"));
            // 拼接加密字符串
            StringBuilder builder = new StringBuilder();
            for (byte item : array) {
                builder.append(Integer.toHexString((item & 0xFF) | 0x100).substring(1, 3));
            }
            return builder.toString().toUpperCase();// 所有字母大写
        } catch (Exception exception) {
            System.out.println("MD5加密算法出现异常...");
        }
        return null;
    }
}
# 1、统一下单参数需要微信签名,签名规则如下
-   文档地址:https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=4_3
-   签名生成的通用步骤如下:
    第一步,设所有发送或者接收到的数据为集合M,将集合M内非空参数值的参数按照参数名ASCII码从小到大排序(字典序),
    使用URL键值对的格式(即key1=value1&key2=value2…)拼接成字符串stringA。

    第二步,在stringA最后拼接上key得到stringSignTemp字符串,并对stringSignTemp进行MD5运算,再将得到的字符
    串所有字符转换为大写,得到sign值signValue。key设置路径:
    微信商户平台(pay.weixin.qq.com)-->账户设置-->API安全-->密钥设置

<---  
    参数:
       SortedMap<String, String> params = new TreeMap<>();  
          params.put("appid", wxPayConfig.getAppId());  //公众账号ID  
          params.put("mch_id", wxPayConfig.getMchId());  //商户号  
          params.put("nonce_str", CommonUtil.generateNonceStr());  //随机字符串  
          params.put("body", videoOrder.getVideoTitle());  // 商品描述  
          //商户订单号,商户系统内部订单号,要求 32个字符内,只能是数字、大小写字母_-|* 且在同一个商户号下唯一
          params.put("out_trade_no", videoOrder.getOutTradeNo()); 
          params.put("total_fee", videoOrder.getTotalFee().toString());  //标价金额 分
          params.put("spbill_create_ip", videoOrder.getIp());  
          //通知地址    
          params.put("notify_url", wxPayConfig.getDomain()+wxPayConfig.getCallbackUrl()); 
          //交易类型 JSAPI 公众号支付 NATIVE 扫码支付 APP APP支付
          params.put("trade_type", "NATIVE");  
          //生成签名
          String sign = WXPayUtil.createSign(params, wxPayConfig.getKey());
          params.put("sign", sign); 
          //参数转xml
          String requestXMl = WXPayUtil.mapToXml(params);

          生成签名后,通过工具去校验
          https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=20_1
--->
#    2、测试地址:localhost:8081/api/v1/order/add?video_id=2

#    3、课程测试签名结果:
    sign: 85118C91DFCB052FB02AC183BF3D57D2
#微信相关配置:
#公众号
wxpay.appid=wx252XXXXX1xs9h
wxpay.appsecret=qm4i2u43oXXXXXXXX7055s8c99a8

#微信开放平台配置
wxopen.appid=wx025XXXXXXa2d5b
wxopen.appsecret=f5b6730c59XXXXXXXXeb8948a9f3
#重定向url 重定向到首页,并根据code拿到token,从而获取微信扫码用户的登录信息
#这个域名是别人认证过的,只能拿来做个参考,不能自己回调
wxopen.redirect_url=http://XXXXXXXXXXXXXX.cn/xdclass/wechat/user/callback

#微信商户平台 商户id 订单秘钥 回调地址
wxpay.mer_id=8XXXXXX068
wxpay.key=MbZL0DiXXXXXXXXX5S51MK2
wxpay.callback=http://XXXXXXXXXXXXXXX.cn/xdclass/
public String unifiedOrder(VideoOrder videoOrder) throws Exception {
        WXPay wxPay = new WXPay();

        // 使用 map 封装 订单参数以及微信支付相关参数
        SortedMap<String, String> data = new TreeMap<>();
        data.put("appid", weChatConfig.getAppid());// 公众账号ID: 微信支付分配的公众账号ID(企业号corpid即为此appId)
        data.put("mch_id", weChatConfig.getMchId());// 商户号: 微信支付分配的商户号
        data.put("nonce_str", CommonUtils.getUUID());// 随机字符串: 自定义参数,可以为终端设备号(门店号或收银设备ID),PC网页或公众号内支付可以传"WEB"
        data.put("body", videoOrder.getVideoTitle());// 商品描述
        data.put("out_trade_no", videoOrder.getOutTradeNo());// 商户订单号: 要求32个字符内,只能是数字、大小写字母_-|* 且在同一个商户号下唯一。
        data.put("total_fee", videoOrder.getTotalFee().toString());// 标价金额: 单位为分
        data.put("spbill_create_ip", videoOrder.getIp());// 下单用户的客户端IP
        data.put("notify_url", weChatConfig.getPayCallbackUrl());// 通知地址: 异步接收微信支付结果通知的回调地址,通知url必须为外网可访问的url,不能携带参数。
        data.put("trade_type", "NATIVE");// 交易类型: 此处指定为扫码支付

        // 生成 sign 签名
        String sign = WXPayUtil.generateSignature(data, weChatConfig.getKey());
        data.put("sign", sign);// 签名: 微信返回的签名值

        System.out.println("---------------------- xml 数据如下:----------------------");
        // map 转 xml
        String payXmlData = WXPayUtil.mapToXml(data);
        System.out.println(payXmlData);

        // 统一下单,发送POST请求微信后台统一下单接口:https://api.mch.weixin.qq.com/pay/unifiedorder 获取返回xml格式的字符串 orderStr
        String orderStr = HTTPUtils.doPost(WeChatConfig.getUnifiedOrderUrl(), payXmlData, 4000);
        System.out.println("---------------------- 请求统一下单接口返回的 orderStr 数据如下:----------------------");
        System.out.println(orderStr);

        if (null == orderStr) {
            return null;
        }

        // 将统一下单接口返回的xml格式的字符串 orderStr 转成 map
        Map<String, String> unifiedOrderMap = WXPayUtil.xmlToMap(orderStr);
        System.out.println("---------------------- 转换成 map 的 orderStr 数据如下:----------------------");
        // 这样做的目的是解决打印出的对象中文乱码问题,无法阅读错误提示信息
        String string = new String(unifiedOrderMap.toString().getBytes("ISO-8859-1"), "UTF-8");
        System.out.println(string);

        if (unifiedOrderMap != null) {
            System.out.println("支付二维码url:" + unifiedOrderMap.get("code_url"));
            return unifiedOrderMap.get("code_url");// 获取统一下单接口返回的 code_url(支付二维码图片的url) 数据
        }

        // 否则返回null
        return null;
    }
932a72c74a1743a2dae962296ccb6711.png
image.png

Nginx文件的默认安装位置如下。

目录说明
/usr/sbin/nginx存放主程序
/etc/nginx存放配置文件
/usr/share/nginx存放静态文件
/var/log/nginx存放日志

执行以下命令打开Nginx配置文件nginx.conf。

sudo vi /etc/nginx/nginx.conf
server {
    listen       80 default_server;
    listen       [::]:80 default_server;
    server_name  _;
    root         /usr/share/nginx/html;

    # Load configuration files for the default server block.
    include /etc/nginx/default.d/*.conf;

    location / {
    proxy_pass https://bucketname.oss-cn-beijing-internal.aliyuncs.com;
    proxy_set_header Host $host;
    }
}
sudo cd /usr/sbin/
sudo ./nginx

https://developers.weixin.qq.com/doc/oplatform/Website_App/WeChat_Login/Wechat_Login.html?spm=a2c6h.12873639.article-detail.6.7d3c4912zCqPuf

https://open.weixin.qq.com/cgi-bin/showdocument?spm=a2c6h.12873639.article-detail.5.7d3c4912zCqPuf&action=dir_list&t=resource/res_list&verify=1&id=open1419316505&token=&lang=zh_CN

加群联系作者vx:xiaoda0423

仓库地址:https://github.com/webVueBlog/JavaGuideInterview

参考资料

[1]

element-plus: https://so.csdn.net/so/search?q=element-plus&spm=1001.2101.3001.7020

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/840126.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

中国1km分辨率月最低温度数据集(1901-2021年)介绍

该数据为中国逐月最低温度数据&#xff0c;空间分辨率为0.0083333&#xff08;约1km&#xff09;&#xff0c;时间为1901.1-2021.12。数据格式为NETCDF&#xff0c;即.nc格式。数据单位为0.1 ℃。该数据集是根据CRU发布的全球0.5气候数据集以及WorldClim发布的全球高分辨率气候…

数据安全治理的关键-数据分类分级工具

强大的资产发现能力 多种资产发现方式的组合应用&#xff0c;能够最大程度地提高资产发现能力。 灵活的敏感数据分类分级规则 内置丰富的敏感数据分类分级规则&#xff0c;支持正则表达式、关键词组、非结构化指纹、结构化指纹、机器聚类等多种匹配方式&#xff0c;并且规则…

vscode插件不能搜索安装

1 现象 vscode搜索自己的插件&#xff0c;报错&#xff1a; Error while fetching extensions. HXR failed2 原因 之前用vscode开发golang语言&#xff0c;设置了proxy代理&#xff0c;所以导致错误&#xff0c;删除即可 重启vscode 3 结果

基于Go编写一个可视化Navicat本地密码解析器

前提 开发小组在测试环境基于docker构建和迁移一个MySQL8.x实例&#xff0c;过程中大意没有记录对应的用户密码&#xff0c;然后发现某开发同事本地Navicat记录了根用户&#xff0c;于是搜索是否能够反解析Navicat中的密码掩码&#xff08;这里可以基本断定Navicat对密码是采用…

IL汇编语言读取控制台输入和转换为整数

新建一个testcvt.il&#xff1b; .assembly extern mscorlib {}.assembly Test{.ver 1:0:1:0}.module test.exe.method static void main() cil managed{.maxstack 1.entrypointldstr "\n请输入一个数字:"call void [mscorlib]System.Console::Write(string)call st…

二分图笔记

什么是二分图&#xff1f; 二分图一般针对无向图问题 一张图中&#xff0c;如果能够把全部的点分到两个集合中&#xff0c;保证两个集合内部没有任何边 &#xff0c;图中的边只存在于两个集合之间&#xff0c;即为二分图 判断二分图 1. 染色法 即用两种颜色对于这张图进行染…

Redis内网主从节点搭建

Redis内网主从节点搭建 1、文件上传2、服务安装3、服务启动4、配置主从复制 1、文件上传 内网环境手动上传gcc-c、redis.tar文件 2、服务安装 # 解压 unzip gcc-c.zip unzip gcc_rpm.zip tar -zxvf redis-6.2.13.tar.gz# 安装 cd gcc_rpm/ rpm -ivh *.rpm --nodeps --force…

LIME(可解释性分析方法)

目录 1.什么是LIME 2.思路 3.LIME在不同任务中的范式&#xff08;待补充&#xff09; 1.什么是LIME 简单理解&#xff1a; 对于分类任务&#xff1a;如下图所示&#xff0c;LIME可以列出分类结果&#xff0c;所依据特征对应给比重。 对于图像分类任务&#xff1a;如下图所示&a…

Python(六十八)元组的创建方式

❤️ 专栏简介&#xff1a;本专栏记录了我个人从零开始学习Python编程的过程。在这个专栏中&#xff0c;我将分享我在学习Python的过程中的学习笔记、学习路线以及各个知识点。 ☀️ 专栏适用人群 &#xff1a;本专栏适用于希望学习Python编程的初学者和有一定编程基础的人。无…

JVM详情

JVM详情 一、JVM内存划分二、双亲委派模型&#xff08;重点考察&#xff09;三、 GC&#xff08;垃圾回收机制&#xff09;垃圾的判定算法垃圾回收算法 一、JVM内存划分 堆&#xff1a;存放new出来的对象&#xff1b;&#xff08;成员变量&#xff09; 方法区&#xff1a;存放…

【代码源每日一题div2 】简单的异或问题

简单的异或问题 - 题目 - Daimayuan Online Judge 题意&#xff1a; 思路&#xff1a; 首先这有一个结论&#xff1a;0~2^m-1的所有数进行XOR运算后&#xff0c;得到的结果是0。我们来证明一下这个结论&#xff1a; 比如m3时&#xff0c;一共是0 1 2 3 4 5 6 7&#xff0c;八…

炼钢工艺流程入门(1)

1. 工序简略词 BF(Blast Furnace)&#xff1a;高炉 KR(Kambara Reactor)&#xff1a;脱硫 BOF(Basic Oxygen Furnace)&#xff1a;氧气顶吹转炉炼钢法 LF(Ladle Furnace)&#xff1a;钢包精炼炉 CCM(Continuous Casting Machine) &#xff1a;连铸机 2. 软处罚约束与硬处…

【N32L40X】学习笔记13-软件IIC读写EEPROM AT24C02

AT24C02 8个字节每页,累计32个页 通讯频率MAX 400K AT24C02大小 2K 芯片地址 对于at24c02 A2A1A0 这三个引脚没有使用 写时序 由于设备在写周期中不会产生ACK恢复&#xff0c;因此这可用于确定周期何时完成&#xff08;此特性可用于最大限度地提高总线吞吐量&#xff09;…

Jmeter 压测工具使用手册[详细]

1. jemter 简介 jmeter 是 apache 公司基于 java 开发的一款开源压力测试工具&#xff0c;体积小&#xff0c;功能全&#xff0c;使用方便&#xff0c;是一个比较轻量级的测试工具&#xff0c;使用起来非常简 单。因为 jmeter 是 java 开发的&#xff0c;所以运行的时候必须先…

gitbook编译报错gitbook\gitbook-plugin-fontsettings\fontsettings.js‘

找到本地电脑gitbook安装的目录&#xff1a;cd ~/.gitbook/versions/版本/lib/output/website/ 可以用 vim copyPluginAssets.js 也可以用记事本打开注释掉或者改为false

Redis 双写一致性实践及案例

面试问题&#xff1a; 你只要用缓存&#xff0c;就可能会涉及到redis缓存与数据库双存储双写&#xff0c;你只要是双写&#xff0c;就一定会有数据一致性的问题&#xff0c;那么你如何解决一致性问题&#xff1f;双写一致性&#xff0c;你先动缓存redis还是数据库mysql哪一个&…

MySQL建表和增添改查

1.创建一个名为mydb的数据库 mysql> show database mydb; 查询 mysql> show database mydb; 2.创建一个学生信息表 mysql> create table mydb.student_informtion( -> student_id int UNSIGNED NOT NULL PRIMARY KEY, //非空&#xff08;不允许为空&#xff0…

Axure RP9中使用Echarts示例

目录 在Axure中拖入一个矩形框&#xff0c;并命名tes 进入Echarts官网示例页面https://echarts.apache.org/examples/zh/index.html 选择自己需要的图表&#xff0c;修改数据&#xff0c;并复制左侧js代码 把上面复制的代码替换下方的option{}; javascript: var script docum…

扩散模型实战(二):扩散模型的发展

推荐阅读列表&#xff1a; 扩散模型实战&#xff08;一&#xff09;&#xff1a;基本原理介绍 扩散模型从最初的简单图像生成模型&#xff0c;逐步发展到替代原有的图像生成模型&#xff0c;直到如今开启 AI 作画的时代&#xff0c;发展速度可谓惊人。下面介绍一下2D图像生成相…