PriorityQueue的使用场景

Queue<Integer> queue1 = new PriorityQueue<>();

Queue<Integer> queue2 = new PriorityQueue<>(Comparator.comparingInt(o -> o));

Queue<Integer> queue3 = new PriorityQueue<>(Comparator.comparingInt(o -> -o));

Java中的PriorityQueue常用于实现小顶堆、大顶堆。由上述代码可见,通常有默认无参构造函数、传入Comparator对象等方式的实现。


困惑

从构造函数层面,完全不清楚默认构造函数的排序规则,也完全不明白Comparator实现的comparingInt方法对应的排序规则

根据网上绝大多数文章的描述,都没有解释或者只是说明了对应的排序规则,但是不知道为什么是对应升序或降序。通过阅读源码,才得到准确的认知。

阅读全文 »

概念

图床是一个网络术语,指的是一种用于存储和托管图片的在线服务。用户可以上传图片文件,并获得一个唯一的链接或嵌入代码,方便在网页、博客、论坛等地方分享和展示这些图片。


七牛云

将七牛云作为图床,实际上是使用了七牛云的对象存储服务(OSS)

新建存储空间

image-20220227224537701

image-20220227224443813

获取密钥(AK、SK)

image-20250124095003483

通过Java进行文件上传

官方开发文档:Java SDK_SDK 下载_对象存储 - 七牛开发者中心

首先添加依赖:

<dependency>
    <groupId>com.qiniu</groupId>
    <artifactId>qiniu-java-sdk</artifactId>
    <version>7.17.0</version>
</dependency>

注意:

7.17.0版本,qiniu-java-sdk自身依赖的gson的scope为runtime,在编译 main 目录下的 Java 类时,编译器会无法找到 gson需要显式添加gson的依赖

<dependency>
    <groupId>com.google.code.gson</groupId>
    <artifactId>gson</artifactId>
    <version>2.11.0</version>
</dependency>

将密钥和目标桶 添加到配置文件中

qiniu:
  accessKey: "实际的ak"
  secretKey: "实际的sk"
  bucket: "目标存储空间名称"

编写文件上传测试代码

import com.qiniu.common.QiniuException;
import com.qiniu.http.Response;
import com.qiniu.storage.Configuration;
import com.qiniu.storage.Region;
import com.qiniu.storage.UploadManager;
import com.qiniu.storage.model.DefaultPutRet;
import com.qiniu.util.Auth;
import org.springframework.beans.factory.annotation.Value;

@SpringBootTest
@Slf4j
public class OSSTest {
    @Value("${qiniu.accessKey}")
    private String accessKey;

    @Value("${qiniu.secretKey}")
    private String secretKey;

    @Value("${qiniu.bucket}")
    private String bucket;


    @Test
    public void testOSS() {
        // 构造一个带指定 Region 对象的配置类
        Configuration cfg = new Configuration(Region.autoRegion());
        cfg.resumableUploadAPIVersion = Configuration.ResumableUploadAPIVersion.V2;// 指定分片上传版本

        UploadManager uploadManager = new UploadManager(cfg);

        // 默认不指定key的情况下,以文件内容的hash值作为文件名
        String key = "hunter.jpg";

        Auth auth = Auth.create(accessKey, secretKey);
        String upToken = auth.uploadToken(bucket);

        try {
            InputStream inputStream = new FileInputStream("C:\\Users\\Hunter\\Pictures\\Saved " +
                    "Pictures\\Rukawa-Sara-Sakuragi-Hanamichi-Slam-Dunk-slum-dunk.jpg");
            Response response = uploadManager.put(inputStream, key, upToken, null, null);
            // 解析上传成功的结果
            DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
            System.out.println(putRet.key);
            System.out.println(putRet.hash);
        } catch (QiniuException ex) {
            ex.printStackTrace();
            if (ex.response != null) {
                System.err.println(ex.response);

                try {
                    String body = ex.response.toString();
                    System.err.println(body);
                } catch (Exception ignored) {
                }
            }
        } catch (FileNotFoundException ex) {
            ex.printStackTrace();
            System.err.println("file not found");
        }
    }
}

实际应用代码

实际应用,需要获取图片上传至图床后的访问链接

七牛云提供了临时的外链域名

image-20250124154458026
qiniu:
  accessKey: "实际的ak"
  secretKey: "实际的sk"
  bucket: "目标存储空间名称"
  domain: "http://外链域名/"

  • 为了便于后期管理上传的图片,当前的 年份/月份/日期 + 随机数 + 文件类型的形式作为文件名,实际会/为分隔,按多级目录进行存储
  • 上传文件后,返回文件访问链接${qiniu.domain} + 文件名
@Service
@Slf4j
public class UploadServiceImpl implements UploadService {
    @Value("${qiniu.accessKey}")
    private String accessKey;

    @Value("${qiniu.secretKey}")
    private String secretKey;

    @Value("${qiniu.bucket}")
    private String bucket;

    /**
     * 域名
     */
    @Value("${qiniu.domain}")
    private String domain;

    @Override
    public ResponseResult<String> uploadImg(MultipartFile img) throws IOException {
        // 判断文件类型
        String originalFilename = img.getOriginalFilename();
        assert originalFilename != null;

        String fileType = originalFilename.substring(originalFilename.lastIndexOf("."));

        if (!".jpg".equals(fileType) && !".jpeg".equals(fileType)
                && !".png".equals(fileType)) {
            throw new GlobalException(HttpCodeEnum.FILE_TYPE_ERROR);
        }

        // “当前的 年份/月份/日期 + 随机数 + 文件类型”作为文件名
        String fileName =
                LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd/"))
                        + UUID.randomUUID()
                        + fileType;

        // 上传文件到七牛云,返回链接地址
        String url = uploadToQiniu(img, fileName);
        return ResponseResult.success(url);
    }

    /**
     * 上传文件到七牛云
     *
     * @param img      上传的文件
     * @param fileName 文件名
     * @return 文件存储的地址
     */
    private String uploadToQiniu(MultipartFile img, String fileName) throws IOException {
        // 构造一个带指定 Region 对象的配置类
        Configuration cfg = new Configuration(Region.autoRegion());
        // 指定分片上传版本
        cfg.resumableUploadAPIVersion = Configuration.ResumableUploadAPIVersion.V2;

        Auth auth = Auth.create(accessKey, secretKey);
        String upToken = auth.uploadToken(bucket);

        try {
            UploadManager uploadManager = new UploadManager(cfg);
            InputStream inputStream = img.getInputStream();
            // 默认不指定key的情况下,以文件内容的hash值作为文件名
            Response response = uploadManager.put(inputStream, fileName, upToken, null, null);
            // 解析上传成功的结果
            DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
            log.info("文件成功上传到七牛云,key: {}, hash: {}", putRet.key, putRet.hash);
            return domain + putRet.key;
        } catch (QiniuException ex) {
            log.error("上传文件到七牛云失败: {}", ex.getMessage(), ex);
            throw ex;
        } catch (FileNotFoundException ex) {
            log.error("文件不存在: {}", ex.getMessage(), ex);
            throw ex;
        }
    }
}

什么是Redis

Redis是基于C语言开发的NoSQL数据库,它是一种存储KV键值对数据的内存数据库,因此读写速度非常快,被广泛应用于分布式缓存方向。

Redis内置了多种数据类型实现:

  • 5种基础数据类型
    1. String
    2. List
    3. Set
    4. Hash
    5. Zset (有序集合)
  • 3种特殊数据类型
    1. HyperLogLog(基数统计)
    2. Bitmap(位图)
    3. Geospatial (地理位置)

Reids还支持事务、持久化(将内存数据保存在磁盘中,重启时可以再次加载使用)、Lua脚本、多种开箱即用的集群方案(Redis Sentinel、Redis Cluster)。

阅读全文 »

简介

Spring Boot让您可以轻松地创建独立的、生产级别的Spring应用程序,并“直接运行”这些应用程序。SpringBoot为大量的第三方库添加了支持,能够做到开箱即用,简化大量繁琐配置,用最少的配置快速构建你想要的项目。

SpringBoot功能有:

  • 能够创建独立的Spring应用程序
  • 内嵌Tomcat、Jetty或Undertow服务器(无需单独部署WAR包,打包成Jar本身就是一个可以运行的应用程序)
  • 提供一站式的“starter”依赖项,以简化Maven配置(需要整合什么框架,直接导对应框架的starter依赖)
  • 尽可能自动配置Spring和第三方库(除非特殊情况,否则几乎不需要进行任何配置)
  • 提供生产环境下相关功能,如指标、运行状况检查和外部化配置
  • 没有任何代码生成,也不需要任何XML配置
阅读全文 »

概述

jmap命令是一个可以输出所有内存中对象的工具,甚至可以将JVM中的heap,以二进制输出成文本。打印出某个java进程(使用pid)内存内的所有对象的情况(如:产生哪些对象,及其数量)。

阅读全文 »

OOM的原因

一次性申请过多的对象

更改申请对象的数量。(分页)


内存资源耗尽 未释放

找到未释放的对象进行释放。


本身资源不够

查看堆信息:

JDK 8: jmap -heap [pid]

JDK 11往后:jhsdb jmap --heap --pid [pid]

image-20231024141116327
阅读全文 »

简介

消息队列提供一个异步通信机制,消息的发送者不必一直等待到消息被成功处理才返回,而是立即返回。消息中间件负责处理网络通信,如果网络连接不可用,消息被暂存于队列当中,当网络畅通时,将消息转发给相应的应用程序或者服务。

如果在商品服务和订单服务之间使用消息中间件,既可以提高并发量,又降低服务之间的耦合度。

RabbitMQ是一个开源的消息代理的队列服务器,用来通过普通协议在完全不同的应用之间共享数据

阅读全文 »

背景

以往的 Java Web 开发中,异常处理通常是通过 try-catch 语句块来实现。这种方法在应用程序规模较小的情况下还可以,但是在大型应用中,可能存在大量的代码重复和不一致问题。此外,在抛出未处理的异常时,用户会看到系统生成的默认错误页面,用户体验差。

阅读全文 »
0%