public class FastDFSTest {

      @Test

      public void testFileUpload() throws Exception {

           // 1、加载配置文件，配置文件中的内容就是tracker服务的地址。

           ClientGlobal.init("D:/workspaces-itcast/e3-manager-web/src/main/resources/resource/client.conf");

           // 2、创建一个TrackerClient对象。直接new一个。

           TrackerClient trackerClient = new TrackerClient();

           // 3、使用TrackerClient对象创建连接，获得一个TrackerServer对象。

           TrackerServer trackerServer = trackerClient.getConnection();

           // 4、创建一个StorageServer的引用，值为null

           StorageServer storageServer = null;

           // 5、创建一个StorageClient对象，需要两个参数TrackerServer对象、StorageServer的引用

           StorageClient storageClient = new StorageClient(trackerServer, storageServer);

           // 6、使用StorageClient对象上传图片。

           //扩展名不带“.”

           String[] strings = storageClient.upload_file("D:/Documents/Pictures/images/200811281555127886.jpg", "jpg", null);

           // 7、返回数组。包含组名和图片的路径。

           for (String string : strings) {

                 System.out.println(string);

           }

      }

}

@Test

      public void testFastDfsClient() throws Exception {

           FastDFSClient fastDFSClient = new FastDFSClient("D:/workspaces-itcast/e3-manager-web/src/main/resources/resource/client.conf");

           String file = fastDFSClient.uploadFile("D:/Documents/Pictures/images/2f2eb938943d.jpg");

           System.out.println(file);

      }

<!-- 定义文件上传解析器 -->

      <bean id="multipartResolver"

           class="org.springframework.web.multipart.commons.CommonsMultipartResolver">

           <!-- 设定默认编码 -->

           <property name="defaultEncoding" value="UTF-8"></property>

           <!-- 设定文件上传的最大值5MB，5*1024*1024 -->

           <property name="maxUploadSize" value="5242880"></property>

      </bean>

@Controller

public class PictureController {

      @Value("${IMAGE_SERVER_URL}")

      private String IMAGE_SERVER_URL;

      @RequestMapping("/pic/upload")

      @ResponseBody

      public Map fileUpload(MultipartFile uploadFile) {

           try {

                 //1、取文件的扩展名

                 String originalFilename = uploadFile.getOriginalFilename();

                 String extName = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);

                 //2、创建一个FastDFS的客户端  读取图片服务器配置文件

                 FastDFSClient fastDFSClient = new FastDFSClient("classpath:resource/client.conf");

                 //3、执行上传处理

                 String path = fastDFSClient.uploadFile(uploadFile.getBytes(), extName);

                 //4、拼接返回的url和ip地址，拼装成完整的url

                 String url = IMAGE_SERVER_URL + path;

                 //5、返回map

                 Map result = new HashMap<>();

                 result.put("error", 0);

                 result.put("url", url);

                 return result;

           } catch (Exception e) {

                 e.printStackTrace();

                 //5、返回map

                 Map result = new HashMap<>();

                 result.put("error", 1);

                 result.put("message", "图片上传失败");

                 return result;

           }

      }

}

@Override

      public E3Result addItem(TbItem item, String desc) {

           // 1、生成商品id

           long itemId = IDUtils.genItemId();

           // 2、补全TbItem对象的属性

           item.setId(itemId);

           //商品状态，1-正常，2-下架，3-删除

           item.setStatus((byte) 1);

           Date date = new Date();

           item.setCreated(date);

           item.setUpdated(date);

           // 3、向商品表插入数据

           itemMapper.insert(item);

           // 4、创建一个TbItemDesc对象

           TbItemDesc itemDesc = new TbItemDesc();

           // 5、补全TbItemDesc的属性

           itemDesc.setItemId(itemId);

           itemDesc.setItemDesc(desc);

           itemDesc.setCreated(date);

           itemDesc.setUpdated(date);

           // 6、向商品描述表插入数据

           itemDescMapper.insert(itemDesc);

           // 7、E3Result.ok()

           return E3Result.ok();

      }

@RequestMapping("/save")

      @ResponseBody

      public E3Result saveItem(TbItem item, String desc) {

           E3Result result = itemService.addItem(item, desc);

           return result;

      }