SpringBoot整合Minio的详细步骤

小伙伴们好,欢迎关注,一起学习,无限进步

minio 是对象存储服务。它基于 Apache License 开源协议,兼容 Amazon S3 云存储接口。适合存储非结构化数据,如图片,音频,视频,日志等。对象文件最大可以达到 5TB。

优点有高性能,可扩展,操作简单,有图形化操作界面,读写性能优异等。官网

minio 部署可参考这篇:Minio 详细安装部署步骤

SpringBoot 快速整合 minio

1、添加 Maven 依赖

pom.xml 文件中添加MinIO客户端依赖项

<dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.2.2</version>
</dependency>
<!-- 如果 minio 版本是8.3.4以上 okhttp 一定要大于 4.8.1 版本 -->
<!--        <dependency>-->
<!--            <groupId>com.squareup.okhttp3</groupId>-->
<!--            <artifactId>okhttp</artifactId>-->
<!--            <version>4.8.2</version>-->
<!--        </dependency>--><!-- 还用到了 fastjson -->
<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.78</version>
</dependency>

2、配置MinIO连接信息

application.propertiesapplication.yml 文件中配置MinIO的连接信息,包括服务器地址、端口、凭据等信息

# Minio 配置
minio.endpoint=127.0.0.1:9000 #对象存储服务的URL
minio.accessKey=admin #Access key账户 写账号也可以
minio.secretKey=admin #Secret key密码
minio.bucketName=test # 桶名称
# 过期时间
minio.expire=7200
# Minio 配置
minio:endpoint:  127.0.0.1:9000 #对象存储服务的URLaccessKey: admin #Access key账户 写账号也可以secretKey: admin #Secret key密码bucketName: test # 桶名称expire: 7200 # 过期时间

3、创建 MinIO 客户端 Bean

在 SpringBoot 应用的配置类中创建一个 MinIO客户端的 Bean,以便在应用中使用 MinIO 服务

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;/*** minio 配置属性*/
@Data
@Component
@ConfigurationProperties(prefix = "minio")
public class MinioProperties {/*** Minio 连接地址*/private String endpoint;/*** accessKey 或 账号*/private String accessKey;/*** secretKey 或 密码*/private String secretKey;/*** 桶名称*/private String bucketName;/*** 默认是秒 地址过期时间,设置默认值7200秒*/private int expire = 7200;}

4、异常枚举类

/*** 异常枚举类*/
public enum ExceptionEnums {FILE_NAME_NOT_NULL("0001", "文件名不能为空"),BUCKET_NAME_NOT_NULL("0002", "桶名称不能为空"),FILE_NOT_EXIST("0003", "文件不存在"),BUCKET_NOT_EXIST("0004", "桶不存在"),BUCKET_NAME_NOT_EXIST("0005", "桶不存在,需要先创建桶在创建文件夹");//枚举类如果写方法的话,此处需要写分号private String code;private String msg;ExceptionEnums(String ecode, String emsg) {this.code = ecode;this.msg = emsg;}public String getCode() {return code;}public String getMsg() {return msg;}public static ExceptionEnums statOf(String code) {for (ExceptionEnums state : values())if (state.getCode().equals(code))return state;return null;}
}

5、全局异常

import org.springframework.http.HttpStatus;/*** 异常*/
public class GeneralException extends RuntimeException {private Integer errorCode;public GeneralException() {}public GeneralException(Throwable throwable) {super(throwable);}public GeneralException(String msg) {super(msg);this.errorCode = HttpStatus.INTERNAL_SERVER_ERROR.value();}public GeneralException(Integer errorCode, String msg) {super(msg);this.errorCode = errorCode;}public Integer getErrorCode() {return this.errorCode;}public void setErrorCode(Integer errorCode) {this.errorCode = errorCode;}
}

6、minio 工具类

工具类包含创建 bucket,获取全部 bucket,获取 bucket 文件名和大小列表,文件上传,获取上传文件的完整路径,创建文件夹或目录,判断 bucket 是否存在,判断文件是否存在,文件下载,删除文件,批量删除文件方法

import com.alibaba.fastjson.JSON;
import io.minio.*;
import io.minio.errors.*;
import io.minio.http.Method;
import io.minio.messages.Bucket;
import io.minio.messages.DeleteError;
import io.minio.messages.DeleteObject;
import io.minio.messages.Item;
import lombok.extern.slf4j.Slf4j;
import org.apache.tomcat.util.http.fileupload.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URLEncoder;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.text.DecimalFormat;
import java.util.*;/*** Minio 工具类*/
@Component
@Slf4j
public class MinioUtils {@Autowiredprivate MinioClient minioClient;@Autowiredprivate MinioProperties minioProperties;/*** 初始化Bucket*/private void createBucket(String bucketName) {try {// 判断 BucketName 是否存在if (bucketExists(bucketName)) {minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());}} catch (Exception e) {e.printStackTrace();}}/*** 验证bucketName是否存在** @return boolean true:存在*/public boolean bucketExists(String bucketName) {if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}boolean flag = true;try {flag = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());} catch (Exception e) {e.printStackTrace();}return flag;}/*** 获取全部bucket* <p>*/public List<String> getAllBuckets() {List<String> list = null;try {final List<Bucket> buckets = minioClient.listBuckets();list = new ArrayList<>(buckets.size());for (Bucket bucket : buckets) {list.add(bucket.name());}} catch (Exception e) {e.printStackTrace();}return list;}/*** 根据bucketName获取信息** @param bucketName bucket名称* @return*/public String getBucket(String bucketName) throws Exception {final Optional<Bucket> first = minioClient.listBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst();String name = null;if (first.isPresent()) {name = first.get().name();}return name;}/*** 获取桶中文件名和大小列表** @param bucketName bucket名称* @param recursive  查询是否递归* @return*/public List<Object> getFileList(String bucketName, boolean recursive) {if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}List<Object> items = new ArrayList<>();try {Iterable<Result<Item>> myObjects = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix("/2022-08-03/4674a894-abaf-48cb-9ea9-40a4e8560af9/Desktop").recursive(recursive).build());Iterator<Result<Item>> iterator = myObjects.iterator();String format = "{'fileName':'%s','fileSize':'%s'}";for (Result<Item> myObject : myObjects) {System.out.println(myObject.get().objectName());}while (iterator.hasNext()) {Item item = iterator.next().get();items.add(JSON.parse(String.format(format, item.objectName(), formatFileSize(item.size()))));
//                items.add(JSON.parse(String.format(format, "/".concat("test").concat("/").concat(item.objectName()), formatFileSize(item.size()))));}} catch (Exception e) {e.printStackTrace();log.info(e.getMessage());}items.remove(0);return items;}/*** 文件上传** @param file* @return*/public Map<String, Object> uploadFile(String bucketName, MultipartFile[] file) {if (file == null || file.length == 0) {throw new GeneralException(ExceptionEnums.FILE_NAME_NOT_NULL.getMsg());}if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}List<String> orgfileNameList = new ArrayList<>(file.length);for (MultipartFile multipartFile : file) {String orgfileName = multipartFile.getOriginalFilename();orgfileNameList.add(orgfileName);try {//文件上传InputStream in = multipartFile.getInputStream();minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(orgfileName).stream(in, multipartFile.getSize(), -1).contentType(multipartFile.getContentType()).build());in.close();} catch (Exception e) {e.printStackTrace();log.error(e.getMessage());}}Map<String, Object> data = new HashMap<>();data.put("bucketName", bucketName);data.put("fileName", orgfileNameList);return data;}/*** 获取上传文件的完整路径** @param bucketName 桶名称* @param fileName   文件名* @param expire     地址过期时间* @return*/public String getPresignedObjectUrl(String bucketName, String fileName, Integer expire) {if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}if (StringUtils.isEmpty(fileName)) {throw new GeneralException(ExceptionEnums.FILE_NAME_NOT_NULL.getMsg());}expire = Objects.isNull(expire) ? minioProperties.getExpire() : expire;// 验证桶是否存在在final boolean validationBucket = bucketExists(bucketName);if (!validationBucket) {throw new GeneralException(ExceptionEnums.BUCKET_NOT_EXIST.getMsg());}// 验证文件是否存在final boolean validationFileName = doFileNameExist(bucketName, fileName);if (!validationFileName) {throw new GeneralException(ExceptionEnums.FILE_NOT_EXIST.getMsg());}String url = null;try {// 获取桶和文件的完整路径url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().bucket(bucketName).object(fileName).method(Method.GET).expiry(expire).build());} catch (MinioException e) {log.error("Error occurred: " + e);} catch (Exception e) {e.printStackTrace();}return url;}/*** 创建文件夹或目录** @param bucketName 存储桶* @param objectName 目录路径*/public Map<String, String> putDirObject(String bucketName, String objectName) throws IOException, InvalidKeyException, InvalidResponseException, InsufficientDataException, NoSuchAlgorithmException, ServerException, InternalException, XmlParserException, ErrorResponseException {// 判断桶是否存在if (!bucketExists(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_EXIST.getMsg());}final ObjectWriteResponse response = minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).stream(new ByteArrayInputStream(new byte[]{}), 0, -1).build());Map<String, String> map = new HashMap<>();map.put("etag", response.etag());map.put("versionId", response.versionId());return map;}/*** 判断桶是否存在** @param bucketName 存储桶* @param objectName 文件夹名称(去掉/)* @return true:存在*/public boolean doFolderExist(String bucketName, String objectName) {boolean exist = false;try {Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(objectName).recursive(false).build());for (Result<Item> result : results) {Item item = result.get();if (item.isDir()) {exist = true;}}} catch (Exception e) {exist = false;}return exist;}/*** 判断文件是否存在** @param fileName 对象* @return true:存在*/public boolean doFileNameExist(String bucketName, String fileName) {if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}if (StringUtils.isEmpty(fileName)) {throw new GeneralException(ExceptionEnums.FILE_NAME_NOT_NULL.getMsg());}boolean exist = true;try {minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(fileName).build());} catch (Exception e) {exist = false;}return exist;}/*** 文件下载** @param response* @param fileName*/public void downloadFile(HttpServletResponse response, String bucketName, String fileName) {if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}if (StringUtils.isEmpty(fileName)) {throw new GeneralException(ExceptionEnums.FILE_NAME_NOT_NULL.getMsg());}// 判断文件是否存在final boolean flag = doFileNameExist(bucketName, fileName);if (!flag) {throw new GeneralException(ExceptionEnums.FILE_NOT_EXIST.getMsg());}InputStream in = null;try {// 获取对象信息StatObjectResponse stat = minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(fileName).build());response.setContentType(stat.contentType());response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));//文件下载in = minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(fileName).build());IOUtils.copy(in, response.getOutputStream());} catch (Exception e) {log.error(e.getMessage());} finally {if (in != null) {try {in.close();} catch (IOException e) {log.error(e.getMessage());}}}}/*** 删除文件** @param bucketName bucket名称* @param fileName   文件名称*                   说明:当前方法不能真正删除,需要验证*/public void deleteFile(String bucketName, String fileName) {if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}if (StringUtils.isEmpty(fileName)) {throw new GeneralException(ExceptionEnums.FILE_NAME_NOT_NULL.getMsg());}try {minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(fileName).build());} catch (Exception e) {log.error(e.getMessage());e.printStackTrace();}}/*** 批量文件删除** @param bucketName bucket名称* @param fileNames  文件名*/public void deleteBatchFile(String bucketName, List<String> fileNames) {if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}if (CollectionUtils.isEmpty(fileNames)) {throw new GeneralException(ExceptionEnums.FILE_NAME_NOT_NULL.getMsg());}try {List<DeleteObject> objects = new LinkedList<>();for (String fileName : fileNames) {objects.add(new DeleteObject(fileName));}Iterable<Result<DeleteError>> results =minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(objects).build());for (Result<DeleteError> result : results) {DeleteError error = result.get();log.error("Error occurred: " + error);}} catch (Exception e) {e.printStackTrace();log.error("批量删除失败!error:{}", e);}}/*** 文件大小** @param fileS* @return*/private static String formatFileSize(long fileS) {DecimalFormat df = new DecimalFormat("#.00");String fileSizeString = "";String wrongSize = "0B";if (fileS == 0) {return wrongSize;}if (fileS < 1024) {fileSizeString = df.format((double) fileS) + " B";} else if (fileS < 1048576) {fileSizeString = df.format((double) fileS / 1024) + " KB";} else if (fileS < 1073741824) {fileSizeString = df.format((double) fileS / 1048576) + " MB";} else {fileSizeString = df.format((double) fileS / 1073741824) + " GB";}return fileSizeString;}
}

7、文件调用接口

上传文件,获取上传文件完整路径,文件下载,文件删除,批量删除

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;import javax.servlet.http.HttpServletResponse;
import java.util.List;
import java.util.Map;@RestController
public class MinioController {@Autowiredprivate MinioUtils minioUtils;/*** 获取桶中文件名和大小列表** @return*/@GetMapping("/getFileList")public List<Object> getFileList() {return minioUtils.getFileList("test", true);}/*** 判断文件是否存在** @param bucketName* @param fileName* @return*/@GetMapping("/doFileNameExist")public boolean doFileNameExist(String bucketName, String fileName) {return minioUtils.doFolderExist(bucketName, fileName);}/*** 上传文件** @param file* @return*/@PostMapping("/uploadFiles")public Map<String, Object> uploadFiles(String bucketName, @RequestParam(name = "file", required = false) MultipartFile[] file) {if (file == null || file.length == 0) {throw new GeneralException(ExceptionEnums.FILE_NAME_NOT_NULL.getMsg());}if (StringUtils.isEmpty(bucketName)) {throw new GeneralException(ExceptionEnums.BUCKET_NAME_NOT_NULL.getMsg());}return minioUtils.uploadFile(bucketName, file);}/*** 获取上传文件的完整浏览路径** @param filename* @return*/@GetMapping("/getPresignedObjectUrl")public String getPresignedObjectUrl(@RequestParam(name = "filename") String filename) {return minioUtils.getPresignedObjectUrl("test", filename, null);}/*** 文件下载** @param response* @param fileName*/@GetMapping("/downloadFile")public void downloadFile(HttpServletResponse response, @RequestParam("fileName") String fileName) {minioUtils.downloadFile(response, "test", fileName);}/*** 删除单个文件** @param fileName 完整路径(不包含bucket)*/@DeleteMapping("/deleteFile")public void deleteFile(String bucketName, String fileName) {minioUtils.deleteFile(bucketName, fileName);}/*** 批量删除文件** @param fileNames 完整路径(不包含bucket)*/@DeleteMapping("/deleteBatchFile")public void deleteBatchFile(String bucketName, @RequestParam("fileNames") List<String> fileNames) {minioUtils.deleteBatchFile(bucketName, fileNames);}
}

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

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

相关文章

方法的使用

1.什么是方法(method) 在java中方法就是一个代码片段.。几乎相当于c语言的函数。 2.方法定义 方法跟函数是几乎一样的。所以语法是大差不差的。就多了一点东西。之前我们在c语言里已经很详细讲过了函数。这里就简便的讲一下。 相比c语言函数多了个修饰符 。 现在看下其注意…

【MATLAB第99期】#源码分享 | 基于MATLAB的SHEPard模型多输入单输出回归预测模型

【MATLAB第99期】#源码分享 | 基于MATLAB的SHEPard模型多输入单输出回归预测模型 Shepard模型(简称SP模型)就是一种直观的、可操作的相似预测法&#xff0c;常用于插值。相似预测法基本原理按照相似原因产生相似结果的原则&#xff0c;从历史样本中集中找出与现在的最相似的一…

OSPF收发报文实验简述

1、OSPF采用组播形式收发报文&#xff0c;这样可以减少对其它不运行OSPF路由器的影响。 通过wireshark软件对r2 e0/0/0 端口进行数据抓包&#xff0c;发现224.0.0.5为组播地址&#xff0c;如下图

每日OJ题_牛客WY28 跳石板(动态规划)

目录 牛客WY28 跳石板 解析代码 牛客WY28 跳石板 跳石板_牛客题霸_牛客网 解析代码 #include <iostream> #include <vector> #include <climits> #include <cmath> using namespace std;void get_div_num(int n, vector<int>& arr) {for…

个人博客系列-后端项目-RBAC角色管理(6)

修改上一篇文章创建的用户表 ## 用户表 from django.contrib.auth.hashers import make_password, check_password from django.contrib.auth.models import AbstractBaseUserclass User(AbstractBaseUser):username models.CharField(max_length255, uniqueTrue, verbose_na…

React-useEffect

1.概念 说明&#xff1a;用于在React组件中创建不是由事件引起而是由渲染本身引起的操作&#xff0c;比如发送 A列AX请求&#xff0c;更改DOM等。 2.案例 // useEffect用于组件不是由事件引起的而是由渲染本身引起的操作&#xff0c;如ajax,更改Dom等。 import { useEffect,…

数学建模-敏感度分析(美赛)

从多个不确定性因素中逐一找出对投资项目经济效益指标有重要影响的敏感性因素&#xff0c;并分析、测算其对项目经济效益指标的影响程度和敏感性程度&#xff0c;进而判断项目承受风险的能力。若某参数的小幅度变化能导致经济效益指标的较大变化&#xff0c;则称此参数为敏感性…

Spring Boot整合MyBatis Plus配置多数据源

Spring Boot 专栏&#xff1a;https://blog.csdn.net/dkbnull/category_9278145.html Spring Cloud 专栏&#xff1a;https://blog.csdn.net/dkbnull/category_9287932.html GitHub&#xff1a;https://github.com/dkbnull/SpringBootDemo Gitee&#xff1a;https://gitee.com/…

macOS系统浏览器设置“检查元素“功能

目录 第一步 点击Safari浏览器&#xff0c;选择"设置" 第二步 选择高级&#xff0c;参照下图勾选"在菜单栏中显示开发菜单" 类似于windows系统的f12快捷键。Mac默认是不支持f12的&#xff0c;右键也没有"检查元素"&#xff0c;如果需要使用&am…

探索Redis CLI:功能强大的Redis命令行工具及其应用场景

Redis CLI&#xff08;Command Line Interface&#xff09;是一种与Redis服务器进行交互的命令行工具&#xff0c;提供了丰富的功能和灵活的命令&#xff0c;方便用户执行各种数据操作和管理任务。以下是Redis CLI的一些常见用法和功能&#xff1a; 1. 连接到Redis服务器 要连…

《vtk9 book》 官方web版 第3章 - 计算机图形基础 (3 / 5)

3.8 演员几何 我们已经看到了光照属性如何控制演员的外观&#xff0c;以及相机如何结合变换矩阵将演员投影到图像平面上。剩下的是定义演员的几何形状&#xff0c;以及如何将其定位在世界坐标系中。 建模 计算机图形学研究中的一个重要主题是建模或表示物体的几何形状。…

搭建Android Studio开发环境

一、JDK 1、下载 2、安装 双击进行安装&#xff0c;修改安装路径为&#xff1a;D:\Java\jdk-17.0.4.1即可&#xff0c;安装完成后目录如下&#xff1a; 配置环境变量 3、测试 WinR&#xff0c;输入cmd&#xff0c;按Enter后&#xff0c;键入&#xff1a;java --version&…

网络安全: Kali Linux 使用 MSF 漏洞利用

目录 一、实验 1.环境 2.POC验证与nmap扫描&#xff08; ms15-034 &#xff09; 3. Kali Linux 使用 MSF 漏洞利用&#xff08; ms15-034 &#xff09; 4.Windows server 安全加固 5.Windows server 安装补丁 6. Kali Linux 使用 MSF 漏洞验证 &#xff08; ms17-010&…

代码随想录算法训练营第23天|669.修剪二叉搜索树、108.将有序数组转换为二叉搜索树、538.把二叉搜索树转换为累加树、总结篇

目录 一、力扣669.修剪二叉搜索树1.1 题目1.2 思路1.3 代码 二、力扣108.将有序数组转换为二叉搜索树2.1 题目2.2 思路2.3 代码2.4 总结 三、力扣538.把二叉搜索树转换为累加树3.1 题目3.2 思路3.3 代码3.4 总结 一、力扣669.修剪二叉搜索树 1.1 题目 1.2 思路 本题递归代码分…

day14_用户前台项目环境搭建(首页接口开发,分类接口开发,网关服务搭建,Redis缓存,Spring Cache)

文章目录 1 尚品甄选H5介绍1.1 业务功能介绍1.2 系统架构1.3 前端H5开发说明 2 搭建项目环境2.1 项目结构说明2.2 模块依赖说明2.3 环境说明2.4 项目模块创建2.4.1 spzx-parent2.4.2 spzx-service2.4.43 service-product 2.5 导入接口文档 3 首页接口开发3.1 需求分析3.3 接口开…

VScode格式化快捷键

vscode格式化代码快捷键 如何使用快捷键格式化代码。使用Java的格式去设置&#xff0c;发现不起作用。 在这里记录一下&#xff1a; 在Windows中&#xff0c;vscode格式化代码快捷键是“ShiftAltF”&#xff1b; 在Mac中&#xff0c;vscode格式化代码快捷键是“ShiftOption…

理解JavaScript中的WeakSet和WeakMap

&#x1f90d; 前端开发工程师、技术日更博主、已过CET6 &#x1f368; 阿珊和她的猫_CSDN博客专家、23年度博客之星前端领域TOP1 &#x1f560; 牛客高级专题作者、打造专栏《前端面试必备》 、《2024面试高频手撕题》 &#x1f35a; 蓝桥云课签约作者、上架课程《Vue.js 和 E…

RabbitMQ事务机制和确认机制

文章目录 生产者&#xff1a;RabbitMQ提供transaction和confirm模式来确保生产者不丢消息RabbitMQ 事务机制RabbitMQ确认机制 生产者&#xff1a;RabbitMQ提供transaction和confirm模式来确保生产者不丢消息 ● 通过事务实现 ● 通过发送方确认机制(publisher confirm)实现 1.…

N32L40x基于串口IAP实现(含升级工具)

bootloader实现要点 bootloader 设计要点 1.分配Flash空间,一部分用于bootloader 一部分用于 APP ,这里bootloader分配了7K空间,APP分配了121K空间 2.需要准备一个通讯接口,可以是串口,也可以时can等 3.准备mcu的内部flash驱动,可以实现连续读写的函数,flash擦除在写函…

数据结构-栈-表达式运算

文章目录 表达式运算实现&#xff1a;1.栈实现2.中缀表达式转后缀表达式计算 表达式运算实现&#xff1a; 1.栈实现 public class ExpressCalc {public static void main(String[] args) {/*使用栈实现一个0-9整数带括号的表达式计算处理步骤&#xff1a;1.创建两个栈&#x…