Browse Source

删除MongDb相关代码,删除多余的配置文件。

huangbo 4 years ago
parent
commit
1b35da4a18

+ 1 - 1
ipu-nacos-demo/src/main/resources/dev/application.properties

@ -31,7 +31,7 @@ nacos.config.server-addr=47.105.160.21:8800
31 31
#nacos.config.ext-config[1].group=DEFAULT_GROUP
32 32
#nacos.config.ext-config[1].refresh=true
33 33

34
#老版本配置,方法------------------------------------------------------
34
#老版本配置,方法------------------------------------------------------
35 35
#nacos.config.shared-dataids=data1, data2
36 36
#nacos.config.refreshable-dataids=data1, data2
37 37
# 主配置 group-id

+ 0 - 123
ipu-rest-scaffold/src/main/java/com/ai/ipu/server/control/MongoDbController.java

@ -1,123 +0,0 @@
1
package com.ai.ipu.server.control;
2
3
import com.ai.ipu.basic.util.IpuException;
4
import com.ai.ipu.basic.util.IpuUtility;
5
import com.ai.ipu.data.JMap;
6
import com.ai.ipu.data.impl.JsonMap;
7
import com.ai.ipu.server.service.MongoDbService;
8
import com.ai.ipu.server.util.RestScaffoldConstant;
9
import org.springframework.beans.factory.annotation.Autowired;
10
import org.springframework.stereotype.Controller;
11
import org.springframework.web.bind.annotation.*;
12
13
/**
14
 * @author miaozy@asiainfo.com
15
 * @desc mongodb使用范例
16
 */
17
@Controller
18
@RequestMapping("/mongodb")
19
public class MongoDbController {
20
21
    @Autowired
22
    MongoDbService MongoDbService;
23
24
    private String connName = "data";
25
    private String dbName = "test";
26
    
27
    @ResponseBody
28
    @RequestMapping("/selectUser")
29
    public JMap executeSelect(JMap params) throws Exception {
30
        JMap retMap = new JsonMap();
31
        params.put("connName", connName);
32
        params.put("dbName", dbName);
33
        if (!params.containsKey("condParam"))
34
        	params.put("condParam", "{\"name\": \"tom\"}");
35
        
36
        try {
37
        	//单独做查询时,不涉及事务控制,因此service的方法名命名就可以不遵照process开头。
38
            retMap.put("resultList", MongoDbService.executeSelect(params));
39
        } catch (IpuException ie) {
40
        	IpuUtility.error(ie.getMessage());
41
        } catch (Exception e) {
42
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_004);
43
        }
44
        return retMap;
45
    }
46
47
    @ResponseBody
48
    @RequestMapping("/insertUser")
49
    public JMap executeInsert(JMap params) throws Exception {
50
        JMap retMap = new JsonMap();
51
        params.put("connName", connName);
52
        params.put("dbName", dbName);
53
        if (!params.containsKey("operType"))
54
        	params.put("operType", "insertUser");
55
        
56
        try {
57
        	/* 涉及事务控制,因此service的方法名命名就要遵照process开头。
58
        	 * 一个process开头的方法里,所有对mongodb的增删改都是一个事务
59
        	 * 如果需要支持多事务,有2种解决方案:
60
        	 * 1、不同的事务使用不同的service方法;参见processInsertUser和processInsertLog
61
        	 * 2、在一个service方法里,直接声明独立事务。参见processInsertUserAndLog
62
        	*/
63
            MongoDbService.processInsertUserAndLog(params);
64
            retMap.put("result", "插入一条用户记录成功");
65
        } catch (IpuException ie) {
66
        	IpuUtility.error(ie.getMessage());
67
        } catch (Exception e) {
68
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_005);
69
        }
70
        return retMap;
71
    }
72
73
    @ResponseBody
74
    @RequestMapping("/updateUser")
75
    public JMap executeUpdate(JMap params) throws Exception {
76
        JMap retMap = new JsonMap();
77
        params.put("connName", connName);
78
        params.put("dbName", dbName);
79
        if (!params.containsKey("operType"))
80
        	params.put("operType", "updateUser");
81
        if (!params.containsKey("condParam"))
82
        	params.put("condParam", "{\"name\": \"tom\"}");
83
        
84
        try {
85
            try {
86
            	MongoDbService.processInsertLog(params);
87
            }catch (Exception e1) {}
88
            MongoDbService.processUpdateUser(params);
89
            retMap.put("result", "更改用户记录成功");
90
        } catch (IpuException ie) {
91
        	IpuUtility.error(ie.getMessage());
92
        } catch (Exception e) {
93
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_006);
94
        }
95
        return retMap;
96
    }
97
98
    @ResponseBody
99
    @RequestMapping("/deleteUser")
100
    public JMap executeDelete(JMap params) throws Exception {
101
        JMap retMap = new JsonMap();
102
        params.put("connName", connName);
103
        params.put("dbName", dbName);
104
        if (!params.containsKey("operType"))
105
        	params.put("operType", "deleteUser");
106
        if (!params.containsKey("condParam"))
107
        	params.put("condParam", "{\"name\": \"tom\"}");
108
        
109
        try {
110
        	try {
111
            	MongoDbService.processInsertLog(params);
112
            }catch (Exception e1) {}
113
            MongoDbService.processDeleteUser(params);
114
            retMap.put("result", "删除用户记录成功");
115
        } catch (IpuException ie) {
116
        	IpuUtility.error(ie.getMessage());
117
        } catch (Exception e) {
118
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_007);
119
        }
120
        return retMap;
121
    }
122
123
}

+ 0 - 25
ipu-rest-scaffold/src/main/java/com/ai/ipu/server/service/MongoDbService.java

@ -1,25 +0,0 @@
1
package com.ai.ipu.server.service;
2
3
import java.util.List;
4
5
import com.ai.ipu.data.JMap;
6
7
8
/**
9
 * @author miaozy@asiainfo.com
10
 */
11
public interface MongoDbService {
12
13
    List<String> executeSelect(JMap params) throws Exception;
14
15
    void processInsertUser(JMap params) throws Exception;
16
    
17
    void processInsertLog(JMap params) throws Exception;
18
    
19
    void processInsertUserAndLog(JMap params) throws Exception;
20
21
    void processUpdateUser(JMap params) throws Exception;
22
23
    void processDeleteUser(JMap params) throws Exception;
24
25
}

+ 0 - 125
ipu-rest-scaffold/src/main/java/com/ai/ipu/server/service/impl/MongoDbServiceImpl.java

@ -1,125 +0,0 @@
1
package com.ai.ipu.server.service.impl;
2
3
import com.ai.ipu.data.JMap;
4
import com.ai.ipu.nosql.INoSql;
5
import com.ai.ipu.nosql.mongodb.MongoCacheFactory;
6
import com.ai.ipu.server.service.MongoDbService;
7
import com.alibaba.fastjson.JSONObject;
8
9
import java.util.HashMap;
10
import java.util.List;
11
import java.util.Map;
12
import java.util.Map.Entry;
13
14
import org.springframework.stereotype.Service;
15
16
17
/**
18
 * @author miaozy@asiainfo.com
19
 */
20
@Service
21
public class MongoDbServiceImpl implements MongoDbService {
22
	private String tableUser = "userInfo";
23
	private String tableLog = "operLog";
24
25
    @Override
26
    public List<String> executeSelect(JMap params) throws Exception {
27
        String condParam = params.getString("condParam");
28
        String sortParam = params.getString("sortParam") == null ? "{}" : params.getString("sortParam");
29
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
30
        return noSql.executeSelect(condParam, sortParam);
31
    }
32
33
    @Override
34
    public void processInsertUser(JMap params) throws Exception {
35
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
36
        JSONObject json = JSONObject.parseObject(buildUser(params));
37
        noSql.executeInsert(json);
38
    }
39
    
40
    @Override
41
    public void processInsertLog(JMap params) throws Exception {
42
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableLog);
43
//        JSONObject json = JSONObject.parseObject(buildLog(params));
44
//        noSql.executeInsert(json);
45
        //也可以直接用标准sql
46
        noSql.executeInsert("insert into " + tableLog + "(connName, dbName, operType, cond) values ('data', 'test', 'insertUser', null)");
47
    }
48
    
49
    @Override
50
    public void processInsertUserAndLog(JMap params) throws Exception {
51
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableLog);
52
        JSONObject json = JSONObject.parseObject(buildLog(params));
53
        noSql.executeInsert(json);
54
        
55
        //声明独立事务。operLog和userInfo是不同事务,userInfo插入失败不会回滚operLog。
56
        //如果不声明,则operLog和userInfo是同一事务;只要任何一个插入失败,则全部做事务回滚。
57
        MongoCacheFactory.commit(params.getString("connName"), params.getString("dbName"), tableLog);
58
        MongoCacheFactory.clear(params.getString("connName"), params.getString("dbName"), tableLog);
59
        
60
        noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
61
        json = JSONObject.parseObject(buildUser(params));
62
        noSql.executeInsert(json);
63
    }
64
65
    @Override
66
    public void processUpdateUser(JMap params) throws Exception {
67
        String condParam = params.getString("condParam");
68
        String updateField = buildUser(params);
69
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
70
        noSql.executeUpdateMany(condParam, updateField);
71
    }
72
73
    @Override
74
    public void processDeleteUser(JMap params) throws Exception {
75
        String condParam = params.getString("condParam");
76
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
77
        noSql.executeDeleteMany(condParam);
78
    }
79
    
80
    private String buildUser(JMap params) {
81
    	StringBuffer result = new StringBuffer();
82
    	if (params.containsKey("data"))
83
    		result.append(params.getString("data"));
84
        else
85
        {
86
        	JSONObject data = new JSONObject();
87
        	for(Entry<String, Object> entry : params.entrySet()){
88
        		if (entry.getKey().equals("connName") || 
89
        				entry.getKey().equals("dbName") ||
90
        				entry.getKey().startsWith("oper") ||
91
        				entry.getKey().startsWith("cond"))       		
92
        			continue;
93
        		
94
        		data.put(entry.getKey(), entry.getValue());	
95
        	}
96
        	if (data.isEmpty())
97
        	{
98
        		data.put("name", "tom");
99
        		data.put("male", true);
100
        		Map info = new HashMap();
101
        		info.put("city", "beijing");
102
        		info.put("tag", "[\"tennis\",\"football\", \"travel\"]");
103
        		data.put("info", info);
104
        	}
105
        	result.append(data.toJSONString());
106
        }
107
    	return result.toString();
108
    }
109
    
110
    private String buildLog(JMap params) {
111
    	JSONObject data = new JSONObject();
112
    	for(Entry<String, Object> entry : params.entrySet()){
113
    		if (entry.getKey().equals("connName") || 
114
    				entry.getKey().equals("dbName") ||
115
    				entry.getKey().startsWith("oper") ||
116
    				entry.getKey().startsWith("cond"))       		
117
    		{
118
    			data.put(entry.getKey(), entry.getValue());
119
    		}
120
    		
121
    			
122
    	}
123
    	return data.toJSONString();
124
    }
125
}

+ 0 - 69
ipu-rest-scaffold/src/main/resources/dev/ipu-nosql.xml

@ -1,69 +0,0 @@
1
<?xml version = '1.0' encoding = 'UTF-8'?>
2
<connections>
3
    <connection name="data" type="mongo">
4
        <servers>
5
            <server ip="10.1.236.121" port="11000" />
6
            <server ip="10.1.236.121" port="11010" />
7
            <server ip="10.1.236.121" port="11020" />
8
        </servers>
9
        <!-- 连接时数据库名,不做身份验证时可空;身份认证时必填 -->
10
        <config name="authSource" value="admin"/>
11
        <!-- 认证机制,不做身份验证时可空;身份认证时必填。mongo3.0及更高版本缺省是SCRAM-SHA-1 -->
12
        <!-- mongo2.6以前缺省是MONGODB-CR, mongo4.0及更高版本已经不再支持-->
13
        <!-- 支持SCRAM-SHA-1、SCRAM-SHA-256-->
14
        <!-- 当前组件不支持x.509证书 -->
15
        <config name="authMechanism" value="SCRAM-SHA-256"/>
16
        <!-- 用户名,不做身份验证时可空;身份认证时必填 -->
17
        <config name="userName" value="ipuOper"/>
18
        <!-- 加密后的用户密码,不做身份验证时可空;身份认证时必填 -->
19
        <!-- 加密算法需要用一对@@包含,并且放在密码的最前面。如果没有发现加密算法,则为明文密码  -->
20
        <config name="encryptedPasswd" value="@DES@cqKYnoRap2YV9L7xEQ4fyw=="/>
21
        <!-- 解密秘钥 ,可为空 -->
22
        <config name="decryptedKey" value="Mongo4@121#_3$"/>
23
        <!-- 自定义解密算法需要在pom.xml里引入所需jar,并在此声明带全包名的类 -->
24
        <config name="decryptedClass" value="com.ai.ipu.nosql.util.DecryptUtil"/>
25
        <!-- 自定义解密算法的解密算法,加密后的秘钥(可为空,为空则只有1个参数)、密码串是算法的2个参数  -->
26
        <config name="decryptedMethod" value="decryptDES"/>
27
        <!-- 是否支持事务,true为支持,其他值为不支持 -->
28
        <config name="needTranscation" value="true"/>
29
        <!-- 复制集名称,可以为空 -->
30
        <config name="replicaSet" value="lpsa_repl"/>
31
        <!-- 客户端最大连接数,超过了将会被阻塞,默认100 -->
32
        <config name="connectionsPerHost" />
33
        <!-- 客户端最小连接数 -->
34
        <config name="minConnectionsPerHost" />
35
        <!-- 可被阻塞的线程数因子,默认值为5,如果connectionsPerHost配置为10, -->
36
        <!-- 那么最多能阻塞50个线程,超过50个之后就会收到一个异常  -->
37
        <config name="threadAllowedToBlockForConnectionMultiplier" />
38
        <!-- 阻塞线程获取连接的最长等待时间,默认120000 ms -->
39
        <config name="maxWaitTime" />
40
        <!-- 连接池连接最大空闲时间,默认为0 -->
41
        <config name="maxConnectionIdleTime" />
42
        <!-- 连接池连接的最大存活时间,默认为0 -->
43
        <config name="maxConnectionLifeTime" />
44
        <!-- 连接超时时间,默认值是0,就是不超时 -->
45
        <config name="connectTimeout" />
46
        <!-- 超时时间,默认值是0,就是不超时 -->
47
        <config name="socketTimeout" />
48
        <!-- 当没有手动关闭游标时,是否自动释放游标对象。默认为 true。-->
49
        <config name="cursorFinalizerEnabled" />
50
        <!-- MongoDB有5种ReadPreference模式 -->
51
        <!-- primary            主节点,默认模式,读操作只在主节点,如果主节点不可用,报错或者抛出异常。-->
52
        <!-- primaryPreferred   首选主节点,大多情况下读操作在主节点,如果主节点不可用,如故障转移,读操作在从节点。-->
53
        <!-- secondary          从节点,读操作只在从节点, 如果从节点不可用,报错或者抛出异常。-->
54
        <!-- secondaryPreferred 首选从节点,大多情况下读操作在从节点,特殊情况(如单主节点架构)读操作在主节点。-->
55
        <!-- nearest            最邻近节点,读操作在最邻近的成员,可能是主节点或者从节点-->
56
        <config name="readPreference" />
57
    </connection>
58
    
59
    <connection name="simple" type="mongo">
60
        <servers>
61
            <server ip="10.1.236.121" port="11000" />
62
            <server ip="10.1.236.121" port="11010" />
63
            <server ip="10.1.236.121" port="11020" />
64
        </servers>
65
        <!-- 复制集名称,可以为空 -->
66
        <config name="replicaSet" value="lpsa_repl"/>
67
    </connection>
68
69
</connections>

+ 0 - 25
ipu-rest-scaffold/src/main/resources/dev/logback.xml

@ -1,25 +0,0 @@
1
<?xml version="1.0" encoding="UTF-8"?>
2
<configuration>
3
	<include resource="org/springframework/boot/logging/logback/base.xml" /> <!-- logback 提供的基本配置 -->
4
5
	<!-- 控制台 -->
6
	<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
7
		<encoder charset="UTF-8">
8
			<!-- <pattern>[%d{yyyy-MM-dd HH:mm:ss.SSS}] %5p %m%n</pattern> -->
9
			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} {%thread} %-5level %logger{50}-%msg%n</pattern>
10
			<charset>UTF-8</charset> <!-- 解决中文乱码问题 -->
11
		</encoder>
12
	</appender>
13
14
	<!-- <root level="DEBUG"> -->
15
	<root level="ERROR"> <appender-ref ref="CONSOLE" /> </root> 
16
17
	<!-- 将上面两个 appender 关联到我们的项目 -->
18
	<logger name="com.ai.ipu" level="DEBUG"
19
		additivity="false"> <!-- name 是项目包名,为了方便调试,输出 DEBUG 级别及其以上的log -->
20
		<appender-ref ref="CONSOLE" />
21
	</logger>
22
        
23
	<logger name="org.springframework" level="INFO" />   <!-- spring 包下的 logger, 只输出 INFO 级别的 -->
24
25
</configuration> 

+ 0 - 69
ipu-rest-scaffold/src/main/resources/pro/ipu-nosql.xml

@ -1,69 +0,0 @@
1
<?xml version = '1.0' encoding = 'UTF-8'?>
2
<connections>
3
    <connection name="data" type="mongo">
4
        <servers>
5
            <server ip="10.1.236.121" port="11000" />
6
            <server ip="10.1.236.121" port="11010" />
7
            <server ip="10.1.236.121" port="11020" />
8
        </servers>
9
        <!-- 连接时数据库名,不做身份验证时可空;身份认证时必填 -->
10
        <config name="authSource" value="admin"/>
11
        <!-- 认证机制,不做身份验证时可空;身份认证时必填。mongo3.0及更高版本缺省是SCRAM-SHA-1 -->
12
        <!-- mongo2.6以前缺省是MONGODB-CR, mongo4.0及更高版本已经不再支持-->
13
        <!-- 支持SCRAM-SHA-1、SCRAM-SHA-256-->
14
        <!-- 当前组件不支持x.509证书 -->
15
        <config name="authMechanism" value="SCRAM-SHA-256"/>
16
        <!-- 用户名,不做身份验证时可空;身份认证时必填 -->
17
        <config name="userName" value="ipuOper"/>
18
        <!-- 加密后的用户密码,不做身份验证时可空;身份认证时必填 -->
19
        <!-- 加密算法需要用一对@@包含,并且放在密码的最前面。如果没有发现加密算法,则为明文密码  -->
20
        <config name="encryptedPasswd" value="@DES@cMBWCqZgG39bQ+PyRkJ4sw=="/>
21
        <!-- 解密秘钥 ,可为空 -->
22
        <config name="decryptedKey" value="325m@#$rt4vt"/>
23
        <!-- 自定义解密算法需要在pom.xml里引入所需jar,并在此声明带全包名的类 -->
24
        <config name="decryptedClass" value="com.ai.ipu.nosql.util.DecryptUtil"/>
25
        <!-- 自定义解密算法的解密算法,加密后的秘钥(可为空,为空则只有1个参数)、密码串是算法的2个参数  -->
26
        <config name="decryptedMethod" value="decryptDES"/>
27
        <!-- 是否支持事务,true为支持,其他值为不支持 -->
28
        <config name="needTranscation" value="true"/>
29
        <!-- 复制集名称,可以为空 -->
30
        <config name="replicaSet" value="lpsa_repl"/>
31
        <!-- 客户端最大连接数,超过了将会被阻塞,默认100 -->
32
        <config name="connectionsPerHost" />
33
        <!-- 客户端最小连接数 -->
34
        <config name="minConnectionsPerHost" />
35
        <!-- 可被阻塞的线程数因子,默认值为5,如果connectionsPerHost配置为10, -->
36
        <!-- 那么最多能阻塞50个线程,超过50个之后就会收到一个异常  -->
37
        <config name="threadAllowedToBlockForConnectionMultiplier" />
38
        <!-- 阻塞线程获取连接的最长等待时间,默认120000 ms -->
39
        <config name="maxWaitTime" />
40
        <!-- 连接池连接最大空闲时间,默认为0 -->
41
        <config name="maxConnectionIdleTime" />
42
        <!-- 连接池连接的最大存活时间,默认为0 -->
43
        <config name="maxConnectionLifeTime" />
44
        <!-- 连接超时时间,默认值是0,就是不超时 -->
45
        <config name="connectTimeout" />
46
        <!-- 超时时间,默认值是0,就是不超时 -->
47
        <config name="socketTimeout" />
48
        <!-- 当没有手动关闭游标时,是否自动释放游标对象。默认为 true。-->
49
        <config name="cursorFinalizerEnabled" />
50
        <!-- MongoDB有5种ReadPreference模式 -->
51
        <!-- primary            主节点,默认模式,读操作只在主节点,如果主节点不可用,报错或者抛出异常。-->
52
        <!-- primaryPreferred   首选主节点,大多情况下读操作在主节点,如果主节点不可用,如故障转移,读操作在从节点。-->
53
        <!-- secondary          从节点,读操作只在从节点, 如果从节点不可用,报错或者抛出异常。-->
54
        <!-- secondaryPreferred 首选从节点,大多情况下读操作在从节点,特殊情况(如单主节点架构)读操作在主节点。-->
55
        <!-- nearest            最邻近节点,读操作在最邻近的成员,可能是主节点或者从节点-->
56
        <config name="readPreference" />
57
    </connection>
58
    
59
    <connection name="simple" type="mongo">
60
        <servers>
61
            <server ip="10.1.236.121" port="11000" />
62
            <server ip="10.1.236.121" port="11010" />
63
            <server ip="10.1.236.121" port="11020" />
64
        </servers>
65
        <!-- 复制集名称,可以为空 -->
66
        <config name="replicaSet" value="lpsa_repl"/>
67
    </connection>
68
69
</connections>

+ 0 - 11
ipu-rest-scaffold/src/main/resources/pro/log4j.properties

@ -1,11 +0,0 @@
1
### set log levels ###
2
log4j.rootLogger=DEBUG
3

4
### direct log messages to stdout ###
5
log4j.appender.A1=org.apache.log4j.ConsoleAppender
6
log4j.appender.A1.Target=System.out
7
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
8
log4j.appender.A1.layout.ConversionPattern=%-5p(%10c{1}) %m%n
9

10
### application log config ###
11
log4j.logger.com.ai.ipu=DEBUG,A1

+ 15 - 0
ipu-rest-scaffold/src/main/resources/pro/log4j2.xml

@ -0,0 +1,15 @@
1
<?xml version="1.0" encoding="UTF-8"?>
2
<Configuration status="WARN">
3
    <Appenders>
4
        <Console name="Console" target="SYSTEM_OUT">
5
            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
6
        </Console>
7
    </Appenders>
8
    <Loggers>
9
        <Root level="WARN">
10
            <AppenderRef ref="Console"/>
11
        </Root>
12
        <logger name="com.ai" level="DEBUG"></logger>
13
        <logger name="org.springframework.boot.web" level="DEBUG"></logger>
14
    </Loggers>
15
</Configuration>

+ 0 - 69
ipu-rest-scaffold/src/main/resources/test/ipu-nosql.xml

@ -1,69 +0,0 @@
1
<?xml version = '1.0' encoding = 'UTF-8'?>
2
<connections>
3
    <connection name="data" type="mongo">
4
        <servers>
5
            <server ip="10.1.236.121" port="11000" />
6
            <server ip="10.1.236.121" port="11010" />
7
            <server ip="10.1.236.121" port="11020" />
8
        </servers>
9
        <!-- 连接时数据库名,不做身份验证时可空;身份认证时必填 -->
10
        <config name="authSource" value="admin"/>
11
        <!-- 认证机制,不做身份验证时可空;身份认证时必填。mongo3.0及更高版本缺省是SCRAM-SHA-1 -->
12
        <!-- mongo2.6以前缺省是MONGODB-CR, mongo4.0及更高版本已经不再支持-->
13
        <!-- 支持SCRAM-SHA-1、SCRAM-SHA-256-->
14
        <!-- 当前组件不支持x.509证书 -->
15
        <config name="authMechanism" value="SCRAM-SHA-256"/>
16
        <!-- 用户名,不做身份验证时可空;身份认证时必填 -->
17
        <config name="userName" value="ipuOper"/>
18
        <!-- 加密后的用户密码,不做身份验证时可空;身份认证时必填 -->
19
        <!-- 加密算法需要用一对@@包含,并且放在密码的最前面。如果没有发现加密算法,则为明文密码  -->
20
        <config name="encryptedPasswd" value="@DES@cMBWCqZgG39bQ+PyRkJ4sw=="/>
21
        <!-- 解密秘钥 ,可为空 -->
22
        <config name="decryptedKey" value="325m@#$rt4vt"/>
23
        <!-- 自定义解密算法需要在pom.xml里引入所需jar,并在此声明带全包名的类 -->
24
        <config name="decryptedClass" value="com.ai.ipu.nosql.util.DecryptUtil"/>
25
        <!-- 自定义解密算法的解密算法,加密后的秘钥(可为空,为空则只有1个参数)、密码串是算法的2个参数  -->
26
        <config name="decryptedMethod" value="decryptDES"/>
27
        <!-- 是否支持事务,true为支持,其他值为不支持 -->
28
        <config name="needTranscation" value="true"/>
29
        <!-- 复制集名称,可以为空 -->
30
        <config name="replicaSet" value="lpsa_repl"/>
31
        <!-- 客户端最大连接数,超过了将会被阻塞,默认100 -->
32
        <config name="connectionsPerHost" />
33
        <!-- 客户端最小连接数 -->
34
        <config name="minConnectionsPerHost" />
35
        <!-- 可被阻塞的线程数因子,默认值为5,如果connectionsPerHost配置为10, -->
36
        <!-- 那么最多能阻塞50个线程,超过50个之后就会收到一个异常  -->
37
        <config name="threadAllowedToBlockForConnectionMultiplier" />
38
        <!-- 阻塞线程获取连接的最长等待时间,默认120000 ms -->
39
        <config name="maxWaitTime" />
40
        <!-- 连接池连接最大空闲时间,默认为0 -->
41
        <config name="maxConnectionIdleTime" />
42
        <!-- 连接池连接的最大存活时间,默认为0 -->
43
        <config name="maxConnectionLifeTime" />
44
        <!-- 连接超时时间,默认值是0,就是不超时 -->
45
        <config name="connectTimeout" />
46
        <!-- 超时时间,默认值是0,就是不超时 -->
47
        <config name="socketTimeout" />
48
        <!-- 当没有手动关闭游标时,是否自动释放游标对象。默认为 true。-->
49
        <config name="cursorFinalizerEnabled" />
50
        <!-- MongoDB有5种ReadPreference模式 -->
51
        <!-- primary            主节点,默认模式,读操作只在主节点,如果主节点不可用,报错或者抛出异常。-->
52
        <!-- primaryPreferred   首选主节点,大多情况下读操作在主节点,如果主节点不可用,如故障转移,读操作在从节点。-->
53
        <!-- secondary          从节点,读操作只在从节点, 如果从节点不可用,报错或者抛出异常。-->
54
        <!-- secondaryPreferred 首选从节点,大多情况下读操作在从节点,特殊情况(如单主节点架构)读操作在主节点。-->
55
        <!-- nearest            最邻近节点,读操作在最邻近的成员,可能是主节点或者从节点-->
56
        <config name="readPreference" />
57
    </connection>
58
    
59
    <connection name="simple" type="mongo">
60
        <servers>
61
            <server ip="10.1.236.121" port="11000" />
62
            <server ip="10.1.236.121" port="11010" />
63
            <server ip="10.1.236.121" port="11020" />
64
        </servers>
65
        <!-- 复制集名称,可以为空 -->
66
        <config name="replicaSet" value="lpsa_repl"/>
67
    </connection>
68
69
</connections>

+ 0 - 11
ipu-rest-scaffold/src/main/resources/test/log4j.properties

@ -1,11 +0,0 @@
1
### set log levels ###
2
log4j.rootLogger=DEBUG
3

4
### direct log messages to stdout ###
5
log4j.appender.A1=org.apache.log4j.ConsoleAppender
6
log4j.appender.A1.Target=System.out
7
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
8
log4j.appender.A1.layout.ConversionPattern=%-5p(%10c{1}) %m%n
9

10
### application log config ###
11
log4j.logger.com.ai.ipu=DEBUG,A1

+ 15 - 0
ipu-rest-scaffold/src/main/resources/test/log4j2.xml

@ -0,0 +1,15 @@
1
<?xml version="1.0" encoding="UTF-8"?>
2
<Configuration status="WARN">
3
    <Appenders>
4
        <Console name="Console" target="SYSTEM_OUT">
5
            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
6
        </Console>
7
    </Appenders>
8
    <Loggers>
9
        <Root level="WARN">
10
            <AppenderRef ref="Console"/>
11
        </Root>
12
        <logger name="com.ai" level="DEBUG"></logger>
13
        <logger name="org.springframework.boot.web" level="DEBUG"></logger>
14
    </Loggers>
15
</Configuration>