美团面试：为什么就能直接调用userMapper接口的方法？

今天药忘吃喽~ 2023-01-01 03:40 94阅读 0赞

关注“Java后端技术全栈”

回复“面试”获取全套面试资料

> 字数：2434，阅读耗时：3分40秒。

老规矩，先上案例代码，这样大家可以更加熟悉是如何使用的，看过Mybatis系列的小伙伴，对这段代码差不多都可以背下来了。

哈哈~，有点夸张吗？不夸张的，就这行代码。

public class MybatisApplication {
            public static final String URL = "jdbc:mysql://localhost:3306/mblog";
            public static final String USER = "root";
            public static final String PASSWORD = "123456";
        
            public static void main(String[] args) {
                String resource = "mybatis-config.xml";
                InputStream inputStream = null;
                SqlSession sqlSession = null;
                try {
                    inputStream = Resources.getResourceAsStream(resource);
                    SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
                    sqlSession = sqlSessionFactory.openSession();
                    //今天主要这行代码
                    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
                    System.out.println(userMapper.selectById(1));
        
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    try {
                        inputStream.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    sqlSession.close();
                }
            }

看源码有什么用？

![format_png][]

> 通过源码的学习，我们可以收获Mybatis的核心思想和框架设计，另外还可以收获设计模式的应用。

前两篇文章我们已经[Mybatis配置文件解析][Mybatis]到[获取SqlSession][SqlSession]，下面我们来分析从SqlSession到userMapper：

UserMapper userMapper = sqlSession.getMapper(UserMapper.class);

前面那篇文章已经知道了这里的sqlSession使用的是默认实现类DefaultSqlSession。所以我们直接进入DefaultSqlSession的getMapper方法。

//DefaultSqlSession中  
        private final Configuration configuration;
        //type=UserMapper.class
        @Override
        public <T> T getMapper(Class<T> type) {
          return configuration.getMapper(type, this);
        }

这里有三个问题：

![format_png 1][]

### 问题1：getMapper返回的是个什么对象？ ###

上面可以看出，getMapper方法调用的是Configuration中的getMapper方法。然后我们进入Configuration中

//Configuration中  
        protected final MapperRegistry mapperRegistry = new MapperRegistry(this);
        type=UserMapper.class
        public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
            return mapperRegistry.getMapper(type, sqlSession);
        }

这里也没做什么，继续调用MapperRegistry中的getMapper：

//MapperRegistry中
        public class MapperRegistry {
          //主要是存放配置信息
          private final Configuration config;
          //MapperProxyFactory 的映射
          private final Map<Class<?>, MapperProxyFactory<?>> knownMappers = new HashMap<>();
        
          //获得 Mapper Proxy 对象
          //type=UserMapper.class,session为当前会话
          public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
            //这里是get，那就有add或者put
            final MapperProxyFactory<T> mapperProxyFactory = (MapperProxyFactory<T>) knownMappers.get(type);
            if (mapperProxyFactory == null) {
              throw new BindingException("Type " + type + " is not known to the MapperRegistry.");
            }
           try {
              //创建实例
              return mapperProxyFactory.newInstance(sqlSession);
            } catch (Exception e) {
              throw new BindingException("Error getting mapper instance. Cause: " + e, e);
            }
          }
          
          //解析配置文件的时候就会调用这个方法，
          //type=UserMapper.class
          public <T> void addMapper(Class<T> type) {
            // 判断 type 必须是接口，也就是说 Mapper 接口。
            if (type.isInterface()) {
                //已经添加过，则抛出 BindingException 异常
                if (hasMapper(type)) {
                    throw new BindingException("Type " + type + " is already known to the MapperRegistry.");
                }
                boolean loadCompleted = false;
                try {
                    //添加到 knownMappers 中
                    knownMappers.put(type, new MapperProxyFactory<>(type));
                    //创建 MapperAnnotationBuilder 对象，解析 Mapper 的注解配置
                    MapperAnnotationBuilder parser = new MapperAnnotationBuilder(config, type);
                    parser.parse();
                    //标记加载完成
                    loadCompleted = true;
                } finally {
                    //若加载未完成，从 knownMappers 中移除
                    if (!loadCompleted) {
                        knownMappers.remove(type);
                    }
                }
            }
        }
        }

MapperProxyFactory对象里保存了mapper接口的class对象，就是一个普通的类，没有什么逻辑。

在MapperProxyFactory类中使用了两种设计模式：

1.  **单例模式**methodCache（注册式单例模式）。
2.  **工厂模式**getMapper()。

继续看MapperProxyFactory中的newInstance方法。

public class MapperProxyFactory<T> {
          private final Class<T> mapperInterface;
          private final Map<Method, MapperMethod> methodCache = new ConcurrentHashMap<>();
        
          public MapperProxyFactory(Class<T> mapperInterface) {
            this.mapperInterface = mapperInterface;
          }
         public T newInstance(SqlSession sqlSession) {
          //创建MapperProxy对象
          final MapperProxy<T> mapperProxy = new MapperProxy<>(sqlSession, mapperInterface, methodCache);
          return newInstance(mapperProxy);
        }
        //最终以JDK动态代理创建对象并返回
         protected T newInstance(MapperProxy<T> mapperProxy) {
            return (T) Proxy.newProxyInstance(mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy);
        }
        }

从代码中可以看出，依然是稳稳的基于 JDK Proxy 实现的，而 InvocationHandler 参数是 MapperProxy 对象。

//UserMapper 的类加载器
        //接口是UserMapper
        //h是mapperProxy对象
        public static Object newProxyInstance(ClassLoader loader,
                                                  Class<?>[] interfaces,
                                               InvocationHandler h){
        }

### 问题2：为什么就可以调用他的方法？ ###

上面调用newInstance方法时候创建了MapperProxy对象，并且是当做newProxyInstance的第三个参数，所以MapperProxy类肯定实现了InvocationHandler。

进入MapperProxy类中：

//果然实现了InvocationHandler接口
        public class MapperProxy<T> implements InvocationHandler, Serializable {
        
          private static final long serialVersionUID = -6424540398559729838L;
          private final SqlSession sqlSession;
          private final Class<T> mapperInterface;
          private final Map<Method, MapperMethod> methodCache;
        
          public MapperProxy(SqlSession sqlSession, Class<T> mapperInterface, Map<Method, MapperMethod> methodCache) {
            this.sqlSession = sqlSession;
            this.mapperInterface = mapperInterface;
            this.methodCache = methodCache;
          }
          //调用userMapper.selectById()实质上是调用这个invoke方法
          @Override
          public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
            try {
              //如果是Object的方法toString()、hashCode()等方法  
              if (Object.class.equals(method.getDeclaringClass())) {
                return method.invoke(this, args);
              } else if (method.isDefault()) {
                //JDK8以后的接口默认实现方法  
                return invokeDefaultMethod(proxy, method, args);
              }
            } catch (Throwable t) {
              throw ExceptionUtil.unwrapThrowable(t);
            }
            //创建MapperMethod对象
            final MapperMethod mapperMethod = cachedMapperMethod(method);
            //下一篇再聊
            return mapperMethod.execute(sqlSession, args);
          }
        }

也就是说，getMapper方法返回的是一个JDK动态代理对象（类型是$Proxy+数字）。这个代理对象会继承Proxy类，实现被代理的接口UserMpper，里面持有了一个MapperProxy类型的触发管理类。

**当我们调用UserMpper的方法时候，实质上调用的是MapperProxy的invoke方法。**

userMapper=$Proxy6@2355。

![format_png 2][]

为什么要在MapperRegistry中保存一个工厂类？

原来他是用来创建并返回代理类的。这里是代理模式的一个非常经典的应用。

![format_png 3][]

MapperProxy如何实现对接口的代理？

#### JDK动态代理 ####

我们知道，JDK动态代理有三个核心角色：

*  被代理类（即就是实现类）
 *  接口
 *  实现了InvocationHanndler的触发管理类，用来生成代理对象。

被代理类必须实现接口，因为要通过接口获取方法，而且代理类也要实现这个接口。

![format_png 4][]

而Mybatis中并没有Mapper接口的实现类，怎么被代理呢？它忽略了实现类，直接对Mapper接口进行代理。

#### MyBatis动态代理： ####

在Mybatis中，JDK动态代理为什么不需要实现类呢？

![format_png 5][]

这里我们的目的其实就是根据一个可以执行的方法，直接找到Mapper.xml中statement ID ，方便调用。

最后返回的userMapper就是MapperProxyFactory的创建的代理对象，然后这个对象中包含了MapperProxy对象，

### 问题3：到底是怎么根据Mapper.java找到Mapper.xml的？ ###

最后我们调用userMapper.selectUserById()，本质上调用的是MapperProxy的invoke()方法。

请看下面这张图：

![format_png 6][]

如果根据(接口+方法名找到Statement ID )，这个逻辑在InvocationHandler子类（MapperProxy类）中就可以完成了，其实也就没有必要在用实现类了。

![format_png 7][]

### 总结 ###

本文中主要是讲getMapper方法，该方法实质上是获取一个JDK动态代理对象（类型是Proxy+数字）,这个代理类会继承MapperProxy类，实现被代理的接口UserMapper，并且里面持有一个MapperProxy类型的触发管理类。这里我们就拿到代理类了，后面我们就可以使用这个代理对象进行方法调用。

问题涉及到的设计模式：

1.  代理模式。
2.  工厂模式。
3.  单例模式。

整个流程图：

![format_png 8][]

> 冰冻三尺，非一日之寒表面意义是冰冻了三尺，并不是一天的寒冷所能达到的效果。学习亦如此，你每一天的一点点努力，都是为你以后的成功做铺垫。

推荐阅读

[面试官：Integer缓存最大范围只能是-128到127吗？][Integer_-128_127]

[6000多字 | 秒杀系统设计注意点【理论】][6000_ _]

[面试官：说说你对Java异常的理解][Java]

[《程序员面试宝典》.pdf下载][.pdf]

[《高性能MySQL》.pdf下载][MySQL_.pdf]

![format_png 9][]

[format_png]: /images/20221120/60f66179969045f8b29c22888653aa37.png
[Mybatis]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd554541ca22cc57af8d3df7c81421dbbc991240323ae9c16e32c70b80683a1406c9f8f45330&idx=1&mid=2247495082&scene=21&sn=7dfd8ce506deffb2924e32c085d1849e#wechat_redirect
[SqlSession]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd555a5aca22d34c137312847b2ed75ee55229627fcacc4de7c03d4148bcda02934a903a31f1&idx=2&mid=2247496369&scene=21&sn=0eb634743e23e6324cffb620cb7850cc#wechat_redirect
[format_png 1]: /images/20221120/86452bc5a40a4bfaa95fad4ed2fc2b06.png
[format_png 2]: /images/20221120/189c9c631a7c435cb8cc05b1084a2cf4.png
[format_png 3]: /images/20221120/5ff11f8dfc914175b5c89e90d19af212.png
[format_png 4]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy8wN0JpY1p5d09WdG1SU1lJaWFNS1ZJdjlrWm92VWRrWWVGNk05UGR3V3NuZFZpYnZ1QjhMc0UwdmhVcnEzOWpLNmFQMElDZU5xUkJadmh3TWlhQlRCa1VsQXcvNjQw?x-oss-process=image/format,png
[format_png 5]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy8wN0JpY1p5d09WdG1SU1lJaWFNS1ZJdjlrWm92VWRrWWVGM0NrZ01jTHM3a01TbmprZlFpYXk0V25pYkNDd2hVcjZ3RnRyZ2UxOVNvMXF2OHBmU251T0Q1bXcvNjQw?x-oss-process=image/format,png
[format_png 6]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy8wN0JpY1p5d09WdG1SU1lJaWFNS1ZJdjlrWm92VWRrWWVGaWFKaWJhcnZsVXBsTGplaWNTdFgwa01NbDZRQXFWWlV2alR3V1JQcEw1dHR6a0NpYnJWcWljMGJjaWF3LzY0MA?x-oss-process=image/format,png
[format_png 7]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy8wN0JpY1p5d09WdG1SU1lJaWFNS1ZJdjlrWm92VWRrWWVGZU5ScnpUb09xUGt2c1JRaDlUNW8wR3hzRFpnNlhLNzIxbTlpY2Q2VjFpY1BTU0JSNDFqSm5FZVEvNjQw?x-oss-process=image/format,png
[format_png 8]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy8wN0JpY1p5d09WdG1SU1lJaWFNS1ZJdjlrWm92VWRrWWVGWVltdWZURkJVOGJpYzA5SmpPczBVZ2dheHlGamFpY1dvZm94WXFIOElCR25VUmlhdUJwNkdBcnhnLzY0MA?x-oss-process=image/format,png
[Integer_-128_127]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd5543f6ca22cae0b599d7aa24a54f785684bd85772f9eb4fa7b92617be0557416b3dd3eb41f&idx=1&mid=2247494429&scene=21&sn=fc7816340859ab7969b00ca90160fc25#wechat_redirect
[6000_ _]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd554364ca22ca725928445323212594625cb2052a1fb1ec27d76fc46c6b813afb942f761f0a&idx=1&mid=2247494543&scene=21&sn=af1c26ff3af473898b32c6256a01871d#wechat_redirect
[Java]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd55439fca22ca893e5f162d3d12c7018bd2741e8799dda78a0be1f98c55f0fefc2820518e9d&idx=1&mid=2247494516&scene=21&sn=a626387810d702ca972c01234b0da172#wechat_redirect
[.pdf]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd5540c2ca22c9d43adaea71eac78fd27ccbc395d86ab9a0bd7058ec846752854ba6891c29aa&idx=2&mid=2247493673&scene=21&sn=56f250a42913fed1b56fe6be41810b56#wechat_redirect
[MySQL_.pdf]: http://mp.weixin.qq.com/s?__biz=MzU4MDM3MDgyMA%3D%3D&chksm=fd554735ca22ce236bc02c247a76f1d8352573de4a949638cdef972f27811e14c498c74b55ad&idx=2&mid=2247495646&scene=21&sn=1c636fc1b0f51955aadb8405cdb79795#wechat_redirect
[format_png 9]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy8wN0JpY1p5d09WdGtrNW5LTTFoT2FSMGlhWHhHSDdpYnVrUEpPUmpvcFRYOGxKNUVscHZyWFBtRzZKNUZlOGVlWUJvclNpYlJKeW00aWN5T1d1cHB5dHgxYzlBLzY0MA?x-oss-process=image/format,png