java实际开发中的一些知识总结，持续更新

妖狐艹你老母 2023-03-13 06:15 15阅读 0赞

**一、将文件上传至阿里OSS服务器**

1.引入oss相关jar包

<dependency>
    	<groupId>com.aliyun.oss</groupId>
    	<artifactId>aliyun-sdk-oss</artifactId>
    	<version>2.8.3</version>
    </dependency>

2.编写一个连接工具类来完成对阿里云OSS存储的连接

@Lazy
    @Service
    public class OssService {
    
        @Value("${ossConfig.endpoint}")
        private String endpoint;
        @Value("${ossConfig.ak}")
        private String accessKeyId;
        @Value("${ossConfig.sk}")
        private String accessKeySecret;
        @Value("${contractGen.bucketName}")
        private String contractBucketName;
    
        private OSSClient ossClient = null;
        
        Log log = LogFactory.getLog(OssService.class);
        
        @PostConstruct
        void setup() {
            ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
        }
        
        @PreDestroy
        void teardown() {
            ossClient.shutdown();
        }
        
        
        public void putOssObject(String bucketName, String key, byte[] content) {
            ossClient.putObject(bucketName, key, new ByteArrayInputStream(content));
        }
    
        public void deleteOssObject(String bucketName, String key){
            ossClient.deleteObject(bucketName, key);
        }
    
        public URL getURL(String resultPath,Date expiration){
            return ossClient.generatePresignedUrl(contractBucketName, resultPath, expiration);
        }
        public OSSObject getOssObject(String bucketName, String key) {
            try {
                return ossClient.getObject(bucketName, key);
            } catch (Exception e) {
                log.error("getOssObject exception " + bucketName + " " + key, e);
            }
    
            return null;
        }
    
    
        public OSSClient getOssClient() {
            return ossClient;
        }
    }

这里我们来看下这部分代码，我们通过@PostConstruct注解来完成对ossClient的初始化加载。这里我们注意下，ossClient是OSS服务的核心，是OSS服务的Java客户端，它为调用者提供了一系列的方法，用于和OSS服务进行交互，只要我们完成了ossClient的初始化操作，基本上就已经成功了一大半，工具类中用到的endpoint、ak、sk、bucketName大家根据自己的OSS服务配置对应的参数即可。

1、下面简单介绍下封装的几个方法

putOssObject文件上传方法：bucketName为阿里云OSS存储对应的目录名称，key对应上传至阿里云服务器后的oss文件地址，content对应待上传文件的byte数组

deleteOssObject文件删除方法：bucketName为阿里云OSS存储对应的目录名称，key对应上传至阿里云服务器后的oss文件地址

getURL获取可访问文件全路径方法：resultPath为上传至阿里云服务器后的oss文件地址，对应putOssObject中的key字段，expiration为超时时间

2、下面展示一个具体的文件上传示例，方便大家理解方法,我这里只是简单写下文件上传的过程，一般开发中都需要将文件路径保存到数据库表，方便获取和删除对应的文件

/**
     * 上传文件
     */
    @PostMapping("/uploadIcon")
    public Map<String,Object> upload(@RequestParam("file") MultipartFile file) throws Exception {
        Map<String,Object> result = new HashMap<String,Object>();
    	if (file.isEmpty()) {
    		throw new RRException("上传文件不能为空");
    	}
    	Map<String, String> fileUploadResult = new HashMap<String, String>();
    	//将客户传入的文件上传到本地服务器
    	try {
    		fileUploadResult = FileUploadUtil.fileUpload(file, iconPath);
    	} catch (Exception e) {
    		e.printStackTrace();
    		return ApiResult.invalid("系统异常，请联系管理员!");
    	}
    	//阿里云存储oss文件地址路径,这里自己可以随便定义
    	String resultContractPath = "icon/"+UUID.randomUUID().toString()+"/"+file.getOriginalFilename();
    	byte[] resultContract = getBytesByFile(fileUploadResult.get("targetPath"));
    	ossSvc.putOssObject(contractBucketName, resultContractPath, resultContract);
    
        result.put("resCode",200);
        result.put("resMess","文件上传成功!");
    	return result;
    }
    
    //将文件转换成Byte数组
    public static byte[] getBytesByFile(String pathStr) {
    	File file = new File(pathStr);
    	try {
    		FileInputStream fis = new FileInputStream(file);
    		ByteArrayOutputStream bos = new ByteArrayOutputStream(1000);
    		byte[] b = new byte[1000];
    		int n;
    		while ((n = fis.read(b)) != -1) {
    			bos.write(b, 0, n);
    		}
    		fis.close();
    		byte[] data = bos.toByteArray();
    		bos.close();
    		return data;
    	} catch (Exception e) {
    		e.printStackTrace();
    	}
    	return null;
    }

3、FileUploadUtil将文件上传至本地服务器的代码我这里也简单贴一下，方便以后使用

public class FileUploadUtil {
    
        /**
         *
         * @param file 客户上传的文件
         * @param targetPath 服务器存放路径
         * @return
         */
        public static Map<String,String> fileUpload(MultipartFile file, String targetPath){
            Map<String,String> result = new HashMap<String,String>();
            if (file.isEmpty()) {
                result.put("code","400");
                result.put("mess","上传文件不能为空！");
                return result;
            }
            try {
                //路径
                SimpleDateFormat sf_ = new SimpleDateFormat("yyyyMMddHHmmss");
                String times = sf_.format(new Date());
                File upload = new File(targetPath + times);
                //若目标文件夹不存在，则创建
                if (!upload.exists()) {
                    upload.mkdirs();
                }
                //根据srcFile大小，准备一个字节数组
                byte[] bytes = file.getBytes();
                //通过项目路径，拼接上传路径
                Path path = Paths.get(upload.getAbsolutePath() + "/" + file.getOriginalFilename());
                //** 开始将源文件写入目标地址
                Files.write(path, bytes);
                String uuid = UUID.randomUUID().toString().replaceAll("-", "");
                // 获得文件原始名称
                String fileName = file.getOriginalFilename();
                // 获得文件后缀名称
                String suffixName = fileName.substring(fileName.lastIndexOf(".") + 1).toLowerCase();
                // 生成最新的uuid文件名称
                String newFileName = uuid + "." + suffixName;
    
                result.put("code","200");
                result.put("mess","文件存入服务器成功！");
                result.put("targetPath",path.toString());
                result.put("fileName",file.getOriginalFilename());
                return result;
            } catch(Exception e){
                result.put("code","400");
                result.put("mess","文件存入服务器异常！");
                e.printStackTrace();
                return result;
            }
        }
    }

4、通过存储路径来获取阿里云OSS真正的访问路径,参数在上面有相关说明

URL intraUrl = ossSvc.getURL(key,expiration);
    String realUrl = intraUrl.toString();

5、通过存储路径来删除阿里云OSS服务器的文件，直接传入对应的参数调用即可，这里就不写示例了

**二、递归获取多级菜单,这其实是一个很好的模板，大家可以直接套用**

//首先我们在全局定义一个集合来接收每一次递归的数组
    public List<SysMenuEntityVO> sysMenuEntityVOList;
    /**
     * 所有菜单列表
     */
    @PostMapping("/list")
    @RequiresPermissions("sys:menu:list")
    public Map<String,Object> list(@RequestBody Map<String,Object> params){
    
    //        这里是分页信息，如需用到分页，可放开这部分代码，针对mysql数据库
    //        int firstIndex=((int)params.get("page")-1)*(int)params.get("rows");
    //        params.put("firstIndex",String.valueOf(firstIndex));
    //        params.put("lastIndex",params.get("rows"));
    	try {
    		List<SysMenuEntityVO> menuList = sysMenuService.queryAllList();
    		if(menuList == null) {
    			return ApiResult.success(menuList);
    		}
    		sysMenuEntityVOList = new ArrayList<>();
    		//最终返回的结果集
    		for(SysMenuEntityVO sysMenuEntityVO:menuList){
                //这里是读取OSS真实路径并返回给前端的逻辑，需要的时候可以放开
    //			Date expiration = new Date(new Date().getTime() + 900 * 1000);
    //			if(sysMenuEntityVO.getIcon()!=null){
    //				URL intraUrl = ossSvc.getURL(sysMenuEntityVO.getIcon(),expiration);
    //				sysMenuEntityVO.setRealUrl(intraUrl.toString());
    //			}
                //我们只对一级菜单进行递归，并将他的子集存放在child集合中
    			if(sysMenuEntityVO.getParentId() ==0){
    				//通过递归获取多级菜单列表
    				getSysMenus(sysMenuEntityVO);
    			}
    		}
    		return ApiResult.success(sysMenuEntityVOList);
    	} catch (Exception e1) {
    		e1.printStackTrace();
    		return ApiResult.sysError("系统异常，请联系管理员!");
    	}
    
    }
    /**
     *递归获取菜单
     * @return
     */
    public void getSysMenus(SysMenuEntityVO sysMenuEntityVO){
    //这里是根据父节点id查询他的子节点信息
    	List<SysMenuEntityVO> sysMenuEntityVOS = sysMenuService.queryListParentId(sysMenuEntityVO.getMenuId());
    	if(sysMenuEntityVOS!=null && sysMenuEntityVOS.size()>0){
    		sysMenuEntityVO.setChildren(sysMenuEntityVOS);
    		if(sysMenuEntityVO.getParentId() ==0){
    			sysMenuEntityVOList.add(sysMenuEntityVO);
    		}
    		for(SysMenuEntityVO sysMenuEntityVO1:sysMenuEntityVOS){
                //同样，这里是获取真实图标访问路径的地址，有需要的可以放开
    //			Date expiration = new Date(new Date().getTime() + 900 * 1000);
    //			if(sysMenuEntityVO1.getIcon()!=null){
    //				URL intraUrl = ossSvc.getURL(sysMenuEntityVO1.getIcon(),expiration);
    //				sysMenuEntityVO1.setRealUrl(intraUrl.toString());
    //			}
    			getSysMenus(sysMenuEntityVO1);
    		}
    	}else if(sysMenuEntityVO.getParentId() == 0){
    		sysMenuEntityVOList.add(sysMenuEntityVO);
    	}
    }