月度归档： 2013年5月

import java.io.IOException;
import java.io.RandomAccessFile;
import java.io.InputStream;
import java.net.URL;
import java.util.Scanner;

/**
 * 单线程下载.
 *
 * @author Ruidong_pu
 * @version 2013.5.4
 */

public class Download {

    public static void main(String[] args) {
        Scanner sc = new Scanner(System.in);
        // http://xunlei.down.chinaz.com/201302/wordpress-3.5.1-zh_CN.tar.gz 示例地址.
        System.out.println("---->请输入需要下载的URL地址('可以是:http[s],ftp,file'):");
        String fileURL = sc.next();
        System.out.println("---->设置下载文件存放地址:" + "\n---------------------------"
                + "\nwindows注意:"
                + "\n'例如-->C:\\[单右斜线在Java中有特殊意义,因此路径须写两个右斜线,并且必须以'\'结尾]'"
                + "\n示例:D:\\tmp\" + "\n---------------------------"
                + "\nLinux注意:" + "\n根路径是从'/'开始,而且路径必须以'/'结尾."
                + "\n示例:/usr/local/tmp/" + "\n>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
        String fileAddress = sc.next();
        URL url = null;
        RandomAccessFile raf = null;
        InputStream is = null;
        try {
            url = new URL(fileURL);
            raf = new RandomAccessFile(fileAddress + getFileAddress(url), "rw");
            System.out.println("文件长度:" + getFileLength(url));
            int hasRead = 0;
            is = url.openStream();
            byte[] buff = new byte[1024];
            while ((hasRead = is.read(buff)) > 0) {
                raf.write(buff, 0, hasRead);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                System.out.println("下载完成!文件名是:" + getFileAddress(url)
                        + ",文件大小:" + getFileLength(url));
                raf.close();
                is.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 获取文件长度.
     *
     * @param url
     * @return 文件长度
     * @throws IOException
     */
    private static long getFileLength(URL url) throws IOException {
        return url.openConnection().getContentLengthLong();
    }

    /**
     * 获取文件后缀名.
     *
     * @param url
     * @return 资源名称.
     */
    private static String getFileAddress(URL url) {
        String FileName = url.getPath();
        int index = FileName.lastIndexOf("/");
        return FileName.substring((index + 1), FileName.length());
    }

}

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


/**
 * 网络简单通信,服务器端.
 * 运行此程序后不会有任何提示,如果在Eclipse上运行此程序,单击运行之后
 * 可以直接去运行客户端类.[如果报错:地址已在使用,表示该类已经运行]
 *
 * @author ruidong
 * @version 2013.5.2
 */

public class Server{

    public static void main (String []args)throws Exception{
        ServerSocket ss = new ServerSocket(10000); //监听的端口号
        /*
         * 如果需要远程访问,
         * 请务必保证此端口是可以被访问的(特别是在Linux系统下面).
         */
        while(true){ //不间断的接收来自客户端的消息.
            Socket s = ss.accpet();
            PrintStream ps = new PrintStream(s.getOutputStream());
            //进行普通IO操作.
            ps.println("您收到了来自服务器新消息!");
        }
                        ps.close();
            s.close();
    }
}

import java.net.Socket;
import java.io.BufferedReader;
import java.io.InputStreamReader;

/**
 * 网络简单通信,客户端.
 * 运行此程序后将会看到来自服务器的消息提示.
 *
 * @author ruidong
 * @version 2013.5.2
 */

public class Client{

    public static void main (String []args)throws Exception{
        //前一个参数是需要访问的地址,可以是本地的,
        //也可以是远程的.后面那个是端口号.
        Socket s = new Socket("127.0.0.1",10000);
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //输出来自服务器的消息.
        System.out.println("来自服务器的信息:"+br.readLine());
        br.close();
        s.close();
    }


}