lyhzzz hace 2 años
padre
commit
8d5cfa0446

+ 5 - 3
src/main/java/com/fdkankan/manage/aop/DecryptRequestBodyAdapter.java

@@ -1,5 +1,6 @@
 package com.fdkankan.manage.aop;
 package com.fdkankan.manage.aop;
 
 
+import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.manage.util.AesUtil;
 import com.fdkankan.manage.util.AesUtil;
 import com.fdkankan.manage.util.RsaUtils;
 import com.fdkankan.manage.util.RsaUtils;
 import com.fdkankan.manage.util.StreamUtil;
 import com.fdkankan.manage.util.StreamUtil;
@@ -77,10 +78,11 @@ public class DecryptRequestBodyAdapter extends RequestBodyAdviceAdapter {
         if (Strings.isNotEmpty(s)) {
         if (Strings.isNotEmpty(s)) {
             // 使用AES解密
             // 使用AES解密
             String bodyDec = RsaUtils.decipher(s);
             String bodyDec = RsaUtils.decipher(s);
-            log.info("解密后请求body:" + bodyDec);
-            if (Strings.isNotEmpty(bodyDec)) {
+            String jsonString = JSONObject.toJSONString(bodyDec);
+            log.info("解密后请求body:" + jsonString);
+            if (Strings.isNotEmpty(jsonString)) {
                 // 使用解密后的数据,构造新的读取流
                 // 使用解密后的数据,构造新的读取流
-                InputStream inputStream = new ByteArrayInputStream(bodyDec.getBytes(StandardCharsets.UTF_8));
+                InputStream inputStream = new ByteArrayInputStream(jsonString.getBytes(StandardCharsets.UTF_8));
                 return new HttpInputMessage() {
                 return new HttpInputMessage() {
                     @Override
                     @Override
                     public HttpHeaders getHeaders() {
                     public HttpHeaders getHeaders() {

+ 13 - 7
src/main/java/com/fdkankan/manage/util/RsaUtils.java

@@ -31,13 +31,19 @@ public class RsaUtils {
 
 
     public static void main(String[] args) {
     public static void main(String[] args) {
         RsaUtils rsa = new RsaUtils();
         RsaUtils rsa = new RsaUtils();
-        KeyPairInfo keyPair = getKeyPair();
-        String publicKey = keyPair.getPublicKey();
-        String privateKey = keyPair.getPrivateKey();
-        System.out.println("公钥:"+publicKey);
-        System.out.println("私钥:"+privateKey);
-
-        String ciphertext = rsa.encipher("abc", publicKey);
+//        KeyPairInfo keyPair = getKeyPair();
+//        String publicKey = keyPair.getPublicKey();
+//        String privateKey = keyPair.getPrivateKey();
+//        System.out.println("公钥:"+publicKey);
+//        System.out.println("私钥:"+privateKey);
+
+        String ciphertext = rsa.encipher("{\n" +
+                "    \"ryId\": 500,\n" +
+                "    \"message\": \"Stream closed\",\n" +
+                "    \"data\": null,\n" +
+                "    \"success\": false,\n" +
+                "    \"timestamp\": 1693293329143\n" +
+                "}", publicKey);
         System.out.println(String.format("密文:"+ciphertext));
         System.out.println(String.format("密文:"+ciphertext));
         String deTxt = rsa.decipher(ciphertext, privateKey);
         String deTxt = rsa.decipher(ciphertext, privateKey);
         System.out.println(deTxt);
         System.out.println(deTxt);