Java如何利用Socket传输信息或文件

package priv.zb.socket;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class FileServer {
	
	@SuppressWarnings("resource")
	public static void main(String[] args) throws IOException {
		ServerSocket server = null;
		Socket socket = null;
		//向外界暴露一个端口9999的服务，默认IP为本机IP：127.0.0.1
		server = new ServerSocket(9999);
		//返回一个Socket对象
		socket = server.accept();
		/**
		 *
		 * 启动服务端之后，会在 server.accept(); 方法处等待客户端的
		 * 连接，当启动客户端连接上服务端之后走过此方法运行后面的代码。
		 */
		System.out.println("接收到客户端的连接");
		//服务端向客户端发送消息	通过OutputStream
		//发出信息使用输出流OutputStream，接收信息使用输入咯InputStream
		OutputStream output = socket.getOutputStream();
		
		//传输字符串
//		byte[] bs = new byte[100];
//		output.write("Hello".getBytes());
		
		//传输文件
		String filePath = "存放文件路径";
		File file = new File(filePath );
		byte[] fileBytes = new byte[100];		//定义文件每次发送大小
		//读入到内存中，new 一个inputStream即可
		//文件较大，不能一次性发送完毕，因此需要循环操作
		InputStream fileIn = new FileInputStream(file);
		int len = -1;
		while((len = fileIn.read(fileBytes)) != -1) {
			output.write(fileBytes, 0, len);
		}
		//接受客户端消息
//		InputStream in = socket.getInputStream();
//		in.read(bs);
//		System.out.println("Server接收到信息：" + new String(bs));
		System.out.println("发送成功");
		output.close();
		fileIn.close();
	}
}

package priv.zb.socket;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class FileClient {
	
	@SuppressWarnings("resource")
	public static void main(String[] args) throws UnknownHostException, IOException {
		//建立连接
		//客户端访问服务端发布的服务
		Socket socket = new Socket("192.168.0.108",9999);
		//通过InputStream接收信息
		InputStream input = socket.getInputStream();
		byte[] fileBytes = new byte[100];
		File file = new File("E:\\JAVA\\Java SE\\srcCopy.zip");
		OutputStream output = new FileOutputStream(file);
		int len = -1;
		while( (len = input.read(fileBytes)) != -1) {
			output.write(fileBytes, 0, len);
		}
		
		//客户端接收到信息返回一个标识
//		byte[] bs = new byte[100];
//		input.read(bs);
//		System.out.println("Client 接收到消息：" + new String(bs));
		
		//客户端向服务端发送一个消息
//		OutputStream output = socket.getOutputStream();
//		output.write("World".getBytes());
		System.out.println("接收成功！！");
		output.close();
		input.close();
	}
}

package priv.zb.socket.runable;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class FileServer {
	
	@SuppressWarnings("resource")
	public static void main(String[] args) throws IOException {
		//向外界暴露一个端口9999的服务，默认IP为本机IP：127.0.0.1
		ServerSocket server = new ServerSocket(9999);
		while(true) {
			Socket socket = server.accept();
			//使用构造方法传入一个Socket对象与下载线程保持关联
			new Thread(new MyDownload(socket)).start();
			//下载线程
			/*
			 * MyDownload download = new MyDownload(socket);
			 * //Runnable变为Thered对象 
			 * new Thread(download).start();
			 */
		}
	}
}

package priv.zb.socket.runable;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class MyDownload implements Runnable {

	//Mydownload.java与Server之间使用Socket对象联系
	private Socket socket;
	public MyDownload(Socket socket) {
		this.socket = socket;
	}
	@Override
	public void run() {
		//返回一个Socket对象
		OutputStream output =null;
		InputStream fileIn = null;
		try {
			System.out.println("接收到客户端的连接");
			//服务端向客户端发送消息	通过OutputStream
			File file = new File("E:\\JAVA\\Java SE\\src.zip");
			byte[] fileBytes = new byte[100];		//定义文件每次发送大小
			//读入到内存中，new 一个inputStream即可
			//文件较大，不能一次性发送完毕，因此需要循环操作
			fileIn = new FileInputStream(file);
			int len = -1;
			output = socket.getOutputStream();
			while((len = fileIn.read(fileBytes)) != -1) {
				output.write(fileBytes, 0, len);
			}
			System.out.println("发送成功");
		} catch (IOException e1) {
			e1.printStackTrace();
		} finally {
			try {
				if(output != null) output.close();
				if(fileIn != null) fileIn.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}