`
l4432848
  • 浏览: 253195 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

局域网文件传输

    博客分类:
  • java
阅读更多

ClientFile.java

/**
 * 更多资料欢迎浏览凯哥学堂官网:http://kaige123.com
 * @author 小沫
 */
 package com.tcp.file;

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;

import javax.swing.JProgressBar;

public class ClientFile extends Thread {

    private static String ip;
    private static int port;
    private String filepath;
    private long size;
    private JProgressBar jprogressbar;
    public ClientFile(String ip, int port, String filepath, JProgressBar jprogressbar) {
        this.ip = ip;
        this.port = port;
        this.filepath = filepath;
        this.jprogressbar = jprogressbar;
    }
    public void run() {
        try {
            Socket socket = new Socket(ip, port);
            InputStream input = socket.getInputStream();
            OutputStream output = socket.getOutputStream();

            File file = new File(filepath);
            // 第一次传输文件名字and文件的大小
            String str1 = file.getName() + "\t" + file.length();
            output.write(str1.getBytes());
            output.flush();
            byte[] b = new byte[100];
            int len = input.read(b);
            String s = new String(b, 0, len);
            // 如果服务器传输过来的是ok那么就开始传输字节
            if (s.equalsIgnoreCase("ok")) {
                long size = 0;
                jprogressbar.setMaximum((int) (file.length() / 10000));// 设置进度条最大值
                FileInputStream fin = new FileInputStream(file);
                byte[] b1 = new byte[1024 * 1024 * 2];
                while (fin.available() != 0) {
                    len = fin.read(b1);
                    output.write(b1, 0, len);
                    output.flush();
                    size += len;
                    jprogressbar.setValue((int) (size / 10000));
                }
                if (fin.available() == 0) {
                    javax.swing.JOptionPane.showMessageDialog(null, "传输完毕!即将推出......");
                    try {
                        Thread.sleep(1500);
                        System.exit(0);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                output.close();
                fin.close();
                socket.close();
            } else {
                // 传输的不是ok那么就弹出个信息框对方拒绝
                javax.swing.JOptionPane.showMessageDialog(null, "对方拒绝接收此数据!");
            }
        } catch (IOException e) {
            javax.swing.JOptionPane.showMessageDialog(null, "IOException");
        }
    }

}

ServerFile.java

/**
 * 更多资料欢迎浏览凯哥学堂官网:http://kaige123.com
 * @author 小沫
 */
 package com.tcp.file;

import java.io.*;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.JFileChooser;
import javax.swing.JOptionPane;
import javax.swing.JProgressBar;

public class ServerFile extends Thread {

    private Socket socket;
    private JProgressBar jprogressbars;

    public ServerFile(Socket socket, JProgressBar jprogressbars) {
        this.socket = socket;
        this.jprogressbars = jprogressbars;
    }

    public void run() {
        try {
            InputStream input = socket.getInputStream();
            OutputStream output = socket.getOutputStream();

            byte[] b = new byte[100];
            int len = input.read(b);
            String ss = new String(b, 0, len);
            String[] str1 = ss.split("\t");// 把接收到的信息按制表符拆分
            String filename = str1[0];// 起始位文件名称
            String filesize = str1[1];// 下标1位文件的大小
            long size = Long.parseLong(filesize);

            InetAddress ip = socket.getInetAddress();// 得到发送端的IP
            int port = socket.getPort();// 得到发送端的端口

            long s = size / 1024 / 1024;
            String name = " M";
            if (s < 1) {
                s = (size / 1024);
                name = " K";
            } else if (s > 1024) {
                float s1 = size / 1024 / 1024;
                s = (size / 1024 / 1024 / 1024);
                name = " G多";
            }
            // 弹出确认款,显示对方的ip端口以及文件的名称和大小是否需要接收
            int i = JOptionPane.showConfirmDialog(null,
                    "来自: " + ip + ":" + port + "\n文件名称: " + filename + "\n文件大小: " + s + name);

            // 如果点击确认
            if (i == JOptionPane.OK_OPTION) {
                // 那么传输ok给发送端示意可以接收
                output.write("ok".getBytes());
                output.flush();
                JFileChooser jf = new JFileChooser();
                // 存储到本地路径的夹子
                jf.setFileSelectionMode(JFileChooser.DIRECTORIES_ONLY);
                jf.showOpenDialog(null);
                jprogressbars.setMaximum((int) (size / 10000));
                FileOutputStream fout = new FileOutputStream(new File(jf.getSelectedFile(), filename));
                b = new byte[1024 * 1024 * 2];
                long size1 = 0;
                while ((len = input.read(b)) != -1) {
                    fout.write(b, 0, len);
                    size1 += len;
                    jprogressbars.setValue((int) (size1 / 10000));
                }
                fout.close();
                input.close();
                socket.close();

            } else {
                // 否不接收此文件
                output.write("no".getBytes());
                output.flush();
            }
        } catch (IOException e) {
            javax.swing.JOptionPane.showMessageDialog(null, "IOException");
        }

    }
    private static ServerSocket server = null;
    // 启动服务器
    public static void openServer(int port, JProgressBar jprogressbar) throws Exception {
        new Thread() {
            public void run() {
                try {
                    if (server != null && !server.isClosed()) {
                        server.close();
                    }
                    server = new ServerSocket(port);
                    new ServerFile(server.accept(), jprogressbar).start();
                } catch (IOException e) {
                    javax.swing.JOptionPane.showMessageDialog(null, "IOException");
                }
            }
        }.start();
    }

    // 关闭服务器
    public static void closeServer() {
        try {
            server.close();
        } catch (IOException e) {
            javax.swing.JOptionPane.showMessageDialog(null, "IOException");
        }
    }

}

SocketFileJFrame.java

/**
 * 更多资料欢迎浏览凯哥学堂官网:http://kaige123.com
 * @author 小沫
 */
 package com.tcp.file;

import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.EventQueue;
import java.awt.Image;
import java.awt.Toolkit;

import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import java.awt.Color;
import javax.swing.JTabbedPane;
import java.awt.Panel;
import javax.swing.border.TitledBorder;
import javax.swing.UIManager;
import javax.swing.border.CompoundBorder;
import javax.swing.JLabel;
import java.awt.Font;
import javax.swing.JTextField;
import javax.swing.JToggleButton;
import javax.swing.JProgressBar;
import javax.swing.JButton;
import javax.swing.JFileChooser;
import javax.swing.event.AncestorListener;
import javax.swing.event.AncestorEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.awt.event.ActionEvent;

public class SocketFileJFrame extends JFrame {

    private JPanel contentPane;
    private JTextField textField;
    private JTextField textField_1;
    private JTextField textField_2;
    private JTextField textField_3;
    private JProgressBar progressBar_2;

    /**
     * Launch the application.
     */
    public static void main(String[] args) {
        EventQueue.invokeLater(new Runnable() {
            public void run() {
                try {
                    SocketFileJFrame frame = new SocketFileJFrame();
                    frame.setVisible(true);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }

    /**
     * Create the frame.
     */
    public SocketFileJFrame() {
        setIconImage(Toolkit.getDefaultToolkit()
                .getImage(SocketFileJFrame.class.getResource("/javax/swing/plaf/metal/icons/ocean/newFolder.gif")));
        setForeground(Color.WHITE);

        setResizable(false);
        setTitle("局域网文件传输 V1.0");
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        int width = Toolkit.getDefaultToolkit().getScreenSize().width;//获取分辨率宽
        int heiht = Toolkit.getDefaultToolkit().getScreenSize().height;//获取分辨率高

        //分辨率宽高减去软件的宽高除以2把软件居中显示
        setBounds((width - 747) / 2, (heiht - 448) / 2, 738, 472);
        contentPane = new JPanel();
        contentPane.setBackground(Color.WHITE);
        contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
        setContentPane(contentPane);
        contentPane.setLayout(null);

        JPanel panel_1 = new JPanel();
        panel_1.setToolTipText("");
        panel_1.setBorder(new TitledBorder(UIManager.getBorder("TitledBorder.border"),
                "\u6587\u4EF6\u63A5\u6536\u670D\u52A1\u5668", TitledBorder.LEADING, TitledBorder.TOP, null,
                new Color(0, 0, 0)));
        panel_1.setBackground(Color.WHITE);
        panel_1.setBounds(39, 28, 652, 119);
        contentPane.add(panel_1);
        panel_1.setLayout(null);

        JLabel label = new JLabel("\u7AEF\u53E3:");
        label.setFont(new Font("新宋体", Font.PLAIN, 22));
        label.setBounds(26, 31, 66, 35);
        panel_1.add(label);

        //端口文本框
        textField = new JTextField();
        textField.setFont(new Font("宋体", Font.PLAIN, 19));
        textField.setText("8080");
        textField.setBounds(89, 36, 126, 26);
        panel_1.add(textField);
        textField.setColumns(10);

        //服务器关闭启动的按钮
        JToggleButton tglbtnNewToggleButton = new JToggleButton("\u542F\u52A8\u670D\u52A1\u5668");
        tglbtnNewToggleButton.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {

                if (tglbtnNewToggleButton.isSelected()) {
                    //如果是按下显示关闭服务器
                    tglbtnNewToggleButton.setText("关闭服务器");
                    textField.setEnabled(false);//按下之后 端口文本框要设置不能写入
                    try {
                        //启动服务器
                        ServerFile.openServer(Integer.parseInt(textField.getText())
                                , progressBar_2);
                    }  catch (Exception e1) {
                        javax.swing.JOptionPane.showMessageDialog(null, "Exception");
                    }
                } else {
                    //否启动服务器
                    tglbtnNewToggleButton.setText("启动服务器");
                    textField.setEnabled(true);////弹起之后 端口文本框要设置可写状态
                    ServerFile.closeServer();//关闭服务器
                }

            }
        });
        tglbtnNewToggleButton.setFont(new Font("微软雅黑 Light", Font.PLAIN, 19));
        tglbtnNewToggleButton.setBackground(Color.WHITE);
        tglbtnNewToggleButton.setForeground(Color.DARK_GRAY);
        tglbtnNewToggleButton.setBounds(345, 34, 138, 28);
        panel_1.add(tglbtnNewToggleButton);

        //文件接收端的进度条
        progressBar_2 = new JProgressBar();
        progressBar_2.setBackground(Color.WHITE);
        progressBar_2.setForeground(new Color(255, 218, 185));
        progressBar_2.setStringPainted(true);
        progressBar_2.setBounds(460, 101, 190, 14);
        panel_1.add(progressBar_2);

        JPanel panel_2 = new JPanel();
        panel_2.setToolTipText("");
        panel_2.setBorder(new TitledBorder(UIManager.getBorder("TitledBorder.border"), "\u6587\u4EF6\u4F20\u8F93\u7AEF",
                TitledBorder.LEADING, TitledBorder.TOP, null, new Color(0, 0, 0)));
        panel_2.setBackground(Color.WHITE);
        panel_2.setBounds(39, 191, 652, 202);
        contentPane.add(panel_2);
        panel_2.setLayout(null);

        //文件传输端的进度条
        JProgressBar progressBar_1 = new JProgressBar();
        progressBar_1.setFont(new Font("宋体", Font.PLAIN, 18));
        progressBar_1.setStringPainted(true);
        progressBar_1.setForeground(new Color(240, 128, 128));
        progressBar_1.setBackground(Color.WHITE);
        progressBar_1.setBounds(96, 169, 472, 20);
        panel_2.add(progressBar_1);

        JLabel lblIp = new JLabel("IP\u5730\u5740:");
        lblIp.setFont(new Font("微软雅黑 Light", Font.PLAIN, 20));
        lblIp.setBounds(26, 44, 70, 27);
        panel_2.add(lblIp);

        //IP地址文本框
        textField_1 = new JTextField();
        textField_1.setText("127.0.0.1");
        textField_1.setFont(new Font("新宋体", Font.PLAIN, 20));
        textField_1.setBounds(96, 44, 184, 30);
        panel_2.add(textField_1);
        textField_1.setColumns(10);

        JLabel label_1 = new JLabel("\u7AEF\u53E3:");
        label_1.setFont(new Font("微软雅黑 Light", Font.PLAIN, 20));
        label_1.setBounds(308, 42, 80, 30);
        panel_2.add(label_1);

        //端口文本框
        textField_2 = new JTextField();
        textField_2.setText("8080");
        textField_2.setFont(new Font("新宋体", Font.PLAIN, 20));
        textField_2.setColumns(10);
        textField_2.setBounds(359, 44, 80, 30);
        panel_2.add(textField_2);

        //打开本地路径的按钮
        JButton button = new JButton("...");
        button.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                JFileChooser jf = new JFileChooser();
                jf.setFileSelectionMode(JFileChooser.FILES_ONLY);
                jf.showOpenDialog(SocketFileJFrame.this);
                textField_3.setText(jf.getSelectedFile().getPath());
            }
        });
        button.setBackground(Color.WHITE);
        button.setBounds(533, 51, 35, 20);
        panel_2.add(button);

        JLabel label_2 = new JLabel("\u8DEF\u5F84:");
        label_2.setFont(new Font("微软雅黑 Light", Font.PLAIN, 15));
        label_2.setBounds(489, 50, 44, 18);
        panel_2.add(label_2);

        //显示文件路径框
        textField_3 = new JTextField();
        textField_3.setEnabled(false);
        textField_3.setFont(new Font("微软雅黑 Light", Font.PLAIN, 20));
        textField_3.setBounds(96, 100, 343, 38);
        panel_2.add(textField_3);
        textField_3.setColumns(10);

        JLabel lblNewLabel = new JLabel("\u6587\u4EF6:");
        lblNewLabel.setFont(new Font("等线 Light", Font.PLAIN, 25));
        lblNewLabel.setBounds(33, 97, 56, 38);
        panel_2.add(lblNewLabel);
        //确定按钮
        JButton button_1 = new JButton("\u786E\u5B9A");
        button_1.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {

                ClientFile client = new ClientFile(
                        textField_1.getText(), Integer.parseInt(textField_2.getText()), 
                        textField_3.getText(), progressBar_1);
                client.start();
            }
        });
        button_1.setForeground(new Color(255, 255, 0));
        button_1.setBackground(new Color(233, 150, 122));
        button_1.setFont(new Font("微软雅黑 Light", Font.BOLD, 20));
        button_1.setBounds(475, 100, 91, 38);
        panel_2.add(button_1);
    }
}
0
0
分享到:
评论

相关推荐

    很好用的局域网文件传输工具——飞鸽传书

    综上所述,飞鸽传书作为一款局域网文件传输工具,其高效、安全和易用性使得它在多种场景下都能发挥出色的表现。无论是在工作还是生活中,只要有局域网环境,飞鸽传书都能成为您理想的文件传输伙伴。

    C# Winform 基于局域网文件传输Demo

    让我们一起探索C# Winform如何与TCP结合,构建一个局域网文件传输系统。 首先,我们需要理解TCP协议的基本概念。TCP提供了一个端到端的数据流服务,确保数据包按照正确的顺序到达,并且在传输过程中无丢失。在C#中...

    C# 局域网文件传输与聊天程序源码

    本项目名为"C# 局域网文件传输与聊天程序源码",它提供了一个使用C#实现的本地网络文件传输和聊天功能的示例。这个程序基于Winform窗体,是Windows应用程序开发的基础部分。 首先,我们要理解局域网(LAN)文件传输...

    基于QT的局域网文件传输

    【基于QT的局域网文件传输】是一种使用C++编程语言和QT库实现的本地网络文件共享技术。QT是一个跨平台的应用程序开发框架,广泛应用于桌面、移动和嵌入式设备,提供了丰富的图形用户界面(GUI)工具和网络通信功能。...

    VB局域网文件传输(C/S)

    在VB(Visual Basic)编程环境中,开发一个C/S(客户端/服务器)架构的局域网文件传输系统是一项常见的任务。这个系统通常利用WINSOCK控件来实现网络通信,允许在局域网内的不同计算机之间高效地交换文件。WINSOCK...

    c# 局域网文件传输工具

    【C# 局域网文件传输工具】是一个实用的软件应用,专为在局域网内的设备间快速、高效地传输大文件而设计。与传统的文件传输方式如QQ相比,该工具不受文件大小限制,且无需互联网连接,仅依赖于局域网内部的网络通信...

    局域网文件传输工具飞秋

    局域网文件传输工具飞秋 局域网文件传输工具飞秋 局域网文件传输工具飞秋 局域网文件传输工具飞秋 局域网文件传输工具飞秋

    java课程设计局域网文件传输系统源代码

    Java课程设计局域网文件传输系统源代码分析 Java课程设计局域网文件传输系统源代码是一个基于Socket套接字技术的网络编程项目,旨在实现局域网中的文件传输。本文将对该系统的源代码进行详细分析,总结出相关的IT...

    C#socket局域网文件传输电脑端131114

    本项目"C# socket局域网文件传输电脑端131114"提供了在C#编程环境下,利用socket技术实现在局域网内的多文件传输功能。下面我们将详细探讨涉及的关键知识点。 1. **C# Socket编程**:Socket是网络通信的基础,它...

    Java 局域网文件传输

    Java 局域网文件传输是Java编程中一个实用的技术,它允许在局域网内的不同设备之间高效地分享数据和文件。实现这一功能通常涉及到网络编程、多线程以及I/O流的使用。下面我们将详细探讨相关的Java知识点。 1. **...

    局域网文件传输软件(支持大文件)

    局域网文件传输软件通常比常规的互联网文件共享更快速、更安全,尤其对于传输大文件而言,它避免了网络延迟和带宽限制的问题。本篇文章将深入探讨局域网文件传输软件的重要性和其支持大文件传输的技术要点。 首先,...

    C++局域网文件传输

    这是一个局域网文件传输程序,做的还可以。花了几天时间的辛苦劳动,愿意与大家共同分享

    易语言局域网文件传送源码.rar

    在实际应用中,局域网文件传输可能涉及到以下知识点: 1. **网络编程基础**:理解IP地址、子网掩码、端口号等基本概念,以及TCP/IP协议栈的工作流程。 2. **套接字编程**:使用易语言的网络库,创建socket对象,...

    java局域网文件传输

    在IT领域,尤其是在Java编程中,局域网文件传输是一个常见的需求,比如在多台设备间共享文件或者在分布式系统中传递数据。本项目聚焦于使用Java实现这一功能,通过局域网(LAN)实现文件的高效、安全传输。下面我们...

    c#局域网文件传输与信息传输

    以下是对C#在局域网文件传输与信息传输方面的重要知识点的详细解析。 ### 一、C#局域网文件传输原理 在局域网内,C#通过调用Socket类库或使用Windows的网络资源共享机制来实现文件的传输。其中,Socket类库提供了...

    java写的局域网文件传输系统

    java写的局域网文件传输系统,j2se的简单应用

    局域网文件传输模块代码

    标题中的“局域网文件传输模块代码”表明这是一个专门用于在局域网内实现文件传输的软件组件。这个模块可能是由一系列的C++源代码文件组成,设计目标是让其他程序能够方便地调用,实现快速、高效的数据共享。描述中...

    用VB的Winsock制作的局域网文件传输系统

    标题中的“用VB的Winsock制作的局域网文件传输系统”表明了这是一个利用Visual Basic (VB)编程语言,借助Winsock控件实现的局域网内文件传输的应用程序。Winsock是Windows操作系统中用于网络通信的一个核心组件,它...

Global site tag (gtag.js) - Google Analytics