Sloth

用 Java 将 LdapTemplate 二次封装为 maven 公共工具包

felix9ia ... 2021-7-27 大约 1 分钟

# 用 Java 将 LdapTemplate 二次封装为 maven 公共工具包

原定为两种方案

主要参考了 Spring LDAP的使用 (opens new window)，将 LdapTemplate 进行二次封装。

<dependency>
            <groupId>org.springframework.ldap</groupId>
            <artifactId>spring-ldap-core</artifactId>
            <version>2.3.2.RELEASE</version>
</dependency>
1
2
3
4
5

然后将这个累使用单例模式进行单例化，最终的代码如下：

package ai.neuvision.sdk.logserver.auth.ldap;

import ai.neuvision.sdk.logserver.auth.entity.AxztLdapUser;
import ai.neuvision.sdk.logserver.auth.ldap.exception.AxztLdapAuthException;
import ai.neuvision.sdk.logserver.auth.ldap.mapper.AxztUserAttributeMapper;
import org.springframework.ldap.core.LdapTemplate;
import org.springframework.ldap.core.support.LdapContextSource;
import org.springframework.ldap.filter.AndFilter;
import org.springframework.ldap.filter.EqualsFilter;
import org.springframework.util.StringUtils;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * ladp 校验器
 *
 * @author jiapengfei
 */
public class AxztLdapKeeper {

    private static LdapTemplate ldapTemplate;
    // TODO 写到配置文件当中
    public static final String LDAP_URL = "ldap://x.x.x.x:389";
    public static final String BASE = "dc=xxxx,dc=xxx";
    public static final String LDAP_USERDN = "cn=xxx,dc=xxxx,dc=xxx";
    public static final String LDAP_PASSWORD = "xxxxxx";


    /**
     * 私有的静态内部类，用于持有一个静态 final 实例
     */
    private static class LdapKeeperClassInstance {
        private static final AxztLdapKeeper instance = new AxztLdapKeeper();
    }

    static {
        LdapContextSource contextSource = new LdapContextSource();
        contextSource.setUrl(LDAP_URL);
        contextSource.setBase(BASE);
        contextSource.setUserDn(LDAP_USERDN);
        contextSource.setPassword(LDAP_PASSWORD);
        contextSource.setPooled(true);
        Map<String, Object> config = new HashMap();
        //  解决 乱码 的关键一句
        config.put("java.naming.ldap.attributes.binary", "objectGUID");
        contextSource.setBaseEnvironmentProperties(config);
        contextSource.afterPropertiesSet();

        ldapTemplate = new LdapTemplate(contextSource);
    }

    // 私有化构造函数,禁止外部构建
    private AxztLdapKeeper() {
    }

    public static AxztLdapKeeper getInstance() {
        return LdapKeeperClassInstance.instance;
    }

    /**
     * 查找所有的用户
     *
     * @return .
     */
    public List<AxztLdapUser> findAll() {
        AndFilter filter = new AndFilter();
        filter.and(new EqualsFilter("objectClass", "person"));

        //查询所有内部人员
        List<AxztLdapUser> users = ldapTemplate.search("ou=People", filter.encode(), new AxztUserAttributeMapper());
        return users;
    }

    /**
     * 查找用户
     *
     * @return
     */
    public AxztLdapUser findByUsername() {
        return null;
    }

    /**
     * 校验用户
     *
     * @param user
     * @return
     */
    public boolean authenticate(AxztLdapUser user) {
        if (StringUtils.isEmpty(user.getUsername()) || StringUtils.isEmpty(user.getPassword())) {
            throw new AxztLdapAuthException("you must set username and password together");
        }

        try {
            AndFilter filter = new AndFilter();
            filter.and(new EqualsFilter("objectClass", "person")).and(new EqualsFilter("cn", user.getUsername()));
            return ldapTemplate.authenticate("", filter.encode(), user.getPassword());
        } catch (Exception e) {
            throw new AxztLdapAuthException("got exception when call authenticate: " + e);
        }

    }


}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

# 参考

openldap介绍和使用 (opens new window)

线程池工具类（单例模式） (opens new window)

各种锁