SocketIo+SpringMvc实现文件的上传下载功能

import java.io.*;import java.net.ServerSocket;import java.net.Socket;import java.nio.channels.FileChannel;public class ChuanServer { public static void protServer(String po) throws IOException {    int port = Integer.parseInt(po);  ServerSocket serverSocket = new ServerSocket(port);  while (true) {   final Socket clientSocket = serverSocket.accept();   new Thread() {    @Override    public void run() {     try {      BufferedReader br = new BufferedReader(        new InputStreamReader(clientSocket.getInputStream(), "GBK")      );      InputStream is = clientSocket.getInputStream();      PrintStream pr = new PrintStream(        clientSocket.getOutputStream()      );      pr.println("我是服务端");      String str = br.readLine();      System.out.println("br.readLine():" + str);      System.out.println("服务端来接收了!!");      out(is, str);     } catch (Exception e) {      e.printStackTrace();     }    }   }.start();  } } public static void out(InputStream is, String str) throws IOException {  FileOutputStream fo = new FileOutputStream("C://Users//Administrator//Desktop//upload//" + str);  BufferedInputStream bi = new BufferedInputStream(is);  BufferedOutputStream bo = new BufferedOutputStream(fo);  int len = 0;  while ((len=bi.read())!=-1){   bo.write(len);  }  bi.close();  bo.close(); }}

import org.springframework.stereotype.Controller;import org.springframework.ui.Model;import org.springframework.web.bind.annotation.RequestMapping;import socket.ChuanServer;import java.io.IOException;@Controllerpublic class PortController { @RequestMapping("/port") public String port(String port,Model model){  model.addAttribute("port",port);  try {   ChuanServer.protServer(port);  } catch (IOException e) {   e.printStackTrace();  }  return "success"; }}

@Controller@RequestMapping("/")public class UpLoadController { @Autowired private UpService upService; private String zhuan=""; @RequestMapping("/upload") public String upload(@RequestParam(value = "file", required = false) MultipartFile file,       HttpServletRequest request, @RequestParam("iphost") String iphost,@RequestParam("port") String port,Model model) throws IOException {  String fileName = file.getOriginalFilename();  InputStream is = file.getInputStream();  upService.upload(fileName,is,iphost,port);  return "success"; }}

@Servicepublic class UpServiceImpl implements UpService { @Override public void upload(String fileName, InputStream is, String iphost, String port) {  getClientSocket(is, fileName, iphost, port); }//建立socket通信 public void getClientSocket(InputStream is, String fileName, String iphost, String port) {  int po = Integer.parseInt(port);  try {   Socket socket = new Socket(iphost, po);   BufferedReader br = new BufferedReader(     new InputStreamReader(socket.getInputStream(), "UTF-8")   );   PrintStream pr = new PrintStream(     socket.getOutputStream()   );   OutputStream os = socket.getOutputStream();   System.out.println("客户端给你传文件了!");   System.out.println("文件名为:" + fileName);   //读取服务器返回的消息   String str = br.readLine();   System.out.println("服务器发来的消息为:" + str);   pr.println(fileName);   in(is, os);   pr.close();   br.close();   System.out.println("客户端已关闭");  } catch (Exception e) {   e.printStackTrace();  } } //上传文本 public static void in(InputStream is, OutputStream os) throws IOException {  //BIO  BufferedInputStream bi = new BufferedInputStream(is);  BufferedOutputStream bo = new BufferedOutputStream(os);  int len = 0;  while ((len=bi.read())!=-1){   bo.write(len);   System.out.println(len);  }  bi.close();  bo.close(); }}