Tcp从Socket客户端上传文件到ServerSocket服务端

时间:2022-05-16 13:06:19

目的:

从客户端上传指定的文件到服务端,服务端返回上传结果


思路:

一、客户端:

       1.创建客户端Socket,指定好IP地址和端口号

       2.创建要上传的文件流对象

       3.创建写入流(网络流),从Socket获取。将指定文件写入到网络流中,以便服务端接收

       4.从网络流中接收服务端返回的信息

       5.关闭流资源

二、服务端:

       1.创建服务端ServerSocket,并指定要监听的端口号

       2.用accept获取客户端对象,

       3.再获取客户端的网络输出流

       4.创建写入流对象,将获取到的网络输出流写入到硬盘中,进行持久化操作

       5.将上传信息(是否上传成功)写入到相对应的客户端写入流中,让客户端接收。

       6.最后完了之后,关闭流对象


注:因为是Tcp协议,所以在通信前要先创建连接。在测试时要先启动服务端程序。


示例:

import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

/*
* 客户端
*
* @author Tangtang
*
* 2015-6-16
*/
public class kehuduan {

public static void main(String[] args) throws Exception {
// 创建客户端
Socket s = new Socket("192.168.1.102", 8888);

// 创建要上传的文件对象
InputStream input = new FileInputStream("F:\\b.txt");
// 创建写入流
OutputStream out = s.getOutputStream();

// 自定义缓冲区
byte[] buf = new byte[1024];

int len = 0;
while ((len = input.read(buf)) != -1) {
out.write(buf, 0, len);
}
// 关闭输出流对象
s.shutdownOutput();

BufferedReader bufs = new BufferedReader(new InputStreamReader(
s.getInputStream()));
System.out.println(new String(bufs.readLine()));

input.close();
s.close();

}

}
import java.io.FileOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;/* * 服务端 *  * 使用TCP协议写一个可以上传文件的服务器和客户端。 *  * @author Tangtang * * 2015-6-16 */public class Serversduan {public static void main(String[] args) throws Exception {// 创建服务端,并指定监听端口号ServerSocket ss = new ServerSocket(8888);// 获取客户端Socket s = ss.accept();// 获取客户端IpString ip = s.getInetAddress().getHostAddress();System.out.println(ip + "...连接成功!");// 得到客户端网络流(字节流文件)InputStream in = s.getInputStream();// 创建服务器端的写入流对象OutputStream out = new FileOutputStream("F:\\a.txt");// 定义缓冲区byte[] ch = new byte[1024];int len = 0;while ((len = in.read(ch)) != -1) {// 把客户端上传的文件写入到服务器中out.write(ch, 0, len);}// 返回给客户端的信息OutputStream outSoc = s.getOutputStream();outSoc.write("上传成功!".getBytes());out.close();s.close();ss.close();}}