Json 字符串到 Java 对象 Avro

使用Avro将JSON字符串转换为Java对象

java
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericData;
import org.apache.avro.generic.GenericRecord;
import org.apache.avro.io.DatumReader;
import org.apache.avro.io.Decoder;
import org.apache.avro.io.DecoderFactory;
import org.apache.avro.specific.SpecificData;
import org.apache.avro.specific.SpecificDatumReader;
public class JsonToJavaExample {
    public static void main(String[] args) {
        // 定义Avro模式
        Schema.Parser parser = new Schema.Parser();
        Schema schema = parser.parse("{\"type\":\"record\",\"name\":\"Person\",\"fields\":[{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"age\",\"type\":\"int\"}]}");
        // JSON字符串
        String jsonString = "{\"name\":\"John\",\"age\":25}";
        // 解析JSON字符串为通用数据记录
        DatumReader reader = new SpecificDatumReader<>(schema);
        Decoder decoder = DecoderFactory.get().jsonDecoder(schema, jsonString);
        GenericRecord genericRecord;
        try {
            genericRecord = reader.read(null, decoder);
        } catch (Exception e) {
            e.printStackTrace();
            return;
        }
        // 将通用数据记录转换为Java对象
        Person person = SpecificData.get().deepCopy(schema, genericRecord);
        // 打印Java对象
        System.out.println(person.getName());
        System.out.println(person.getAge());
    }
    public static class Person {
        private String name;
        private int age;
        public String getName() {
            return name;
        }
        public void setName(String name) {
            this.name = name;
        }
        public int getAge() {
            return age;
        }
        public void setAge(int age) {
            this.age = age;
        }
    }
}