socket简单传输文件例子

package com.wf.demo.socket.socketfile;import java.net.*;
import java.io.*;/*** 2.socket的Util辅助类* * @author willson* */
public class ClientSocket {private String ip;private int port;private Socket socket = null;DataOutputStream out = null;DataInputStream getMessageStream = null;public ClientSocket(String ip, int port) {this.ip = ip;this.port = port;}/*** 创建socket连接* * @throws Exception*             exception*/public void CreateConnection() throws Exception {try {socket = new Socket(ip, port);} catch (Exception e) {e.printStackTrace();if (socket != null)socket.close();throw e;} finally {}}// 发送消息public void sendMessage(String sendMessage) throws Exception {try {out = new DataOutputStream(socket.getOutputStream());if (sendMessage.equals("Windows")) {out.writeByte(0x1);out.flush();return;}if (sendMessage.equals("Unix")) {out.writeByte(0x2);out.flush();return;}if (sendMessage.equals("Linux")) {out.writeByte(0x3);out.flush();} else {out.writeUTF(sendMessage);out.flush();}} catch (Exception e) {e.printStackTrace();if (out != null)out.close();throw e;} finally {}}// 接受消息public DataInputStream getMessageStream() throws Exception {try {getMessageStream = new DataInputStream(new BufferedInputStream(socket.getInputStream()));return getMessageStream;} catch (Exception e) {e.printStackTrace();if (getMessageStream != null)getMessageStream.close();throw e;} finally {}}// 关闭连接public void shutDownConnection() {try {if (out != null)out.close();if (getMessageStream != null)getMessageStream.close();if (socket != null)socket.close();} catch (Exception e) {}}
}

package com.wf.demo.socket.socketfile;import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.net.ServerSocket;
import java.net.Socket;/*** 1.服务器端* * @author willson* */
public class ServerTest {int port = 8821;void start() {Socket socket = null;try {ServerSocket serverSocket = new ServerSocket(port);while (true) {// 选择进行传输的文件String filePath = "E:\\lib.zip";File fi = new File(filePath);System.out.println("File Name：" + fi.getName() + ";\tFile Size()：" + (int) fi.length() + "bytes");// public Socket accept() throws// IOException侦听并接受到此套接字的连接。此方法在进行连接之前一直阻塞。System.out.println("等待客户端连接，连接端口：" + port);socket = serverSocket.accept();System.out.println("建立socket链接");DataInputStream dis = new DataInputStream(new BufferedInputStream(socket.getInputStream()));dis.readByte();DataInputStream fis = new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));DataOutputStream ps = new DataOutputStream(socket.getOutputStream());// 将文件名及长度传给客户端。这里要真正适用所有平台，例如中文名的处理，还需要加工，具体可以参见Think In Java// 4th里有现成的代码。ps.writeUTF(fi.getName());ps.flush();ps.writeLong((long) fi.length());ps.flush();int bufferSize = 8192;byte[] buf = new byte[bufferSize];while (true) {int read = 0;if (fis != null) {read = fis.read(buf);}if (read == -1) {break;}ps.write(buf, 0, read);}ps.flush();// 注意关闭socket链接哦，不然客户端会等待server的数据过来，// 直到socket超时，导致数据不完整。fis.close();socket.close();System.out.println("文件传输完成\n");}} catch (Exception e) {e.printStackTrace();}}public static void main(String arg[]) {new ServerTest().start();}
}

package com.wf.demo.socket.socketfile;import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileOutputStream;/*** 3.客户端* * @author willson* */
public class ClientTest {private ClientSocket cs = null;private String ip = "localhost";// 设置成服务器IPprivate int port = 8821;private String sendMessage = "Windwos";public ClientTest() {try {if (createConnection()) {sendMessage();getMessage("F:\\");}} catch (Exception ex) {ex.printStackTrace();}}private boolean createConnection() {cs = new ClientSocket(ip, port);try {cs.CreateConnection();System.out.print("连接服务器成功!" + "\n");return true;} catch (Exception e) {System.out.print("连接服务器失败!" + "\n");return false;}}private void sendMessage() {if (cs == null)return;try {cs.sendMessage(sendMessage);} catch (Exception e) {System.out.print("发送消息失败!" + "\n");}}private void getMessage(String savePath) {if (cs == null)return;DataInputStream inputStream = null;try {inputStream = cs.getMessageStream();} catch (Exception e) {System.out.print("接收消息缓存错误\n");return;}try {// 本地保存路径，文件名会自动从服务器端继承而来。int bufferSize = 8192;byte[] buf = new byte[bufferSize];int passedlen = 0;long len = 0;savePath += inputStream.readUTF();DataOutputStream fileOut = new DataOutputStream(new BufferedOutputStream(new BufferedOutputStream(new FileOutputStream(savePath))));len = inputStream.readLong();System.out.println("File Size()：" + len + "bytes");System.out.println("开始接收文件!" + "\n");while (true) {int read = 0;if (inputStream != null) {read = inputStream.read(buf);}passedlen += read;if (read == -1) {break;}// 下面进度条本为图形界面的prograssBar做的，这里如果是打文件，可能会重复打印出一些相同的百分比System.out.println("文件接收了" + (passedlen * 100 / len) + "%\n");fileOut.write(buf, 0, read);}System.out.println("接收完成，文件存为" + savePath + "\n");fileOut.close();} catch (Exception e) {System.out.println("接收消息错误" + "\n");return;}}public static void main(String arg[]) {new ClientTest();}
}

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！