高速服务框架HSF的基本原理

public interface HelloWorldService {
    /**     * 根据参数中指定的名字，生成问候语     *     * @param name 被问候的姓名     * @return 问候语     */    String sayHi(String name);}

    com.alibaba.middleware    hsf-guide-api

// 实现接口public class HelloWorldServiceImpl implements HelloWorldService {
    @Override    public String sayHi(String name) {        // 编写业务代码        if (name == null || name.length() == 0) {            return null;        }        return "Hi, " + name + "! Welcome to the HSF world.";    }}

    com.alibaba.middleware    hsf-guide-biz
    com.taobao.hsf    hsf-all

// [定义] 服务的实现Object target = new HelloWorldServiceImpl();
// [设置] HSF服务发布逻辑HSFApiProviderBean hsfApiProviderBean = new HSFApiProviderBean();// [设置] 发布服务的接口hsfApiProviderBean.setServiceInterface("com.alibaba.middleware.hsf.guide.api.service.HelloWorldService");// [设置] 服务的实现对象hsfApiProviderBean.setTarget(target);// [设置] 服务的版本hsfApiProviderBean.setServiceVersion("1.0.0");// [设置] 服务的归组hsfApiProviderBean.setServiceGroup("HSF");// [设置] 服务的响应时间hsfApiProviderBean.setClientTimeout(3000);// [设置] 服务传输业务对象时的序列化类型hsfApiProviderBean.setSerializeType("hessian2");
// [发布] HSF服务hsfApiProviderBean.init();

    com.alibaba.boot    pandora-hsf-spring-boot-starter    2023-04-release

@HSFProvider(serviceInterface = HelloWorldService.class, serviceGroup = "HSF", serviceVersion = "1.0.0", clientTimeout = 3000, serializeType = "hessian2")public class HelloWorldServiceImpl implements HelloWorldService {
    @Override    public String sayHi(String name) {        if (name == null || name.length() == 0) {            return null;        }        return "Hi, " + name + "! Welcome to the HSF world.";    }}

HSFApiConsumerBean hsfApiConsumerBean = new HSFApiConsumerBean();// [设置] 订阅服务的接口hsfApiConsumerBean.setInterfaceName("com.alibaba.middleware.hsf.guide.api.service.HelloWorldService");// [设置] 服务的版本hsfApiConsumerBean.setVersion("1.0.0");// [设置] 服务的组别hsfApiConsumerBean.setGroup("HSF");
// [订阅] HSF服务，同步等待地址推送，默认false（异步），同步默认超时时间为3000mshsfApiConsumerBean.init(true);
// [代理] 获取HSF代理HelloWorldService helloWorldService = (HelloWorldService) hsfApiConsumerBean.getObject();
// [调用] 像调用本地接口一样，发起HSF调用String hi = helloWorldService.sayHi("松张");System.out.println(hi);

@Configurationpublic class HsfConfig {
    @HSFConsumer(serviceVersion = "1.0.0", serviceGroup = "HSF")    HelloWorldService helloWorldService;}

@AutowiredHelloWorldService helloWorldService;

HSFApiConsumerBean hsfApiConsumerBean = new HSFApiConsumerBean();hsfApiConsumerBean.setInterfaceName("com.alibaba.middleware.hsf.guide.api.service.HelloWorldService");hsfApiConsumerBean.setVersion("1.0.0");hsfApiConsumerBean.setGroup("HSF");
// [设置] 异步future调用List asyncCallMethods = new ArrayList();// [格式] name:{methodName};type:futureasyncCallMethods.add("name:sayHi;type:future");hsfApiConsumerBean.setAsyncallMethods(asyncCallMethods);
hsfApiConsumerBean.init(true);
HelloWorldService helloWorldService = (HelloWorldService) hsfApiConsumerBean.getObject();
String hi = helloWorldService.sayHi("松张");// 运行后控制台打印nullSystem.out.println(hi);
// 及时在当前调用上下文中获取future对象；因为该对象是放在ThreadLocal中的，同一线程中后续调用会覆盖future对象，所以要及时取出HSFFuture hsfFuture = HSFResponseFuture.getFuture();
// do something else
try {    // 这里才是真正地获取结果，如果调用还未完成，将阻塞等待结果，3000ms是等待结果的最大时间    System.out.println(hsfFuture.getResponse(3000));} catch (Throwable e) {    e.printStackTrace();}

// 实现了HSFResponseCallback接口的Listenerpublic class MyCallbackHandler implements HSFResponseCallback {
    @Override    public void onAppException(Throwable t) {        t.printStackTrace();    }
    @Override    public void onAppResponse(Object o) {        // 取callback调用时设置的上下文        Object context = CallbackInvocationContext.getContext();        // 打印远程调用结果 + callback调用时设置的上下文        System.out.println(o.toString() + context);    }
    @Override    public void onHSFException(HSFException e) {        e.printStackTrace();    }}

HSFApiConsumerBean hsfApiConsumerBean = new HSFApiConsumerBean();hsfApiConsumerBean.setInterfaceName("com.alibaba.middleware.hsf.guide.api.service.HelloWorldService");hsfApiConsumerBean.setVersion("1.0.0");hsfApiConsumerBean.setGroup("HSF");
// [设置] 异步callback调用List asyncCallMethods = new ArrayList();// [格式] name:{methodName};type:callback;listener:{listenerFullyQualifiedName}asyncCallMethods.add("name:sayHi;type:callback;listener:com.alibaba.middleware.hsf.guide.client.handler.CallbackHandler");hsfApiConsumerBean.setAsyncallMethods(asyncCallMethods);
hsfApiConsumerBean.init(true);
HelloWorldService helloWorldService = (HelloWorldService) hsfApiConsumerBean.getObject();
// 可选步骤，设置上下文。CallbackHandler中通过api可以获取到CallbackInvocationContext.setContext(" in callback");
String hi = helloWorldService.sayHi("松张");// 运行后控制台打印nullSystem.out.println(hi);
// 清理上下文CallbackInvocationContext.setContext(null);
// do something else

HSFApiConsumerBean hsfApiConsumerBean = new HSFApiConsumerBean();hsfApiConsumerBean.setInterfaceName("com.alibaba.middleware.hsf.guide.api.service.HelloWorldService");hsfApiConsumerBean.setVersion("1.0.0");hsfApiConsumerBean.setGroup("HSF");
// [设置] 泛化配置hsfApiConsumerBean.setGeneric("true");hsfApiConsumerBean.init(true);
// 使用泛化接口获取代理GenericService genericHelloWorldService = (GenericService)hsfApiConsumerBean.getObject();
// [调用] 发起HSF泛化调用，返回指定类型的resultString helloWorldStr = (String)genericHelloWorldService.$invoke("sayHi",    // 方法入参类型数组（xxx.getClass().getName())    new String[] {String.class.getName()},    // 参数，如果是pojo，则需要转成Map    new Object[] {"松张"});System.out.println(helloWorldStr);

Protocol protocol = HSFServiceContainer.getInstance(Protocol.class);List handlers = HSFServiceContainer.getInstances(ProtocolInterceptor.class);
//initProtocol last = protocol;for (int i = handlers.size() - 1; i >= 0; i--) {    handlers.get(i).setProtocol(last);    last = handlers.get(i);}return last;

public abstract class AbstractDelegateProtocolInterceptor implements ProtocolInterceptor {
    protected Protocol protocol;
    @Override    public List export(ServiceMetadata serviceMetadata, InvocationHandler invocationHandler) {        return protocol.export(serviceMetadata,invocationHandler);    }}

@Order(250)public class EagleEyeProtocolInterceptor extends AbstractDelegateProtocolInterceptor {
    /**     * container信息(edas)     */    private ContainerInfo containerInfo = HSFServiceContainer.getInstance(ContainerInfo.class);
    @Override    public List export(ServiceMetadata serviceMetadata, InvocationHandler invo服务器托管cationHandler) {        if (containerInfo.isSupportContainer()) {            serviceMetadata.addProperty(HSFConstants.CONTAINER_ID_KEY, containerInfo.getContainerId());        }
        return protocol.export(serviceMetadata, invocationHandler);    }}

Object proxy = proxyFactory.getProxy(metadata, decorateInterfaces);

public Object getProxy(ServiceMetadata metadata, Class>... interfacesArray) {    try {        JdkProxyInvocationHandler jdkProxyInvocationHandler = new JdkProxyInvocationHandler(metadata);        Object instance = Proxy.newProxyInstance(metadata.getIfClazz().getClassLoader(), interfacesArray, jdkProxyInvocationHandler);        jdkProxyInvocationHandler.init(instance);        return instance;    } catch (Throwable t) {        throw new HSFException("failed to generate jdk proxy",t);    }}

public Object invoke(final Object proxy, final Method method, final Object[] args) throws Throwable {    ApplicationModelFactory.setCurrentApplication(serviceMetadata.getApplicationModel());
    ConsumerMethodModel methodModel = serviceMetadata.getConsumerServiceModel().getMethodModel(method);    return InvocationUtil.invoke(methodModel, args);}

public void registerListener(Object listener) {    synchronized (eventBus) {        if (lastRule != null) {            eventBusHelp.register(listener);            eventBusHelp.post(lastRule);            eventBusHelp.unregister(listener);        }
        eventBus.register(listener);    }}

/** * 使用该接口对客户端元数据进行处理，返回需要装饰的接口 */@Shared@Scope(Scope.Option.SINGLETON)public interface ProxyDecorator {
    /**     * 用来装饰当前的调用接口     *     * @param serviceMetadata 客户端元数据     * @return 装饰接口，如果不进行装饰返回null     */    Class> decorate(ServiceMetadata serviceMetadata);}

// 生成调用远程HSF服务的代理ProxyDecoratorGenerator proxyDecoratorGenerator = HSFServiceContainer.getInstance(        ProxyDecoratorGenerator.class);// 获取装饰后的接口Class>[] decorateInterfaces = proxyDecoratorGenerator.getDecorateInterfaces(metadata);
ProxyFactory proxyFactory = HSFServiceContainer.getInstance(ProxyFactory.class, metadata.getProxyStyle());Object proxy = proxyFactory.getProxy(metadata, decorateInterfaces);Method[] methods = proxyFactory.getMethods(proxy);