经过一番调查,我发现了一个可行的解决方案。我使用了cyrus-sasl项目以及来自Apache THRIFT的补丁。
首先使用在安全集群中运行的配置单元服务创建一个 TTransport。
boost::shared_ptr<TTransport> socket(new TSocket("hive_host", hive_port));
boost::shared_ptr<TTransport> transport(new TBufferedTransport(socket));
创建回调数组以从客户端获取用户名和简单密码,并从客户端获取密码。
static sasl_callback_t callbacks[] ={
{
SASL_CB_USER, (sasl_callback_ft)&simple, NULL
}, {
SASL_CB_AUTHNAME, (sasl_callback_ft)&simple, NULL
}, {
SASL_CB_PASS, (sasl_callback_ft)&getsecret, NULL
}, {
SASL_CB_LIST_END, NULL, NULL
}
};
使用 saslimpl.cpp 中的 libSaslClient 来选择机制和服务。这将初始化客户端。并在 TSaslTransport 中使用此客户端打开连接并与服务器通信。
map<string, string> props;
sasl::libSaslClient libSaslClient("PLAIN", "", "ldap", "host", props, callbacks);
boost::shared_ptr<TSaslTransport> tsaslTransport(new TSaslTransport(&libSaslClient, transport));
tsaslTransport->open();
tsaslTransport->close();
成功打开后,您将能够与给定正确的用户名和密码的安全集群通信。