Java Jackson，用map编组类，不访问类代码基

Question

com.fasterxml.jackson 2.8.11 com.rabbitmq.client 5.4.3

我的代码：

private RawMessage parseMetadata(RawMessage rawMessage, Envelope envelope, AMQP.BasicProperties properties) throws JsonProcessingException {
    ObjectMapper mapper = new ObjectMapper();
    mapper.setVisibility(PropertyAccessor.FIELD, JsonAutoDetect.Visibility.ANY);
    mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);


    JsonNode rootNode = mapper.createObjectNode();

    JsonNode message = mapper.valueToTree(new String(rawMessage.getPayload()));
    ((ObjectNode) rootNode).set("message", message);

    JsonNode envelopeNode = mapper.valueToTree(envelope);
    ((ObjectNode) rootNode).set("envelope", envelopeNode);

    JsonNode propertiesNode = mapper.valueToTree(properties);
    ((ObjectNode) rootNode).set("properties", propertiesNode);

    return new RawMessage(mapper.writerWithDefaultPrettyPrinter().writeValueAsBytes(rootNode));
}

结果：

{
  "properties": {
    "bodySize": 0,
    "headers": {
      "connection_name": {
        "bytes": "MTcyLjE5LjAuMTo0NTgzNiAtPiAxNzIuMTkuMC40OjU2NzI=",
        "stream": {
          "in": { "buf": "MTcyLjE5LjAuMTo0NTgzNiAtPiAxNzIuMTkuMC40OjU2NzI=", "pos": 0, "mark": 0, "count": 35 },
          "bytearr": "A...",
          "chararr": "\u0000...",
          "readBuffer": "AAAAAAAAAAA="
        }
      },
      "timestamp_in_ms": 1565957758662,
      "protocol": {
        "bytes": "ezAsOSwxfQ==",
        "stream": {
          "in": { "buf": "ezAsOSwxfQ==", "pos": 0, "mark": 0, "count": 7 },
          "bytearr": "AAA...",
          "chararr": "\u0000\u0000\...",
          "readBuffer": "AAAAAAAAAAA="
        }
      },...
      },
      "ssl": false
    },
    "deliveryMode": 2,
    "timestamp": 1565957758000,
    "classId": 60,
    "className": "basic"
  }
}

class BasicProperties extends com.rabbitmq.client.impl.AMQBasicProperties {
        private String contentType;
        private String contentEncoding;
        private Map<String,Object> headers; <--- 
        private Integer deliveryMode;
        private Integer priority;
        private String correlationId;
        private String replyTo;
        private String expiration;
        private String messageId;
        private Date timestamp;
        private String type;
        private String userId;
        private String appId;
        private String clusterId;
...}

import com.rabbitmq.client.AMQP;

Map<String, Object> map = new HashMap<>();
byte[] test =  "test".getBytes();
map.put("test", test);
AMQP.BasicProperties prop = new AMQP.BasicProperties(null, null, map,null,null,null,null,null,null,null,null,null,null,null);

ObjectMapper objectMapper = new ObjectMapper();
objectMapper.setVisibility(PropertyAccessor.FIELD, JsonAutoDetect.Visibility.ANY);
objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);

JsonNode root = objectMapper.createObjectNode();

JsonNode propertiesN = objectMapper.valueToTree(prop);
((ObjectNode) root).set("properties", propertiesN);

LOG.info(root.toString());

结果：

{
  "properties": {
    "bodySize": 0,
    "headers": { "test": "dGVzdA==" },
    "classId": 60,
    "className": "basic"
  }
}

我认为杰克逊·米辛斯应该是这样做的方式。

Answer 1

这个问题的答案：-让您拥有Jackson Mixin，用自定义JsonSerialize类注释您的类-创建您自己的Serialize类，扩展JsonSerializer类-用addMixIn（dataclass.class,Mixin.class）方法将Mixin注册到mapper

示例：

创建密心

abstract class MixIn {
  @JsonSerialize(using = MyPairSerializer.class)
  abstract Map<String, Object> get_map();
}

class MyPairSerializer extends JsonSerializer<Map<String, Object>> {
  public void serialize(Map<String, Object> map, JsonGenerator gen, SerializerProvider serializerProvider) throws IOException {
    for (Map.Entry<String, Object> entry : map.entrySet()) {
      gen.writeStringField(entry.getKey(), entry.getValue().toString());
    }
  }
}

// API call
Data data = getData();

ObjectMapper objectMapper = new ObjectMapper();
JsonNode node = objectMapper.valueToTree(data);
System.out.println("node = " + node);