@IPU_REQ_0014@weihf@添加ipu-nosql事务控制示例

ipu-rest-demo/pom.xml

@@ -32,6 +32,7 @@
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<ipu>3.1-SNAPSHOT</ipu>
		<msgframe>1.9.2</msgframe>
		<mongo.java.driver>3.11.2</mongo.java.driver>
		<jms>1.1</jms>
	</properties>
@@ -65,6 +66,16 @@
		    <artifactId>ipu-sql-mgmt</artifactId>
		    <version>${ipu}</version>
		</dependency>
		<dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-nosql</artifactId>
            <version>${ipu}</version>
        </dependency>
        <dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongo-java-driver</artifactId>
            <version>${mongo.java.driver}</version>
        </dependency>
	</dependencies>
	<build>

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/mongodb/MongoDbController.java

@@ -0,0 +1,117 @@
package com.ai.ipu.server.demo.control.mongodb;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.server.demo.service.MongoServiceImpl;
/**
 * @author weihf@asiainfo.com
 * @team IPU
 * @date 2020年9月27日下午13:02:22
 * @desc 基于ipu-nosql组件对mongodb操作范例
 */
@Controller
@RequestMapping("/mongodb/")
public class MongoDbController {
	private String connName = "data";
	@Autowired
	private MongoServiceImpl service;
	
    /**
     * @author weihf@asiainfo.com
     * @title: insert
     * @desc: 使用mongodb语法插入1条记录，并使用mongodb语法查询插入的记录
     */
	@ResponseBody
    @RequestMapping("/insert")
    public JMap insert(JMap param) throws Exception {
		JMap result = new JsonMap();
        service.processInsertTranscation(connName);
        result.put("result", "insert successful");
		return result;		
    }
	
    /**
     * @author weihf@asiainfo.com
     * @title: insertRollback
     * @desc: 使用sql语法插入1条记录，然后抛异常回滚插入操作
     */
	@ResponseBody
    @RequestMapping("/insertRollback")
    public JMap insertRollback(JMap param) throws Exception {
		JMap result = new JsonMap();
        service.processRollback(connName);
        //永远执行不到这里
        result.put("result", "insert error.Rollback successful.");
		return result;
    }
	
    /**
     * @author weihf@asiainfo.com
     * @title: insertMulti
     * @desc: 自己控制事务+系统事务。
     *        使用sql语法插入1条记录，然后自己控制事务提交；
     *        再接着使用sql语法插入2条记录，抛异常，系统事务回滚插入操作，自己提交的事务不回滚。
     */
	@ResponseBody
    @RequestMapping("/insertMulti")
    public JMap insertMulti(JMap param) throws Exception {
		JMap result = new JsonMap();
		service.processMultiTranscation(connName);
		//永远执行不到这里
		result.put("result", "MultiTranscation successful");
		return result;
    }
    /**
     * @author weihf@asiainfo.com
     * @title: delete
     * @desc: 使用mongodb语法删除记录；
     *        并使用mongodb语法查询被删除记录，查不到表示删除成功。
     */
	@ResponseBody
    @RequestMapping("/delete")
    public JMap delete(JMap param) throws Exception {
		JMap result = new JsonMap();
		service.processDeleteTranscation(connName);
		result.put("result", "delete successful");
		return result;
	}
    /**
     * @author weihf@asiainfo.com
     * @title: update
     * @desc: 使用mongodb语法修改记录，并使用mongodb语法查询被修改的记录
     */
	@ResponseBody
    @RequestMapping("/update")
    public JMap update(JMap param) throws Exception {
		JMap result = new JsonMap();
		service.processUpdateTranscation(connName);
		result.put("result", "update successful");
		return result;
	}
    /**
     * @author weihf@asiainfo.com
     * @title: query
     * @desc: 使用sql语法查询记录
     */
	@ResponseBody
    @RequestMapping("/query")
    public JMap query(JMap param) throws Exception {
		JMap result = new JsonMap();
		result.put("result", service.query(connName));
		return result;
	}
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/service/MongoServiceImpl.java

@@ -0,0 +1,100 @@
package com.ai.ipu.server.demo.service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import org.springframework.stereotype.Service;
import com.ai.ipu.nosql.INoSql;
import com.ai.ipu.nosql.mongodb.MongoCacheFactory;
import com.alibaba.fastjson.JSONObject;
@Service
public class MongoServiceImpl {
    private ILogger log = IpuLoggerFactory.createLogger(MongoServiceImpl.class);
    public MongoServiceImpl() {
    }
    public void processRollback(String connName) throws Exception {
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, "test", "mycol1");
        noSql.executeInsert("insert into mycol1 (name, nickName) values ('mongo', 'kevin')");
        //rollback
        noSql.executeInsert("this is rollback test.");
    }
    public void processMultiTranscation(String connName) throws Exception {
        //操作日志是一个单独事务，不会因为其他事务失败而回退
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, "test", "oplog");
        noSql.executeInsert("insert into oplog (name, operTime, memo) values ('mongo', '2020-09-27 12:35:00', '操作测试')");
        //先提交,再关闭
        MongoCacheFactory.close(connName, "test", "oplog");
        //其他事务
        noSql = MongoCacheFactory.getMongoDao(connName, "test", "mycol1");
        noSql.executeInsert("insert into mycol1 (name, nickName) values ('mongo', 'kevin')");
        noSql = MongoCacheFactory.getMongoDao(connName, "test", "mycol1");
        noSql.executeInsert("insert into mycol1 (name) values ('mongo')");
        //rollback
        noSql.executeInsert("this is rollback test.");
    }
    public void processInsertTranscation(String connName) throws Exception {
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, "test", "mycol1");
        //插入一条数据       
        JSONObject data = new JSONObject();
        data.put("name", "mongo");
        data.put("nickName", "tom2");
        Map info = new HashMap();
        info.put("ver", 7.1);
        data.put("info", info);
        noSql.executeInsert(data);
        
        //查询该刚插入的数据
        JSONObject param = new JSONObject();
        param.put("name", "mongo");
        param = new JSONObject();
        param.put("info.ver", 7.1);
        log.debug("查询name='mongo' && info.ver=7.1的结果为:[" + noSql.executeSelect(param.toJSONString(), "{}") + "]");
    }
    public void processDeleteTranscation(String connName) throws Exception {
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, "test", "mycol1");
        //删除数据
        noSql.executeDelete("delete from mycol1 where nickName='tom2'");
        
        //查询删除的数据
        log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where nickName='tom2'"));
    }
    public void processUpdateTranscation(String connName) throws Exception {
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, "test", "mycol1");
        //更新数据
        noSql.executeUpdate("update mycol2 set name='jack' where name='mongo' and nickName='tom1'");
        
        //查询更新的数据
        log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where name='jack'"));
    }
    public List<String> query(String connName) throws Exception {
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, "test", "mycol1");
        //查询数据
        return noSql.executeSelect("select * from mycol1 where name='mongo'");
    }
}

ipu-rest-demo/src/main/java/com/ipu/server/aspect/TransactionAspect.java

@@ -0,0 +1,41 @@
package com.ipu.server.aspect;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.nosql.mongodb.MongoCacheFactory;
@Aspect
public class TransactionAspect {
    transient protected ILogger log = IpuLoggerFactory.createLogger(TransactionAspect.class);
    final static String executionService = "execution(* com.ai..service..*Impl.process*(..))";
    
    @Pointcut(executionService)
    private void serviceTransaction() {}
    
    @Around("serviceTransaction()")
    public Object aroundMethod(ProceedingJoinPoint jp) throws Throwable {
        Object result = null;
        try {
            result = jp.proceed();           
            long start = System.currentTimeMillis();
            MongoCacheFactory.commitAll();
            log.debug("提交mongo数据库连接耗时："+(System.currentTimeMillis()-start));
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            log.debug("mongo数据库全量回滚");
            MongoCacheFactory.rollbackAll(); 
            throw e;
        } finally{
        	log.debug("mongo数据库切面控制完成");
        	MongoCacheFactory.closeAll();
        }
        return result;
    }
}

ipu-rest-demo/src/main/resources/dev/ipu-nosql.xml

@@ -0,0 +1,69 @@
<?xml version = '1.0' encoding = 'UTF-8'?>
<connections>
    <connection name="data" type="mongo">
        <servers>
            <server ip="47.105.160.21" port="10030" />
            <server ip="47.105.160.21" port="10040" />
            <server ip="47.105.160.21" port="10050" />
        </servers>
        <!-- 连接时数据库名，不做身份验证时可空；身份认证时必填 -->
        <config name="authSource" value="test"/>
        <!-- 认证机制，不做身份验证时可空；身份认证时必填。mongo3.0及更高版本缺省是SCRAM-SHA-1 -->
        <!-- mongo2.6以前缺省是MONGODB-CR， mongo4.0及更高版本已经不再支持-->
        <!-- 支持SCRAM-SHA-1、SCRAM-SHA-256-->
        <!-- 当前组件不支持x.509证书 -->
        <config name="authMechanism" value="SCRAM-SHA-256"/>
        <!-- 用户名，不做身份验证时可空；身份认证时必填 -->
        <config name="userName" value="ipuOper"/>
        <!-- 加密后的用户密码，不做身份验证时可空；身份认证时必填 -->
        <!-- 加密算法需要用一对@@包含，并且放在密码的最前面。如果没有发现加密算法，则为明文密码  -->
        <config name="encryptedPasswd" value="@DES@L4+tgpw/Q67MvcM4mN1AhQ=="/>
        <!-- 解密秘钥 ，可为空 -->
        <config name="decryptedKey" value="325m@#$rt4vt"/>
        <!-- 自定义解密算法需要在pom.xml里引入所需jar，并在此声明带全包名的类 -->
        <config name="decryptedClass" value="com.ai.ipu.nosql.util.DecryptUtil"/>
        <!-- 自定义解密算法的解密算法，加密后的秘钥（可为空，为空则只有1个参数）、密码串是算法的2个参数  -->
        <config name="decryptedMethod" value="decryptDES"/>
        <!-- 是否支持事务，true为支持，其他值为不支持 -->
        <config name="needTranscation" value="true"/>
        <!-- 复制集名称，可以为空 -->
        <config name="replicaSet" value="lpsa_repl"/>
        <!-- 客户端最大连接数，超过了将会被阻塞，默认100 -->
        <config name="connectionsPerHost" />
        <!-- 客户端最小连接数 -->
        <config name="minConnectionsPerHost" />
        <!-- 可被阻塞的线程数因子，默认值为5，如果connectionsPerHost配置为10， -->
        <!-- 那么最多能阻塞50个线程，超过50个之后就会收到一个异常  -->
        <config name="threadAllowedToBlockForConnectionMultiplier" />
        <!-- 阻塞线程获取连接的最长等待时间，默认120000 ms -->
        <config name="maxWaitTime" />
        <!-- 连接池连接最大空闲时间，默认为0 -->
        <config name="maxConnectionIdleTime" />
        <!-- 连接池连接的最大存活时间，默认为0 -->
        <config name="maxConnectionLifeTime" />
        <!-- 连接超时时间，默认值是0，就是不超时 -->
        <config name="connectTimeout" />
        <!-- 超时时间，默认值是0，就是不超时 -->
        <config name="socketTimeout" />
        <!-- 当没有手动关闭游标时,是否自动释放游标对象。默认为 true。-->
        <config name="cursorFinalizerEnabled" />
        <!-- MongoDB有5种ReadPreference模式 -->
        <!-- primary            主节点，默认模式，读操作只在主节点，如果主节点不可用，报错或者抛出异常。-->
        <!-- primaryPreferred   首选主节点，大多情况下读操作在主节点，如果主节点不可用，如故障转移，读操作在从节点。-->
        <!-- secondary          从节点，读操作只在从节点， 如果从节点不可用，报错或者抛出异常。-->
        <!-- secondaryPreferred 首选从节点，大多情况下读操作在从节点，特殊情况（如单主节点架构）读操作在主节点。-->
        <!-- nearest            最邻近节点，读操作在最邻近的成员，可能是主节点或者从节点-->
        <config name="readPreference" />
    </connection>
    
    <connection name="simple" type="mongo">
        <servers>
            <server ip="10.1.236.121" port="11000" />
            <server ip="10.1.236.121" port="11010" />
            <server ip="10.1.236.121" port="11020" />
        </servers>
        <!-- 复制集名称，可以为空 -->
        <config name="replicaSet" value="lpsa_repl"/>
    </connection>
</connections>

ipu-rest-demo/src/main/resources/ipu-spring-mvc.xml

@@ -11,4 +11,5 @@
		http://www.springframework.org/schema/mvc/spring-mvc.xsd">
	<!-- 自定义的control扫描目录 -->
    <context:component-scan base-package="com.ai.ipu.server.demo" />
    <bean id="transcationAspects" class="com.ipu.server.aspect.TransactionAspect" />
</beans>