From 5d1d54e83546ba9fc85c69b32287883d04f4a475 Mon Sep 17 00:00:00 2001 From: liusheng <337615773@qq.com> Date: 星期五, 01 十一月 2024 18:56:13 +0800 Subject: [PATCH] 代码提交 --- ruoyi-admin/src/main/java/com/ruoyi/web/test/MQTest.java | 72 ++++++++++++++++++++++++++--------- 1 files changed, 53 insertions(+), 19 deletions(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/test/MQTest.java b/ruoyi-admin/src/main/java/com/ruoyi/web/test/MQTest.java index 0bc2d96..1f15e17 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/test/MQTest.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/test/MQTest.java @@ -1,31 +1,65 @@ package com.ruoyi.web.test; -import com.ruoyi.web.task.PhoneTask; +import com.ruoyi.common.config.RuoYiConfig; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.utils.file.FileUploadUtils; +import com.ruoyi.common.utils.file.FileUtils; +import io.swagger.models.auth.In; import org.junit.Test; -import org.springframework.amqp.rabbit.core.RabbitTemplate; -import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.mock.web.MockMultipartFile; +import org.springframework.web.multipart.MultipartFile; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; +import java.io.*; +import java.nio.file.Files; +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.CompletableFuture; + +import static org.eclipse.jetty.http.HttpGenerator.CHUNK_SIZE; //@SpringBootTest //@RunWith(SpringRunner.class) public class MQTest { - @Autowired - private RabbitTemplate rabbitTemplate; @Test - public void testSend() { - String str = "absdf"; - String c = Character.toUpperCase(str.charAt(0)) + str.substring(1); - System.out.println(c); - "鎮ㄥソ锛屾垜鏄禉浜屽尰闄㈠紶鍖荤敓锛屾偍鏄�${name}鍚楋紵杩樻槸瀹跺睘?".replaceAll("$$*variable", "AA"); -// Pattern pattern = Pattern.compile("^(?!.*(濂絴澶ソ)).*$"); -// Matcher matcher = pattern.matcher("鐫$湢涓嶅ソ"); -// System.out.println(matcher.matches()); - // 鍒涘缓鍥哄畾澶у皬鐨勭嚎绋嬫睜 -// ExecutorService executorService = Executors.newFixedThreadPool(10); -// -// executorService.submit(new PhoneTask()); + public void testSend22() { +// uploadFileInChunks(new File("C:\\Users\\86176\\Desktop\\19-鍥捐Вes鍐呴儴鍩轰簬_version涔愯閿佹帶鍒�.mp4")); + File file = new File("C:\\Users\\86176\\Desktop\\19-鍥捐Вes鍐呴儴鍩轰簬_version涔愯閿佹帶鍒�.mp4"); + + + FileInputStream input = null; + try { + input = new FileInputStream(new File("C:\\Users\\86176\\Desktop\\19-鍥捐Вes鍐呴儴鍩轰簬_version涔愯閿佹帶鍒�.mp4")); + MultipartFile multipartFile = new MockMultipartFile(file.getName(), file.getName(), "application/octet-stream", input); + aa(multipartFile); + } catch (FileNotFoundException e) { + e.printStackTrace(); + } catch (IOException e) { + e.printStackTrace(); + } + } + + @Test + public void bb(){ + + for (int j = 0; j < 5; j++) { + if(j==5-1){ + System.out.println("11111111111111111111"); + } + } + } + + public void aa(MultipartFile file) throws IOException { + System.out.println("寮�濮婣a锛�" + System.currentTimeMillis()); + String filePath = "D:\\test\\Ab"; + // 涓婁紶骞惰繑鍥炴柊鏂囦欢鍚嶇О + String fileName = FileUploadUtils.upload(filePath, file); + System.out.println("缁撴潫Aa锛�" + System.currentTimeMillis()); + + } + + } + + -- Gitblit v1.9.3