• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java AuthenticationToken类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.security.authentication.server.AuthenticationToken的典型用法代码示例。如果您正苦于以下问题:Java AuthenticationToken类的具体用法?Java AuthenticationToken怎么用?Java AuthenticationToken使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



AuthenticationToken类属于org.apache.hadoop.security.authentication.server包,在下文中一共展示了AuthenticationToken类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testValidDelegationTokenQueryString

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void testValidDelegationTokenQueryString() throws Exception {
  HttpServletRequest request = Mockito.mock(HttpServletRequest.class);
  HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
  Token<DelegationTokenIdentifier> dToken =
      (Token<DelegationTokenIdentifier>) handler.getTokenManager().createToken(
          UserGroupInformation.getCurrentUser(), "user");
  Mockito.when(request.getQueryString()).thenReturn(
      DelegationTokenAuthenticator.DELEGATION_PARAM + "=" +
      dToken.encodeToUrlString());

  AuthenticationToken token = handler.authenticate(request, response);
  Assert.assertEquals(UserGroupInformation.getCurrentUser().
          getShortUserName(), token.getUserName());
  Assert.assertEquals(0, token.getExpires());
  Assert.assertEquals(handler.getType(),
      token.getType());
  Assert.assertTrue(token.isExpired());
}
 
开发者ID:nucypher,项目名称:hadoop-oss,代码行数:20,代码来源:TestDelegationTokenAuthenticationHandlerWithMocks.java


示例2: testValidDelegationTokenHeader

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void testValidDelegationTokenHeader() throws Exception {
  HttpServletRequest request = Mockito.mock(HttpServletRequest.class);
  HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
  Token<DelegationTokenIdentifier> dToken =
      (Token<DelegationTokenIdentifier>) handler.getTokenManager().createToken(
          UserGroupInformation.getCurrentUser(), "user");
  Mockito.when(request.getHeader(Mockito.eq(
      DelegationTokenAuthenticator.DELEGATION_TOKEN_HEADER))).thenReturn(
      dToken.encodeToUrlString());

  AuthenticationToken token = handler.authenticate(request, response);
  Assert.assertEquals(UserGroupInformation.getCurrentUser().
      getShortUserName(), token.getUserName());
  Assert.assertEquals(0, token.getExpires());
  Assert.assertEquals(handler.getType(),
      token.getType());
  Assert.assertTrue(token.isExpired());
}
 
开发者ID:nucypher,项目名称:hadoop-oss,代码行数:20,代码来源:TestDelegationTokenAuthenticationHandlerWithMocks.java


示例3: testValidDelegationToken

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
private void testValidDelegationToken(AuthenticationHandler handler)
  throws Exception {
  HttpServletRequest request = Mockito.mock(HttpServletRequest.class);
  HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
  Token<DelegationTokenIdentifier> dToken =
    HttpFSServerWebApp.get().get(DelegationTokenManager.class).createToken(
      UserGroupInformation.getCurrentUser(), "user");
  Mockito.when(request.getParameter(HttpFSKerberosAuthenticator.DELEGATION_PARAM)).
    thenReturn(dToken.encodeToUrlString());

  AuthenticationToken token = handler.authenticate(request, response);
  Assert.assertEquals(UserGroupInformation.getCurrentUser().getShortUserName(),
                      token.getUserName());
  Assert.assertEquals(0, token.getExpires());
  Assert.assertEquals(HttpFSKerberosAuthenticationHandler.TYPE,
                      token.getType());
  Assert.assertTrue(token.isExpired());
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:19,代码来源:TestHttpFSKerberosAuthenticationHandler.java


示例4: testValidDelegationToken

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
private void testValidDelegationToken(AuthenticationHandler handler)
    throws Exception {
  HttpServletRequest request = Mockito.mock(HttpServletRequest.class);
  HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
  Token<DelegationTokenIdentifier> dToken =
      HttpFSServerWebApp.get().get(DelegationTokenManager.class)
          .createToken(UserGroupInformation.getCurrentUser(), "user");
  Mockito.when(
      request.getParameter(HttpFSKerberosAuthenticator.DELEGATION_PARAM)).
      thenReturn(dToken.encodeToUrlString());

  AuthenticationToken token = handler.authenticate(request, response);
  Assert
      .assertEquals(UserGroupInformation.getCurrentUser().getShortUserName(),
          token.getUserName());
  Assert.assertEquals(0, token.getExpires());
  Assert.assertEquals(HttpFSKerberosAuthenticationHandler.TYPE,
      token.getType());
  Assert.assertTrue(token.isExpired());
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:21,代码来源:TestHttpFSKerberosAuthenticationHandler.java


示例5: testRenewToken

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
private void testRenewToken(AuthenticationHandler handler)
  throws Exception {
  DelegationTokenOperation op =
    DelegationTokenOperation.RENEWDELEGATIONTOKEN;
  HttpServletRequest request = Mockito.mock(HttpServletRequest.class);
  HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
  Mockito.when(request.getParameter(HttpFSFileSystem.OP_PARAM)).
    thenReturn(op.toString());
  Mockito.when(request.getMethod()).
    thenReturn(op.getHttpMethod());

  Assert.assertFalse(handler.managementOperation(null, request, response));
  Mockito.verify(response).sendError(
    Mockito.eq(HttpServletResponse.SC_UNAUTHORIZED),
    Mockito.contains("equires SPNEGO authentication established"));

  Mockito.reset(response);
  AuthenticationToken token = Mockito.mock(AuthenticationToken.class);
  Mockito.when(token.getUserName()).thenReturn("user");
  Assert.assertFalse(handler.managementOperation(token, request, response));
  Mockito.verify(response).sendError(
    Mockito.eq(HttpServletResponse.SC_BAD_REQUEST),
    Mockito.contains("requires the parameter [token]"));

  Mockito.reset(response);
  StringWriter writer = new StringWriter();
  PrintWriter pwriter = new PrintWriter(writer);
  Mockito.when(response.getWriter()).thenReturn(pwriter);
  Token<DelegationTokenIdentifier> dToken =
    HttpFSServerWebApp.get().get(DelegationTokenManager.class).createToken(
      UserGroupInformation.getCurrentUser(), "user");
  Mockito.when(request.getParameter(HttpFSKerberosAuthenticator.TOKEN_PARAM)).
    thenReturn(dToken.encodeToUrlString());
  Assert.assertFalse(handler.managementOperation(token, request, response));
  Mockito.verify(response).setStatus(HttpServletResponse.SC_OK);
  pwriter.close();
  Assert.assertTrue(writer.toString().contains("long"));
  HttpFSServerWebApp.get().get(DelegationTokenManager.class).verifyToken(dToken);
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:40,代码来源:TestHttpFSKerberosAuthenticationHandler.java


示例6: getToken

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
@Override
protected AuthenticationToken getToken(HttpServletRequest request)
        throws IOException, AuthenticationException {
    AuthenticationToken token = null;
    String tokenStr = null;
    Cookie[] cookies = request.getCookies();
    if (cookies != null) {
        for (Cookie cookie : cookies) {
            if (cookie.getName().equals(AuthenticatedURL.AUTH_COOKIE)) {
                tokenStr = cookie.getValue();
                try {
                    tokenStr = this.signer.verifyAndExtract(tokenStr);
                } catch (SignerException ex) {
                    throw new AuthenticationException(ex);
                }
            }
        }
    }

    if (tokenStr != null) {
        token = AuthenticationToken.parse(tokenStr);
        if (token != null) {
            AuthenticationHandler authHandler = getAuthenticationHandler();
            if (!token.getType().equals(authHandler.getType())) {
                throw new AuthenticationException("Invalid AuthenticationToken type");
            }
            if (token.isExpired()) {
                throw new AuthenticationException("AuthenticationToken expired");
            }
        }
    }
    return token;
}
 
开发者ID:apache,项目名称:incubator-atlas,代码行数:34,代码来源:AtlasAuthenticationFilter.java


示例7: testRenewToken

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
private void testRenewToken(AuthenticationHandler handler) throws Exception {
  DelegationTokenOperation op = DelegationTokenOperation.RENEWDELEGATIONTOKEN;
  HttpServletRequest request = Mockito.mock(HttpServletRequest.class);
  HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
  Mockito.when(request.getParameter(HttpFSFileSystem.OP_PARAM)).
      thenReturn(op.toString());
  Mockito.when(request.getMethod()).
      thenReturn(op.getHttpMethod());

  Assert.assertFalse(handler.managementOperation(null, request, response));
  Mockito.verify(response)
      .sendError(Mockito.eq(HttpServletResponse.SC_UNAUTHORIZED),
          Mockito.contains("equires SPNEGO authentication established"));

  Mockito.reset(response);
  AuthenticationToken token = Mockito.mock(AuthenticationToken.class);
  Mockito.when(token.getUserName()).thenReturn("user");
  Assert.assertFalse(handler.managementOperation(token, request, response));
  Mockito.verify(response)
      .sendError(Mockito.eq(HttpServletResponse.SC_BAD_REQUEST),
          Mockito.contains("requires the parameter [token]"));

  Mockito.reset(response);
  StringWriter writer = new StringWriter();
  PrintWriter pwriter = new PrintWriter(writer);
  Mockito.when(response.getWriter()).thenReturn(pwriter);
  Token<DelegationTokenIdentifier> dToken =
      HttpFSServerWebApp.get().get(DelegationTokenManager.class)
          .createToken(UserGroupInformation.getCurrentUser(), "user");
  Mockito.when(request.getParameter(HttpFSKerberosAuthenticator.TOKEN_PARAM)).
      thenReturn(dToken.encodeToUrlString());
  Assert.assertFalse(handler.managementOperation(token, request, response));
  Mockito.verify(response).setStatus(HttpServletResponse.SC_OK);
  pwriter.close();
  Assert.assertTrue(writer.toString().contains("long"));
  HttpFSServerWebApp.get().get(DelegationTokenManager.class)
      .verifyToken(dToken);
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:39,代码来源:TestHttpFSKerberosAuthenticationHandler.java


示例8: getEncryptedAuthToken

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
private AuthenticatedURL.Token getEncryptedAuthToken(Signer signer,
    String user) throws Exception {
  AuthenticationToken token =
      new AuthenticationToken(user, user, "kerberos");
  token.setExpires(System.currentTimeMillis() + TIMEOUT);
  return new AuthenticatedURL.Token(signer.sign(token.toString()));
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:8,代码来源:TestHttpServerWithSpengo.java


示例9: managementOperation

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
@Override
public boolean managementOperation(AuthenticationToken authenticationToken,
                                   HttpServletRequest httpServletRequest,
                                   HttpServletResponse httpServletResponse)
    throws IOException, AuthenticationException {
  return false;
}
 
开发者ID:WANdisco,项目名称:s3hdfs,代码行数:8,代码来源:AWSAuthenticationHandler.java


示例10: managementOperation

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
@Override
public boolean managementOperation(AuthenticationToken token,
    HttpServletRequest request, HttpServletResponse response)
    throws IOException, AuthenticationException {
  return false;
}
 
开发者ID:nucypher,项目名称:hadoop-oss,代码行数:7,代码来源:TestWebDelegationToken.java


示例11: testRenewToken

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void testRenewToken() throws Exception {
  DelegationTokenAuthenticator.DelegationTokenOperation op =
      DelegationTokenAuthenticator.DelegationTokenOperation.
          RENEWDELEGATIONTOKEN;
  HttpServletRequest request = Mockito.mock(HttpServletRequest.class);
  HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
  Mockito.when(request.getQueryString()).
      thenReturn(DelegationTokenAuthenticator.OP_PARAM + "=" + op.toString());
  Mockito.when(request.getMethod()).
      thenReturn(op.getHttpMethod());

  Assert.assertFalse(handler.managementOperation(null, request, response));
  Mockito.verify(response).setStatus(
      Mockito.eq(HttpServletResponse.SC_UNAUTHORIZED));
  Mockito.verify(response).setHeader(Mockito.eq(
          KerberosAuthenticator.WWW_AUTHENTICATE),
      Mockito.eq("mock")
  );

  Mockito.reset(response);
  AuthenticationToken token = Mockito.mock(AuthenticationToken.class);
  Mockito.when(token.getUserName()).thenReturn("user");
  Assert.assertFalse(handler.managementOperation(token, request, response));
  Mockito.verify(response).sendError(
      Mockito.eq(HttpServletResponse.SC_BAD_REQUEST),
      Mockito.contains("requires the parameter [token]"));

  Mockito.reset(response);
  StringWriter writer = new StringWriter();
  PrintWriter pwriter = new PrintWriter(writer);
  Mockito.when(response.getWriter()).thenReturn(pwriter);
  Token<DelegationTokenIdentifier> dToken =
      (Token<DelegationTokenIdentifier>) handler.getTokenManager().createToken(
          UserGroupInformation.getCurrentUser(), "user");
  Mockito.when(request.getQueryString()).
      thenReturn(DelegationTokenAuthenticator.OP_PARAM + "=" + op.toString() +
          "&" + DelegationTokenAuthenticator.TOKEN_PARAM + "=" +
          dToken.encodeToUrlString());
  Assert.assertFalse(handler.managementOperation(token, request, response));
  Mockito.verify(response).setStatus(HttpServletResponse.SC_OK);
  pwriter.close();
  Assert.assertTrue(writer.toString().contains("long"));
  handler.getTokenManager().verifyToken(dToken);
}
 
开发者ID:nucypher,项目名称:hadoop-oss,代码行数:46,代码来源:TestDelegationTokenAuthenticationHandlerWithMocks.java


示例12: testGetToken

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
private void testGetToken(String renewer, Text expectedTokenKind)
    throws Exception {
  DelegationTokenAuthenticator.DelegationTokenOperation op =
      DelegationTokenAuthenticator.DelegationTokenOperation.
          GETDELEGATIONTOKEN;
  HttpServletRequest request = Mockito.mock(HttpServletRequest.class);
  HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
  Mockito.when(request.getQueryString()).
      thenReturn(DelegationTokenAuthenticator.OP_PARAM + "=" + op.toString());
  Mockito.when(request.getMethod()).thenReturn(op.getHttpMethod());

  AuthenticationToken token = Mockito.mock(AuthenticationToken.class);
  Mockito.when(token.getUserName()).thenReturn("user");
  Mockito.when(response.getWriter()).thenReturn(new PrintWriter(
      new StringWriter()));
  Assert.assertFalse(handler.managementOperation(token, request, response));

  Mockito.when(request.getQueryString()).
      thenReturn(DelegationTokenAuthenticator.OP_PARAM + "=" + op.toString() +
      "&" + DelegationTokenAuthenticator.RENEWER_PARAM + "=" + renewer);

  Mockito.reset(response);
  Mockito.reset(token);
  Mockito.when(token.getUserName()).thenReturn("user");
  StringWriter writer = new StringWriter();
  PrintWriter pwriter = new PrintWriter(writer);
  Mockito.when(response.getWriter()).thenReturn(pwriter);
  Assert.assertFalse(handler.managementOperation(token, request, response));
  if (renewer == null) {
    Mockito.verify(token).getUserName();
  } else {
    Mockito.verify(token).getUserName();
  }
  Mockito.verify(response).setStatus(HttpServletResponse.SC_OK);
  Mockito.verify(response).setContentType(MediaType.APPLICATION_JSON);
  pwriter.close();
  String responseOutput = writer.toString();
  String tokenLabel = DelegationTokenAuthenticator.
      DELEGATION_TOKEN_JSON;
  Assert.assertTrue(responseOutput.contains(tokenLabel));
  Assert.assertTrue(responseOutput.contains(
      DelegationTokenAuthenticator.DELEGATION_TOKEN_URL_STRING_JSON));
  ObjectMapper jsonMapper = new ObjectMapper();
  Map json = jsonMapper.readValue(responseOutput, Map.class);
  json = (Map) json.get(tokenLabel);
  String tokenStr;
  tokenStr = (String) json.get(DelegationTokenAuthenticator.
      DELEGATION_TOKEN_URL_STRING_JSON);
  Token<DelegationTokenIdentifier> dt = new Token<DelegationTokenIdentifier>();
  dt.decodeFromUrlString(tokenStr);
  handler.getTokenManager().verifyToken(dt);
  Assert.assertEquals(expectedTokenKind, dt.getKind());
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:54,代码来源:TestDelegationTokenAuthenticationHandlerWithMocks.java


示例13: managementOperation

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
@Override
public boolean managementOperation(AuthenticationToken token,
    HttpServletRequest request, HttpServletResponse response) {
  return true;
}
 
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:6,代码来源:RMAuthenticationHandler.java


示例14: getEffectiveUser

import org.apache.hadoop.security.authentication.server.AuthenticationToken; //导入依赖的package包/类
/**
 * Resolves the effective user that will be used to request a FileSystemAccess filesystem.
 * <p/>
 * If the doAs-user is NULL or the same as the user, it returns the user.
 * <p/>
 * Otherwise it uses proxyuser rules (see {@link ProxyUser} to determine if the
 * current user can impersonate the doAs-user.
 * <p/>
 * If the current user cannot impersonate the doAs-user an
 * <code>AccessControlException</code> will be thrown.
 *
 * @param user principal for whom the filesystem instance is.
 * @param doAs do-as user, if any.
 *
 * @return the effective user.
 *
 * @throws IOException thrown if an IO error occurrs.
 * @throws AccessControlException thrown if the current user cannot impersonate
 * the doAs-user.
 */
private String getEffectiveUser(Principal user, String doAs) throws IOException {
  String effectiveUser = user.getName();
  if (doAs != null && !doAs.equals(user.getName())) {
    ProxyUser proxyUser = HttpFSServerWebApp.get().get(ProxyUser.class);
    String proxyUserName;
    if (user instanceof AuthenticationToken) {
      proxyUserName = ((AuthenticationToken)user).getUserName();
    } else {
      proxyUserName = user.getName();
    }
    proxyUser.validate(proxyUserName, HostnameFilter.get(), doAs);
    effectiveUser = doAs;
    AUDIT_LOG.info("Proxy user [{}] DoAs user [{}]", proxyUserName, doAs);
  }
  return effectiveUser;
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:37,代码来源:HttpFSServer.java



注:本文中的org.apache.hadoop.security.authentication.server.AuthenticationToken类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java Database类代码示例发布时间:2022-05-21
下一篇:
Java Dao类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap