博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java 学习笔记 网络编程 使用Socket传输文件 CS模式
阅读量:4975 次
发布时间:2019-06-12

本文共 3465 字,大约阅读时间需要 11 分钟。

Socket的简单认识

Socket是一种面向连接的通信协议,Socket应用程序是一种C/S(Client端/Server端)结构的应用程序

Socket是两台机器间通信的端点。
Socket是连接运行在网络上的两个程序间的双向通讯端点。

Socket通信原理

1210268-20190416130627569-235304381.png

  • Server服务端的输入流相当于Client客户端的输出流
  • Server服务端的输出流相当于Client客户端的输入流

注意

  • 文件传输使用字节流(Steam)
  • 使用DataOutputStream,DataOutputStream可以传java的基本类型和流

代码

Server.java

package csmode2;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;/** * @author StarsOne * @date Create in  2019-4-14 0014 10:53:58 * @description */class Server {    public static void main(String[] args) {        try (ServerSocket serverSocket = new ServerSocket(9090)){            System.out.println("服务器已启动...");                        while (true) {                System.out.println("等待接收文件");                //调用了accept方法之后,会一直处于等待接受文件的状态                Socket socket = serverSocket.accept();//接收客户端传来的数据                //交给后台线程处理                new AcceptThread(socket.getInputStream()).start();            }        } catch (IOException e) {            e.printStackTrace();        }    }}

AcceptThread.java

package csmode2;import java.io.DataInputStream;import java.io.File;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;/** * @author StarsOne * @date Create in  2019/4/15 0015 14:17 * @description */class AcceptThread extends Thread {    private InputStream inputStream;    public AcceptThread(InputStream inputStream) {        this.inputStream = inputStream;    }    @Override    public void run() {        try {            //使用DataInputStream包装输入流            DataInputStream dataInputStream = new DataInputStream(inputStream);            String fileName = dataInputStream.readUTF();            System.out.println(fileName);//在控制台显示文件名            //往某个位置写入文件            FileOutputStream fileOutputStream = new FileOutputStream("Q:\\MY" + File.separator + fileName);            int c = -1;            while ((c = dataInputStream.read()) != -1) {                fileOutputStream.write(c);                fileOutputStream.flush();            }            System.out.println("文件上传成功!");        } catch (IOException e) {            e.printStackTrace();        }    }}

Client.java

package csmode2;import java.io.*;import java.net.Socket;/** * @author StarsOne * @date Create in  2019-4-14 0014 10:53:49 * @description */class Client {    public static void main(String[] args) {        //        File[] files = new File("E:\\wan\\testfile").listFiles();        //如果是多个文件,只需要把文件放入一个list或者数组中,使用for循环把数组的文件全部上传到服务器        //上传的文件        File file = new File("R:\\动漫图片\\test.jpg");        try(Socket socket = new Socket("localhost", 9090)) {            OutputStream outputStream = socket.getOutputStream();            //使用DataOutputStream            DataOutputStream dataOutputStream = new DataOutputStream(outputStream);            //向服务器端传文件名            dataOutputStream.writeUTF(file.getName());            dataOutputStream.flush();//刷新流,传输到服务端            //向服务器端传文件,通过字节流            //字节流先读取硬盘文件            BufferedInputStream bufferedInputStream = new BufferedInputStream(new FileInputStream(file));                        int c = -1;            while ((c=bufferedInputStream.read())!=-1) {                //将读取的文件以字节方式写入DataOutputStream,之后传输到服务端                //这里也可以使用byte[]数据进行读取和写入                dataOutputStream.write(c);                dataOutputStream.flush();            }        } catch (IOException e) {            e.printStackTrace();        }    }}

转载于:https://www.cnblogs.com/kexing/p/10712415.html

你可能感兴趣的文章
2019微软Power BI 每月功能更新系列——Power BI 4月版本功能完整解读
查看>>
truncate 、delete、drop的区别
查看>>
DynamoDB 中的限制
查看>>
mysql做主从配置
查看>>
Docker练习例子:基于 VNCServer + noVNC 构建 Docker 桌面系统
查看>>
《码出高效 Java开发手册》第六章 数据结构与集合
查看>>
Python获取本机外网IP
查看>>
sleep和wait的区别
查看>>
[导入]弯管机3D DEMO
查看>>
关于51单片机使用printf串口调试
查看>>
软件工程-读书笔记(1-3章)
查看>>
Sublime 快捷键
查看>>
GNU make manual 翻译(二十六)
查看>>
poj1436
查看>>
iOS 电话在后台运行时,我的启动图片被压缩
查看>>
pod 常用命令
查看>>
MySQL修复打不开的视图定义
查看>>
PHP max_execution_time 超时
查看>>
NTBootAutofix:一款极为优秀的自动修复XP/VISTA/WIN7系统引导的工具
查看>>
js获取对象、数组的实际长度,元素实际个数
查看>>