thrift连接hive的java代码

以下是连接Hive的Java代码：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
import org.apache.hadoop.hive.metastore.api.*;

public class HiveClient {
    private static String host = "localhost";
    private static int port = 9083;

    public static void main(String[] args) throws TException {
        // Set Hadoop configuration
        Configuration conf = new Configuration();
        conf.set("hadoop.security.authentication", "Kerberos");

        // Set Kerberos security
        System.setProperty("java.security.krb5.realm", "EXAMPLE.COM");
        System.setProperty("java.security.krb5.kdc", "kdc.example.com");
        UserGroupInformation.setConfiguration(conf);
        UserGroupInformation.loginUserFromKeytab("user@EXAMPLE.COM", "/path/to/user.keytab");

        // Connect to Hive Metastore service
        TTransport transport = new TSocket(host, port);
        transport.open();
        TBinaryProtocol protocol = new TBinaryProtocol(transport);
        ThriftHiveMetastore.Client client = new ThriftHiveMetastore.Client(protocol);

        // Get list of databases
        List<String> databases = client.get_all_databases();
        for (String database : databases) {
            System.out.println(database);
        }

        // Close connection
        transport.close();
    }
}

需要注意的是，代码中涉及到了Kerberos认证和安全配置，需要根据实际情况进行调整。同时，需要根据实际的Hive Metastore服务地址和端口进行设置。