搜索

SpringBoot 微信点餐开源系统

Java引导者

共 5301字，需浏览 11分钟

 · 2021-02-14


  • 作者：Tommmmm

  • www.jianshu.com/p/ae14101989f2

架构

前后端分离:

Nginx 与 Tomcat 的关系在这篇文章，几分钟可以快速了解：

https://www.jianshu.com/p/22dcb7ef9172

补充：

  • setting.xml 文件的作用：settings.xml 是 maven 的全局配置文件。而 pom.xml 文件是所在项目的局部配置。Settings.xml 中包含类似本地仓储位置、修改远程仓储服务器、认证信息等配置。

  • maven 的作用：借助 Maven，可将 jar 包仅仅保存在 “仓库” 中，有需要该文件时，就引用该文件接口，不需要复制文件过来占用空间。

注：这个 “仓库” 应该就是本地安装 maven 的目录下的 Repository 的文件夹

分布式锁

线程锁：当某个方法或代码使用锁，在同一时刻仅有一个线程执行该方法或该代码段。线程锁只在同一 JVM 中有效，因为线程锁的实现在根本上是依靠线程之间共享内存实现的。如 synchronized

进程锁：为了控制同一操作系统中多个进程访问某个共享资源。

分布式锁：当多个进程不在同一个系统中，用分布式锁控制多个进程对资源的访问。

分布式锁一般有三种实现方式：

  1. 数据库乐观锁；

  2. 基于 Redis 的分布式锁；

  3. 基于 ZooKeeper 的分布式锁。

乐观锁的实现：使用版本标识来确定读到的数据与提交时的数据是否一致。提交后修改版本标识，不一致时可以采取丢弃和再次尝试的策略。

CAS：可以阅读这篇文章：

https://www.jianshu.com/p/456bb1ea9627

分布式锁基于 Redis 的实现：(本系统锁才用的)

基本命令：

  • SETNX（SET if Not exist）：当且仅当 key 不存在，将 key 的值设为 value ，并返回 1；若给定的 key 已经存在，则 SETNX 不做任何动作，并返回 0。

  • GETSET：将给定 key 的值设为 value ，并返回 key 的旧值。先根据 key 获取到旧的 value，再 set 新的 value。

  • EXPIRE 为给定 key 设置生存时间, 当 key 过期时，它会被自动删除。

加锁方式：

这里的 jedis 是 Java 对 Redis 的集成

  1. jedis.set(String key, String value, String nxxx, String expx, int time)

错误的加锁方式 1：

如果程序在执行完 setnx() 之后突然崩溃，导致锁没有设置过期时间。那么将会发生死锁。

  1. Long result = jedis.setnx(Key, value);
  2.     if (result == 1) {
  3.         // 若在这里程序突然崩溃，则无法设置过期时间，将发生死锁
  4.         jedis.expire(Key, expireTime);
  5.     }

错误的加锁方式 2：

分布式锁才用（Key，过期时间）的方式，如果锁存在，那么获取它的过期时间，如果锁的确已经过期了，那么获得锁，并且设置新的过期时间

错误分析：不同的客户端之间需要同步好时间。

  1.  long expires = System.currentTimeMillis() + expireTime;
  2.     String expiresStr = String.valueOf(expires);

  4.     // 如果当前锁不存在，返回加锁成功
  5.     if (jedis.setnx(lockKey, expiresStr) == 1) {
  6.         return true;
  7.     }

  9.     // 如果锁存在，获取锁的过期时间
  10.     String currentValueStr = jedis.get(lockKey);
  11.     if (currentValueStr != null && Long.parseLong(currentValueStr) < System.currentTimeMillis()) {
  12.         // 锁已过期，获取上一个锁的过期时间，并设置现在锁的过期时间
  13.         String oldValueStr = jedis.getSet(lockKey, expiresStr);
  14.         if (oldValueStr != null && oldValueStr.equals(currentValueStr)) {
  15.             // 考虑多线程并发的情况，只有一个线程的设置值和当前值相同，它才有权利加锁
  16.             return true;
  17.         }
  18.     }

  20.     // 其他情况，一律返回加锁失败
  21.     return false;

解锁：判断锁的拥有者后可以使用 jedis.del(lockKey) 来释放锁。

分布式锁基于 Zookeeper 的实现

Zookeeper 简介：Zookeeper 提供一个多层级的节点命名空间（节点称为 znode），每个节点都用一个以斜杠（/）分隔的路径表示，而且每个节点都有父节点（根节点除外）。

例如，/foo/doo 这个表示一个 znode，它的父节点为 / foo，父父节点为 /，而 / 为根节点没有父节点。

client 不论连接到哪个 Server，展示给它都是同一个视图，这是 zookeeper 最重要的性能。

Zookeeper 的核心是原子广播，这个机制保证了各个 Server 之间的同步。实现这个机制的协议叫做 Zab 协议。Zab 协议有两种模式，它们分别是恢复模式（选主）和广播模式（同步）。*当服务启动或者在领导者崩溃后，Zab 就进入了恢复模式*，当领导者被选举出来，且大多数 Server 完成了和 leader 的状态同步以后，恢复模式就结束了。状态同步保证了 leader 和 Server 具有相同的系统状态。

为了保证事务的顺序一致性，zookeeper 采用了递增的事务 id 号（zxid）来标识事务，实现中 zxid 是一个 64 位的数字。

Zookeeper 的分布式锁原理

获取分布式锁的流程：

  1. 在获取分布式锁的时候在 locker 节点 (locker 节点是 Zookeeper 的指定节点) 下创建临时顺序节点，释放锁的时候删除该临时节点。

  2. 客户端调用 createNode 方法在 locker 下创建临时顺序节点，然后调用 getChildren(“locker”) 来获取 locker 下面的所有子节点，注意此时不用设置任何 Watcher。

  3. 客户端获取到所有的子节点 path 之后，如果发现自己创建的子节点序号最小，那么就认为该客户端获取到了锁。

  4. 如果发现自己创建的节点并非 locker 所有子节点中最小的，说明自己还没有获取到锁，此时客户端需要找到比自己小的那个节点，然后对其调用 exist() 方法，同时对其注册事件监听器。

  5. 之后，让这个被关注的节点删除，则客户端的 Watcher 会收到相应通知，此时再次判断自己创建的节点是否是 locker 子节点中序号最小的，如果是则获取到了锁，如果不是则重复以上步骤继续获取到比自己小的一个节点并注册监听。

我的解释：

A 在 Locker 下创建了 Noden —> 循环 (每次获取 Locker 下的所有子节点 —> 对这些节点按节点自增号排序顺序 —> 判断自己创建的 Noden 是否是第一个节点 —> 如果是则获得了分布式锁 —> 如果不是监听上一个节点 Node_n-1 等它释放掉分布式锁。)

@ControllerAdvice 处理全局异常
Mybatis 注解方式的使用：
@insert 用注解方式写 SQL 语句

分布式系统的下的 Session

1、分布式系统：多节点，节点发送数据交互，不共享主内存，但通过网络发送消息合作。

分布式：不同功能模块的节点

集群：相同功能的节点

2、Session 与 token

服务端在 HTTP 头里设置 SessionID 而客户端将其保存在 cookie

而使用 Token 时需要手动在 HTTP 头里设置，服务器收到请求后取出 cookie 进行验证。

都是一个用户一个标志

3、分布式系统中的 Session 问题：

高并发：通过设计保证系统能够同时并行处理很多请求。

当高并发量的请求到达服务端的时候通过负载均衡的方式分发到集群中的某个服务器，这样就有可能导致同一个用户的多次请求被分发到集群的不同服务器上，就会出现取不到 session 数据的情况。

根据访问不同的 URL，负载到不同的服务器上去

三台机器，A1 部署类目，A2 部署商品，A3 部署单服务

通用方案：用 Redis 保存 Session 信息，服务器需要时都去找 Redis 要。登录时保存好 key-value，登出时让他失效

垂直扩展：IP 哈希 IP 的哈希值相同的访问同一台服务器

session 的一致性：只要用户不重启浏览器，每次 http 短连接请求，理论上服务端都能定位到 session，保持会话。

Redis 作为分布式锁

高并发：通过设计保证系统能够同时并行处理很多请求。

同步：Java 中的同步指的是通过人为的控制和调度，保证共享资源的多线程访问成为线程安全。

线程的 Block 状态：

a. 调用 join() 和 sleep() 方法，sleep() 时间结束或被打断

b.wait()，使该线程处于等待池, 直到 notify()/notifyAll()：不释放资源

此外，在 runnable 状态的线程是处于被调度的线程，Thread 类中的 yield 方法可以让一个 running 状态的线程转入 runnable。

Q：为什么 wait,notify 和 notifyAll 必须与 synchronized 一起使用？Obj.wait()、Obj.notify 必须在 synchronized(Obj){…} 语句块内。

A：wait 就是说线程在获取对象锁后，主动释放对象锁，同时本线程休眠。

Q：Synchronized：

A：Synchronized 就是非公平锁，它无法保证等待的线程获取锁的顺序。

公平和非公平锁的队列都基于锁内部维护的一个双向链表，表结点 Node 的值就是每一个请求当前锁的线程。公平锁则在于每次都是依次从队首取值。

ReentrantLock 重入性：

重入锁可以看这两篇文章，都比较简单

https://www.jianshu.com/p/587a4559442b
https://www.jianshu.com/p/1c52f17efaab

Spring + Redis 缓存的两个重要注解：

  • @cacheable 只会执行一次，当标记在一个方法上时表示该方法是支持缓存的，Spring 会在其被调用后将其返回值缓存起来，以保证下次利用同样的参数来执行该方法时可以直接从缓存中获取结果。

  • @cacheput：与 @Cacheable 不同的是使用 @CachePut 标注的方法在执行前不会去检查缓存中是否存在之前执行过的结果，而是每次都会执行该方法，并将执行结果以键值对的形式存入指定的缓存中。

对数据库加锁（乐观锁 与 悲观锁）

悲观锁依赖数据库实现：

  1. select * from account where name=”Erica” for update

这条 sql 语句锁定了 account 表中所有符合检索条件（name=”Erica”）的记录，使该记录在修改期间其它线程不得占有。

代码层加锁：

  1. String hql ="from TUser as user where user.;
  2. Query query = session.createQuery(hql);
  3. query.setLockMode("user",LockMode.UPGRADE); //加锁
  4. List userList = query.list();//执行查询，获取数据

其它

@Data 类似于自动生成了 Getter()、Setter()、ToString() 等方法。

JAVA1.8 的新特性 StreamAPI：Collectors 中提供了将流中的元素累积到汇聚结果的各种方式

  1. List<Menu> menus=Menu.getMenus.stream().collect(Collectors.toList())

For - each 写法：

for each 语句是 java5 新增，在遍历数组、集合的时候，for each 拥有不错的性能。

  1. public static void main(String[] args) {
  2.         String[] names = {"beibei", "jingjing"};
  3.         for (String name : names) {
  4.             System.out.println(name);
  5.         }
  6.     }

for each 虽然能遍历数组或者集合，但是只能用来遍历，无法在遍历的过程中对数组或者集合进行修改。

BindingResult：一个 @Valid 的参数后必须紧挨着一个 BindingResult 参数，否则 spring 会在校验不通过时直接抛出异常。

  1. @Data
  2. public class OrderForm {

  4.     @NotEmpty(message = "姓名必填")
  5.     private String name;
  6. }

后台：

  1. @RequestMapping("save")  
  2.     public String save( @Valid OrderForm order,BindingResult result) {  
  3.         //  
  4.         if(result.hasErrors()){  
  5.             List<ObjectError> ls=result.getAllErrors();  
  6.             for (int i = 0; i < ls.size(); i++) {  
  7.                 log.error("参数不正确，OrderForm={}", order);
  8.                 throw new SellException(
  9.                  ………… ,
  10.              result.getFeildError.getDefaultMessage()
  11.               )
  12.                 System.out.println("error:"+ls.get(i));  
  13.             }  
  14.         }  
  15.         return "adduser";  
  16.     }

result.getFeildError.getDefaultMessage() 可抛出 “姓名必填” 的异常。

4、List 转为 Map

  1. public class Apple {
  2.     private Integer id;
  3.     private String name;
  4.     private BigDecimal money;
  5.     private Integer num;
  6.    /*构造函数*/
  7. }
  1. List<Apple> appleList = new ArrayList<>();//存放apple对象集合
  2. Apple apple1 =  new Apple(1,"苹果1",new BigDecimal("3.25"),10);
  3. Apple apple12 = new Apple(1,"苹果2",new BigDecimal("1.35"),20);
  4. Apple apple2 =  new Apple(2,"香蕉",new BigDecimal("2.89"),30);
  5. Apple apple3 =  new Apple(3,"荔枝",new BigDecimal("9.99"),40);
  6. appleList.add(apple1);
  7. appleList.add(apple12);
  8. appleList.add(apple2);
  9. appleList.add(apple3);
  1. Map<Integer, Apple> appleMap = 
  2. appleList.stream().collect(Collectors.toMap(Apple::getId, a -> a,(k1,k2)->k1));

5、Collection 的子类：List、Set

List：ArrayList、LinkedList 、Vector

List：有序容器，允许 null 元素，允许重复元素

Set：元素是无序的，不允许元素

最流行的是基于 HashMap 实现的 HashSet，由 [hashCode() 和 equals()]保证元素的唯一性。

可以用 set 帮助去掉 List 中的重复元素，set 的构造方法的参数可以是 List，构造后是一个去重的 set。

HashMap 的补充：它不是 Collection 下的

Map 可以使用 containsKey()/containsValue() 来检查其中是否含有某个 key/value。

HashMap 会利用对象的 hashCode 来快速找到 key。

插入过程：通过一个 hash 函数确定 Entry 的插入位置 index=hash(key)，但是数组的长度有限，可能会发生 index 冲突，当发生了冲突时，会使用头插法，即为新来的 Entry 指向旧的 Entry，成为一个链表。

每次插入时依次遍历它的 index 下的单链表，如果存在 Key 一致的节点，那么直接替换，并且返回新的值。

但是单链表不会一直增加元素，当元素个数超过 8 个时，会尝试将单链表转化为红黑树存储。

为何加载因子默认为 0.75？*（0.75 开始扩容）*

答：通过源码里的 javadoc 注释看到，元素在哈希表中分布的桶频率服从参数为 0.5 的泊松分布。

源码地址：

https://github.com/923310233/wxOrder

——————END——————


欢迎关注“Java引导者”，我们分享最有价值的Java的干货文章，助力您成为有思想的Java开发工程师！

浏览 2
点赞
评论
收藏
分享

手机扫一扫分享

举报
评论
图片
表情
推荐
真高！比亚迪员工爆料比亚迪在越南的薪资水平：基本工资480万，全勤奖35万，交通补助20万，餐补110万，每周6天，每天10小时
上一篇：某大公司为逼迫员工离职，竟然把他的工位安排到厕所旁，没想到他直接开始记录领导的如厕时间，还发到公司大群...对此，你怎么看？--完--PS：欢迎在留言区留下你的观点，一起讨论提高。如果今天的文章让你有新的启发，欢迎转发分享给更多人。全文完，感谢你的耐心阅读。如果你还想看到我的文章，请一定给本
开发者全社区
0
偷偷告诉你如何一台电脑开多个微信！
大家好，我是轩辕。前几天在粉丝群里，有人问我是怎么在一台电脑上同时登录两个微信的？正好之前写过一篇文章，分析过原理，分享给没看过的小伙伴学习一下。手机端多开微信估计很多人都知道，像华为、小米等手机系统都对此做了支持，不过在运行Windows系统的电脑上怎么启动两个微信呢？其实很简单，你只需要写一个批
编程技术宇宙
0
轻松掌握开源项目的二次开发技巧
大厂技术  高级前端  Node进阶点击上方 程序员成长指北，关注公众号回复1，加入高级Node交流群本文作者：@方长_beezen 原文链接：https://juejin.cn/post/7358647992608489535前言随着软件行业的迅速
程序员成长指北
0
人工智能周刊#18：微软发布手机端大模型、Llama 3 中文模型列表、苹果开源新项目、
 主打尊重隐私的搜索引擎 duckduckgo，也推出了 ai chat 服务，可以使用 chatgpt 或者 claude机器学习周刊：关注 Python、机器学习、深度学习、大模型等硬核技术本期目录：1、Qwen1.5-110B：Qwen1.5 系列的首个千亿参数开源模型2、苹果开源
机器学习算法与Python实战
0
测试新人，如何快速上手一个陌生的系统！
大家好，我是狂师！作为刚入行不久的测试新人，面对一个陌生的系统时，可能会感到有些手足无措。面对一个全新的系统系统，如何快速上手并展开有效的测试工作是一个重要的挑战。本文将探讨测试新人如何通过一系列步骤和策略，快速熟悉并掌握新系统的测试要点，从而提高测试效率和质量。本文旨在为测试新手提供一份指导，帮助
测试开发技术
0
微软开源MS-DOS操作系统源码，冲到GitHub第一了！
大家好，我是轩辕。这两天逛GitHub的时候，突然发现一个叫 MS-DOS的项目冲到Trending榜首了！定睛一看，微软官方啊，搜了一下才知道，原来前两天，微软把MS-DOS 4.0系统开源了！关于这个系统，估计现在很多程序员都不知道了，或者只在古老的教科书上看过这玩意儿。MS-DOS，全称为Mi
编程技术宇宙
6
Open-Sora全面开源升级：支持16s视频生成和720p分辨率
机器之心发布 机器之心编辑部Open-Sora 在开源社区悄悄更新了，现在单镜头支持长达16秒的视频生成，分辨率最高可达720p，并且可以处理任何宽高比的文本到图像、文本到视频、图像到视频、视频到视频和无限长视频的生成需求。我们来试试效果。生成个横屏圣诞雪景，发b站再生成个竖屏，发抖音还能
机器学习算法与Python实战
0
SpringBoot 实现图片防盗链功能
程序员的成长之路互联网/程序员/技术/资料共享 关注阅读本文大概需要 4 分钟。来自：blog.csdn.net/weixin_46157208/article/details/138051737前言出于安全考虑，我们需要后端返回的图片只允许在某个网站内展示，不想被爬虫拿到图片地
程序员的成长之路
0
全球第一“开源”名门望族
Python入门到精通 Python入门到精通：人生苦短，我用Python！Python每日推送、Python教程、Python资料、Python视频、Python项目、Python学习等。
源码共读
0
大量 Java 开源项目停更...
点击关注公众号，Java 干货及时推送↓推荐阅读：投了 100 多份简历后…出品 | OSC开源社区（ID：oschina2013)Sonatype 发布了最新的一份《软件供应链状况》报告，深入探讨了如何在充满选择的世界中定义更好的软件，并探讨人工智能 (AI) 对软件开发的深远
Java技术栈
0
点赞
评论
收藏
分享

手机扫一扫分享

举报