代码整理、补充注释

Author: Yang-xingchen

base/process.txt

@@ -2,7 +2,7 @@ jdk8.SaySomething
 proxy.ForumServiceImpl
 proxy.Service2
 proxy.LoadTest
-stack.Stack
+other.StackTrace
 invoke.Impl
 invoke.MethodHandleTest
 Jfame_text.PaintOrderTest
@@ -19,11 +19,11 @@ processor.MyProcessor
 processor.Main
 other.UnsafeTest
 Jfame_text.DNDFileTest
-thread.ThreadLocalTest
+other.ThreadLocalTest
 jdk8.SayBye
 socket_text.Client
 stack.Test
-nio.NIO2Test
+nio.AsyncChannelTest
 nio.NIO2Server
 proxy.ForumService
 processor.ProcessorClass
@@ -43,8 +43,8 @@ nio.NIO2Client
 other.Over
 Jfame_text.CustomWindow
 Jfame_text.j_02
-nio.NIOTest
-codeAndDecode.EncodeAndDecode
+nio.BufferTest
+codeAndDecode.CipherTest
 Jfame_text.MyLabel
 Jfame_text.Label
 invoke.A

base/src/main/java/codeAndDecode/Base64Test.java

@@ -0,0 +1,22 @@
+package codeAndDecode;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import java.util.Base64;
+
+public class Base64Test {
+
+    private final String SRC = "Test";
+
+    @Test
+    void base64() {
+        // 编码
+        byte[] encode = Base64.getEncoder().encode(SRC.getBytes());
+        System.out.println("encode=" + new String(encode) + ", length=" + encode.length);
+        // 解码
+        byte[] decode = Base64.getDecoder().decode(encode);
+        Assertions.assertArrayEquals(SRC.getBytes(), decode);
+    }
+
+}

base/src/main/java/codeAndDecode/CipherTest.java

@@ -0,0 +1,134 @@
+package codeAndDecode;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import javax.crypto.BadPaddingException;
+import javax.crypto.Cipher;
+import javax.crypto.KeyGenerator;
+import javax.crypto.spec.SecretKeySpec;
+import java.security.SecureRandom;
+
+@SuppressWarnings({"SameParameterValue", "FieldCanBeLocal"})
+public class CipherTest {
+
+    private final String SRC = "Test";
+    private final String KEY = "key";
+
+    @Test
+    void aes() throws Exception {
+        test("AES", 128);
+    }
+
+    @Test
+    void aes2() throws Exception {
+        test("AES", 256);
+    }
+
+    @Test
+    void des() throws Exception {
+        test("DES", 56);
+    }
+
+    @Test
+    void desEde() throws Exception {
+        test("DESede", 168);
+    }
+
+    private void test(String algorithm, int keySize) throws Exception {
+        byte[] encode = encode(SRC, KEY, algorithm, keySize);
+        System.out.printf("code=%s, length=%d\n", new String(encode), encode.length);
+
+        byte[] decode = decode(encode, KEY, algorithm, keySize);
+        Assertions.assertArrayEquals(SRC.getBytes(), decode, "not equals");
+
+        Assertions.assertThrows(BadPaddingException.class, () -> decode(encode, "KEY", algorithm, keySize), "false key");
+    }
+
+    /**
+     * 加密
+     */
+    byte[] encode(String context, String key, String algorithm, int keySize) throws Exception {
+        SecretKeySpec keySpec = getKey(keySize, algorithm, key.getBytes());
+        System.out.println("encode = " + keySpec.hashCode());
+
+        // 加密
+        Cipher cipher = Cipher.getInstance(algorithm);
+        cipher.init(Cipher.ENCRYPT_MODE, keySpec);
+        System.out.println("block size=" + cipher.getBlockSize());
+        return cipher.doFinal(context.getBytes());
+    }
+
+    /**
+     * 解密
+     */
+    byte[] decode(byte[] context, String key, String algorithm, int keySize) throws Exception {
+        SecretKeySpec keySpec = getKey(keySize, algorithm, key.getBytes());
+        System.out.println("decode = " + keySpec.hashCode());
+
+        // 解密
+        Cipher cipher = Cipher.getInstance(algorithm);
+        cipher.init(Cipher.DECRYPT_MODE, keySpec);
+        System.out.println("block size=" + cipher.getBlockSize());
+        return cipher.doFinal(context);
+    }
+
+    @Test
+    void keyTest() throws Exception {
+        Assertions.assertArrayEquals(
+                getKey(128, "AES", "AES".getBytes()).getEncoded(),
+                getKey(128, "AES", "AES".getBytes()).getEncoded());
+    }
+
+    /**
+     * 生成密钥
+     * 采用传入密钥为随机算法种子生成实际密钥，可规避不同加密算法要求密钥长度不同
+     */
+    private SecretKeySpec getKey(int keySize, String algorithm, byte[] key) throws Exception {
+        // 密钥生成器
+        KeyGenerator keyGenerator = KeyGenerator.getInstance(algorithm);
+        // 随机数算法
+        SecureRandom secureRandom = SecureRandom.getInstance("SHA1PRNG");
+        // 种子
+        secureRandom.setSeed(key);
+        // 生成
+        keyGenerator.init(keySize, secureRandom);
+        return new SecretKeySpec(keyGenerator.generateKey().getEncoded(), algorithm);
+    }
+
+//    @Test
+//    void nio() throws Exception {
+//        // fail
+//        ByteBuffer src = ByteBuffer.allocate(64);
+//        src.put("Test1".getBytes());
+//        src.flip();
+//        System.out.println("src=" + src);
+//
+//        SecretKeySpec encodeKeySpec = getKey(256, "AES", KEY.getBytes());
+//        Cipher encodeCipher = Cipher.getInstance("AES");
+//        encodeCipher.init(Cipher.ENCRYPT_MODE, encodeKeySpec);
+//
+//        ByteBuffer encode = ByteBuffer.allocate(128);
+//        System.out.println("encode=" + encodeCipher.update(src, encode));
+//        System.out.println("encode result=" + encode);
+//        encodeCipher.doFinal();
+//        System.out.println("encode final=" + encode);
+//        encode.flip();
+//
+//        SecretKeySpec decodeKeySpec = getKey(256, "AES", KEY.getBytes());
+//        Cipher decodeCipher = Cipher.getInstance("AES");
+//        decodeCipher.init(Cipher.DECRYPT_MODE, decodeKeySpec);
+//
+//        ByteBuffer decode = ByteBuffer.allocate(64);
+//        System.out.println("decode=" + decodeCipher.update(encode, decode));
+//        System.out.println("getOutputSize=" + decodeCipher.getOutputSize(64));
+//        decodeCipher.doFinal();
+//
+//        System.out.println(decode);
+//        decode.flip();
+//        byte[] data = new byte[decode.limit()];
+//        decode.get(data);
+//        System.out.println("decode result=" + new String(data));
+//    }
+
+}

base/src/main/java/codeAndDecode/EncodeAndDecode.java

@@ -1,4 +1,4 @@
-package jdk17;
+package feature.jdk17;
 
 public class InstanceOf {
 

base/src/main/java/jdk17/InstanceOf.java renamed to base/src/main/java/feature/jdk17/InstanceOf.java

@@ -1,4 +1,4 @@
-package jdk17;
+package feature.jdk17;
 
 public class Record {
 

base/src/main/java/jdk17/Record.java renamed to base/src/main/java/feature/jdk17/Record.java

@@ -1,4 +1,4 @@
-package jdk17;
+package feature.jdk17;
 
 /**
  * 加sealed必须有子类

base/src/main/java/jdk17/Sealed.java renamed to base/src/main/java/feature/jdk17/Sealed.java

@@ -1,4 +1,4 @@
-package jdk17;
+package feature.jdk17;
 
 public class Switch {
 

base/src/main/java/jdk17/Switch.java renamed to base/src/main/java/feature/jdk17/Switch.java

@@ -1,4 +1,4 @@
-package jdk17;
+package feature.jdk17;
 
 public class TextBlock {
 

base/src/main/java/jdk17/TextBlock.java renamed to base/src/main/java/feature/jdk17/TextBlock.java

@@ -1,4 +1,4 @@
-package jdk21;
+package feature.jdk21;
 
 public class SwitchPattern {
 

base/src/main/java/jdk21/SwitchPattern.java renamed to base/src/main/java/feature/jdk21/SwitchPattern.java

@@ -0,0 +1,31 @@
+package feature.jdk21;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+public class Thread {
+
+    public static void main(String[] args) throws InterruptedException {
+        long start = System.currentTimeMillis();
+        CountDownLatch latch = new CountDownLatch(10_000);
+        try (ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor()) {
+            for (int i = 0; i < 10_000; i++) {
+                executor.submit(() -> {
+                    try {
+                        TimeUnit.SECONDS.sleep(1);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    } finally {
+                        latch.countDown();
+                    }
+                });
+            }
+        }
+        latch.await();
+        // 略大于1000
+        System.out.println(System.currentTimeMillis() - start);
+    }
+
+}

base/src/main/java/feature/jdk21/Thread.java

@@ -1,4 +1,4 @@
-package jdk8;
+package feature.jdk8;
 
 import java.util.function.Supplier;