解析JSON格式文本并处理数据

在处理日志文件时，我们经常遇到包含复杂嵌套结构的JSON格式文本。这些文本通常包括时间戳、IP地址、设备信息和其他参数。为了有效地解析和处理这类数据，我们可以使用阿里云提供的fastjson库。

### 示例JSON文本
以下是一个典型的日志条目示例：
```json
2017-02-15T18:00:00.001Z-{
"visitTime": "1487152800001",
"ip": "xx.xxx.xxx.xxx",
"params": "{\"encode\":\"utf-8\",\"xxx\":\"0.0\",\"xxxx\":\"6869679\",\"resType\":\"json\",\"ak\":\"xxxxxxxxxxxxxxxxxxxxxxx\",\"xxx\":\"98\",\"uri\":\"/xx/xxx\",\"out_coord_type\":\"xxx\",\"coord_type\":\"xxxx\",\"domain\":null,\"location\":\"xxxx,xxxxx\",\"enc\":\"utf-8\",\"pois\":\"1\"}",
"device": "xxxxxx",
"sid": "xxxx"
}
```

### 代码实现
下面的代码展示了如何使用fastjson库解析上述JSON格式的日志文件，并提取关键信息进行处理和保存。

```java
package com.entity;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.math.BigDecimal;
import java.text.DecimalFormat;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;

public class ReadAndWrite {
public static void main(String[] args) {
excute("F:\\xxxx.log");
}

public static void excute(String path) {
File file = new File(path);
BufferedReader reader = null;
try {
reader = new BufferedReader(new FileReader(file));
String tempString;
while ((tempString = reader.readLine()) != null) {
JSONObject parseObject = JSON.parseObject(tempString);
String params = parseObject.getString("params");
JSONObject parseObject2 = JSON.parseObject(params);

// 获取车辆ID
String carID;
if (parseObject2.get("vhcid") == null) {
String ip = parseObject.getString("ip");
String carID1 = MD5Utils.md5(ip).substring(0, 5);
int parseInt = Integer.parseInt(carID1, 16) + 10000000;
carID = String.valueOf(parseInt);
} else {
carID = parseObject2.getString("vhcid");
}

// 获取定位时间
long visitTime = Long.parseLong(parseObject.getString("visitTime")) / 1000;
String UTC = String.valueOf(visitTime);

// 获取经纬度
String du;
if (parseObject2.containsKey("location")) {
String location = parseObject2.getString("location");
String[] split = location.split(",");
BigDecimal bd = new BigDecimal(split[0]).multiply(BigDecimal.TEN.pow(5));
BigDecimal bd1 = new BigDecimal(split[1]).multiply(BigDecimal.TEN.pow(5));
DecimalFormat dcmFmt = new DecimalFormat("0.0");
du = dcmFmt.format(bd).substring(0, dcmFmt.format(bd).length() - 2) + "," + dcmFmt.format(bd1).substring(0, dcmFmt.format(bd1).length() - 2);
} else if (parseObject2.containsKey("coords")) {
String coords = parseObject2.getString("coords");
String[] split = coords.split(",");
BigDecimal bd = new BigDecimal(split[0]).multiply(BigDecimal.TEN.pow(5));
BigDecimal bd1 = new BigDecimal(split[1]).multiply(BigDecimal.TEN.pow(5));
DecimalFormat dcmFmt = new DecimalFormat("0.0");
du = dcmFmt.format(bd).substring(0, dcmFmt.format(bd).length() - 2) + "," + dcmFmt.format(bd1).substring(0, dcmFmt.format(bd1).length() - 2);
} else {
du = "00000000,00000000";
}

// 获取速度
String speed = parseObject2.containsKey("speed") ? String.valueOf((int) Double.parseDouble(parseObject2.getString("speed"))) : "0";

// 获取方向
String head = parseObject2.containsKey("direction") ? String.valueOf((int) Double.parseDouble(parseObject2.getString("direction"))) : (parseObject2.containsKey("dir") ? String.valueOf((int) Double.parseDouble(parseObject2.getString("dir"))) : "0");

// 设置状态和接收时间
String status = "1";
String time = UTC;

// 拼接字符串并写入文件
if (!du.equals("00000000,00000000")) {
StringBuilder sb = new StringBuilder();
sb.append(carID).append(",").append(UTC).append(",").append(du).append(",").append(speed).append(",").append(head).append(",").append(status).append(",").append(time);
String message = sb.toString();
try (BufferedWriter bw = new BufferedWriter(new FileWriter("F:\\mspVisitLog20170223.txt", true))) {
bw.write(message + "\r\n");
}
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
if (reader != null) {
try {
reader.close();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
}
```

此代码片段实现了对日志文件中每一行JSON数据的解析，提取了必要的字段（如时间戳、IP地址、经纬度等），并对这些数据进行了进一步处理，最终将处理后的结果写入新的文件中。