A timeout exceeded while waiting to proceed with the request, please reduce your request rate【已解决】

àì夳堔傛蜴生んèń 2023-09-24 17:52 97阅读 0赞

#### 文章目录 ####

*  1.问题描述
 *  2.问题分析
 *  3.问题解决

## 1.问题描述 ##

![image-20230212152812038][]

## 2.问题分析 ##

报错消息：A timeout exceeded while waiting to proceed with the request, please reduce your request rate

即 等待处理请求时超时，请降低请求速率。

实际项目中报该错误后，响应了 503 ，还会导致后面对minio的操作全部超时卡住，登录到minio的控制台时也无法打开与加载桶中的文件信息，提示超时错误。

1️⃣ 首先我考虑是不是请求过于频繁的原因，于是在每次对 minio 进行操作前加了500ms休眠，然后再进行请求，但依旧报该错误。说明不是请求频繁的原因。

2️⃣ 后来在报该错误后，我将项目停止运行，发现minio控制台又可以访问了。这时候我就意识到应该是项目中对minio的操作完成后一直挤占了资源，没有关闭流，导致minio由于这些操作一直与项目保持了多个连接。

于是我抽取出项目出错位置的核心代码进行测试：

import io.minio.GetObjectArgs;
    import io.minio.MinioClient;
    
    import java.io.InputStream;
    
    
    /**
     * @author 狐狸半面添
     * @create 2023-02-12 15:06
     */
    public class MinioDemo {
        
        public static void main(String[] args) throws Exception {
        
            // Create a minioClient with the MinIO server playground, its access key and secret key.
            MinioClient minioClient =
                    MinioClient.builder()
                            // 指定连接的ip和端口
                            .endpoint("http://192.168.65.130:9000")
                            // 指定 访问秘钥（也称用户id） 和 私有秘钥（也称密码）
                            .credentials("minioadmin", "minioadmin")
                            .build();
            // 获取桶
            String bucket = "waveedu";
            // 指定获取文件的路径
            String filePath = "林屿森LIN - 小幸运【吉他】 (伴奏).mp3";
            try {
        
                
                //=======================================================================
                for (int i = 1; i < 100; i++) {
        
                    // 获取输入流
                    InputStream inputStream = minioClient.getObject(
                            GetObjectArgs
                                    .builder()
                                    .bucket(bucket)
                                    .object(filePath)
                                    .build()
                    );
                    System.out.println("第 " + i + " 次请求完毕");
                }
                //=======================================================================
                
            } catch (Exception e) {
        
                System.out.println(e.getMessage());
                e.printStackTrace();
            }
        }
    }

果不其然，在循环十二次后卡主，应该是由于前十二次循环没有关闭流，导致minio资源一直被占用，第十三次请求获取输入流超时了。

![image-20230212154729520][]

## 3.问题解决 ##

通过这个demo就说明了关闭流的重要性，我们修改代码加入对流的关闭再进行测试：

import io.minio.GetObjectArgs;
    import io.minio.MinioClient;
    
    import java.io.InputStream;
    
    
    /**
     * @author 狐狸半面添
     * @create 2023-02-12 15:06
     */
    public class MinioDemo {
        
        public static void main(String[] args) throws Exception {
        
            // Create a minioClient with the MinIO server playground, its access key and secret key.
            MinioClient minioClient =
                    MinioClient.builder()
                            // 指定连接的ip和端口
                            .endpoint("http://192.168.65.130:9000")
                            // 指定 访问秘钥（也称用户id） 和 私有秘钥（也称密码）
                            .credentials("minioadmin", "minioadmin")
                            .build();
            // 获取桶
            String bucket = "waveedu";
            // 指定获取文件的路径
            String filePath = "林屿森LIN - 小幸运【吉他】 (伴奏).mp3";
            try {
        
                
                //=======================================================================
                
                for (int i = 1; i < 100; i++) {
        
                    // 获取输入流
                    InputStream inputStream = minioClient.getObject(
                            GetObjectArgs
                                    .builder()
                                    .bucket(bucket)
                                    .object(filePath)
                                    .build()
                    );
                    // 关闭流
                	inputStream.close();
                    System.out.println("第 " + i + " 次请求完毕");
                }
                
                //=======================================================================
                
            } catch (Exception e) {
        
                System.out.println(e.getMessage());
                e.printStackTrace();
            }
        }
    }

这时候就没有问题了，能够正常全部循环完。

因此如果你遇到了这个报错，一定要仔细检查自己的代码中是否将所有与外界交互的流及时关闭，一定要自己去手动关闭，而不是等它自己关闭！！！

> 当我们用了虚拟机以外的资源，比如端口、显存、文件的时候（访问本地资源），超出了虚拟机能够释放资源的界限，这时候虚拟机并不能通过垃圾回收机制对你占用的资源进行释放，如果在没有关闭的情况下第一次运行程序是不会发生问题的，但是随着资源占有量逐渐增多而你又不自己进行close释放资源的话，垃圾只会越积越多，导致系统无法存储其他的资源，甚至会导致系统崩溃。如果你再次对未关闭流的文件进行读写，编译就会报错，告诉你这个文件被占用。

[image-20230212152812038]: https://img-blog.csdnimg.cn/img_convert/7c1163d8b629ea46be199e7b6ec43b05.png
[image-20230212154729520]: https://img-blog.csdnimg.cn/img_convert/38b3b5f64e705df5f8b3e73fd9019423.png