跳到主要内容

嵌入代码

步骤 1 : 导入

导入用于发送 HTTP 请求的库。

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.security.InvalidKeyException;
import java.security.KeyFactory;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.security.interfaces.ECPrivateKey;
import java.security.interfaces.ECPublicKey;
import java.security.spec.PKCS8EncodedKeySpec;
import java.security.spec.X509EncodedKeySpec;
import java.util.Base64;

import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;

import com.nimbusds.jose.JOSEException;
import com.nimbusds.jose.crypto.impl.ECDH;
import com.nimbusds.jose.util.ByteUtils;
import com.nimbusds.jose.util.IntegerUtils;

步骤 2 : 生成密钥

使用EC私钥和Finexus POS公钥生成密钥以加密请求体中的数据。请参考 附录 4 生成 EC 密钥对。

public void run() throws Exception {
    try {
        ECPrivateKey privateKey2 = getECPrivateKeyFromPEM("path/to/ec_private_key_pkcs8.pem");
        ECPublicKey fnxPublicKey = getECPublicKeyFromPEM("path/to/finexus_pos_public_key.key");

        SecretKey encryptSecretKey = ECDH.deriveSharedSecret(fnxPublicKey, privateKey2, null); 
        int keyDataLen = 512;
        String partyVInfo = "1.0"; 

        SecretKey derivedKey = getSecretKey(
                encryptSecretKey,
                keyDataLen,
                partyVInfo.getBytes()
        );

        byte[] keyBytes = derivedKey.getEncoded();
        String base64Key = Base64.getEncoder().encodeToString(keyBytes); 

    } catch (NoSuchAlgorithmException e) {
        e.printStackTrace();
    }
}

public static ECPrivateKey getECPrivateKeyFromPEM(String pemFilePath) throws Exception {
    String pem = new String(Files.readAllBytes(Paths.get(pemFilePath)));

    pem = pem.replace("-----BEGIN PRIVATE KEY-----", "")
            .replace("-----END PRIVATE KEY-----", "")
            .replaceAll("\\s", "");  // Remove line breaks and spaces

    byte[] encoded = Base64.getDecoder().decode(pem);
    PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(encoded);

    KeyFactory keyFactory = KeyFactory.getInstance("EC");
    return (ECPrivateKey) keyFactory.generatePrivate(keySpec);
}

public static ECPublicKey getECPublicKeyFromPEM(String pemFilePath) throws Exception {
    String pem = new String(Files.readAllBytes(Paths.get(pemFilePath)));

    pem = pem.replace("-----BEGIN PUBLIC KEY-----", "")
            .replace("-----END PUBLIC KEY-----", "")
            .replaceAll("\\s", "");  // Remove line breaks and spaces

    byte[] encoded = Base64.getDecoder().decode(pem);
    X509EncodedKeySpec keySpec = new X509EncodedKeySpec(encoded);

    KeyFactory keyFactory = KeyFactory.getInstance("EC");
    return (ECPublicKey) keyFactory.generatePublic(keySpec);
}

public SecretKey getSecretKey(final SecretKey sharedSecret,
        final int keyLength,
        final byte[] partyVInfo)
        throws JOSEException, IOException, NoSuchAlgorithmException, InvalidKeyException {

    SecretKey derivedKey = deriveKey(
            sharedSecret,
            keyLength,
            encodeDataWithLength(new byte[0]),
            encodeDataWithLength(new byte[0]),
            encodeDataWithLength(partyVInfo),
            encodeIntData(keyLength),
            encodeNoData());

    return derivedKey;
}

public String bytesToHex(byte[] bytes) {
    StringBuilder sb = new StringBuilder();
    for (byte b : bytes) {
        sb.append(String.format("%02x", b));
    }
    return sb.toString();
}

public SecretKey deriveKey(final SecretKey sharedSecret,
        final int keyLength,
        final byte[] algID,
        final byte[] partyUInfo,
        final byte[] partyVInfo,
        final byte[] suppPubInfo,
        final byte[] suppPrivInfo)
        throws JOSEException, IOException, NoSuchAlgorithmException, InvalidKeyException {

    final byte[] otherInfo = composeOtherInfo(algID, partyUInfo, partyVInfo, suppPubInfo, suppPrivInfo); 

    return deriveKeyOtherInfo(sharedSecret, keyLength, otherInfo);
}

public SecretKey deriveKeyOtherInfo(final SecretKey sharedSecret,
        final int keyLengthBits,
        final byte[] otherInfo)
        throws JOSEException, IOException, NoSuchAlgorithmException, InvalidKeyException {

    ByteArrayOutputStream baos = new ByteArrayOutputStream();

    MessageDigest md;
    try {
        md = MessageDigest.getInstance("SHA-256");
    } catch (NoSuchAlgorithmException e) {
        throw new JOSEException("Algorithm not found: SHA-256", e);
    }

    for (int i = 1; i <= computeDigestCycles(ByteUtils.safeBitLength(md.getDigestLength()), keyLengthBits); i++) {
        byte[] counterBytes = IntegerUtils.toBytes(i);

        md.update(counterBytes);
        md.update(sharedSecret.getEncoded());

        if (otherInfo != null) {
            md.update(otherInfo);
        }

        try {
            baos.write(md.digest());
        } catch (IOException e) {
            throw new JOSEException("Couldn't write derived key: " + e.getMessage(), e);
        }
    }

    byte[] derivedKeyMaterial = baos.toByteArray();

    final int keyLengthBytes = ByteUtils.byteLength(keyLengthBits);

    if (derivedKeyMaterial.length == keyLengthBytes) {
        return new SecretKeySpec(derivedKeyMaterial, "AES");
    }

    return new SecretKeySpec(ByteUtils.subArray(derivedKeyMaterial, 0, keyLengthBytes), "AES");
}

public int computeDigestCycles(final int digestLengthBits, final int keyLengthBits) {
    return (keyLengthBits + digestLengthBits - 1) / digestLengthBits;
}

public byte[] composeOtherInfo(final byte[] algID, final byte[] partyUInfo, final byte[] partyVInfo, final byte[] suppPubInfo, final byte[] suppPrivInfo) {

    return ByteUtils.concat(algID, partyUInfo, partyVInfo, suppPubInfo, suppPrivInfo);
}

public byte[] encodeDataWithLength(final byte[] data) {

    byte[] bytes = data != null ? data : new byte[0];
    byte[] length = IntegerUtils.toBytes(bytes.length);
    return ByteUtils.concat(length, bytes);
}

public static byte[] encodeIntData(final int data) {

    return IntegerUtils.toBytes(data);
}

public static byte[] encodeNoData() {
    return new byte[0];
}

步骤 3 : 源代码

构造 HTTP 请求正文。

ECPrivateKey thirdAppPrivateKey = UtilCrypto.getECPrivateKeyFromPEM(KEYPAIR_DIR + "ec_private_key_pkcs8.pem");
ECPublicKey thirdAppPublicKey = UtilCrypto.getECPublicKeyFromPEM(KEYPAIR_DIR + "ec_public_key.pem");
ECPublicKey yippiePosPublicKey = UtilCrypto.getECPublicKeyFromPEM(KEYPAIR_DIR + "yippiepos_public_key.key");

SecretKey encryptSecretKey = UtilCrypto.generateECDHSecret(thirdAppPrivateKey, yippiePosPublicKey, "1.0");

String requestJson = "{"
    + "'msgVer': '1.0',"
    + "'billerType': 'PS',"
    + "'callerDeviceType': '02',"
    + "'callerDeviceVer': '1',"
    + "'sequenceNo': '2022091511262185',"
    + "'sellerId': 'A123',"
    + "'mid': '000010000012XXX',"
    + "'mrn': '2021061414062021078',"
    + "'cancelMrn': '2021061414062021078',"
    + "'currency': '458',"
    + "'refundAmount': '100',"
    + "'cancelReason': '...'"
    + "}";

ECKey publicKeyAsJWK = new ECKey.Builder(Curve.P_256, thirdAppPublicKey)
    .keyID(UUID.randomUUID().toString())
    .build();
JWEHeader.Builder builder = new JWEHeader.Builder(JWEAlgorithm.DIR, EncryptionMethod.A256CBC_HS512);
builder.keyID("123");
builder.ephemeralPublicKey((JWK) ECKey.parse(publicKeyAsJWK.toJSONString()));
JWEHeader header = builder.build();
JWEObject jweObject = new JWEObject(header, new Payload(requestJson));
DirectEncrypter encrypter = new DirectEncrypter(encryptSecretKey);
jweObject.encrypt(encrypter);

步骤 4 : 生成签名

请参阅 附录1了解如何生成相应语言的签名。

步骤 5 : 将数据作为 POST 请求发布

在 生成签名 步骤中，在 POST 请求的标头中使用创建的 signedMessage，并在请求正文中使用 message。

String mti = "001X";
String jweString = jweObject.serialize();
String requestBody = mti + jweString;

URL url = new URL("https://xxx.finexusgroup.com/fnx-fintech/xxx/mqpos-host/api/xxx");
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("POST");
connection.setRequestProperty("Signature", signatureStr);
connection.setRequestProperty("sourceSystem", "mxs");
connection.setRequestProperty("Content-Type", "text/plain");
connection.setDoOutput(true);

OutputStream os = connection.getOutputStream();
byte[] input = requestBody.getBytes("utf-8");
os.write(input, 0, input.length);
os.close();

int responseCode = connection.getResponseCode();

BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "utf-8"));
StringBuilder response = new StringBuilder();
String responseLine;
while ((responseLine = in.readLine()) != null) {
    response.append(responseLine.trim());
}
in.close();

步骤 6 : 解密数据

要查看加密数据，请按如下方式解密：

JWEObject jweResObject = JWEObject.parse(responseLine.substring(4));
ECPublicKey recipientPublicKey = jweResObject.getHeader().getEphemeralPublicKey().toECKey().toECPublicKey();

SecretKey secrectKey = generateECDHSecret(thirdAppPrivateKey, recipientPublicKey, "1.0");
jweResObject.decrypt(new DirectDecrypter(secrectKey));
String decryptedRes = jweResObject.getPayload().toString();

© 2024 Finexus Group。版权所有。