<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-web</artifactId>
    <version>6.1.0+</version> <!-- 必須6.1+ -->
</dependency>

/**  
 * <pre>
 *  調(diào)用遠(yuǎn)程同步角色權(quán)限服務(wù)
 *    注：http://horus/horus這個配置，非常關(guān)鍵：
 *       1. 第一個horus表示遠(yuǎn)程服務(wù)應(yīng)用的名字（注冊到nacos注冊中心的應(yīng)用名，運行期間會被負(fù)載均衡攔截并替換成實際的ip和端口）
 *       2. 第二個horus配置表示遠(yuǎn)程服務(wù)的base上下文路徑，即contextPath，如果遠(yuǎn)程應(yīng)用不帶上下文路徑，這里配置成http://horus即可
 * </pre>
 * @author sinhy
 * @since 2022-07-13 17:00
 * @version V1.0  
 */
@HttpExchange(url = "http://horus/horus")
public interface AuthoritySyncSDKService
{
    /**
     * 同步角色權(quán)限
     * @author sinhy
     * @since 2022-07-13 16:06  void
     */
    @PostExchange("/syncRoleAuthority")
    void syncRoleAuthority();
}

@Configuration
public class HttpExchangeFluxConfiguration
{
    /**
     *  @LoadBalanced負(fù)載均衡注入，此注解用于標(biāo)記RestTemplate、RestClient或WebClient.Builder這幾類對象。將生成器bean配置為使用LoadBalancerClient。
     * @author lilinhai
     * @since 2025-04-15 16:23 
     * @return WebClient.Builder
     */
    @LoadBalanced
    @Bean
    public RestClient.Builder loadBalancedWebClientBuilder()
    {
        return RestClient.builder().requestFactory(new HttpComponentsClientHttpRequestFactory(httpClient()));
    }
    @Bean
    public TokenPropagationExchangeFilterFunction tokenFilter()
    {
        return new TokenPropagationExchangeFilterFunction();
    }
    @Bean
    public HttpServiceProxyFactory httpServiceProxyFactory(RestClient.Builder restClientBuilder, TokenPropagationExchangeFilterFunction tokenFilter)
    {
        restClientBuilder.requestInterceptor(tokenFilter);
        RestClient restClient = restClientBuilder.build();
        return HttpServiceProxyFactory.builderFor(RestClientAdapter.create(restClient)).build();
    }
    private PoolingHttpClientConnectionManager poolingConnManager()
    {
        PoolingHttpClientConnectionManager pool = new PoolingHttpClientConnectionManager();
        // 最大連接數(shù)
        pool.setMaxTotal(200);
        // 每個路由的最大連接數(shù)
        pool.setDefaultMaxPerRoute(50);
        return pool;
    }
    private HttpClient httpClient()
    {
        return HttpClients.custom()
            .setConnectionManager(poolingConnManager())
            .setConnectionReuseStrategy(new DefaultClientConnectionReuseStrategy())
            .evictExpiredConnections()
            .evictIdleConnections(TimeValue.ofSeconds(30))
            .build();
    }
}

/**  
 * 令牌透傳過濾器
 * @author lilinhai
 * @since 2025-04-15 14:35
 * @version V1.0  
 */
public class TokenPropagationExchangeFilterFunction implements ClientHttpRequestInterceptor
{
    @Override
    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException
    {
        // 設(shè)置授權(quán)信息
        RequestAttributes ra = RequestContextHolder.getRequestAttributes();
        if (ra != null)
        {
            ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) ra;
            String clientInfoJsonStr = servletRequestAttributes.getRequest().getHeader(WebHttpConstant.CLIENT_INFO_HEADER_NAME);
            if (clientInfoJsonStr != null)
            {
                request.getHeaders().add(WebHttpConstant.CLIENT_INFO_HEADER_NAME, clientInfoJsonStr);
            }
            String acceptLanguage = servletRequestAttributes.getRequest().getHeader(HttpHeaders.ACCEPT_LANGUAGE);
            if (acceptLanguage != null)
            {
                request.getHeaders().add(HttpHeaders.ACCEPT_LANGUAGE, acceptLanguage);
            }
        }
        return execution.execute(request, body);
    }
}

@RestController
@RequestMapping("/authority")
public class AuthoritySyncController {
    private final AuthoritySyncSDKService authoritySyncSDKService;
    public AuthoritySyncController(AuthoritySyncSDKService authoritySyncSDKService)
    {
        this.authoritySyncSDKService = authoritySyncSDKService;
    }
    @GetMapping("/sync")
    public void sync() {
        authoritySyncSDKService.syncRoleAuthority();
    }
}