security

type AccessDecisionManager ¶

type AccessDecisionManager interface {
	// Decide 决定是否允许访问。
	Decide(ctx context.Context, authentication Authentication, object any, attributes []string) error
}

AccessDecisionManager 访问决策管理器接口。

决定是否允许访问受保护的资源。 基于认证主体的权限和资源的访问控制属性进行决策。

type AccessDecisionVoter ¶

type AccessDecisionVoter interface {
	Vote(ctx context.Context, authentication Authentication, object any, attributes []string) int
}

AccessDecisionVoter 访问决策投票者接口。

投票决定是否授予访问权限。

type AccessDeniedHandler ¶

type AccessDeniedHandler interface {
	// Handle 处理访问拒绝。
	Handle(ctx context.Context, request SecurityRequest, response SecurityResponse, err error) error
}

AccessDeniedHandler 访问拒绝处理器接口。

处理访问被拒绝的情况，如权限不足。 可以自定义响应格式或重定向到错误页面。

type AffirmativeBased ¶

type AffirmativeBased struct {
	// contains filtered or unexported fields
}

AffirmativeBased 肯定优先访问决策管理器 只要有一个投票者授予访问权限就允许访问（最宽松策略） 适用场景：多个权限满足其一即可访问

func NewAffirmativeBased(voters ...AccessDecisionVoter) *AffirmativeBased

func (m *AffirmativeBased) AddVoter(voter AccessDecisionVoter)

func (m *AffirmativeBased) Decide(ctx context.Context, authentication Authentication, object any, attributes []string) error

func (m *AffirmativeBased) SetAllowIfAllAbstainDecisions(allow bool)

type AnonymousAuthenticationFilter ¶

type AnonymousAuthenticationFilter struct {
	// contains filtered or unexported fields
}

AnonymousAuthenticationFilter 匿名认证过滤器 职责：如果当前请求未认证，则创建匿名认证令牌 使用场景：允许未登录用户访问公开资源

func NewAnonymousAuthenticationFilter() *AnonymousAuthenticationFilter

func (f *AnonymousAuthenticationFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type AnonymousAuthenticationProvider ¶

type AnonymousAuthenticationProvider struct{}

AnonymousAuthenticationProvider 匿名认证提供者 为匿名用户创建认证令牌，当其他认证提供者都无法处理时使用 使用场景：用户未登录但需要访问某些公开资源时

func NewAnonymousAuthenticationProvider() *AnonymousAuthenticationProvider

func (p *AnonymousAuthenticationProvider) Authenticate(ctx context.Context, authentication Authentication) (Authentication, error)

func (p *AnonymousAuthenticationProvider) Supports(authentication Authentication) bool

type AnonymousAuthenticationToken ¶

type AnonymousAuthenticationToken struct {
	// contains filtered or unexported fields
}

AnonymousAuthenticationToken 匿名认证令牌

func NewAnonymousAuthenticationToken(key string, principal any, authorities []string) *AnonymousAuthenticationToken

func (t *AnonymousAuthenticationToken) Authenticated() bool

func (t *AnonymousAuthenticationToken) Authorities() []string

func (t *AnonymousAuthenticationToken) Credentials() any

func (t *AnonymousAuthenticationToken) Name() string

func (t *AnonymousAuthenticationToken) Principal() any

type AuthenticatedVoter ¶

type AuthenticatedVoter struct{}

AuthenticatedVoter 认证投票者 检查用户是否满足特定的认证级别 支持三种认证级别：FULLY（完全认证）、REMEMBERED（记住我）、ANONYMOUSLY（匿名）

func NewAuthenticatedVoter() *AuthenticatedVoter

func (v *AuthenticatedVoter) Vote(ctx context.Context, authentication Authentication, object any, attributes []string) int

type Authentication ¶

type Authentication interface {
	// Principal 返回认证主体的标识，通常是用户名或用户对象。
	Principal() any
	// Credentials 返回凭证信息，如密码或令牌。
	Credentials() any
	// Authorities 返回授权列表，如角色和权限。
	Authorities() []string
	// Authenticated 是否已认证。
	Authenticated() bool
	// Name 返回认证主体的名称。
	Name() string
}

Authentication 认证信息接口。

代表一个已认证主体的完整信息，包括身份标识、凭证和权限。 实现应包含用户身份、角色列表和认证状态。

userDetailsService := NewInMemoryUserDetailsService()
userDetailsService.CreateUser("admin", "admin123", []string{"ROLE_ADMIN", "ROLE_USER"})

passwordEncoder := NewNoOpPasswordEncoder()
authProvider := NewDaoAuthenticationProvider(userDetailsService, passwordEncoder, log.Build())
authManager := NewProviderManager(authProvider)

ctx := context.Background()

authToken := NewUsernamePasswordAuthenticationToken("admin", "admin123")
authenticated, err := authManager.Authenticate(ctx, authToken)
if err != nil {
	fmt.Printf("Authentication failed: %v\n", err)
	return
}

fmt.Printf("Authentication successful!\n")
fmt.Printf("Principal: %v\n", authenticated.Principal())
fmt.Printf("Authorities: %v\n", authenticated.Authorities())
fmt.Printf("Authenticated: %v\n", authenticated.Authenticated())
fmt.Printf("Name: %s\n", authenticated.Name())

func GetAuthentication() Authentication

func GetAuthenticationFromContext(ctx context.Context) Authentication

type AuthenticationEntryPoint ¶

type AuthenticationEntryPoint interface {
	// Commence 开始认证流程。
	Commence(ctx context.Context, request SecurityRequest, response SecurityResponse, err error) error
}

AuthenticationEntryPoint 认证入口点接口。

处理未认证用户访问受保护资源的情况。 通常返回 401 状态码或重定向到登录页面。

type AuthenticationManager ¶

type AuthenticationManager interface {
	// Authenticate 执行认证。
	Authenticate(ctx context.Context, authentication Authentication) (Authentication, error)
}

AuthenticationManager 认证管理器接口。

负责处理认证请求，验证用户凭证并返回认证信息。 通常与 UserDetailsService 配合使用。

type AuthenticationProvider ¶

type AuthenticationProvider interface {
	Authenticate(ctx context.Context, authentication Authentication) (Authentication, error)
	Supports(authentication Authentication) bool
}

AuthenticationProvider 认证提供者接口。

定义认证逻辑。

type AuthorizeRequests ¶

type AuthorizeRequests interface {
	// AntMatchers 配置 Ant 风格的路径匹配器。
	AntMatchers(patterns ...string) ExpressionInterceptUrlRegistry
	// AnyRequest 配置所有请求。
	AnyRequest() ExpressionInterceptUrlRegistry
}

AuthorizeRequests 授权请求配置接口。

配置 URL 路径的访问规则。

type BasicAuthenticationEntryPointWithRealm ¶

type BasicAuthenticationEntryPointWithRealm struct {
	// contains filtered or unexported fields
}

BasicAuthenticationEntryPointWithRealm Basic认证入口点（带Realm）

func NewBasicAuthenticationEntryPointWithRealm(realmName string, logger log.Logger) *BasicAuthenticationEntryPointWithRealm

func (e *BasicAuthenticationEntryPointWithRealm) Commence(ctx context.Context, request SecurityRequest, response SecurityResponse, err error) error

type BasicAuthenticationFilter ¶

type BasicAuthenticationFilter struct {
	// contains filtered or unexported fields
}

BasicAuthenticationFilter Basic认证过滤器 职责：从Authorization头中提取Basic认证信息并进行认证 认证流程： 1. 检查Authorization头是否存在且为Basic类型 2. 解码Base64获取用户名和密码 3. 调用AuthenticationManager进行认证 4. 认证成功后将认证信息设置到全局安全上下文和request context

func NewBasicAuthenticationFilter(authenticationManager AuthenticationManager) *BasicAuthenticationFilter

func (f *BasicAuthenticationFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type BasicAuthenticationFilterWithRealm ¶

type BasicAuthenticationFilterWithRealm struct {
	// contains filtered or unexported fields
}

BasicAuthenticationFilterWithRealm 带Realm的Basic认证过滤器

func NewBasicAuthenticationFilterWithRealm(authManager AuthenticationManager, realmName string, logger log.Logger) *BasicAuthenticationFilterWithRealm

func (f *BasicAuthenticationFilterWithRealm) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type CasbinEnforcer ¶

type CasbinEnforcer interface {
	// Enforce 检查请求是否允许。
	// 参数：subject - 主体（用户/角色），object - 资源，action - 操作
	// 返回：是否允许，错误
	Enforce(ctx context.Context, subject, object, action string) (bool, error)
	// AddPolicy 添加策略。
	// 参数：sub - 主体，obj - 资源，act - 操作
	// 返回：错误
	AddPolicy(ctx context.Context, sub, obj, act string) error
	// RemovePolicy 移除策略。
	// 参数：sub - 主体，obj - 资源，act - 操作
	// 返回：错误
	RemovePolicy(ctx context.Context, sub, obj, act string) error
	// GetPolicy 获取所有策略。
	// 返回：策略列表（二维数组），错误
	GetPolicy(ctx context.Context) ([][]string, error)
	// LoadPolicy 重新加载策略。
	// 返回：错误
	LoadPolicy(ctx context.Context) error
	// SavePolicy 保存策略。
	// 返回：错误
	SavePolicy(ctx context.Context) error
}

CasbinEnforcer Casbin 执行器接口。

封装 Casbin 的核心功能，提供权限检查。 实现类：DefaultCasbinEnforcer（starter/casbin）、GormCasbinEnforcer（starter/casbin-gorm）、XormCasbinEnforcer（starter/casbin-xorm）

type CasbinVoter ¶

type CasbinVoter struct {
	// contains filtered or unexported fields
}

CasbinVoter Casbin 投票者实现。

实现 AccessDecisionVoter 接口，将 Casbin 的权限检查集成到 enhance 的访问决策机制中。

工作流程：

1. 检查用户是否已认证（未认证则弃权）
2. 从 Authentication 中提取用户名作为 subject
3. 从 SecurityRequest 中提取 URI 和 HTTP 方法作为 object 和 action
4. 调用 CasbinEnforcer.Enforce() 进行权限检查
5. 返回投票结果（ACCESS_GRANTED / ACCESS_DENIED / ACCESS_ABSTAIN）

投票策略：

• 未认证用户：ACCESS_ABSTAIN（弃权，让其他 Voter 决定）
• Casbin 允许：ACCESS_GRANTED（授予访问）
• Casbin 拒绝：ACCESS_DENIED（拒绝访问）
• 发生错误：ACCESS_ABSTAIN（弃权，让其他 Voter 决定）

注意：CasbinVoter 的投票结果会被 AffirmativeBased 决策管理器使用， 只要有一个 Voter 返回 ACCESS_GRANTED 就允许访问。

func NewCasbinVoter(enforcer CasbinEnforcer) *CasbinVoter

func (v *CasbinVoter) Supports(ctx context.Context, authentication Authentication, object any, attributes []string) bool

func (v *CasbinVoter) Vote(ctx context.Context, authentication Authentication, object any, attributes []string) int

type ConsensusBased ¶

type ConsensusBased struct {
	// contains filtered or unexported fields
}

ConsensusBased 共识优先访问决策管理器 根据多数投票结果决定访问权限（民主策略） 适用场景：需要综合考虑多个权限维度

func NewConsensusBased(voters ...AccessDecisionVoter) *ConsensusBased

func (m *ConsensusBased) AddVoter(voter AccessDecisionVoter)

func (m *ConsensusBased) Decide(ctx context.Context, authentication Authentication, object any, attributes []string) error

func (m *ConsensusBased) SetAllowIfAllAbstainDecisions(allow bool)

func (m *ConsensusBased) SetAllowIfEqualGrantedDenied(allow bool)

type CookieClearingLogoutHandler ¶

type CookieClearingLogoutHandler struct {
	// contains filtered or unexported fields
}

CookieClearingLogoutHandler Cookie清除登出处理器 职责：登出时清除指定的Cookie（如会话Cookie、CSRF Token等）

func NewCookieClearingLogoutHandler(cookieNames ...string) *CookieClearingLogoutHandler

func (h *CookieClearingLogoutHandler) Logout(ctx context.Context, request SecurityRequest, response SecurityResponse, authentication Authentication)

type CookieCsrfTokenRepository ¶

type CookieCsrfTokenRepository struct {
	// contains filtered or unexported fields
}

CookieCsrfTokenRepository 基于Cookie的CSRF令牌仓库 职责：生成、保存和验证CSRF Token 存储策略：将Token保存到Cookie中，客户端需在请求头中携带Token

func NewCookieCsrfTokenRepository() *CookieCsrfTokenRepository

func (r *CookieCsrfTokenRepository) ClearToken(ctx context.Context, request SecurityRequest, response SecurityResponse)

func (r *CookieCsrfTokenRepository) GenerateToken(ctx context.Context, request SecurityRequest) (*CsrfToken, error)

func (r *CookieCsrfTokenRepository) SaveToken(ctx context.Context, request SecurityRequest, response SecurityResponse, token *CsrfToken)

func (r *CookieCsrfTokenRepository) ValidateToken(ctx context.Context, request SecurityRequest, token string) bool

type CorsConfig ¶

type CorsConfig struct {
	AllowedOrigins   []string
	AllowedMethods   []string
	AllowedHeaders   []string
	ExposedHeaders   []string
	AllowCredentials bool
	MaxAge           int
	Log              log.Logger
}

CorsConfig CORS配置

type CorsFilter ¶

type CorsFilter struct {
	// contains filtered or unexported fields
}

CorsFilter CORS过滤器

func NewCorsFilter(config CorsConfig) *CorsFilter

func (f *CorsFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type CsrfAuthenticationStrategy ¶

type CsrfAuthenticationStrategy struct {
	// contains filtered or unexported fields
}

CsrfAuthenticationStrategy CSRF 令牌会话认证策略。

func NewCsrfAuthenticationStrategy() *CsrfAuthenticationStrategy

func (s *CsrfAuthenticationStrategy) OnAuthentication(ctx context.Context, authentication Authentication, request SecurityRequest, response SecurityResponse)

type CsrfFilter ¶

type CsrfFilter struct {
	// contains filtered or unexported fields
}

CsrfFilter CSRF防护过滤器 职责：防止跨站请求伪造攻击 执行流程： 1. GET/HEAD/OPTIONS/TRACE请求：生成并保存CSRF Token到Cookie 2. POST/PUT/DELETE等请求：验证请求头中的CSRF Token 3. Token验证失败则拒绝请求

func NewCsrfFilter(tokenRepository CsrfTokenRepository) *CsrfFilter

func (f *CsrfFilter) AddExcludePath(paths ...string) error

func (f *CsrfFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type CsrfToken ¶

type CsrfToken struct {
	Identifier string // 令牌标识符
	Value      string // 令牌值
}

- CsrfToken: CSRF 令牌结构。

type CsrfTokenManager ¶

type CsrfTokenManager struct {
	// contains filtered or unexported fields
}

CsrfTokenManager CSRF 令牌管理器。

func NewCsrfTokenManager() *CsrfTokenManager

func (m *CsrfTokenManager) GenerateToken(principal string) string

func (m *CsrfTokenManager) RemoveToken(principal string)

func (m *CsrfTokenManager) ValidateToken(principal, token string) bool

type CsrfTokenRepository ¶

type CsrfTokenRepository interface {
	// GenerateToken 生成新的 CSRF 令牌。
	GenerateToken(ctx context.Context, request SecurityRequest) (*CsrfToken, error)
	// ValidateToken 验证 CSRF 令牌。
	ValidateToken(ctx context.Context, request SecurityRequest, token string) bool
	// SaveToken 保存 CSRF 令牌到响应。
	SaveToken(ctx context.Context, request SecurityRequest, response SecurityResponse, token *CsrfToken)
	// ClearToken 清除 CSRF 令牌。
	ClearToken(ctx context.Context, request SecurityRequest, response SecurityResponse)
}

CsrfTokenRepository CSRF 令牌仓库接口。

管理 CSRF 令牌的生成、验证、保存和清除。

type DaoAuthenticationProvider ¶

type DaoAuthenticationProvider struct {
	// contains filtered or unexported fields
}

DaoAuthenticationProvider 基于DAO的认证提供者 从UserDetailsService加载用户并验证密码 认证流程： 1. 从认证令牌中提取用户名 2. 通过UserDetailsService加载用户详情 3. 验证密码是否匹配 4. 检查用户状态（是否启用、是否锁定等） 5. 认证成功后返回包含用户详情的认证令牌

func NewDaoAuthenticationProvider(userDetailsService UserDetailsService, passwordEncoder PasswordEncoder, logger log.Logger) *DaoAuthenticationProvider

func (p *DaoAuthenticationProvider) Authenticate(ctx context.Context, authentication Authentication) (Authentication, error)

func (p *DaoAuthenticationProvider) Supports(authentication Authentication) bool

type DefaultLogoutSuccessHandler ¶

type DefaultLogoutSuccessHandler struct {
	// contains filtered or unexported fields
}

DefaultLogoutSuccessHandler 默认登出成功处理器 职责：登出成功后重定向到指定URL（默认/login?logout）

func NewDefaultLogoutSuccessHandler(defaultTargetUrl string) *DefaultLogoutSuccessHandler

func (h *DefaultLogoutSuccessHandler) OnLogoutSuccess(ctx context.Context, request SecurityRequest, response SecurityResponse, authentication Authentication)

type DefaultSecurityFilterChain ¶

type DefaultSecurityFilterChain struct{}

DefaultSecurityFilterChain 默认安全过滤器链 当所有过滤器都执行完毕后调用

func (c *DefaultSecurityFilterChain) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse) error

type DelegatingPasswordEncoder ¶

type DelegatingPasswordEncoder struct {
	// contains filtered or unexported fields
}

DelegatingPasswordEncoder 委托密码编码器 职责：支持多种编码器，可根据编码ID选择合适的编码器 编码格式：{编码器ID}encodedPassword，例如：{bcrypt}$2a$10$... 优势：支持密码编码算法迁移，历史密码无需重新编码

func NewDelegatingPasswordEncoder(idForEncode string, passwordEncoders map[string]PasswordEncoder) *DelegatingPasswordEncoder

func (e *DelegatingPasswordEncoder) Encode(rawPassword string) string

func (e *DelegatingPasswordEncoder) Matches(rawPassword, encodedPassword string) bool

type EnhancedRateLimitFilter ¶

type EnhancedRateLimitFilter struct {
	// contains filtered or unexported fields
}

EnhancedRateLimitFilter 增强版限流过滤器 职责：基于策略模式的限流过滤器，支持自定义限流策略和回调 与RateLimitFilter的区别：使用RateLimitStrategy接口，更灵活

func NewEnhancedRateLimitFilter(strategy RateLimitStrategy, opts ...EnhancedRateLimitOption) *EnhancedRateLimitFilter

func (f *EnhancedRateLimitFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type EnhancedRateLimitOption ¶

type EnhancedRateLimitOption func(*EnhancedRateLimitFilter)

EnhancedRateLimitOption 增强限流配置选项。

func WithExcludePaths(paths ...string) EnhancedRateLimitOption

func WithOnRateLimit(fn func(ctx context.Context, request SecurityRequest, response SecurityResponse)) EnhancedRateLimitOption

type ExceptionTranslationFilter ¶

type ExceptionTranslationFilter struct {
	// contains filtered or unexported fields
}

ExceptionTranslationFilter 异常转换过滤器 职责：捕获安全异常并转换为适当的HTTP响应 处理逻辑： - 未认证用户访问受保护资源：返回401或重定向到登录页 - 已认证用户访问无权限资源：返回403 Forbidden

func NewExceptionTranslationFilter(accessDeniedHandler AccessDeniedHandler, authenticationEntryPoint AuthenticationEntryPoint) *ExceptionTranslationFilter

func (f *ExceptionTranslationFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type ExpressionBasedFilterInvocationSecurityMetadataSource ¶

type ExpressionBasedFilterInvocationSecurityMetadataSource struct {
	// contains filtered or unexported fields
}

ExpressionBasedFilterInvocationSecurityMetadataSource 基于表达式的过滤器调用安全元数据源 职责：根据请求URL和HTTP方法，返回对应的安全属性（权限表达式） 支持Ant风格路径模式：/**, /path/*, /path/** 示例："/admin/**" -> ["hasRole('ADMIN')"]

func NewExpressionBasedFilterInvocationSecurityMetadataSource() *ExpressionBasedFilterInvocationSecurityMetadataSource

func (s *ExpressionBasedFilterInvocationSecurityMetadataSource) AddMapping(pattern string, attributes []string)

func (s *ExpressionBasedFilterInvocationSecurityMetadataSource) GetAttributes(ctx context.Context, request SecurityRequest) ([]string, error)

type ExpressionInterceptUrlRegistry ¶

type ExpressionInterceptUrlRegistry interface {
	// PermitAll 允许所有访问。
	PermitAll() HttpSecurity
	// Authenticated 需要认证。
	Authenticated() HttpSecurity
	// HasRole 需要指定角色。
	HasRole(role string) HttpSecurity
	// HasAnyRole 需要指定角色之一。
	HasAnyRole(roles ...string) HttpSecurity
	// HasAuthority 需要指定权限。
	HasAuthority(authority string) HttpSecurity
	// HasAnyAuthority 需要指定权限之一。
	HasAnyAuthority(authorities ...string) HttpSecurity
	// DenyAll 拒绝所有访问。
	DenyAll() HttpSecurity
}

ExpressionInterceptUrlRegistry URL 拦截注册接口。

配置特定 URL 的访问表达式。

type FilterChainProxy ¶

type FilterChainProxy struct {
	// contains filtered or unexported fields
}

FilterChainProxy 过滤器链代理 管理和执行多个安全过滤器，实现过滤器链式调用 执行流程：按顺序执行每个过滤器，最后调用目标处理器

func NewFilterChainProxy(filters []SecurityFilter, chain SecurityFilterChain) *FilterChainProxy

func (p *FilterChainProxy) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse) error

type FilterSecurityInterceptor ¶

type FilterSecurityInterceptor struct {
	// contains filtered or unexported fields
}

FilterSecurityInterceptor 过滤器安全拦截器 职责：执行访问决策检查，决定是否允许请求继续 执行流程： 1. 从SecurityMetadataSource获取URL对应的安全属性（权限表达式） 2. 如果已处理过该请求（observeOncePerRequest），直接放行 3. 调用AccessDecisionManager进行权限决策 4. 决策通过则继续执行后续过滤器，否则抛出异常

func NewFilterSecurityInterceptor(securityMetadataSource SecurityMetadataSource, accessDecisionManager AccessDecisionManager, authenticationManager AuthenticationManager) *FilterSecurityInterceptor

func (f *FilterSecurityInterceptor) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

func (f *FilterSecurityInterceptor) SetAccessDecisionManager(manager AccessDecisionManager)

func (f *FilterSecurityInterceptor) SetAuthenticationManager(manager AuthenticationManager)

func (f *FilterSecurityInterceptor) SetSecurityMetadataSource(source SecurityMetadataSource)

type FixedWindowCounterRateLimiter ¶

type FixedWindowCounterRateLimiter struct {
	// contains filtered or unexported fields
}

FixedWindowCounterRateLimiter 固定窗口计数器限流器 算法原理：将时间划分为固定窗口，每个窗口内计数请求数量 优点：实现简单，内存占用小 缺点：存在窗口临界问题（窗口切换时可能允许2倍流量） 适用场景：对限流精度要求不高的场景

func NewFixedWindowCounterRateLimiter(windowSize time.Duration, maxRequests int) *FixedWindowCounterRateLimiter

func (r *FixedWindowCounterRateLimiter) Allow(key string) bool

func (r *FixedWindowCounterRateLimiter) Cleanup()

type GrantedAuthority ¶

type GrantedAuthority interface {
	// Authority 返回权限字符串。
	Authority() string
}

GrantedAuthority 授予权限接口。

代表一个具体的权限，如 "ROLE_ADMIN"、"ROLE_USER"。

func NewAuthority(authority string) GrantedAuthority

type Http401UnauthorizedEntryPoint ¶

type Http401UnauthorizedEntryPoint struct{}

Http401UnauthorizedEntryPoint 401未认证入口点

func NewHttp401UnauthorizedEntryPoint() *Http401UnauthorizedEntryPoint

func (e *Http401UnauthorizedEntryPoint) Commence(ctx context.Context, request SecurityRequest, response SecurityResponse, err error) error

type Http403ForbiddenAccessDeniedHandler ¶

type Http403ForbiddenAccessDeniedHandler struct{}

Http403ForbiddenAccessDeniedHandler 403禁止访问拒绝处理器

func NewHttp403ForbiddenAccessDeniedHandler() *Http403ForbiddenAccessDeniedHandler

func (e *Http403ForbiddenAccessDeniedHandler) Handle(ctx context.Context, request SecurityRequest, response SecurityResponse, err error) error

type Http403ForbiddenEntryPoint ¶

type Http403ForbiddenEntryPoint struct{}

Http403ForbiddenEntryPoint 403禁止访问入口点

func NewHttp403ForbiddenEntryPoint() *Http403ForbiddenEntryPoint

func (e *Http403ForbiddenEntryPoint) Commence(ctx context.Context, request SecurityRequest, response SecurityResponse, err error) error

type HttpRequestAdapter ¶

type HttpRequestAdapter struct {
	// contains filtered or unexported fields
}

HttpRequestAdapter HTTP请求适配器 职责：将标准库的http.Request适配为SecurityRequest接口 使安全模块能够透明地访问HTTP请求信息

func NewHttpRequestAdapter(request *http.Request) *HttpRequestAdapter

func (a *HttpRequestAdapter) GetAttribute(key string) (any, bool)

func (a *HttpRequestAdapter) GetHeader(key string) string

func (a *HttpRequestAdapter) GetMethod() string

func (a *HttpRequestAdapter) GetURI() string

func (a *HttpRequestAdapter) SetAttribute(key string, value any)

type HttpResponseAdapter ¶

type HttpResponseAdapter struct {
	// contains filtered or unexported fields
}

HttpResponseAdapter HTTP响应适配器 职责：将标准库的http.ResponseWriter适配为SecurityResponse接口 使安全模块能够透明地写入HTTP响应

func NewHttpResponseAdapter(responseWriter http.ResponseWriter) *HttpResponseAdapter

func (a *HttpResponseAdapter) SetHeader(key, value string)

func (a *HttpResponseAdapter) SetStatusCode(code int)

func (a *HttpResponseAdapter) StatusCode() int

func (a *HttpResponseAdapter) Write(data []byte) error

type HttpSecurity ¶

type HttpSecurity interface {
	// AuthenticationManager 设置认证管理器。
	AuthenticationManager(authManager AuthenticationManager) HttpSecurity
	// UserDetailsService 设置用户详情服务。
	UserDetailsService(userDetailsService UserDetailsService) HttpSecurity
	// PasswordEncoder 设置密码编码器。
	PasswordEncoder(encoder PasswordEncoder) HttpSecurity
	// AccessDecisionManager 设置访问决策管理器。
	AccessDecisionManager(manager AccessDecisionManager) HttpSecurity
	// SecurityMetadataSource 设置安全元数据源。
	SecurityMetadataSource(source SecurityMetadataSource) HttpSecurity
	// AuthorizeRequests 配置授权规则。
	AuthorizeRequests(authorizer AuthorizeRequests) HttpSecurity
	// AddFilter 添加过滤器。
	AddFilter(filter SecurityFilter) HttpSecurity
	// AddFilterBefore 在指定过滤器之前添加过滤器。
	AddFilterBefore(filter SecurityFilter, beforeFilter SecurityFilter) HttpSecurity
	// AddFilterAfter 在指定过滤器之后添加过滤器。
	AddFilterAfter(filter SecurityFilter, afterFilter SecurityFilter) HttpSecurity
	// Anonymous 启用匿名访问。
	Anonymous() HttpSecurity
	// ExceptionHandling 配置异常处理。
	ExceptionHandling(handler AccessDeniedHandler, entryPoint AuthenticationEntryPoint) HttpSecurity
	// Csrf 启用 CSRF 防护。
	Csrf() HttpSecurity
	// Logout 配置登出。
	Logout(logoutUrl string, successHandler ...LogoutSuccessHandler) HttpSecurity
	// FormLogin 配置表单登录。
	FormLogin(loginProcessingUrl string, defaultSuccessUrl ...string) HttpSecurity
	// HttpBasic 启用 HTTP Basic 认证。
	HttpBasic() HttpSecurity
	// Build 构建安全过滤器链。
	Build() (SecurityFilterChain, error)
}

HttpSecurity HTTP 安全配置接口。

提供链式 API 配置 HTTP 安全规则。 支持认证管理器、用户详情服务、过滤器、CSRF、登出等配置。

使用示例：

httpSec := security.NewHttpSecurity()
httpSec.FormLogin("/login").
    Logout("/logout").
    Csrf().
    AuthorizeRequests(func(authz security.AuthorizeRequests) {
        authz.AntMatchers("/api/**", "ROLE_API")
        authz.AnyAuthenticated()
    })

userDetailsService := NewInMemoryUserDetailsService()
userDetailsService.CreateUser("admin", "admin123", []string{"ROLE_ADMIN"})
userDetailsService.CreateUser("user", "user123", []string{"ROLE_USER"})

passwordEncoder := NewNoOpPasswordEncoder()
authProvider := NewDaoAuthenticationProvider(userDetailsService, passwordEncoder, log.Build())
authManager := NewProviderManager(authProvider)

metadataSource := NewExpressionBasedFilterInvocationSecurityMetadataSource()
metadataSource.AddMapping("/public/**", []string{"permitAll"})
metadataSource.AddMapping("/admin/**", []string{"hasRole('ADMIN')"})
metadataSource.AddMapping("/api/**", []string{"authenticated"})

httpSecurity := NewHttpSecurity()
httpSecurity.
	AuthenticationManager(authManager).
	SecurityMetadataSource(metadataSource)

chain, err := httpSecurity.Build()
if err != nil {
	fmt.Printf("Failed to build: %v\n", err)
	return
}

fmt.Printf("Security chain built successfully: %v\n", chain != nil)

func NewHttpSecurity() HttpSecurity

type InMemoryUserDetails ¶

type InMemoryUserDetails struct {
	// contains filtered or unexported fields
}

InMemoryUserDetails 内存用户详情实现 存储用户的完整认证和授权信息，包括： - 用户名和密码 - 权限列表（角色和权限） - 账户状态（是否启用、是否过期、是否锁定）

func NewInMemoryUserDetails(username, password string, authorities []string) *InMemoryUserDetails

func (u *InMemoryUserDetails) AccountNonExpired() bool

func (u *InMemoryUserDetails) AccountNonLocked() bool

func (u *InMemoryUserDetails) Authorities() []string

func (u *InMemoryUserDetails) CredentialsNonExpired() bool

func (u *InMemoryUserDetails) Enabled() bool

func (u *InMemoryUserDetails) Password() string

func (u *InMemoryUserDetails) Username() string

type InMemoryUserDetailsService ¶

type InMemoryUserDetailsService struct {
	// contains filtered or unexported fields
}

InMemoryUserDetailsService 内存用户详情服务 使用内存map存储用户信息，线程安全 适用场景：开发和测试环境，生产环境应使用数据库实现

func NewInMemoryUserDetailsService() *InMemoryUserDetailsService

func (s *InMemoryUserDetailsService) CreateUser(username, password string, authorities []string)

func (s *InMemoryUserDetailsService) DeleteUser(username string)

func (s *InMemoryUserDetailsService) LoadUserByUsername(ctx context.Context, username string) (UserDetails, error)

func (s *InMemoryUserDetailsService) UserCount() int

type LeakyBucketRateLimiter ¶

type LeakyBucketRateLimiter struct {
	// contains filtered or unexported fields
}

LeakyBucketRateLimiter 漏桶限流器 算法原理：请求像水滴进入桶中，桶以固定速率漏水（处理请求） 优点：平滑处理请求，防止突发流量 适用场景：需要均匀处理请求的场景

func NewLeakyBucketRateLimiter(capacity int, rate time.Duration) *LeakyBucketRateLimiter

func (r *LeakyBucketRateLimiter) Allow(key string) bool

func (r *LeakyBucketRateLimiter) Cleanup()

type LoginUrlAuthenticationEntryPoint ¶

type LoginUrlAuthenticationEntryPoint struct {
	// contains filtered or unexported fields
}

LoginUrlAuthenticationEntryPoint 登录URL认证入口点 未认证用户访问受保护资源时重定向到登录页

func NewLoginUrlAuthenticationEntryPoint(loginFormUrl string) *LoginUrlAuthenticationEntryPoint

func (e *LoginUrlAuthenticationEntryPoint) Commence(ctx context.Context, request SecurityRequest, response SecurityResponse, err error) error

type LogoutFilter ¶

type LogoutFilter struct {
	// contains filtered or unexported fields
}

LogoutFilter 登出过滤器 职责：处理登出请求，清除认证信息并执行登出处理器 执行流程： 1. 检查请求方法和URL是否匹配登出配置 2. 执行所有LogoutHandler（清除安全上下文、清除Cookie等） 3. 清除全局认证信息 4. 调用登出成功处理器（重定向或返回JSON）

func NewLogoutFilter(logoutUrl string, handlers []LogoutHandler) *LogoutFilter

func (f *LogoutFilter) AddLogoutHandler(handler LogoutHandler)

func (f *LogoutFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

func (f *LogoutFilter) SetSuccessHandler(handler LogoutSuccessHandler)

type LogoutHandler ¶

type LogoutHandler interface {
	// Logout 处理登出。
	Logout(ctx context.Context, request SecurityRequest, response SecurityResponse, authentication Authentication)
}

LogoutHandler 登出处理器接口。

type LogoutSuccessHandler ¶

type LogoutSuccessHandler interface {
	// OnLogoutSuccess 处理登出成功。
	OnLogoutSuccess(ctx context.Context, request SecurityRequest, response SecurityResponse, authentication Authentication)
}

LogoutSuccessHandler 登出成功处理器接口。

type NoOpPasswordEncoder ¶

type NoOpPasswordEncoder struct{}

NoOpPasswordEncoder 不进行编码的密码编码器 适用场景：仅用于开发和测试环境，明文存储密码 警告：生产环境绝对不要使用此编码器

func NewNoOpPasswordEncoder() *NoOpPasswordEncoder

func (e *NoOpPasswordEncoder) Encode(rawPassword string) string

func (e *NoOpPasswordEncoder) Matches(rawPassword, encodedPassword string) bool

type PasswordEncoder ¶

type PasswordEncoder interface {
	// Encode 编码密码。
	Encode(rawPassword string) string
	// Matches 验证密码是否匹配。
	Matches(rawPassword, encodedPassword string) bool
}

PasswordEncoder 密码编码器接口。

用于密码的编码和验证。 推荐使用 bcrypt、argon2 等安全算法，避免使用 MD5、SHA1 等不安全算法。

noop := NewNoOpPasswordEncoder()
encoded := noop.Encode("secret")
fmt.Printf("NoOp encoded: %s\n", encoded)
fmt.Printf("NoOp matches: %v\n", noop.Matches("secret", encoded))

sha256 := NewSha256PasswordEncoder()
encoded = sha256.Encode("secret")
fmt.Printf("SHA256 encoded: %s\n", encoded[:20]+"...")
fmt.Printf("SHA256 matches: %v\n", sha256.Matches("secret", encoded))

standard := NewStandardPasswordEncoder("mysecret")
encoded = standard.Encode("secret")
fmt.Printf("Standard encoded: %s\n", encoded[:20]+"...")
fmt.Printf("Standard matches: %v\n", standard.Matches("secret", encoded))

type ProviderManager ¶

type ProviderManager struct {
	// contains filtered or unexported fields
}

ProviderManager 认证提供者管理器 管理多个认证提供者，按顺序尝试认证 执行流程：遍历所有支持的提供者，返回第一个成功认证的结果

func NewProviderManager(providers ...AuthenticationProvider) *ProviderManager

func (m *ProviderManager) AddProvider(provider AuthenticationProvider)

func (m *ProviderManager) Authenticate(ctx context.Context, authentication Authentication) (Authentication, error)

type RateLimitConfig ¶

type RateLimitConfig struct {
	Enabled      bool
	Rate         int
	Burst        int
	ExcludePaths []string
	Log          log.Logger
}

RateLimitConfig 限流配置

type RateLimitFilter ¶

type RateLimitFilter struct {
	// contains filtered or unexported fields
}

RateLimitFilter 限流过滤器

func NewRateLimitFilter(config RateLimitConfig) *RateLimitFilter

func (f *RateLimitFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type RateLimitStrategy ¶

type RateLimitStrategy interface {
	// Allow 判断是否允许请求。
	Allow(key string) bool
}

RateLimitStrategy 限流策略接口。

type RateLimiter ¶

type RateLimiter interface {
	// Allow 判断是否允许请求。
	Allow(key string) bool
	// Cleanup 清理过期数据。
	Cleanup()
}

RateLimiter 限流器接口。

提供请求频率限制功能，防止恶意请求和暴力攻击。

type Role ¶

type Role struct {
	// contains filtered or unexported fields
}

Role 角色实现 实现GrantedAuthority接口

func NewRole(authority string) *Role

func (r *Role) Authority() string

type RoleVoter ¶

type RoleVoter struct {
	// contains filtered or unexported fields
}

RoleVoter 角色投票者 只处理具有指定前缀(默认ROLE_)的角色 用于基于角色的访问控制（RBAC）

func NewRoleVoter() *RoleVoter

func (v *RoleVoter) SetRolePrefix(prefix string)

func (v *RoleVoter) Vote(ctx context.Context, authentication Authentication, object any, attributes []string) int

type SecurityAutoConfiguration ¶

type SecurityAutoConfiguration struct {
	// contains filtered or unexported fields
}

SecurityAutoConfiguration 安全模块自动配置 当 security.enabled=true 时自动装配以下组件： - UserDetailsService: 默认使用内存存储（可自定义） - PasswordEncoder: 默认使用NoOp编码器（生产环境应使用BCrypt） - AuthenticationManager: 包含DaoAuthenticationProvider和AnonymousAuthenticationProvider - SecurityFilterChain: 默认安全过滤器链（支持CORS、限流、JWT等）

自动配置流程： 1. 检查容器是否已有UserDetailsService，没有则创建默认的InMemoryUserDetailsService 2. 检查容器是否已有PasswordEncoder，没有则创建NoOpPasswordEncoder 3. 构建AuthenticationManager（包含DAO认证提供者和匿名认证提供者） 4. 构建SecurityFilterChain（包含CORS、限流、认证、授权等过滤器） 5. 将组件注册到容器中

func (c *SecurityAutoConfiguration) Configure(ctx boot.ApplicationContext) error

type SecurityBuilder ¶

type SecurityBuilder struct {
	// contains filtered or unexported fields
}

SecurityBuilder 安全配置构建器

func NewSecurityBuilder() *SecurityBuilder

func (b *SecurityBuilder) AccessDecisionManager(manager AccessDecisionManager) *SecurityBuilder

func (b *SecurityBuilder) AddFilter(filter SecurityFilter) *SecurityBuilder

func (b *SecurityBuilder) AddFilterAfter(filter SecurityFilter, after SecurityFilter) *SecurityBuilder

func (b *SecurityBuilder) AddFilterBefore(filter SecurityFilter, before SecurityFilter) *SecurityBuilder

func (b *SecurityBuilder) AuthenticationManager(manager AuthenticationManager) *SecurityBuilder

func (b *SecurityBuilder) Build() SecurityConfig

func (b *SecurityBuilder) EnableAnonymous() *SecurityBuilder

func (b *SecurityBuilder) EnableCsrf() *SecurityBuilder

func (b *SecurityBuilder) EnableFormLogin(processingUrl string, defaultSuccessUrl ...string) *SecurityBuilder

func (b *SecurityBuilder) EnableHttpBasic() *SecurityBuilder

func (b *SecurityBuilder) EnableLogout(url string, successHandler ...LogoutSuccessHandler) *SecurityBuilder

func (b *SecurityBuilder) PasswordEncoder(encoder PasswordEncoder) *SecurityBuilder

func (b *SecurityBuilder) UserDetailsService(service UserDetailsService) *SecurityBuilder

type SecurityConfig ¶

type SecurityConfig interface {
	// Configure 配置 HTTP 安全。
	Configure(http HttpSecurity) error
}

SecurityConfig 安全配置接口。

提供自定义安全配置的入口。

type SecurityContext ¶

type SecurityContext interface {
	// Authentication 获取当前认证信息。
	Authentication() Authentication
	// SetAuthentication 设置认证信息。
	SetAuthentication(auth Authentication)
	// ClearAuthentication 清除认证信息。
	ClearAuthentication()
}

SecurityContext 安全上下文接口。

提供对当前认证信息的访问和管理。 通常与请求生命周期绑定，用于存储和检索认证主体信息。

使用示例：

ctx := security.NewSecurityContext()
ctx.SetAuthentication(auth)
auth := ctx.Authentication()

func GetSecurityContext() SecurityContext

func NewSecurityContext() SecurityContext

type SecurityContextHolderFilter ¶

type SecurityContextHolderFilter struct {
	// contains filtered or unexported fields
}

SecurityContextHolderFilter 安全上下文持有者过滤器 职责： 1. 请求开始前：保存当前全局认证信息并清除，防止请求间污染 2. 请求执行中：允许其他过滤器设置认证信息到全局上下文 3. 请求结束后：恢复之前的认证信息并清理当前请求的认证 注意：当前请求的认证信息会保存到请求属性中，供SecurityFilterChainHandler传递给业务handler

func NewSecurityContextHolderFilter(securityContext SecurityContext) *SecurityContextHolderFilter

func (f *SecurityContextHolderFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type SecurityContextLogoutHandler ¶

type SecurityContextLogoutHandler struct{}

SecurityContextLogoutHandler 安全上下文登出处理器 职责：登出时清除全局认证信息

func NewSecurityContextLogoutHandler() *SecurityContextLogoutHandler

func (h *SecurityContextLogoutHandler) Logout(ctx context.Context, request SecurityRequest, response SecurityResponse, authentication Authentication)

type SecurityFilter ¶

type SecurityFilter interface {
	// DoFilter 执行过滤器。
	DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error
}

SecurityFilter 安全过滤器接口。

处理安全相关的请求过滤，如认证、授权、CSRF 防护等。 过滤器按顺序执行，形成安全过滤器链。

type SecurityFilterChain ¶

type SecurityFilterChain interface {
	// DoFilter 执行过滤器链。
	DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse) error
}

SecurityFilterChain 安全过滤器链接口。

按顺序执行多个安全过滤器。 每个过滤器可以决定是否继续执行下一个过滤器。

type SecurityFilterChainHandler ¶

type SecurityFilterChainHandler struct {
	// contains filtered or unexported fields
}

SecurityFilterChainHandler 安全过滤器链处理器 职责：将SecurityFilterChain适配为标准库的http.Handler 执行流程： 1. 接收HTTP请求，适配为SecurityRequest和SecurityResponse 2. 执行安全过滤器链（认证、授权等） 3. 如果过滤器链执行成功且状态码正常，将认证信息注入request context 4. 调用下一个handler（业务处理器）

func NewSecurityFilterChainHandler(securityFilterChain SecurityFilterChain, nextHandler http.Handler) *SecurityFilterChainHandler

func (h *SecurityFilterChainHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (h *SecurityFilterChainHandler) SetNextHandler(handler http.Handler)

type SecurityMetadataSource ¶

type SecurityMetadataSource interface {
	// GetAttributes 获取安全属性。
	GetAttributes(ctx context.Context, request SecurityRequest) ([]string, error)
}

SecurityMetadataSource 安全元数据源接口。

提供访问资源所需的安全属性（如角色要求）。 用于动态访问控制决策。

type SecurityRequest ¶

type SecurityRequest interface {
	// GetMethod 获取请求方法。
	GetMethod() string
	// GetURI 获取请求 URI。
	GetURI() string
	// GetHeader 获取请求头。
	GetHeader(key string) string
	// SetAttribute 设置请求属性。
	SetAttribute(key string, value any)
	// GetAttribute 获取请求属性。
	GetAttribute(key string) (any, bool)
}

SecurityRequest 安全请求接口。

抽象 HTTP 请求，提供安全相关的访问方法。 用于获取请求方法、URI、头部等信息。

type SecurityResponse ¶

type SecurityResponse interface {
	// SetStatusCode 设置状态码。
	SetStatusCode(code int)
	// SetHeader 设置响应头。
	SetHeader(key, value string)
	// Write 写入响应数据。
	Write(data []byte) error
}

SecurityResponse 安全响应接口。

抽象 HTTP 响应，提供安全相关的修改方法。 用于设置状态码、头部和响应体。

type Sha256PasswordEncoder ¶

type Sha256PasswordEncoder struct{}

Sha256PasswordEncoder 基于 SHA256 的密码编码器

注意: 此实现仅适用于兼容性场景，不推荐用于生产环境。 生产环境应使用 BCryptPasswordEncoder 或 Argon2PasswordEncoder。

func NewSha256PasswordEncoder() *Sha256PasswordEncoder

func (e *Sha256PasswordEncoder) Encode(rawPassword string) string

func (e *Sha256PasswordEncoder) Matches(rawPassword, encodedPassword string) bool

type SimpleLogoutSuccessHandler ¶

type SimpleLogoutSuccessHandler struct {
	// contains filtered or unexported fields
}

SimpleLogoutSuccessHandler 简单登出成功处理器。

func NewSimpleLogoutSuccessHandler(targetUrl string) *SimpleLogoutSuccessHandler

func (h *SimpleLogoutSuccessHandler) OnLogoutSuccess(ctx context.Context, request SecurityRequest, response SecurityResponse, authentication Authentication)

type SlidingWindowRateLimiter ¶

type SlidingWindowRateLimiter struct {
	// contains filtered or unexported fields
}

SlidingWindowRateLimiter 滑动窗口限流器 算法原理：记录每个请求的时间戳，只统计窗口时间范围内的请求数量 优点：避免固定窗口的临界问题，限流更平滑 适用场景：需要精确控制请求频率的场景

func NewSlidingWindowRateLimiter(windowSize time.Duration, maxRequests int) *SlidingWindowRateLimiter

func (r *SlidingWindowRateLimiter) Allow(key string) bool

func (r *SlidingWindowRateLimiter) Cleanup()

type StandardPasswordEncoder ¶

type StandardPasswordEncoder struct {
	// contains filtered or unexported fields
}

StandardPasswordEncoder 标准密码编码器 使用密钥对密码进行SHA256哈希

func NewStandardPasswordEncoder(secret string) *StandardPasswordEncoder

func (e *StandardPasswordEncoder) Encode(rawPassword string) string

func (e *StandardPasswordEncoder) Matches(rawPassword, encodedPassword string) bool

type StrategyRateLimiterAdapter ¶

type StrategyRateLimiterAdapter struct {
	// contains filtered or unexported fields
}

StrategyRateLimiterAdapter 限流器适配器。

func NewStrategyRateLimiterAdapter(limiter RateLimiter) *StrategyRateLimiterAdapter

func (a *StrategyRateLimiterAdapter) Allow(key string) bool

type TokenBucket ¶

type TokenBucket struct {
	// contains filtered or unexported fields
}

TokenBucket 令牌桶

func NewTokenBucket(capacity, rate int) *TokenBucket

func (b *TokenBucket) Take() bool

type UnanimousBased ¶

type UnanimousBased struct {
	// contains filtered or unexported fields
}

UnanimousBased 一致通过访问决策管理器 只有所有投票者都不拒绝才允许访问（最严格策略） 适用场景：需要满足所有权限要求才能访问

func NewUnanimousBased(voters ...AccessDecisionVoter) *UnanimousBased

func (m *UnanimousBased) AddVoter(voter AccessDecisionVoter)

func (m *UnanimousBased) Decide(ctx context.Context, authentication Authentication, object any, attributes []string) error

func (m *UnanimousBased) SetAllowIfAllAbstainDecisions(allow bool)

type UserDetails ¶

type UserDetails interface {
	// Username 返回用户名。
	Username() string
	// Password 返回密码。
	Password() string
	// Authorities 返回权限列表。
	Authorities() []string
	// Enabled 账户是否启用。
	Enabled() bool
	// AccountNonExpired 账户是否未过期。
	AccountNonExpired() bool
	// CredentialsNonExpired 凭证是否未过期。
	CredentialsNonExpired() bool
	// AccountNonLocked 账户是否未锁定。
	AccountNonLocked() bool
}

UserDetails 用户详情接口。

包含用户的完整认证和授权信息。 实现应提供用户名、密码、权限列表和账户状态。

type UserDetailsService ¶

type UserDetailsService interface {
	// LoadUserByUsername 根据用户名加载用户详情。
	LoadUserByUsername(ctx context.Context, username string) (UserDetails, error)
}

UserDetailsService 用户详情服务接口。

根据用户名加载用户信息，用于认证和授权。 实现可以从数据库、LDAP、内存等来源加载用户。

service := NewInMemoryUserDetailsService()

service.CreateUser("john", "password123", []string{"ROLE_USER"})
service.CreateUser("jane", "password456", []string{"ROLE_USER", "ROLE_ADMIN"})

ctx := context.Background()

john, _ := service.LoadUserByUsername(ctx, "john")
fmt.Printf("Username: %s\n", john.Username())
fmt.Printf("Authorities: %v\n", john.Authorities())

fmt.Printf("Total users: %d\n", service.UserCount())

service.DeleteUser("john")
fmt.Printf("Users after delete: %d\n", service.UserCount())

type UsernamePasswordAuthenticationFilter ¶

type UsernamePasswordAuthenticationFilter struct {
	// contains filtered or unexported fields
}

UsernamePasswordAuthenticationFilter 用户名密码认证过滤器

func NewUsernamePasswordAuthenticationFilterWithDefaults(
	loginProcessingURL,
	defaultSuccessURL,
	failureURL string,
	authManager AuthenticationManager,
	logger log.Logger,
) *UsernamePasswordAuthenticationFilter

func (f *UsernamePasswordAuthenticationFilter) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse, chain SecurityFilterChain) error

type UsernamePasswordAuthenticationToken ¶

type UsernamePasswordAuthenticationToken struct {
	// contains filtered or unexported fields
}

UsernamePasswordAuthenticationToken 用户名密码认证令牌 用于在认证过程中传递和存储用户凭证 认证前：包含用户名和密码（authenticated=false） 认证后：包含用户详情和权限列表（authenticated=true）

func NewAuthenticatedUsernamePasswordAuthenticationToken(principal any, authorities []string) *UsernamePasswordAuthenticationToken

func NewUsernamePasswordAuthenticationToken(principal, credentials any) *UsernamePasswordAuthenticationToken

func (t *UsernamePasswordAuthenticationToken) Authenticated() bool

func (t *UsernamePasswordAuthenticationToken) Authorities() []string

func (t *UsernamePasswordAuthenticationToken) Credentials() any

func (t *UsernamePasswordAuthenticationToken) Name() string

func (t *UsernamePasswordAuthenticationToken) Principal() any

func (t *UsernamePasswordAuthenticationToken) SetAuthenticated(authenticated bool)

func (t *UsernamePasswordAuthenticationToken) SetAuthorities(authorities []string)

type VirtualFilterChain ¶

type VirtualFilterChain struct {
	// contains filtered or unexported fields
}

VirtualFilterChain 虚拟过滤器链 在过滤器执行过程中跟踪当前索引，实现链式调用 每个过滤器执行完毕后，通过VirtualFilterChain触发下一个过滤器

func (c *VirtualFilterChain) DoFilter(ctx context.Context, request SecurityRequest, response SecurityResponse) error

type WebExpressionVoter ¶

type WebExpressionVoter struct{}

WebExpressionVoter Web表达式投票者 支持Spring Security风格的Web表达式语言 用于解析和执行权限表达式（如hasRole、hasAuthority等）

func NewWebExpressionVoter() *WebExpressionVoter

func (v *WebExpressionVoter) Vote(ctx context.Context, authentication Authentication, object any, attributes []string) int

type WebSecurity ¶

type WebSecurity struct{}

WebSecurity Web安全配置入口 提供创建HTTP安全配置的工厂方法

func NewWebSecurity() *WebSecurity

func (w *WebSecurity) Build() (SecurityFilterChain, error)

func (w *WebSecurity) HttpSecurity() *httpSecurity