主頁 > 軟體設計 > 一站式訊息管理器

一站式訊息管理器

2023-03-28 14:28:21 軟體設計

一站式的訊息管理器

在網路應用中,訊息處理是必不可少的,該文章主要簡單介紹一款簡單的訊息管理器的實作,其具備以下功能:

  • 提供多種訊息序列化和反序列化方式,目前支持JDK、ProtoStuff以及JSON,提供其他自定義的序列化/反序列化器插口,
  • 提供多種訊息加密/解密,目前支持對稱加密:AES、不對稱加密:RSA、不可逆散列加密:MD5以及Base64的轉化并且提供自定義的加密/解密器插口,
  • 提供簡單方便的訊息構造,支持鏈式構造,
  • 支持創建可復用的流程化訊息發送器和接收器、可以完成從訊息發布、訊息格式化、訊息序列化/反序列化,訊息加密/解密的流程處理,并且發送器和接收器支持序列化保存,

首先需要引入依賴:

<dependency>
      <groupId>io.protostuff</groupId>
      <artifactId>protostuff-core</artifactId>
      <version>1.6.0</version>
</dependency>
<dependency>
      <groupId>io.protostuff</groupId>
      <artifactId>protostuff-runtime</artifactId>
      <version>1.6.0</version>
</dependency>
<dependency>
      <groupId>com.google.code.gson</groupId>
      <artifactId>gson</artifactId>
      <version>2.8.5</version>
</dependency>

然后直接拷貝原始碼

import com.google.gson.*;
import io.protostuff.LinkedBuffer;
import io.protostuff.ProtostuffIOUtil;
import io.protostuff.Schema;
import io.protostuff.runtime.RuntimeSchema;
import sun.misc.BASE64Decoder;
import sun.misc.BASE64Encoder;

import javax.crypto.Cipher;
import javax.crypto.spec.SecretKeySpec;
import java.io.*;
import java.lang.reflect.Type;
import java.math.BigInteger;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.security.*;
import java.security.spec.PKCS8EncodedKeySpec;
import java.security.spec.X509EncodedKeySpec;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;

/**
 * 提供一站式的訊息處理
 *
 * @author JingGe(* ^ ▽ ^ *)
 * @date 2023-03-24 15:53
 * @email [email protected]
 */
public class MessageManager {
    /*=================訊息序列化/反序列化器=================>*/
    private static final Gson GSON = new GsonBuilder()
            .enableComplexMapKeySerialization()
            .setDateFormat("yyyy-MM-dd HH:mm:ss")
            .registerTypeAdapter(Class.class, new ClassCodec())
            .create();
    public static final MessageSerializer<String> JSON_SERIALIZER = GSON::toJson;
    public static final MessageDeserializer<Object> JSON_DESERIALIZER = (source, type) -> GSON.fromJson(new String(source, StandardCharsets.UTF_8), type);
    public static final MessageSerializer<byte[]> PROTO_STUFF_SERIALIZER = ProtoStuffUtil::serialize;
    public static final MessageDeserializer<Object> PROTO_STUFF_DESERIALIZER = ProtoStuffUtil::deserialize;
    public static final MessageSerializer<byte[]> JDK_SERIALIZER = source -> {
        ByteArrayOutputStream stream = new ByteArrayOutputStream();
        try {
            ObjectOutputStream outputStream = new ObjectOutputStream(stream);
            outputStream.writeObject(source);
        } catch (IOException e) {
            e.printStackTrace();
        }

        return stream.toByteArray();
    };
    public static final MessageDeserializer<Object> JDK_DESERIALIZER = (source, type) -> {
        ByteArrayInputStream stream = new ByteArrayInputStream(source);
        try {
            ObjectInputStream inputStream = new ObjectInputStream(stream);
            return (Serializable) inputStream.readObject();
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
        return null;
    };

    public interface MessageSerializer<T> {
        T serialize(Object source);
    }

    public interface MessageDeserializer<T> {
        T deserialize(byte[] source, Class<T> type);
    }
    /*=======================Finished======================<*/

    /*=================加密/解密器=================>*/
    public static final Encryptor<Object> NO_ENCRYPTOR = (source, key) -> source;
    public static final Decipher<Object> NO_DECIPHER = (source, key) -> source;
    public static final Encryptor<byte[]> AES_ENCRYPTOR = (source, key) -> {
        try {
            Cipher cipher = Cipher.getInstance("AES/ECB/PKCS5Padding");
            cipher.init(Cipher.ENCRYPT_MODE, new SecretKeySpec(bytes(key, Charset.defaultCharset(), "密鑰只能是byte array或者String"), "AES"));
            return cipher.doFinal(source);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    };
    public static final Decipher<byte[]> AES_DECIPHER = (source, key) -> {
        try {
            Cipher cipher = Cipher.getInstance("AES/ECB/PKCS5Padding");
            cipher.init(Cipher.DECRYPT_MODE, new SecretKeySpec(bytes(key, Charset.defaultCharset(), "密鑰只能是byte array或者String"), "AES"));
            return cipher.doFinal(source);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    };
    public static final RSAEncryptor RSA_ENCRYPTOR = new RSAEncryptor();
    public static final RSADecipher RSA_DECIPHER = new RSADecipher();

    public static final MD5Encryptor MD5_ENCRYPTOR = new MD5Encryptor();

    public static final Encryptor<String> BASE64_ENCRYPTOR = (source, key) -> {
        BASE64Encoder encoder = new BASE64Encoder();
        return encoder.encode(source);
    };
    public static final Decipher<byte[]> BASE64_DECIPHER = (source, key) -> {
        try {
            BASE64Decoder decoder = new BASE64Decoder();
            return decoder.decodeBuffer(new String(source));
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    };

    public static class RSAEncryptor implements Encryptor<byte[]> {

        @Override
        public byte[] encrypt(byte[] source, Object publicKey) {
            try {
                PublicKey key = null;
                if (publicKey instanceof PublicKey) {
                    key = (PublicKey) publicKey;
                } else {
                    byte[] content = bytes(publicKey, Charset.defaultCharset(), "密鑰格式例外:" + publicKey
                            .getClass()
                            .getName());
                    X509EncodedKeySpec keySpec = new X509EncodedKeySpec(content);
                    KeyFactory keyFactory = KeyFactory.getInstance("RSA");
                    key = keyFactory.generatePublic(keySpec);
                    ;
                }
                Cipher cipher = Cipher.getInstance("RSA");
                cipher.init(Cipher.ENCRYPT_MODE, key);
                return cipher.doFinal(source);
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }

        public KeyPair generateKeyPair(int keySize) {
            try {
                keySize = keySize <= 0 ? 2048 : keySize;
                KeyPairGenerator keyPairGenerator = KeyPairGenerator.getInstance("RSA");
                keyPairGenerator.initialize(keySize);
                return keyPairGenerator.generateKeyPair();
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }


    }

    public static class RSADecipher implements Decipher<byte[]> {
        @Override
        public byte[] decrypt(byte[] source, Object privateKey) {
            try {
                PrivateKey key = null;
                if (privateKey instanceof PrivateKey) {
                    key = (PrivateKey) privateKey;
                } else {
                    byte[] content = bytes(privateKey, Charset.defaultCharset(), "密鑰格式例外:" + privateKey
                            .getClass()
                            .getName());
                    PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(content);
                    KeyFactory keyFactory = KeyFactory.getInstance("RSA");
                    key = keyFactory.generatePrivate(keySpec);
                }
                Cipher cipher = Cipher.getInstance("RSA");
                cipher.init(Cipher.DECRYPT_MODE, key);
                return cipher.doFinal(source);
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }
    }

    public static class MD5Encryptor implements Encryptor<String> {
        @Override
        public String encrypt(byte[] source, Object saltKey) {
            byte[] key = bytes(saltKey, Charset.defaultCharset(), "密鑰只能是String或byte array");
            byte[] content = new byte[source.length + key.length];
            System.arraycopy(source, 0, content, 0, source.length);
            System.arraycopy(key, 0, content, source.length, key.length);
            byte[] res;
            try {
                MessageDigest messageDigest = MessageDigest.getInstance("md5");
                res = messageDigest.digest(messageDigest.digest(content));
                if (res != null) {
                    StringBuilder md5code = new StringBuilder(new BigInteger(1, res).toString(16));
                    for (int i = 0; i < 32 - md5code.length(); i++) {
                        md5code.insert(0, "0");
                    }
                    return md5code.toString();
                }
            } catch (NoSuchAlgorithmException e) {
                e.printStackTrace();
            }
            return null;
        }
    }

    public interface Encryptor<T> {
        T encrypt(byte[] source, Object key);
    }

    public interface Decipher<T> {
        T decrypt(byte[] source, Object key);
    }
    /*=======================Finished======================<*/

    /*=================訊息格式化器=================>*/


    public interface MessageFormatter<T> {
        void format(T msg);
    }
    /*=======================Finished======================<*/

    public static MessageBuilder newMessageBuilder() {
        return new MessageBuilder();
    }

    public static <T> MessageSenderWrapper<T> newMessageSenderWrapper(MessageSender<T> sender) {
        return new MessageSenderWrapper<>(sender);
    }

    public static <T> MessageReceiverWrapper<T> newMessageReceiverBuilder(MessageReceiver<T> receiver) {
        return new MessageReceiverWrapper<>(receiver);
    }

    public static <R> R getMessage(Object msg, MessageSerializer<R> serializer) {
        return serializer.serialize(msg);
    }

    public static <R> R encryptMessage(byte[] msg, byte[] key, Encryptor<R> encryptor) {
        return encryptor.encrypt(msg, key);
    }

    public static <R> R decryptMessage(byte[] msg, byte[] key, Decipher<R> decipher) {
        return decipher.decrypt(msg, key);
    }

    public static String convert2Base64(byte[] msg) {
        return BASE64_ENCRYPTOR.encrypt(msg, null);
    }

    public static byte[] base642Bytes(String base64) {
        return BASE64_DECIPHER.decrypt(base64.getBytes(), null);
    }

    @SuppressWarnings("unchecked")
    public static <T> T fromMessage(byte[] msg, Class<T> type, MessageDeserializer<Object> deserializer) {
        return (T) deserializer.deserialize(msg, (Class<Object>) type);
    }

    public static Map<String, Object> wrapper2Map(Code code, String message, Object data) {
        Map<String, Object> msg = new HashMap<>();
        msg.put("code", code.flag);
        msg.put("message", message);
        msg.put("data", data);
        return msg;
    }

    public static String getJsonMessage(Code code, String message, Object data) {
        return getMessage(wrapper2Map(code, message, data), JSON_SERIALIZER);
    }

    public static String getJsonMessage(Code code, String message) {
        return getMessage(wrapper2Map(code, message, null), JSON_SERIALIZER);
    }

    public static byte[] getProtoStuffMessage(Code code, String message, Object data) {
        return getMessage(wrapper2Map(code, message, data), PROTO_STUFF_SERIALIZER);
    }

    public static byte[] getProtoStuffMessage(Code code, String message) {
        return getMessage(wrapper2Map(code, message, null), PROTO_STUFF_SERIALIZER);
    }

    public static byte[] getJDKMessage(Code code, String message, Object data) {
        return getMessage(wrapper2Map(code, message, data), JDK_SERIALIZER);
    }

    public static byte[] getJDKMessage(Code code, String message) {
        return getMessage(wrapper2Map(code, message, null), JDK_SERIALIZER);
    }

    public static class MessageBuilder {
        private final Map<String, Object> container = new ConcurrentHashMap<>();
        private MessageSerializer<?> serializer;

        private MessageBuilder() {
        }

        public MessageBuilder addMsg(String title, Object content) {
            container.put(title, content);
            return this;
        }

        public MessageBuilder addAllMsg(Map<String, Object> msg) {
            container.putAll(msg);
            return this;
        }

        public MessageBuilder code(Code code) {
            container.put("code", code.flag);
            return this;
        }

        public MessageBuilder message(String message) {
            container.put("message", message);
            return this;
        }

        public MessageBuilder data(Object data) {
            container.put("data", data);
            return this;
        }

        public MessageBuilder setSerializer(MessageSerializer<?> serializer) {
            this.serializer = serializer;
            return this;
        }

        public void clear() {
            container.clear();
        }

        @SuppressWarnings("unchecked")
        public <T> T getFinalMessage() {
            return (T) (serializer == null ? JSON_SERIALIZER : serializer).serialize(container);
        }
    }

    public static class MessageSender<T> implements Serializable, MessageHandler<T> {
        private final List<MessageFormatter<Object>> formatters = new ArrayList<>();
        private MessageSerializer<?> serializer;
        private Encryptor<?> encryptor;
        private Object key;
        private Charset charset;
        private boolean encode2Base64WhenEncrypted;

        public MessageSender() {
        }

        @Override
        @SuppressWarnings("unchecked")
        public T getFinalMessage(Object msg) {
            if (msg == null) {
                return null;
            }
            for (MessageFormatter<Object> formatter : formatters) {
                if (formatter != null) {
                    formatter.format(msg);
                }
            }
            Object ser = serializer == null ? msg : serializer.serialize(msg);
            byte[] content = bytes(ser, charset, "序列化后的訊息只能是String或者byte array");
            if (encryptor != null) {
                if (encode2Base64WhenEncrypted) {
                    return (T) convert2Base64(bytes(encryptor.encrypt(content, key), charset, "加密后的訊息只能是String或者byte array"));
                }
                return (T) encryptor.encrypt(content, key);
            }
            return (T) ser;
        }

        @SuppressWarnings("unchecked")
        public static <T> MessageSender<T> fromBytes(byte[] source, MessageDeserializer<Object> deserializer) {
            return (MessageSender<T>) fromMessage(source, MessageSender.class, deserializer);
        }
    }

    public static class MessageReceiver<T> implements Serializable, MessageHandler<T> {
        private final List<MessageFormatter<Object>> formatters = new ArrayList<>();
        private MessageDeserializer<Object> deserializer;
        private Decipher<?> decipher;
        private Class<T> type;
        private Object key;
        private Charset charset;
        private boolean decode2Base64BeforeDecrypt;

        public MessageReceiver() {
        }

        @Override
        @SuppressWarnings("unchecked")
        public T getFinalMessage(Object msg) {
            byte[] content = null;
            if (decode2Base64BeforeDecrypt) {
                if (msg instanceof String) {
                    content = base642Bytes((String) msg);
                } else {
                    throw new UnsupportedOperationException("訊息不是String型別,無法進行Base64解碼");
                }
            }
            Object des = content == null ? msg : content;
            if (decipher != null) {
                des = decipher.decrypt(content == null ? bytes(msg, charset, "如果訊息需要解密,則訊息必須是byte array") : content, key);
            }
            T ser = (T) des;
            if (deserializer != null) {
                ser = (T) deserializer.deserialize(bytes(des, charset, "解密后的結果必須是String或者byte array"), (Class<Object>) type);
            }
            for (MessageFormatter<Object> formatter : formatters) {
                if (formatter != null) {
                    formatter.format(ser);
                }
            }
            return (T) ser;
        }

        @SuppressWarnings("unchecked")
        public static <T> MessageReceiver<T> fromBytes(byte[] source, MessageDeserializer<Object> deserializer) {
            return (MessageReceiver<T>) fromMessage(source, MessageReceiver.class, deserializer);
        }
    }

    public interface MessageHandler<T> {
        T getFinalMessage(Object msg);
    }

    private static byte[] bytes(Object src, Charset charset, String errorMsg) {
        if (src instanceof byte[]) {
            return (byte[]) src;
        } else if (src instanceof String) {
            return charset == null ? ((String) src).getBytes() : ((String) src).getBytes(charset);
        }
        throw new UnsupportedOperationException(errorMsg);
    }

    public static class MessageSenderWrapper<T> {
        private final MessageSender<T> sender;

        private MessageSenderWrapper(MessageSender<T> sender) {
            this.sender = sender;
        }

        public MessageSenderWrapper<T> addFormatter(MessageFormatter<Object> formatter) {
            sender.formatters.add(formatter);
            return this;
        }

        public MessageSenderWrapper<T> setSerializer(MessageSerializer<?> serializer) {
            sender.serializer = serializer;
            return this;
        }

        public MessageSenderWrapper<T> setEncryptor(Encryptor<?> encryptor, Object key, Charset charset, boolean encode2Base64) {
            if (encryptor == null || key == null) {
                throw new IllegalArgumentException("加密器和密鑰不能為空");
            }
            sender.encryptor = encryptor;
            sender.key = key;
            sender.charset = charset;
            sender.encode2Base64WhenEncrypted = encode2Base64;
            return this;
        }

        public MessageSender<T> wrap() {
            return sender;
        }
    }

    public static class MessageReceiverWrapper<T> {
        private final MessageReceiver<T> receiver;

        public MessageReceiverWrapper(MessageReceiver<T> receiver) {
            this.receiver = receiver;
        }

        public MessageReceiverWrapper<T> addFormatter(MessageFormatter<Object> formatter) {
            receiver.formatters.add(formatter);
            return this;
        }

        public MessageReceiverWrapper<T> setDeserializer(MessageDeserializer<Object> deserializer, Class<T> type) {
            receiver.deserializer = deserializer;
            receiver.type = type;
            return this;
        }

        public MessageReceiverWrapper<T> setDecipher(Decipher<?> decipher, Object key, Charset charset, boolean decodeBase642ByteArray) {
            if (decipher == null || key == null) {
                throw new IllegalArgumentException("解密器和密鑰不能為空");
            }
            receiver.decipher = decipher;
            receiver.key = key;
            receiver.charset = charset;
            receiver.decode2Base64BeforeDecrypt = decodeBase642ByteArray;
            return this;
        }

        public MessageReceiver<T> wrap() {
            return receiver;
        }
    }

    /**
     * 狀態列舉,支持列舉標識修改
     *
     * @author Huang Yongxiang
     * @date 2021/9/30 9:25
     */
    public enum Code {
        /**
         * 請求成功
         */
        OK("success", 200),
        /**
         * 服務器內部錯誤
         */
        ERROR("error", 500),
        /**
         * 客戶端請求的語法錯誤,服務器無法理解
         */
        BAD_REQUEST("bad request", 400),
        /**
         * 服務器理解請求客戶端的請求,但是拒絕執行此請求
         */
        FORBIDDEN("Forbidden", 403),
        /**
         * 超時
         */
        TIME_OUT("time out", 408),
        /**
         * 服務器無法根據客戶端請求的內容特性完成請求
         */
        NOT_ACCEPTABLE("Not Acceptable", 406),
        /**
         * 服務器不支持請求的功能,無法完成請求
         */
        NOT_SUPPORT("Not Implemented", 501),
        /**
         * 已接受,已經接受請求,但未處理完成
         */
        ACCEPTED("Accepted", 202);
        private String message;
        private Integer flag;

        Code(String message, Integer flag) {
            this.message = message;
            this.flag = flag;
        }

        public String getMessage() {
            return message;
        }

        public Code setMessage(String message) {
            this.message = message;
            return this;
        }

        public Integer getFlag() {
            return flag;
        }

        public Code setFlag(Integer flag) {
            this.flag = flag;
            return this;
        }

        @Override
        public String toString() {
            return "Code{" + "message='" + message + '\'' + ", flag=" + flag + '}';
        }
    }

    private static class ClassCodec implements JsonSerializer<Class<?>>, JsonDeserializer<Class<?>> {
        @Override
        public Class<?> deserialize(JsonElement json, Type typeOfT, JsonDeserializationContext context) throws JsonParseException {
            try {
                String str = json.getAsString();
                return Class.forName(str);
            } catch (ClassNotFoundException e) {
                throw new JsonParseException(e);
            }
        }

        @Override
        public JsonElement serialize(Class<?> src, Type typeOfSrc, JsonSerializationContext context) {
            return new JsonPrimitive(src.getName());
        }
    }

    private static class ProtoStuffUtil {
        private static final ThreadLocal<LinkedBuffer> threadSafeBuffer = new ThreadLocal<>();
        private static final Map<Class<?>, Schema<?>> schemaMap = new ConcurrentHashMap<>();

        @SuppressWarnings("unchecked")
        public static <T> byte[] serialize(T source) {
            if (source == null) {
                return null;
            }
            Class<T> clazz = (Class<T>) source.getClass();
            Schema<T> schema = getSchema(clazz);
            if (schema == null) {
                throw new NullPointerException("無法獲取" + clazz + "的模式");
            }
            try {
                if (threadSafeBuffer.get() == null) {
                    threadSafeBuffer.set(LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE));
                }
                return ProtostuffIOUtil.toByteArray(source, schema, threadSafeBuffer.get());
            } finally {
                threadSafeBuffer
                        .get()
                        .clear();
            }
        }

        public static <T> T deserialize(byte[] data, Class<T> type) {
            if (data =https://www.cnblogs.com/hyxl-top/archive/2023/03/28/= null || data.length == 0) {
                return null;
            }
            Schema schema = getSchema(type);
            if (schema == null) {
                throw new NullPointerException("無法獲取" + type + "的模式");
            }
            T source = schema.newMessage();
            ProtostuffIOUtil.mergeFrom(data, source, schema);
            return source;
        }

        @SuppressWarnings("unchecked")
        private static <T> Schema<T> getSchema(Class<T> clazz) {
            Schema<T> schema = (Schema<T>) schemaMap.get(clazz);
            if (schema == null) {
                schema = RuntimeSchema.getSchema(clazz);
                schemaMap.put(clazz, schema);
            }
            return schema;
        }
    }

可以增加一個main方法測驗

public static void main(String[] args) {
        //直接獲取訊息
        System.out.println(getJsonMessage(Code.OK, "請求成功"));

        //構建更加復雜的訊息
        System.out.println((String) newMessageBuilder()
                //修改默認Code的標識
                .code(Code.OK.setFlag(0))
                .message("成功")
                .addMsg("totalNum", 1000)
                .getFinalMessage());

        //對訊息加密
        String message = "你好世界";
        String en = BASE64_ENCRYPTOR.encrypt(AES_ENCRYPTOR.encrypt(message.getBytes(), "autoJob!@#=123.?"), null);
        System.out.println("加密后:" + en);
        System.out.println("解密后:" + new String(AES_DECIPHER.decrypt(BASE64_DECIPHER.decrypt(en.getBytes(), null), "autoJob!@#=123.?")));


        System.out.println("/*=================創建可以復用的訊息發送器和接收器=================>*/");
        //創建使用RSA加/解密的發送/接收器
        KeyPair keyPair = RSA_ENCRYPTOR.generateKeyPair(2048);
        MessageSender<String> sender = newMessageSenderWrapper(new MessageSender<String>())
                //可以嘗試使用其他序列化器
                .setSerializer(PROTO_STUFF_SERIALIZER)
                //可以嘗試使用其他加密器
                .setEncryptor(RSA_ENCRYPTOR, keyPair.getPublic(), Charset.defaultCharset(), true)
                .wrap();


        MessageReceiver<String> receiver = newMessageReceiverBuilder(new MessageReceiver<String>())
                //必須和發送器序列化器對應
                .setDeserializer(PROTO_STUFF_DESERIALIZER, String.class)
                //必須和發送器加密器對應
                .setDecipher(RSA_DECIPHER, keyPair.getPrivate(), Charset.defaultCharset(), true)
                .wrap();
        String msg = sender.getFinalMessage("你好世界");
        System.out.println(msg);
        System.out.println(receiver.getFinalMessage(msg));
        System.out.println("/*=======================Finished======================<*/");

        System.out.println("/*=================對發送器/接收器進行序列化保存=================>*/");
        //序列化
        byte[] senderContent = getMessage(sender, PROTO_STUFF_SERIALIZER);
        byte[] receiverContent = getMessage(receiver, PROTO_STUFF_SERIALIZER);

        //反序列化
        MessageSender<String> savedSender = MessageSender.fromBytes(senderContent, PROTO_STUFF_DESERIALIZER);

        MessageReceiver<String> savedReceiver = MessageReceiver.fromBytes(receiverContent, PROTO_STUFF_DESERIALIZER);

        //反序列化后發送訊息
        String sMsg = savedSender.getFinalMessage("你好世界");
        System.out.println(sMsg);
        System.out.println(savedReceiver.getFinalMessage(sMsg));
        System.out.println("/*=======================Finished======================<*/");
    }
}
{"code":200,"message":"請求成功"}
{"code":0,"totalNum":1000,"message":"成功"}
加密后:PXDEasQsDfG4Ca0WLdO4Sg==
解密后:你好世界
/*=================創建可以復用的訊息發送器和接收器=================>*/
YeKSWWdYPu4BK9gAehP5cYLhBcRPaGFN4qlC8mtieRCSNjBuqj9uLb2B4ca/FmYGOxHTYgikUZ2w
/ANc04Vrgz3isKF9VuA03hiW1oWpP3yIIROSji+ribhc6U0ihhelpqimrTQaaVi3mZ8AqrdPKGmM
KSrc/DaHZq/xMzCm1jlucPixm5Nss8Qk9u0lZltKzx8X6vjhaWmLonF7RXL76fiIq6dA45C6JbEG
33R87VMO0xYwIWenvPfwrELrJ/1fqoWFZIBCJWmrqIkulNW7REZqSkFd2pVwF+NH9abN5HH/QOl0
Y3kwRuazZtydkchw0s80WyP1CZ9lC/RK5HKQpQ==
你好世界
/*=======================Finished======================<*/
/*=================對發送器/接收器進行序列化保存=================>*/
lDUZdBYoU86AKilWY1ZdQR9SS/ud1xxnKyUDaKgoMRFLEQqEd2lnD7LDROSfqRNSGwG8ubQ37Db+
2FjiCYsZMoU9B41m5nhm96lu5sWJrhhVLN7zvjdW5G3i6xWuzQrI9S3RiXUCK2zYBh9r2CIm9iAM
mQ9VMZJKYewjKDJYta+hKGcKVg7/lJnX+lu8EmXLuKeCKymXycXHY3VMeURJZQrgLsz9qrQYw/4u
l1nREc2LsL9/TVP3un98XpjUJxTkeyYJ74iLti5FPP3WD+ObR3OTzEZ/9sZndTEKZYFOYlanqavR
hotfSDDTah108C9gNsnnxYUnUasNqF3xOgMETw==
你好世界
/*=======================Finished======================<*/

Process finished with exit code 0

轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/548432.html

標籤:其他

上一篇:一站式訊息管理器

下一篇:專案中如何對XSS統一處理

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C#(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • 面試突擊第一季,第二季,第三季

    第一季必考 https://www.bilibili.com/video/BV1FE411y79Y?from=search&seid=15921726601957489746 第二季分布式 https://www.bilibili.com/video/BV13f4y127ee/?spm_id_fro ......

    uj5u.com 2020-09-10 05:35:24 more
  • 第三單元作業總結

    1.前言 這應該是本學期最后一次寫作業總結了吧。總體來說,對作業的節奏也差不多掌握了,作業做起來的效率也更高了。雖然和之前的作業一樣,作業中都要用到新的知識,但是相比之前,更加懂得了如何利用工具以及資料。雖然之間卡過殼,但總體而言,這幾次作業還算完成的比較好。 2.作業程序總結 相比前兩個單元,此單 ......

    uj5u.com 2020-09-10 05:35:41 more
  • 北航OO(2020)第四單元博客作業暨課程總結博客

    北航OO(2020)第四單元博客作業暨課程總結博客 本單元作業的架構設計 在本單元中,由于UML圖具有比較清晰的樹形結構,因此我對其中需要進行查詢操作的元素進行了包裝,在樹的父節點中存盤所有孩子的參考。考慮到性能問題,我采用了快取機制,一次查詢后盡可能快取已經遍歷過的資訊,以減少遍歷次數。 本單元我 ......

    uj5u.com 2020-09-10 05:35:48 more
  • BUAA_OO_第四單元

    一、UML決議器設計 ? 先看下題目:第四單元實作一個基于JDK 8帶有效性檢查的UML(Unified Modeling Language)類圖,順序圖,狀態圖分析器 MyUmlInteraction,實際上我們要建立一個有向圖模型,UML中的物件(元素)可能與同級元素連接,也可與低級元素相連形成 ......

    uj5u.com 2020-09-10 05:35:54 more
  • 6.1邏輯運算子

    邏輯運算子 1. && 短路與 運算式1 && 運算式2 01.運算式1為true并且運算式2也為true 整體回傳為true 02.運算式1為false,將不會執行運算式2 整體回傳為false 03.只要有一個運算式為false 整體回傳為false 2. || 短路或 運算式1 || 運算式2 ......

    uj5u.com 2020-09-10 05:35:56 more
  • BUAAOO 第四單元 & 課程總結

    1. 第四單元:StarUml檔案決議 本單元采用了圖模型決議UML。 UML檔案可以抽象為圖、子圖、邊的邏輯結構。 在實作中,圖的節點包括類、介面、屬性,子圖包括狀態圖、順序圖等。 采用了三次遍歷UML元素的方法建圖,第一遍遍歷建點,第二、三次遍歷設定屬性、連邊,實作圖物件的初始化。這里借鑒了一些 ......

    uj5u.com 2020-09-10 05:36:06 more
  • 談談我對C# 多型的理解

    面向物件三要素:封裝、繼承、多型。 封裝和繼承,這兩個比較好理解,但要理解多型的話,可就稍微有點難度了。今天,我們就來講講多型的理解。 我們應該經常會看到面試題目:請談談對多型的理解。 其實呢,多型非常簡單,就一句話:呼叫同一種方法產生了不同的結果。 具體實作方式有三種。 一、多載 多載很簡單。 p ......

    uj5u.com 2020-09-10 05:36:09 more
  • Python 資料驅動工具:DDT

    背景 python 的unittest 沒有自帶資料驅動功能。 所以如果使用unittest,同時又想使用資料驅動,那么就可以使用DDT來完成。 DDT是 “Data-Driven Tests”的縮寫。 資料:http://ddt.readthedocs.io/en/latest/ 使用方法 dd. ......

    uj5u.com 2020-09-10 05:36:13 more
  • Python里面的xlrd模塊詳解

    那我就一下面積個問題對xlrd模塊進行學習一下: 1.什么是xlrd模塊? 2.為什么使用xlrd模塊? 3.怎樣使用xlrd模塊? 1.什么是xlrd模塊? ?python操作excel主要用到xlrd和xlwt這兩個庫,即xlrd是讀excel,xlwt是寫excel的庫。 今天就先來說一下xl ......

    uj5u.com 2020-09-10 05:36:28 more
  • 當我們創建HashMap時,底層到底做了什么?

    jdk1.7中的底層實作程序(底層基于陣列+鏈表) 在我們new HashMap()時,底層創建了默認長度為16的一維陣列Entry[ ] table。當我們呼叫map.put(key1,value1)方法向HashMap里添加資料的時候: 首先,呼叫key1所在類的hashCode()計算key1 ......

    uj5u.com 2020-09-10 05:36:38 more
最新发布
  • 【中介者設計模式詳解】C/Java/JS/Go/Python/TS不同語言實作

    * 中介者模式是一種行為型設計模式,它可以用來減少類之間的直接依賴關系,
    * 將物件之間的通信封裝到一個中介者物件中,從而使得各個物件之間的關系更加松散。
    * 在中介者模式中,物件之間不再直接相互互動,而是通過中介者來中轉訊息。 ......

    uj5u.com 2023-04-20 08:20:47 more
  • 露天煤礦現場調研和交流案例分享

    他們集團的資訊化公司及研究院在一個礦區正在做智能礦山的統一平臺的 試點,專案投資大概1億,包括了礦山的各方面的內容,顯示得我們這次交流有點多余。他們2年前開始做智能礦山的規劃,有很多煤礦行業專家的加持,他們的描述是非常完美,但是去年底應該上線的平臺,現在還沒有看到影子。他們確實有很多場景需求,但是被... ......

    uj5u.com 2023-04-20 08:20:25 more
  • 《社區人員管理》實戰案例設計&個人案例分享

    設計是一個讓人夢想成真程序,開始編碼、測驗、除錯之前進行需求分析和架構設計,才能保證關鍵方面都做正確 ......

    uj5u.com 2023-04-20 08:20:17 more
  • 軟體架構生態化-多角色交付的探索實踐

    作為一個技術架構師,不僅僅要緊跟行業技術趨勢,還要結合研發團隊現狀及痛點,探索新的交付方案。在日常中,你是否遇到如下問題 “ 業務需求排期長研發是瓶頸;非研發角色感受不到研發技改提效的變化;引入ISV 團隊又擔心質量和安全,培訓周期長“等等,基于此我們探索了一種新的技術體系及交付方案來解決如上問題。 ......

    uj5u.com 2023-04-20 08:20:10 more
  • 【中介者設計模式詳解】C/Java/JS/Go/Python/TS不同語言實作

    * 中介者模式是一種行為型設計模式,它可以用來減少類之間的直接依賴關系,
    * 將物件之間的通信封裝到一個中介者物件中,從而使得各個物件之間的關系更加松散。
    * 在中介者模式中,物件之間不再直接相互互動,而是通過中介者來中轉訊息。 ......

    uj5u.com 2023-04-20 08:19:44 more
  • 露天煤礦現場調研和交流案例分享

    他們集團的資訊化公司及研究院在一個礦區正在做智能礦山的統一平臺的 試點,專案投資大概1億,包括了礦山的各方面的內容,顯示得我們這次交流有點多余。他們2年前開始做智能礦山的規劃,有很多煤礦行業專家的加持,他們的描述是非常完美,但是去年底應該上線的平臺,現在還沒有看到影子。他們確實有很多場景需求,但是被... ......

    uj5u.com 2023-04-20 08:19:07 more
  • 《社區人員管理》實戰案例設計&個人案例分享

    設計是一個讓人夢想成真程序,開始編碼、測驗、除錯之前進行需求分析和架構設計,才能保證關鍵方面都做正確 ......

    uj5u.com 2023-04-20 08:18:57 more
  • 軟體架構生態化-多角色交付的探索實踐

    作為一個技術架構師,不僅僅要緊跟行業技術趨勢,還要結合研發團隊現狀及痛點,探索新的交付方案。在日常中,你是否遇到如下問題 “ 業務需求排期長研發是瓶頸;非研發角色感受不到研發技改提效的變化;引入ISV 團隊又擔心質量和安全,培訓周期長“等等,基于此我們探索了一種新的技術體系及交付方案來解決如上問題。 ......

    uj5u.com 2023-04-20 08:18:49 more
  • 05單件模式

    #經典的單件模式 public class Singleton { private static Singleton uniqueInstance; //一個靜態變數持有Singleton類的唯一實體。 // 其他有用的實體變數寫在這里 //構造器宣告為私有,只有Singleton可以實體化這個類! ......

    uj5u.com 2023-04-19 08:42:51 more
  • 【架構與設計】常見微服務分層架構的區別和落地實踐

    軟體工程的方方面面都遵循一個最基本的道理:沒有銀彈,架構分層模型更是如此,每一種都有各自優缺點,所以請根據不同的業務場景,并遵循簡單、可演進這兩個重要的架構原則選擇合適的架構分層模型即可。 ......

    uj5u.com 2023-04-19 08:42:41 more