tfs demo

TFS今天刚刚做好的。

Mark一下,坐个记录

1. 搭建TFS服务器.

详见google

TFS服务器环境:

Centos

Linux version 2.6.32-431.el6.x86_64 ([e-mail]) (gcc version 4.4.7 20120313 (Red Hat 4.4.7-4) (GCC) ) #1 SMP Fri Nov 22 03:15:09 UTC 2013

2. 开发环境：spring+springmvc+mybatis

3. 引入Jar包:

直接下载http://code.taobao.org/p/tfs-client-java/file/404/tfs-javaclient-2.1.1.jar

下载http://code.taobao.org/p/tair-client-java/file/40/tair-client-2.3.1.jar

还要用到一个叫apache-mina的包。

然后在本地的Nexus上加依赖.

最后在parent的pom.xml里面加上

<!-- TFS的相关依赖 -->
<dependency>
	<groupId>com.taobao.common.tair</groupId>
	<artifactId>common-tair</artifactId>
	<version>2.3.1</version>
</dependency>
<dependency>
	<groupId>com.taobao.common.tfs</groupId>
	<artifactId>tfs-javaclient</artifactId>
	<version>2.1.1</version>
</dependency>
<!-- http://mvnrepository.com/artifact/org.apache.mina/mina-core -->
<dependency>
	<groupId>org.apache.mina</groupId>
	<artifactId>apache-mina</artifactId>
	<version>2.0.6</version>
</dependency>
<!-- TFS的相关依赖 Over -->

然后在core里面的pom.xml里面依赖。

3. 做xml配置

TFS.xml文件

<?xml version="1.0" encoding="UTF-8"?>   
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"
        default-lazy-init="true">
    <bean id="tfsManager" class="com.taobao.common.tfs.DefaultTfsManager" init-method="init" >  
      <!-- 整个进程中系统最多等待多少个请求,取决于你有多少个线程并发的请求TFS -->  
       <property name="maxWaitThread">  
        <value>100</value>
      </property>  
      <!-- 单个请求最大的等待时间(ms) 超过这个时间放弃这次请求-->  
      <property name="timeout">  
        <value>2000</value>  
      </property>
      <!-- Tfs master nameserver ip address -->  
      <property name="nsip">
        <value>10.0.1.228:8666</value>  
      </property>
      <!-- TFS 集群的编号,这个编号只是一种参考,系统初始化的时候会从ns上取,取不到才用本地设置的.!-->  
      <property name="tfsClusterIndex">  
        <value>1</value>
      </property>
      <!-- TFS在读取文件的时候会缓存block所在的数据服务器ip,这个参数配置了最多缓存的记录个数!-->  
      <property name="maxCacheItemCount">
        <value>10000</value>
      </property>
      <!-- 上一项缓存最大有效的时间(ms)!-->
      <property name="maxCacheTime">
        <value>5000</value>
      </property>
   </bean>
</beans>

4. 写了一个TFSUtil.java的工具类

package com.esteel.until;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import org.apache.poi.util.IOUtils;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.taobao.common.tfs.TfsManager;
import com.taobao.common.tfs.packet.FileInfo;

public class TFSUtil {

	static ApplicationContext context = new ClassPathXmlApplicationContext("config_spring/TFS.xml");

	private static TfsManager getTfSManager() {
		return (TfsManager) context.getBean("tfsManager");
	}

	private static String getFileExt(String fileName) {
		return fileName.substring(fileName.lastIndexOf("."));
	}

	/*存储文件后返回在TFS中存储的文件码*/
	public static String saveTfsByteFile(byte[] fileBytes, String fileName) {
		TfsManager tfsManager = getTfSManager();
		String fileExt = getFileExt(fileName);
		String tfsfileName = tfsManager.saveFile(fileBytes, null, fileExt, true);
		return tfsfileName;
	}
	
	/*存储文件后返回在TFS中存储的文件码*/
	public static String saveTfsFile(InputStream inputStream, String fileName) {
		try {
			TfsManager tfsManager = getTfSManager();
			byte[] fileBytes = IOUtils.toByteArray(inputStream);
			String fileExt = getFileExt(fileName);
			String tfsfileName = tfsManager.saveFile(fileBytes, null, fileExt, true);
			return tfsfileName;
		} catch (IOException e) {
			e.printStackTrace();
			return "";
		}
	}

	public static OutputStream getTfsFile(String tfsFileName) {
		TfsManager tfsManager = getTfSManager();
		OutputStream outputStream = new ByteArrayOutputStream();
		boolean result = tfsManager.fetchFile(tfsFileName, "", outputStream);
		if (result) {
			return outputStream;
		} else {
			return null;
		}
	}

	public static void deleteTfsFile(String tfsFileName) {
		TfsManager tfsManager = getTfSManager();
		boolean flag = tfsManager.unlinkFile(tfsFileName, null);
		System.out.println(flag);
	}

	public void fetchTfsFile(String tfsFileName, String newFileName) {
		TfsManager tfsManager = getTfSManager();
		boolean flag = tfsManager.fetchFile(tfsFileName, null, newFileName);
		System.out.println(flag);
	}

	public void hideTfsFile(String tfsFileName, int isHidden) {
		TfsManager tfsManager = getTfSManager();
		boolean flag = tfsManager.hideFile(tfsFileName, null, isHidden);
		System.out.println(flag);
	}

	public FileInfo stateTfsFile(String tfsFileName) {
		TfsManager tfsManager = getTfSManager();
		FileInfo fileInfo = tfsManager.statFile(tfsFileName, null);
		return fileInfo;
	}

}

5. 调用工具类的类

package com.esteel.until;

import java.io.IOException;

import javax.servlet.http.HttpServletRequest;

import org.springframework.web.multipart.MultipartFile;

import com.esteel.until.TFSUtil;

public class UpLoadUtil6 {

	/*存储文件返回格式为"/file/upload/"+picture.getOriginalFilename()+"/"+uploadMethod6(picture)+"/open"*/
	public static String uploadMethodWithPath(MultipartFile picture)
			throws IOException {
		/*String dateString = new SimpleDateFormat("yyyyMMdd").format(Calendar.getInstance().getTime());
		indentity=indentity + File.separator
				+ dateString + File.separator + UUID.randomUUID().toString().replaceAll("-", "");*/
		return "/file/upload/"+picture.getOriginalFilename()+"/"+uploadMethod6(picture)+"/open";
	}

	/*存储文件返回格式tfsFileName*/
	public static String uploadMethod6(MultipartFile picture)
			throws IOException {
		String tfsFileName = "";
		String fileName="";
		if (!picture.isEmpty()) {
			/*String path = request.getSession().getServletContext().getRealPath("/") + File.separator + "upload"
					+ File.separator + indentity;*/
			fileName = picture.getOriginalFilename();
			tfsFileName = TFSUtil.saveTfsByteFile(picture.getBytes(), fileName);
			/*pathnew = File.separator + "upload" + File.separator + indentity + File.separator + fileName;
			System.out.println(fileName);
			File targetFile = new File(path, fileName);
			if (!targetFile.exists()) {
				targetFile.mkdirs();
			}
			picture.transferTo(targetFile);*/
		}
		return tfsFileName;
	}
	
	/*删除文件，格式为/file/upload/"+picture.getOriginalFilename()+"/"+uploadMethod6(picture)+"/open*/
	public static void deleteFileWithPath(String fileName) {
		/*String fileFullPath = request.getSession().getServletContext().getRealPath("/") + filePath;
		(new File(fileFullPath)).delete();
		String folderName = fileFullPath.substring(0, fileFullPath.lastIndexOf(File.separator));
		deleteDir(new File(folderName));*/
		String[] temp = fileName.split("file/upload/");
		String[] temp1 = temp[1].split("/");
		TFSUtil.deleteTfsFile(temp1[1]);
	}
	
	/*删除文件，格式为tfsFileName*/
	public static void deleteFile(String fileName) {
		/*String fileFullPath = request.getSession().getServletContext().getRealPath("/") + filePath;
		(new File(fileFullPath)).delete();
		String folderName = fileFullPath.substring(0, fileFullPath.lastIndexOf(File.separator));
		deleteDir(new File(folderName));*/
		TFSUtil.deleteTfsFile(fileName);
	}

}

6. 然后controller里面读文件

package com.esteel.system.controller;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;

import com.esteel.exception.EsteelException;
import com.esteel.until.TFSUtil;

@Controller
public class TFSFileController extends BaseController {

	@RequestMapping(value = "/file/upload/{originName}/{fileName}/open")
	public void tbBasBedSrtList(HttpSession session, HttpServletRequest request, HttpServletResponse response,
			@PathVariable String fileName,
			@PathVariable String originName) throws EsteelException, IOException {
		response.setCharacterEncoding("UTF-8");
		System.out.println(fileName);
		ByteArrayOutputStream fosByte = (ByteArrayOutputStream) TFSUtil.getTfsFile(fileName);
		byte[] bytes = fosByte.toByteArray();
		ByteArrayInputStream fis = new ByteArrayInputStream(bytes);
        byte[] bytesRead = new byte[1024*1024];
        int length = 0;
        while((length=fis.read(bytesRead))!=-1){
            response.getOutputStream().write(bytesRead,0,length);
        }
	}

}

7. 保存文件

	@RequestMapping(value = "/system/tbPactContracttpl/insert", method = RequestMethod.POST)
	public ModelAndView insert(@RequestParam(value = "tempFile", required = false) MultipartFile tempFile,
			TbPactContracttpl tbPactContracttpl, HttpServletRequest request) throws IOException {
		if (tempFile != null && tempFile.getSize() > 0) {
			String dateString = new SimpleDateFormat("yyyyMMdd").format(Calendar.getInstance().getTime());
			String pathnew = UpLoadUtil6.uploadMethodWithPath( tempFile);
			tbPactContracttpl.setTempPath(pathnew);
		}
		try {
			tbPactContracttplService.insertTbPactContracttpl(setDateAndUpdateUser(tbPactContracttpl));
		} catch (EsteelException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return ajaxDoneTbPactContracttpl(200, "操作成功", "");
	}