@IPU_FIXBUG_2021@示例代码优化

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/cache/RedisController.java

@@ -37,16 +37,18 @@ public class RedisController {
		try {
			cache = CacheFactory.getCache(connName);
			result.put("result", cache.get(key));
			LOGGER.debug(key + " is " + result.getString("result"));			
			LOGGER.debug(key + " is " + result.getString("result"));	
			CacheFactory.commit(connName);
		} catch (Exception e)
		{
			CacheFactory.rollback(connName);
			String errorMsg = "从redis中获取" + key + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {
			//使用完redis需要将连接关闭/释放
			if (cache != null)
				cache.close();
				CacheFactory.close(connName, cache);
		}
		return result;
	}
@@ -65,16 +67,18 @@ public class RedisController {
		try {
			cache = CacheFactory.getCache(connName);
			result.put("result", cache.put(key, value));
			LOGGER.debug(result.getString("result"));				
			LOGGER.debug(result.getString("result"));	
			CacheFactory.commit(connName);
		} catch (Exception e)
		{
			CacheFactory.rollback(connName);
			String errorMsg = "从redis中获取" + key + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {
			//使用完redis需要将连接关闭/释放
			if (cache != null)
				cache.close();
				CacheFactory.close(connName, cache);
		}
		return result;
	}
@@ -91,16 +95,18 @@ public class RedisController {
		try {
			cache = CacheFactory.getCache(connName);
			result.put("result", cache.remove(key));
			LOGGER.debug(result.getString("result"));		
			LOGGER.debug(result.getString("result"));	
			CacheFactory.commit(connName);
		} catch (Exception e)
		{
			CacheFactory.rollback(connName);
			String errorMsg = "从redis中获取" + key + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {
			//使用完redis需要将连接关闭/释放
			if (cache != null)
				cache.close();
				CacheFactory.close(connName, cache);
		}
		return result;
	}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/dfs/MinIOController.java

@@ -5,6 +5,7 @@ import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.basic.file.FileUtil;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.server.demo.service.MinIOServiceImpl;
@@ -126,7 +127,7 @@ public class MinIOController {
		String bucketName = param.getString("bucketName", DEFAULT_BUCKET_NAME);
		String localFile = LOCAL_FILE_PATH + "/2.txt";
		JMap result = new JsonMap();
		result.put("result", service.uploadFile(DEFAULT_DFS_NAME, bucketName, localFile, "text/plain"));
		result.put("result", service.uploadFile(DEFAULT_DFS_NAME, bucketName, localFile, FileUtil.getFileExtension(localFile)));
		return result;
	}
}