From cc374a6aa224c4475df66edc4d0d78759028848f Mon Sep 17 00:00:00 2001
From: wcc1433 <37837522+wcc1433@users.noreply.github.com>
Date: Mon, 26 May 2025 19:19:00 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E4=B8=AA=E7=8E=AF=E5=A2=83=EF=BC=8C?=
 =?UTF-8?q?=E6=AF=8F=E4=B8=AA=E7=8E=AF=E5=A2=83=E5=8A=A0=E8=BD=BD=E7=9B=B8?=
 =?UTF-8?q?=E5=90=8C=20Mapper=20=EF=BC=88=E4=BE=8B=E5=A6=82=20RowMapper?=
 =?UTF-8?q?=EF=BC=89=E4=BC=9A=E5=AF=BC=E8=87=B4=E7=8E=AF=E5=A2=83=E5=86=B2?=
 =?UTF-8?q?=E7=AA=81=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

创建多个环境，每个环境加载相同 Mapper （例如 RowMapper）会导致环境冲突。
代码：
// 环境实例1
MybatisFlexBootstrap client1 = ...;
client1.addMapper(RowMapper.class);
// 环境实例2：
MybatisFlexBootstrap client2 = // ;
client2.addMapper(RowMapper.class);

client1.getMapper(RowMapper.class);
// client2 拿到的永远都是 client1 的 RowMapper
client2.getMapper(RowMapper.class);
---
 .../src/main/java/com/mybatisflex/core/mybatis/Mappers.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/mybatis-flex-core/src/main/java/com/mybatisflex/core/mybatis/Mappers.java b/mybatis-flex-core/src/main/java/com/mybatisflex/core/mybatis/Mappers.java
index f30512ec..95d5491c 100644
--- a/mybatis-flex-core/src/main/java/com/mybatisflex/core/mybatis/Mappers.java
+++ b/mybatis-flex-core/src/main/java/com/mybatisflex/core/mybatis/Mappers.java
@@ -28,7 +28,6 @@ import com.mybatisflex.core.util.MapUtil;
 import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.Method;
 import java.lang.reflect.Proxy;
-import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
@@ -80,7 +79,7 @@ public class Mappers {
      * @return {@link BaseMapper} 对象
      */
     public static <M> M ofMapperClass(Class<M> mapperClass) {
-        Map<Class<?>, Object> mapperObjects = MapUtil.computeIfAbsent(MAPPER_OBJECTS_OF_ENV, "default", envId -> new HashMap<>());
+        Map<Class<?>, Object> mapperObjects = MapUtil.computeIfAbsent(MAPPER_OBJECTS_OF_ENV, "default", envId -> new ConcurrentHashMap<>());
         Object mapperObject = MapUtil.computeIfAbsent(mapperObjects, mapperClass, clazz ->
             Proxy.newProxyInstance(mapperClass.getClassLoader()
                 , new Class[]{mapperClass}
@@ -88,7 +87,7 @@ public class Mappers {
         return (M) mapperObject;
     }
     public static <M> M ofMapperClass(String environmentId, Class<M> mapperClass) {
-        Map<Class<?>, Object> mapperObjects = MapUtil.computeIfAbsent(MAPPER_OBJECTS_OF_ENV, environmentId, envId -> new HashMap<>());
+        Map<Class<?>, Object> mapperObjects = MapUtil.computeIfAbsent(MAPPER_OBJECTS_OF_ENV, environmentId, envId -> new ConcurrentHashMap<>());
         Object mapperObject = MapUtil.computeIfAbsent(mapperObjects, mapperClass, clazz ->
             Proxy.newProxyInstance(mapperClass.getClassLoader()
                 , new Class[]{mapperClass}