如何使用Java在Elasticsearch中上传Json数据或文件？

import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.common.xcontent.json.JsonXContent;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

public class ElasticsearchUploader {
    private RestHighLevelClient client;

    public ElasticsearchUploader(RestHighLevelClient client) {
        this.client = client;
    }

    public void uploadJsonData(String indexName, String jsonData) throws IOException {
        IndexRequest request = new IndexRequest(indexName);
        request.source(jsonData, XContentType.JSON);

        IndexResponse response = client.index(request, RequestOptions.DEFAULT);
        if (response.getResult() == DocWriteResponse.Result.CREATED) {
            System.out.println("Json data uploaded successfully");
        } else {
            System.out.println("Failed to upload json data");
        }
    }

    public static void main(String[] args) throws IOException {
        RestHighLevelClient client = createElasticsearchClient(); // 创建Elasticsearch客户端

        ElasticsearchUploader uploader = new ElasticsearchUploader(client);
        
        String indexName = "your_index_name"; // 替换成实际的索引名称
        String jsonData = "{\"name\": \"John Doe\", \"age\": 30}"; // 替换成实际的Json数据

        uploader.uploadJsonData(indexName, jsonData);

        client.close();
    }

    private static RestHighLevelClient createElasticsearchClient() {
        // 创建Elasticsearch客户端的代码
    }
}