zoukankan      html  css  js  c++  java
  • dubbo的本地存根(Stub)

    dubbo的本地存根的原理是:远程服务后,客户端通常只剩下接口,而实现全在服务器端,但提供方有些时候想在客户端也执行部分逻辑,那么就在服务消费者这一端提供了一个Stub类,然后当消费者调用provider方提供的dubbo服务时,客户端生成 Proxy 实例,这个Proxy实例就是我们正常调用dubbo远程服务要生成的代理实例,然后消费者这方会把 Proxy 通过构造函数传给 消费者方的Stub ,然后把 Stub 暴露给用户,Stub 可以决定要不要去调 Proxy。会通过代理类去完成这个调用,这样在Stub类中,就可以做一些额外的事,来对服务的调用过程进行优化或者容错的处理。附图:

    实现步骤:

     1. 定义一个服务接口和服务实现类

    public interface UserInterface {
        
        
           public User getUserById(Integer id) ;
    
    }
    public class UserService implements UserInterface {
    
        public User getUserById(Integer id) {
            User user  = new User() ;
            user.setId(id);
            user.setName("hu");
            return user;
        }  
    
    }

    2. 服务分布配置

    <dubbo:service  interface="org.huxin.dubbo.test.user.service.UserInterface" ref="userService" protocol="dubbo"    retries="0"/>
            
    
        <bean id="userService" class="org.huxin.dubbo.test.user.service.impl.UserService" />

    3.服务消费者的Stub类

    public class UserServiceStub implements UserInterface {
        
        //必须定义这个接口,以便接收dubbo在调用远程服务生成的服务代理类
        private UserInterface userLocalService ;
        
        
        
        //这个构造函数必须要提供,dubbo框架会在消费者这一方调用这个方法
        public UserServiceStub(UserInterface userLocalService ) {
            this.userLocalService = userLocalService  ;
        }
    
        public User getUserById(Integer id) {

            User user = null ;
            try {
              if (id == 1) {
                user = this.userLocalService.getUserById(id) ;
              }else {
                user = new User();
                user.setName("系统用户");
              }
            }catch(Exception e) {
              user = new User();
              user.setName("异常用户");
            }

                  return user ;

        }
    }

    4. 服务消费方的配置

     <dubbo:reference id="userService" interface="org.huxin.dubbo.test.user.service.UserInterface" 
                        stub="org.huxin.dubbo.test.UserServiceStub" protocol="dubbo"/>

    5.测试代码

    @Test
    	public void testGetUserById(){
    		Integer id = 2 ;
    	        UserInterface  userService = context.getBean(UserInterface.class) ;
    		User user = userService.getUserById( id) ;
    		System.out.println(user.getName());  
    		
    	}
    

      

    总结:上述代码当调用服务出错时,消费方会返回“异常用户”,起到了容错的作用。

  • 相关阅读:
    [转][LeetCode]Longest Common Prefix ——求字符串的最长公共前缀
    [转]最长回文子串——4种解法
    [转]通过金矿模型介绍动态规划
    一句话说清楚什么是闭包函数
    [转]as3事件流机制彻底理解
    Eclipse 快捷键
    文件打包与解压缩
    第5节 环境变量与文件查找
    vim的多标签
    java思维导图
  • 原文地址:https://www.cnblogs.com/hzhuxin/p/8250602.html
Copyright © 2011-2022 走看看