Enplee's blog

public interface BuyHouse {
   void buyHosue();
}
// 被代理类
 public class BuyHouseImpl implements BuyHouse {
    @Override
    public void buyHosue() {
        System.out.println("我要买房");
    }
 }
 
public class Proxy implements BuyHouse {
    
    BuyHouseImpl buyHouseImpl;
    
    @Override
    public void buyHosue() {
        System.out.println("-----");
        buyHouseImpl.buyHosue();
        System.out.println("-----");
    }
}

Proxy.newProxyInstance(ClassLoader loader,Class<?>[] interfaces,InvocationHandler invocationHandler)

@Slf4j
public class RpcClientProxy implements InvocationHandler {

    private static final String INTERFACE_NAME = "interfaceName :";
    private final RpcServiceConfig rpcServiceConfig;
    private final RpcRequestTransposter rpcRequestTransposter;

    public RpcClientProxy(RpcServiceConfig rpcServiceConfig, RpcRequestTransposter rpcRequestTransposter) {
        this.rpcServiceConfig = rpcServiceConfig;
        this.rpcRequestTransposter = rpcRequestTransposter;
    }
    
    @SuppressWarnings("unchecked")
    public <T> T getProxy(Class<T> clazz) {
        return (T) Proxy.newProxyInstance(clazz.getClassLoader(),new Class<?>[]{clazz},  this);
    }

    @SuppressWarnings("unchecked")
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        //封装RpcReques
        log.info("invoke method [{}]", method.getName());
        RpcRequest rpcRequest = RpcRequest.builder().methordName(method.getName())
                                .args(args)
                                .argsType(method.getParameterTypes())
                                .requestId(UUID.randomUUID().toString())
                                .group(rpcServiceConfig.getGroup())
                                .version(rpcServiceConfig.getVersion())
                                .serviceName(method.getDeclaringClass().getName()).build();
        // rpcTransport::sendRpcRequest
        RpcResponce<Object> rpcResponce = null;
        CompletableFuture<RpcResponce<Object>> future = (CompletableFuture<RpcResponce<Object>>) rpcRequestTransposter.sendRpcRequest(rpcRequest);
        log.info("get future,wait process coming......");
        // future::get
        rpcResponce = future.get();
        // check
        this.check(rpcRequest,rpcResponce);
        //return
        return rpcResponce.getData();
    }

    public void check(RpcRequest rpcRequest, RpcResponce<Object> rpcResponce) {
        // judge null：invoke fail
        if(rpcResponce == null) {
            throw new RpcException(RpcErrorMessageEnum.SERVICE_INVOKATION_FAILURE,INTERFACE_NAME+rpcRequest.getServiceName());
        }
        // requestId：request resp not match
        if(!rpcRequest.getRequestId().equals(rpcResponce.getRequstId())){
            throw new RpcException(RpcErrorMessageEnum.REQUEST_NOT_MATCH_REQUEST,INTERFACE_NAME+rpcRequest.getServiceName());
        }
        // getCode： service invoke fail
        if(rpcResponce.getCode() == null || !rpcResponce.getCode().equals(RpcResponseCodeEnum.SUCCESS.getCode())) {
            throw new RpcException(RpcErrorMessageEnum.SERVICE_INVOKATION_FAILURE,INTERFACE_NAME+rpcRequest.getServiceName());
        }
    }
}

public boolean checkZeroOnes(String s) {
    int maxOne = 0, maxZero = 0;
    int idx = 0;
    while (idx<s.length()) {
        if(s.charAt(idx)=='1'){
            int temp = 0;
            while (idx<s.length() && s.charAt(idx) == '1'){
                idx++;
                temp++;
            }
            maxOne = Math.max(maxOne,temp);
        }else {
            int temp = 0;
            while (idx<s.length() && s.charAt(idx) == '0'){
                idx++;
                temp++;
            }
            maxZero = Math.max(maxZero,temp);
        }
    }
    return maxOne>maxZero;
}

public int subsetXORSum(int[] nums) {
    int len = nums.length;
    int res = 0;
    for(int i=0;i<(1<<len);i++){
        res += getXOR(nums,i);
    }
    return res;
}
public int getXOR(int[] nums,int i){
    int sum = 0;
    if(i==0) return 0;
    for(int k=0;k<31;k++){
        if((i&k)!=0) sum^= nums[k];
    }
    return sum;
}

public int minimumTimeRequired(int[] jobs, int k) {
    int n = jobs.lenth;
    int m = 1<<n;
    
    int[][] dp = new int[n][m];
    int[] sum = new int[m];
    
    for(int i=1;i<m;i++){
        int j = Integer.numberOfTrailingZeros(i),x = i^(1<<j);
        sum[i] = sum[x] + jobs[j];
        dp[0][i] = sum[i];
    }
    
    for(int i=1;i<k;i++){
        for(int j=1;j<m;j--){
            int maxn = Integer.MAX_VALUE;
            for(int k=j;k!=0;k=(k-1)&j) {
                maxn = Math.min(maxn,Math.Max(sum[k],dp[i-1][j-k]));
            }
        }
    }
    return dp[k-1][m-1];
}