我试图将一个json对象（序列化为字符串）发送到一个sqs队列中，该队列触发lambda。sqs消息超出了sqs的最大256 kb限制。我试图在发送之前压缩我的消息。以下是我尝试的方法：

public static String compress(String str) throws Exception {
        System.out.println("Original String Length : " + str.length());
        ByteArrayOutputStream obj=new ByteArrayOutputStream();
        GZIPOutputStream gzip = new GZIPOutputStream(obj);
        gzip.write(str.getBytes("UTF-8"));
        gzip.close();
        String base64Encoded = Base64.getEncoder().encodeToString(obj.toByteArray());
        System.out.println("Compressed String length : " + base64Encoded.length());
        return base64Encoded;
    }

这个sqs队列触发的lambda是一个基于nodejs的lambda，在这里我需要解压并解码这个消息。我试图使用nodejs中的zlib库来解压缩和解码我的消息，如下所示：

exports.handler = async (event, context) => {
  let msg = null
  event.Records.forEach(record => {
    let { body } = record;
    var buffer = zlib.inflateSync(new Buffer(body, 'base64')).toString();
    msg = JSON.parse(JSON.parse(JSON.stringify(buffer.toString(), undefined, 4)))
  });
}

执行时出现以下错误：

{
    "errorType": "Error",
    "errorMessage": "incorrect header check",
    "code": "Z_DATA_ERROR",
    "errno": -3,
    "stack": [
        "Error: incorrect header check",
        "    at Zlib.zlibOnError [as onerror] (zlib.js:180:17)",
        "    at processChunkSync (zlib.js:429:12)",
        "    at zlibBufferSync (zlib.js:166:12)",
        "    at Object.syncBufferWrapper [as unzipSync] (zlib.js:764:14)",
        "    at /var/task/index.js:12:19",
        "    at Array.forEach (<anonymous>)",
        "    at Runtime.exports.handler (/var/task/index.js:10:17)",
        "    at Runtime.handleOnce (/var/runtime/Runtime.js:66:25)"
    ]
}

有人能告诉我怎样才能更好地解决这个问题吗？有没有更好的方法来压缩java中的字符串？有没有更好的方法来解压、解码和解析nodejs中的json？