mc洪磊个人资料,mc洪磊被判刑了吗

CL.enT.I.es.J.va /** * 更多...料欢迎浏览凯哥学堂官网：http://K.ige123.com * @author 小沫 */ pacKage com.files.mc; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; puB.ic class ClientFiles extends Thread { public void run() { try { Socket socket = new Socket( "127.0.0.1", 8080); InputStream fin = socket.getInputStream(); OutputStream fout = socket.getOutputStream(); File file = new File( "E:/迅雷下载/170322-04.mp4"); loNg times = System.currentTimeMillis(); System.out.println( "\t正在校验 " + file.getName() + "文件MD5请稍后...\n"); String md5 = MD5FileUtil.getFileMD5String(file); // 把此文件数据进行MD5加密System.out.println( "[MD5验证完毕 耗时: " + (System.currentTimeMillis() - times) / 1000 + " 秒 正在执行数据传输]\n"); fout.write(md5.getBytes()); // 把加密出来的MD5发送到服务端fout.flush(); if (fin.read() == 0) { // 服务端传过来的是0 说明服务端上有相同数据 // 打印秒传了System.out.println( "数据传输完毕！大小: " + file.length() + " 字节 耗时: 0秒 ！ 秒传机制"); } else { // 打印的不是0,那么开始把数据传输给服务端 long time = System.currentTimeMillis(); System.out.println( "\t\t数据传输中...\n"); FileInputStream filein = new FileInputStream(file); byte[] b = new byte[ 1024 * 1024 * 2]; while (filein.available() != 0) { int len = filein.read(b); fout.write(b, 0, len); fout.flush(); } System.out.println( "文件传输完毕！大小: " + file.length() + " 字节 耗时: " + (System.currentTimeMillis() - time) / 1000 + "秒"); filein.close(); } fout.close(); fin.close(); socket.close(); } catch (IOException e) { e.printStackTrAce(); } } public static void main(String[] args) { new ClientFiles().start(); // 启动客户端线程} } ServerFiles.java /** * 更多资料欢迎浏览凯哥学堂官网：http://kaige123.com * @author 小沫 */ package com.files.mc; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.zip.InflaterOutputStream; public class ServerFiles implements Runnable { private Socket socket; public ServerFiles(Socket socket) { this.socket = socket; } public void run() { try { InputStream fin = socket.getInputStream(); OutputStream fout = socket.getOutputStream(); byte[] b = new byte[ 1024]; int len = 0; len = fin.read(b); String md5 = new String(b, 0, len); //接收客户端传的MD5System.out.println(md5); File file = new File( "filess"); File[] files = file.listFiles(); boolean state = false; //状态默认为false 用来判断MD5是否存在 for (File file2 : files) { //如果找到了相同的MD5 if (file2.getName().equalsIgnoreCase(md5)) { state = true; //状态就改为true 表示有相同的MD5 break; } } if (state == false) { //没有找到相同的MD5 就给客户端发送1过去 让客户端开始把数据发过来fout.write( 1); fout.flush(); FileOutputStream fileout = new FileOutputStream( new File( "filess", md5)); byte[] b1 = new byte[ 1024 * 1024 * 2]; //把客户端发来的数据存储到文件中 while ((len = fin.read(b)) != - 1) { fileout.write(b1, 0, len); } fileout.close(); } else { //如果找到了相同的MD5那么发送0给客户端 fout.write( 0); fout.flush(); } fout.close(); fin.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } public static void openServer() throws Exception { ServerSocket server = new ServerSocket( 8080); ExecutorService executor = Executors.newFixedThreadPool( 10); //线程池 while ( true) { ServerFiles socket = new ServerFiles(server.accept()); executor.execute(socket); } } public static void main(String[] args) { try { openServer(); //启动服务端} catch (Exception e) { e.printStackTrace(); } } }