苍穹外卖知识点

导入依赖
在这里插入图片描述

@Component
@Aspect
public class MyselfAspect{
	@Before("excution(* com.services.*.(..))")
	public myBefore(JointPoint jointPoint){
		System.out.println("在前面执行");
	}
}

只要注意如何使用@Before注解就行了,里面存放的是*(方法返回类型)+类路径+方法名+(函数参数)
在Service方法前面执行。
后面执行:@After
环绕执行:@Around

@Component
@Aspect
public class MyselfAspect{
	@Around("excution(* com.services.*.(..))")
	public myBefore(ProceedingJointPoint jointPoint){
		System.out.println("在前面执行");
		jointPoint.proceed();
		System.out.println("在后面执行");
	}
}

公共字段自动填充

需求背景

在进行插入和更新的时候,数据库有的表中有 创建时间、更新时间、创建用户ID、更新用户ID的字段;
每次进行写的时候都要手动的写一摸一样的代码,所以需要自动注入的功能;

选用方法

使用JDK自带的动态代理也能实现,但是复杂;
使用Spring-Boot-Web-Strater-Aop中的动态代理简便

定义操作类型的枚举类

public enum OperationType{
	UPDATE,
	INSERT,
}

定义一个注解@AutoFill

@Target(ElementType.METHOD)//使用范围为方法
@Retention(RetentionPolicy.RUNTIME)//生命周期为运行时,也是最长的周期,一般定义注解都是这个周期
public @interface AutoFill{
	OperationType value();//前面为value的类型为OperationType,参数名称为value
}

定义切面类

注意这种代码的写法、如何获得注解、获得注解中的值

@Aspect
@Componet
public class AutoFillAspect{
	@PointCut("execution(* *.*.*(..)) && @annotation(com.itheima.annotation.AutoFill)")
	public void autoFillPointCut();
	
	@Before("autoFillPointCut()")//在切入点之前执行
    public void autoFill(JoinPoint joinPoint){

        log.info("开始进行公共字段自动填充...");
        //1.获取到当前被拦截的方法上的数据库操作类型(比如是Insert还是Update,不同的类型需要给不同的参数赋值)
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();//通过连接点对象来获取签名,向下转型为MethodSignature
        AutoFill autoFill = signature.getMethod().getAnnotation(AutoFill.class);//获得方法上的注解对象
        OperationType operationType = autoFill.value();//获得数据库操作类型(Insert or Update)
        //2.获取到当前被拦截的方法的参数--实体对象(比如传入的参数是员工还是菜品还是其它的)
        Object[] args = joinPoint.getArgs(); //获得了方法所有的参数
        if(args == null || args.length==0 ){ //没有参数
            return;
        }
        Object entity = args[0];//现在约定实体放在第1个位置,传入实体可能不同所以用Object
        //3.准备赋值的数据(给公共字段赋值的数据,比如时间就是系统时间,用户ID是从ThreadLocal获取)
        LocalDateTime now = LocalDateTime.now();
        Long currentId = BaseContext.getCurrentId();
        if(operationType == OperationType.INSERT){
            //为4个公共字段赋值
            try {
                Method setCreateTime = entity.getClass().getDeclaredMethod("SET_CREATE_TIME", LocalDateTime.class); //把方法名全部换成常量类,防止写错
                Method setCreateUser = entity.getClass().getDeclaredMethod("SET_CREATE_USER", Long.class);
                Method setUpdateTime = entity.getClass().getDeclaredMethod("SET_UPDATE_TIME", LocalDateTime.class);
                Method setUpdateUser = entity.getClass().getDeclaredMethod("SET_UPDATE_USER", Long.class);
                //4.根据当前不同的操作类型,为对应的属性通过反射来赋值
                setCreateTime.invoke(entity,now);
                setCreateUser.invoke(entity,currentId);
                setUpdateTime.invoke(entity,now);
                setUpdateUser.invoke(entity,currentId);
            }catch (Exception e){
                e.printStackTrace();
            }
        }else if(operationType == OperationType.UPDATE){
            try {
                //为2个公共字段赋值
                Method setUpdateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME, LocalDateTime.class);
                Method setUpdateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class);
                //4.根据当前不同的操作类型,为对应的属性通过反射来赋值
                setUpdateTime.invoke(entity, now);
                setUpdateUser.invoke(entity, currentId);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        }
}

最后在mapper类的方法上加上@AutoFill(value= OperationType.INSERT)注解

OSS文件上传

OSS的配置类

@Component
@ConfigurationProperties(prefix = "sky.alioss")
@Data
public class AliOssProperties {

    private String endpoint;
    private String accessKeyId;
    private String accessKeySecret;
    private String bucketName;

}

配置文件中写数据

注意大写使用-来表明

  alioss:
    endpoint: oss-cn-shenzhen.aliyuncs.com
    access-key-id: LTAI5tHzX4fMjySKcCoCvYci
    access-key-secret: vPKhVa4Kux8jUP6fU4614CQ3FW0wiC
    bucket-name: cangqiongwaimaipbj

上传工具类

@Data
@AllArgsConstructor
@Slf4j
public class AliOssUtil {

    private String endpoint;
    private String accessKeyId;
    private String accessKeySecret;
    private String bucketName;

    /**
     * 文件上传
     *
     * @param bytes
     * @param objectName
     * @return
     */
    public String upload(byte[] bytes, String objectName) {

        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

        try {
            // 创建PutObject请求。
            ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(bytes));
        } catch (OSSException oe) {
            System.out.println("Caught an OSSException, which means your request made it to OSS, "
                    + "but was rejected with an error response for some reason.");
            System.out.println("Error Message:" + oe.getErrorMessage());
            System.out.println("Error Code:" + oe.getErrorCode());
            System.out.println("Request ID:" + oe.getRequestId());
            System.out.println("Host ID:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Caught an ClientException, which means the client encountered "
                    + "a serious internal problem while trying to communicate with OSS, "
                    + "such as not being able to access the network.");
            System.out.println("Error Message:" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
            }
        }

        //文件访问路径规则 https://BucketName.Endpoint/ObjectName
        StringBuilder stringBuilder = new StringBuilder("https://");
        stringBuilder
                .append(bucketName)
                .append(".")
                .append(endpoint)
                .append("/")
                .append(objectName);

        log.info("文件上传到:{}", stringBuilder.toString());

        return stringBuilder.toString();
    }
}

OSS的工具类注册对象

@Bean 注解用于在配置类中声明一个 Bean。当配置类(带有 @Configuration)被 Spring 容器加载时,其中带有 @Bean 注解的方法会被自动调用,其返回值会注册为一个 Bean,这些 Bean 然后可以在 Spring 容器中被其他部分使用。
@ConditionalOnMissingBean注解的意思:当没有这个对象的时候再去创建。

@Configuration
@Slf4j
public class OssConfiguration {
    @Bean
    @ConditionalOnMissingBean
    public AliOssUtil aliOssUtil(AliOssProperties aliOssProperties){
        log.info("开始创建阿里云文件上传工具类对象:{}",aliOssProperties);
        return new AliOssUtil(aliOssProperties.getEndpoint(),
                aliOssProperties.getAccessKeyId(),
                aliOssProperties.getAccessKeySecret(),
                aliOssProperties.getBucketName());
    }
}

接口中使用OSS

由于UUID具有固定的大小并包含时间字段,在特定算法下,随着时间推移,理论上在大约公元3400年左右会出现值的循环,所以问题不大。

@RestController
@RequestMapping("/admin/common")
@Api(tags="通用接口")
@Slf4j
public class CommonController {
    @Autowired
    private AliOssUtil aliOssUtil;
    //文件上传
    @PostMapping("/upload")
    @ApiOperation("文件上传")
    public Result<String> upload(MultipartFile file){
        log.info("文件上传:{}",file);
        try {
            String originalFilename = file.getOriginalFilename();//原始文件名
            //截取原始文件名的的后缀
            String extention = originalFilename.substring(originalFilename.lastIndexOf("."));
            //构造新文件名称
            String objectName = UUID.randomUUID().toString()+extention;
            //文件的请求路径
            String filePath = aliOssUtil.upload(file.getBytes(), objectName);
            return Result.success(filePath);
        }catch(IOException e){
            log.error("文件上传失败:{}",e);
        }
        return null;
    }
}

使用事务

启动类上面加上@EnableTransactionManagement注解

Service实现类上面加上 @Transactional 注解

HttpClient

这个是用来发送Http请求的接口

大致使用方式

导入坐标

<dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.13</version>
</dependency>

创建HttpClient类、根据请求的类型去创建GetClient类或者PostClient类

Get请求
public class HttpClientTest{
    @Test
    public void testGET() throws Exception {
        //创建httpclient对象
        CloseableHttpClient httpClient = HttpClients.createDefault();
        //创建请求对象
        HttpGet httpGet = new HttpGet("http://localhost:8080/user/shop/status");
        //发送请求
        CloseableHttpResponse response = httpClient.execute(httpGet);
        //获取服务端返回的状态码
        int statusCode = response.getStatusLine().getStatusCode();
        System.out.println("服务端返回的状态码为:"+statusCode);
        //获取服务端返回的数据
        HttpEntity entity = response.getEntity();
        String body = EntityUtils.toString(entity);
        System.out.println("服务端返回的数据为:"+body);
        //关闭资源
        response.close();
        httpClient.close();
    }
}
Post请求
public class HttpClientTest{
    @Test
    public void testGET() throws Exception {
        //创建httpclient对象
        CloseableHttpClient httpClient = HttpClients.createDefault();
        //创建请求对象
        HttpGet httpGet = new HttpGet("http://localhost:8080/user/shop/status");
        //发送请求
        CloseableHttpResponse response = httpClient.execute(httpGet);
        //获取服务端返回的状态码
        int statusCode = response.getStatusLine().getStatusCode();
        System.out.println("服务端返回的状态码为:"+statusCode);
        //获取服务端返回的数据
        HttpEntity entity = response.getEntity();
        String body = EntityUtils.toString(entity);
        System.out.println("服务端返回的数据为:"+body);
        //关闭资源
        response.close();
        httpClient.close();
    }
}

微信小程序登录流程

登录流程为小程序前端调用wx.login()函数,然后获得授权码;授权码可以获得微信用户的唯一标识openid;授权码只能使用一次;
前端获得授权码之后,传入到后端的接口中;
后端接口根据配置的微信appid和密钥,授权码使用HttpClient调用Get方法获得openid;
根据openid从数据库中查找是否为新用户,并自动注册;
返回jwt token

插入数据库的时候,返回插入对象自增的ID

useGenerateKeys=true, keyProperty = “id”

在这里插入图片描述

SpringCache

SpringCache是Spring提供的缓存框架。提供了基于注解的缓存功能。
SpringCache提供了一层抽象,底层可以切换不同的缓存实现(只需要导入不同的Jar包即可),如EHCache,Caffeine,Redis。
在这里插入图片描述

引入坐标

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

@CachePut示例

@PostMapping
@CachePut(cacheNames="userCache",key="#user.id") 
//如果使用spring Cache缓存数据,redis中实际的key为:userCache::1。user是从参数取到的。
//并且方法执行完毕之后才会缓存;创建的树形key为userCache::1,值为user;并且当前存储的key为树形结构,::代表为空的一级

//@CachePut(cacheNames="userCache",key="#result.id") //result是从返回值return取到的
//@CachePut(cacheNames="userCache",key="#p0.id")//参数一
//@CachePut(cacheNames="userCache",key="#a0.id")//参数一的另一种写法
//@CachePut(cacheNames="userCache",key="#root.args[0].id")//参数一的另一种写法
public User save(@RequestBody User user){
    userMapper.insert(user);
    return user;
}

创建的展示

在这里插入图片描述

另一个创建多级key的展示

这里创建树形的key
在这里插入图片描述

运行接口中的方法体之前先从redis中查询id,如果有就直接返回,没有再查数据库(@Cacheabel)

它底层还是使用代理的功能
在这里插入图片描述

清理缓存 @CacheEvict

执行流程为先进行接口的方法体中的逻辑,然后再执行Redis中清楚缓存的操作;
在这里插入图片描述

删除所有redis中的数据

在这里插入图片描述

用户微信下单

订单支付流程

好像流程比较固定,微信支付代码也比较繁琐,所以就不展示了。

定时任务

CRON表达式

cron表达式是一个字符串,通过cron表达式可以定义任务触发的时间。
构成规则:分为6或7个域,由空格分隔开,每个域代表一个含义。
每个域的含义分别为:秒、分钟、小时、日、月、周、年(可选)
cron表达式可以上在线Cron表达式生成器生成。CRON生成工具
在这里插入图片描述

大概流程

导入maven坐标,spring-context(已存在)
启动类添加注解@EnableScheduling开启任务调度
自定义定时任务类

@Component //实例化,自动生成bean交给容器管理
@Slf4j
public class MyTask {
    @Scheduled(cron="0/5 * * * * ?")
    public void executeTask(){
        log.info("定时任务开始执行:{}",new Date());
    }
}

0/5的意思是从0秒开始,每隔5秒触发一次。

WebSocket

前端好像很简单,就是new 一个WebSocket对象,建立ws协议的链接;
然后通过WebSocket对象设置回调函数,比如接受到消息调用自己定义的显示函数;

流程

导入maven坐标

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

前端代码

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

导入WebSocket服务端组件WebSocketServer,用于和客户端通信

@Component
@ServerEndpoint("/ws/{sid}")
public class WebSocketServer {

    //存放会话对象
    private static Map<String, Session> sessionMap = new HashMap();

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session, @PathParam("sid") String sid) {
        System.out.println("客户端:" + sid + "建立连接");
        sessionMap.put(sid, session);
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message 客户端发送过来的消息
     */
    @OnMessage
    public void onMessage(String message, @PathParam("sid") String sid) {
        System.out.println("收到来自客户端:" + sid + "的信息:" + message);
    }

    /**
     * 连接关闭调用的方法
     *
     * @param sid
     */
    @OnClose
    public void onClose(@PathParam("sid") String sid) {
        System.out.println("连接断开:" + sid);
        sessionMap.remove(sid);
    }

    /**
     * 群发
     *
     * @param message
     */
    public void sendToAllClient(String message) {
        Collection<Session> sessions = sessionMap.values();
        for (Session session : sessions) {
            try {
                //服务器向客户端发送消息
                session.getBasicRemote().sendText(message);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

}

上面为组件,有建立链接的方法,发送的方法,那么这些方法肯定是一个对象调用的,所以还要引入webSocket的配置类

/**
 * WebSocket配置类,用于注册WebSocket的Bean
 */
@Configuration
public class WebSocketConfiguration {
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }
}

来单提醒

ServiceImpl中,支付成功之后发消息;
为什么可以推消息?因为管理端登录之后,就建立websocket链接;
//通过websocket向客户端浏览器推送消息 type orderId content
Map map = new HashMap();
map.put("type",1);
map.put("orderId",this.orders.getId());
map.put("content","订单号:"+this.orders.getNumber());
String json = JSON.toJSONString(map);
webSocketServer.sendToAllClient(json);

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

MySQL系列之身份鉴别(安全)

导览 前言Q&#xff1a;如何保障MySQL数据库身份鉴别的有效性一、有效性检查 1. 用户唯一2. 启用密码验证3. 是否存在空口令用户4. 是否启用口令复杂度校验5. 是否设置口令的有效期6. 是否限制登录失败尝试次数7. 是否设置&#xff08;超过尝试次数&#xff09;锁定的最小时长…

OneNote手机/平板“更多笔记本”中有许多已经删掉或改名的,如何删除

问题描述&#xff1a; OneNote 在手机或平板上添加“更多笔记本”中&#xff0c;有许多已经删掉或改名的笔记本&#xff01;如何删除&#xff1f; OR&#xff1a;如何彻底删除OneNote中的笔记本&#xff1f; 处理做法&#xff1a; 这个列表对应365里面的【最近打开】&#…

区块链共识机制深度揭秘:从PoW到PoS,谁能主宰未来?

区块链的技术背后&#xff0c;最大的挑战之一就是如何让多个分布在全球各地的节点在没有中心化管理者的情况下达成一致&#xff0c;确保数据的一致性和安全性。这一切都依赖于区块链的核心——共识机制。共识机制不仅决定了区块链的安全性、效率和去中心化程度&#xff0c;还对…

观察者模式说明(C语言版本)

观察者模式主要是为了实现一种一对多的依赖关系&#xff0c;让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时&#xff0c;会通知所有观察者对象&#xff0c;使它们能够自动更新自己。下面使用C语言实现了一个具体的应用示例&#xff0c;有需要的可以参考…

Linux System V - 消息队列与责任链模式

概念 消息队列是一种以消息为单位的进程间通信机制&#xff0c;允许一个或多个进程向队列中发送消息&#xff0c;同时允许一个或多个进程从队列中接收消息。消息队列由内核维护&#xff0c;具有以下特点&#xff1a; 异步通信&#xff1a;发送方和接收方不需要同时运行&#x…

微信小程序客服消息接收不到微信的回调

微信小程序客服消息&#xff0c;可以接收到用户进入会话事件的回调&#xff0c;但是接收不到用户发送消息的回调接口。需要在微信公众平台&#xff0c;把转发消息给客服的开关关闭。需要把这个开关关闭&#xff0c;否则消息会直接发送给设置的客服&#xff0c;并不会走设置的回…

pycharm社区版有个window和arm64版本,到底下载哪一个?还有pycharm官网

首先pycharm官网是这一个。我是在2025年2月16日9:57进入的网站。如果网站还没有更新的话&#xff0c;那么就往下滑一下找到 community Edition,这个就是社区版了免费的。PyCharm&#xff1a;适用于数据科学和 Web 开发的 Python IDE 适用于数据科学和 Web 开发的 Python IDE&am…

风险价值VaR、CVaR与ES

风险价值VaR、CVaR与ES 一、VaR风险价值1. VaR的定义及基本概念2.VaR的主要性质3.风险价值的优缺点 二、CVaR条件风险价值与ES预期损失1.CVaR的基本概念2.性质3.ES预期损失 一、VaR风险价值 1. VaR的定义及基本概念 20年前&#xff0c;JP的大佬要每天下午收盘后的4:15在桌上看…

老游戏回顾:d2

游戏中玩家创建属于自己的角色&#xff0c;在一片片暗黑大地上奔跑、杀敌、寻宝、成长&#xff0c;最终打败统治各个大陆的黑暗势力&#xff0c;拯救游戏中的各个种族。 《暗黑破坏神II》的制作团队包括编程小组、运动物体制作小组和背景制作小组。游戏设计很大程度上是开放的&…

The Heliosphere 日球层

转自 The Heliosphere - NASA This is an artists concept of our Heliosphere as it travels through our galaxy with the major features labeled. Termination Shock: Blowing outward billions of kilometers from the Sun is the solar wind, a thin stream of electrica…

el-dropdown选中效果

vue2版本 <template><el-dropdown size"mini" command"handleCommand"><span class"el-dropdown-link">{{ selectedOption }}<i class"el-icon-arrow-down el-icon--right"></i></span><el-d…

TOGAF之架构标准规范-信息系统架构 | 应用架构

TOGAF是工业级的企业架构标准规范&#xff0c;信息系统架构阶段是由数据架构阶段以及应用架构阶段构成&#xff0c;本文主要描述信息系统架构阶段中的应用架构阶段。 如上所示&#xff0c;信息系统架构&#xff08;Information Systems Architectures&#xff09;在TOGAF标准规…

【 Avalonia UI 语言国际化 I18n】图文结合教学,保姆级教学,语言国际化就是这么简单(.Net C#)

完整项目地址 github : https://github.com/Crazy-GrowUp/AvaloniaI18nTest/tree/master gitee :https://gitee.com/jack_of_disco/avalonia-i18n-test 0.项目新建 Properties 文件夹 对应的项目配置文件里面就会增加 <Folder Include"Properties\" /> 1.项…

【IoPortDirect】- KRTS C++示例精讲(12)

IoPortDirect示例讲解 文章目录 IoPortDirect示例讲解结构说明代码说明 项目打开请查看【BaseFunction精讲】。 结构说明 IoPortDirect.cpp &#xff1a;源码 其余文件说明请查看【BaseFunction精讲】中的结构说明。 ps : 内核层中的数据、结构体需要一字节对齐&#xff0c;需…

Python——生成AIGC图像

文章目录 一、背景介绍 二、效果图展示 三、完整代码 四、分步解释 五、实用建议 1&#xff09;提示词技巧 2&#xff09;性能优化 3&#xff09;常见问题处理 4&#xff09;扩展功能建议 六、注意事项 1. 硬件要求 2. 法律合规 3. 模型安全 一、背景介绍 AIGC&a…

分巧克力(二分查找)

#include <iostream> using namespace std; int main() {// 请在此输入您的代码int n,k;cin>>n>>k;int N100005;int a[N],b[N];for(int i0;i<n;i){cin>>a[i]>>b[i];}int l1,r1e5;int ans;while(l<r){int midl(r-l)/2;long long cnt0;for(i…

嵌入式经常用到串口,如何判断串口数据接收完成?

说起通信&#xff0c;首先想到的肯定是串口&#xff0c;日常中232和485的使用比比皆是&#xff0c;数据的发送、接收是串口通信最基础的内容。这篇文章主要讨论串口接收数据的断帧操作。 空闲中断断帧 一些mcu&#xff08;如&#xff1a;stm32f103&#xff09;在出厂时就已经在…

大白话实战Gateway

网关功能 网关在分布式系统中起了什么作用?参考下图: 前端想要访问业务访问,就需要知道各个访问的地址,而业务集群服务有很多,前端需要记录非常多的服务器地址,这种情况下,我们需要对整个业务集群做一个整体屏蔽,这个时候就引入Gateway网关,它就是所有服务的请求入…

用大内存主机下载Visual Studio

用一台内存达到128G的主机下载Visual Studio 2022&#xff0c;用的是公司网络。下载速度让我吃了一惊&#xff0c;没人用网络了&#xff1f;还是网站提速了&#xff1f;以前最大只能达到5MB/秒。记录这段经历&#xff0c;是用来分析公司网络用的......

【C++语言】string 类

一、为什么要学习 string 类 C语言中&#xff0c;字符串是以 “\0” 结尾的一些字符的集合&#xff0c;为了操作方便&#xff0c;C标准库中提供了一些 str 系列的库函数&#xff0c;但是这些库函数与字符串是分离开的&#xff0c;不太符合 OOP 的思想&#xff0c;而且底层空间需…