this is a extra element for clear the floated element
封装JNDI操作LDAP服务器的工具类(2)
  • 12/31
  • 2008
J2ee核心 | Java 3197 次查看
  目标:使用者只需要会使用List,Map 数据结构,将对LDAP的操作进行封装

  类:主要有三个类

  1 Env类 包含LDAP的连接信息

  2 LdapConnectionFactory类 ldap连接工厂,提供初始化及获取ldap连接的方法

  3 LdapOperUtils ldap的处理工具类,提供了各种操作ldap的方法。

  ldap连接工厂,提供初始化ldap连接的方法

  package com.common.ldapconnection;

  import java.util.Properties;

  import javax.naming.Context;

  import javax.naming.NamingException;

  import javax.naming.directory.DirContext;

  import javax.naming.directory.InitialDirContext;

  import org.apache.log4j.Logger;

  import org.apache.commons.lang.StringUtils;

  /**

  * 功能描述:ldap连接工厂,提供初始化ldap连接的方法。

  * @author liaowufeng

  * @version 1.0

  */

  public class LdapConnectionFactory {

  // 初始化日志处理类

  static Logger log = Logger.getLogger(LdapConnectionFactory.class.getName());

  /**

  *

  构造函数私有,防止实例化

  */

  private LdapConnectionFactory() {

  }

  /**

  * 从LDAP连接池中取得一个连接

  * @param poolName String 连接池名

  * @env

  连接LDAP的连接信息

  * @return DirContext

  */

  public static DirContext getDirContext(String poolName,Env env) {

  // 取得Context

  try {

  // 日志打印,表明进入此方法

  log.debug(Constants.INTOMETHOD + "getDirContext");

  // 初始化Properties对象

  Properties mEnv = new Properties();

  // 使用LDAP/AD的认证方式

  mEnv.put(Context.AUTHORITATIVE, "true");

  // 使用连接池

  mEnv.put("com.sun.jndi.ldap.connect.pool", "true");

  // 设定LDAP/AD的连接工厂

  mEnv.put(Context.INITIAL_CONTEXT_FACTORY, env.factory);

  // 设定LDAP/AD的url地址

  mEnv.put(Context.PROVIDER_URL, env.url);

  // 设定连接TimeOut

  if(!StringUtils.isEmpty(env.timeOut)) {

  mEnv.put("com.sun.jndi.ldap.connect.timeout", env.timeOut);

  }

  // 设定安全模式为simple方式

  mEnv.put(Context.SECURITY_AUTHENTICATION, "simple");

  // ssl通道访问

  if (env != null && "ssl".equals(env.securityProtocol)) {

  // 设定访问协议为ssl

  mEnv.put(Context.SECURITY_PROTOCOL, env.securityProtocol);

  // 设置访问证书属性,若没有此证书将无法通过ssl访问AD

  System.setProperty("javax.net.ssl.trustStore",

  env.sslTrustStore);

  }

  // 读取可以登陆ldap的帐号、密码

  mEnv.put(Context.SECURITY_PRINCIPAL, env.adminUID);

  mEnv.put(Context.SECURITY_CREDENTIALS, env.adminPWD);

  log.debug(Constants.INIT + "DirContext");

  // 通过参数连接LDAP/AD

  DirContext ctx = new InitialDirContext(mEnv);

  log.debug("LdapConnectionFactory:" + Constants.INIT + "DirContext" +

  Constants.SUCCESS);

  return ctx;

  }

  catch (NamingException ex) {

  ex.printStackTrace();

  log.error("LdapConnectionFactory:" + Constants.INIT + "DirContext" +

  Constants.FAIL);

  log.error(ex.getMessage());

  return null;

  }

  }

  /**

  * 关闭LDAP连接

  * @param dirContext DirContext 已连接的LDAP的Context实例

  */

  public static void closeDirContext(DirContext dirContext) {

  try {

  if (dirContext != null)

  dirContext.close();

  }

  catch (Exception ex) {

  ex.printStackTrace();

  log.error("not close DirContext");

  }

  }

  /**

  * 获取 LDAP 服务器连接的方法

  * @param env 连接LDAP的连接信息

  * @return DirContext - LDAP server的连接

  */

  public static DirContext getDirContext(Env env) {

  try {

  // 初始化Properties对象

  Properties mEnv = new Properties();

  // 使用LDAP/AD的认证方式

  mEnv.put(Context.AUTHORITATIVE, "true");

  // 设定LDAP/AD的连接工厂

  mEnv.put(Context.INITIAL_CONTEXT_FACTORY, env.factory);

  // 设定LDAP/AD的url地址

  mEnv.put(Context.PROVIDER_URL, env.url);

  // 设定连接TimeOut

  if (!StringUtils.isEmpty(env.timeOut)) {

  mEnv.put("com.sun.jndi.ldap.connect.timeout", env.timeOut);

  }

  // 设定安全模式为simple方式

  mEnv.put(Context.SECURITY_AUTHENTICATION, "simple");

  // ssl通道访问

  if (env != null && "ssl".equals(env.securityProtocol)) {

  // 设定访问协议为ssl

  mEnv.put(Context.SECURITY_PROTOCOL, env.securityProtocol);

  // 设置访问证书属性,若没有此证书将无法通过ssl访问AD

  System.setProperty("javax.net.ssl.trustStore",

  env.sslTrustStore);

  }

  // 读取可以登陆ldap的帐号、密码

  mEnv.put(Context.SECURITY_PRINCIPAL, env.adminUID);

  mEnv.put(Context.SECURITY_CREDENTIALS, env.adminPWD);

  log.debug(Constants.INIT + "DirContext");

  // 通过参数连接LDAP/AD

  DirContext ctx = new InitialDirContext(mEnv);

  log.debug("LdapConnectionFactory:" + Constants.INIT + "DirContext" +

  Constants.SUCCESS);

  return ctx;

  }

  catch (NamingException ex) {

  ex.printStackTrace();

  log.error("LdapConnectionFactory:" + Constants.INIT + "DirContext" +

  Constants.FAIL);

  log.error(ex.getMessage());

  return null;

  }

  }

  }