首页 > 编程语言 > 详细

14.2 Java的基本网络支持

时间:2020-05-15 20:13:06      阅读:37      评论:0      收藏:0      [点我收藏+]

一、使用InetAddress

1.1 InetAddress类和其子类

Java提供了InetAddress类来代表IP地址,InetAddress下还有2个子类:Inet4Address、Inet6Address,它们分别代表Internet Protocol version 4(IPv4)地址和Internet Protocol version 6(IPv6)地址。
技术分享图片

1.2 InetAddress类的获取和方法

1、InetAddress类没有提供构造器,而是提供了如下两个静态方法来获取InetAddress实例:
(1)getByName(String host):根据主机获取对应的InetAddress对象。——参数是“www...”的域名
(2)getByAddress(byte[] addr):根据原始IP地址来获取对应的InetAddress对象。——参数是IP地址
2、InetAddress还提供了如下三个方法来获取InetAddress实例对应的IP地址和主机名:
(1)String getCanonicalHostName():获取此 IP 地址的全限定域名。
(2)String getHostAddress():返回该InetAddress实例对应的IP地址字符串(以字符串形式)。——"www..."的形式
(3)String getHostName():获取此 IP 地址的主机名。
InetAddress类还提供了一个getLocalHost()方法来获取本机IP地址对应的InetAddress实例
InetAddress类还提供了一个isReachable()方法,用于测试是否可以到达该地址。该方法将尽可能尽最大的努力试图到达主机,但防火墙和服务器配置可能阻塞请求,使它在访问某些特定的端口时处于不可达状态。如果可以获取权限,典型的实现将使用ICMP ECHO REQUEST;否则它试图在目标主机的端口7(Echo)上建立TCP连接。

1.3 InetAddress类的应用举例

下面程序测试InetAddress类的简单用法:

package section2;

        import java.net.InetAddress;

public class InetAddressTest
{
    public static void main(String[] args)
            throws Exception
    {
        //根据主机名来获取对应得InetAddress实例
        InetAddress ip=InetAddress.getByName("www.crazyit.org");
        //判断是否可达
        System.out.println("crazyit是否可达:"+ip.isReachable(2000));//true
        //获取该InetAddress实例的IP字符串
        System.out.println(ip.getHostName());//www.crazyit.org
        //获取该InetAddress实例对应得全限定域名
        System.out.println(ip.getCanonicalHostName());//43.243.169.21

        //根据原始得IP地址来获取对应得InetAddress实例
        InetAddress local=InetAddress.getByAddress(new byte[]{(byte)192,(byte)168,1,5});
        System.out.println("本机是否可达:"+local.isReachable(5000));//true
        //获取该InetAddress实例的IP地址字符串
        System.out.println(local.getHostAddress());
        //获取该InetAddress实例对应得全限定域名
        System.out.println(local.getCanonicalHostName());
        //获得此IP地址的主机名
        System.out.println(local.getHostName());

    }
}
crazyit是否可达:true
www.crazyit.org
43.243.169.21
本机是否可达:true
192.168.1.5
DESKTOP-TBC0ODP
DESKTOP-TBC0ODP

二、使用URLDecoder和URLEncoder

URLDecoder和URLEncoder用于完成普通字符串和application/x-www-form-urlencoded MIME字符串之间的相互转换。
技术分享图片

当URL地址里包含非西欧字符的其它字符串时,系统会将这些非西欧字符串转换为如图所示的特殊字符串。编程过程中可能涉及普通字符串和这种特殊字符串的相互转换,这就需要URLDecoder和URLEncoder类。
(1)URLDecoder类包含一个decode(String s,String enc)静态方法,它可以将看上去是乱码的特殊字符串转转成普通字符串。
(2)URLEncoder类包含一个encode(String s,String enc)静态方法,它可以将普通字符串转换成application/x-www-form-urlencoded MIME字符串。
下面程序示范了如何实现普通字符串和application/x-www-form-urlencoded MIME字符串之间的相互转换:

package section2;


import java.net.*;
public class URLDecoderTest
{
    public static void main(String[] args)
            throws Exception
    {
        // 将application/x-www-form-urlencoded字符串
        // 转换成普通字符串
        String keyWord = URLDecoder.decode(
                "%E7%96%AF%E7%8B%82java", "utf-8");
        System.out.println(keyWord);
        // 将普通字符串转换成
        // application/x-www-form-urlencoded字符串
        String urlStr = URLEncoder.encode(
                "疯狂Android讲义", "utf-8");
        System.out.println(urlStr);
    }
}
疯狂java
%E7%96%AF%E7%8B%82Android%E8%AE%B2%E4%B9%89

提示:仅包含西欧字母的普通字符串和application/x-www-form-urlencoded MIME字符串无须转换,而包含中文符的字符串则需要转换,转换方法是每个中文字符占两个字节,每个字节可以转换成两个十六进制的数字,所以每个中文符将转换为%XX%XX的形式。当然采用不同的字符集,每个中文字符所对应的字节数并不完全相同,所以使用URLDecoder和URLEncoder类进行转换时也需要指定字符集。

三、URL、URLConnection和URLPermission

URL代表一个网络地址;
URLConnection代表于网络地址的连接
?
HttpURLConnection:基于HTTP协议的网络连接。
URL(Uniform Resource Locator)对象代表统一资源定位器,它是指向互联网“资源”的指针。资源可以是简单的文件或目录,也可以是对更复杂的对象引用,例如对数据库或搜索引擎的查询。通常情况而言,URL可以由协议名、主机、端口和资源组成。即满足如下格式:
protocol://host:port/resourceName
例如如下URL地址:
htto://www.crazyit.org/index.php
提示:JDK还提供了一个URI(Uniform Resource Identifier)类,其实例代表一个统一资源标识符,Java的URI不能定位任何资源,他唯一的作用就是解析。与此对应的是,URL则包含一个可以打开到达该资源的输入流,可以将URL理解成URI的特例。
URL提供了多个构造器用于创建URL对象,一旦获得了URL对象之后,就可以调用如下方法来访问URL的对应资源:
(1)String getFile():获取该URL的资源名。
(2)String getHost():获取该URL的主机名。
(3)String getPath():获取该URL的路径部分。
(4)int getPort():获取该URL的端口号。
(5)String getProtocol():获取该URL的协议名称。
(6)String getQuery():获取该URL的查询字符串部分。
(7)URLConnection openConnection():返回一个URLConnection对象,它代表与URL所引用的远程对象的连接。
(8)InputStream openStream():打开与此URL的连接,并返回一个可以读取该URL资源的InputStream。
URL对象的前几个方法很易理解,而该对象的openStream()方法可以读取该URL资源得InputStream,通过该方法可以很方便地读取远程资源——甚至实现多线程下载。如下程序就是一个多线程下载得工具类。

package section2;

import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.*;

public class DownUtil
{
    // 定义下载资源的路径
    private String path;
    // 指定所下载的文件的保存位置
    private String targetFile;
    // 定义需要使用多少线程下载资源
    private int threadNum;
    // 定义下载的线程对象
    private DownThread[] threads;
    // 定义下载的文件的总大小
    private int fileSize;

    public DownUtil(String path, String targetFile, int threadNum)
    {
        this.path = path;
        this.threadNum = threadNum;
        // 初始化threads数组
        threads = new DownThread[threadNum];
        this.targetFile = targetFile;
    }

    public void download() throws Exception
    {
        var url = new URL(path);
        //返回一个URLConnection对象,它代表与URL所引用的远程对象的连接
        var conn = (HttpURLConnection) url.openConnection();
        conn.setConnectTimeout(5 * 1000);
        conn.setRequestMethod("GET");
        conn.setRequestProperty(
                "Accept",
                "image/gif, image/jpeg, image/pjpeg, image/pjpeg, "
                        + "application/x-shockwave-flash, application/xaml+xml, "
                        + "application/vnd.ms-xpsdocument, application/x-ms-xbap, "
                        + "application/x-ms-application, application/vnd.ms-excel, "
                        + "application/vnd.ms-powerpoint, application/msword, */*");
        conn.setRequestProperty("Accept-Language", "zh-CN");
        conn.setRequestProperty("Charset", "UTF-8");
        conn.setRequestProperty("Connection", "Keep-Alive");
        // 得到文件大小
        fileSize = conn.getContentLength();
        conn.disconnect();
        int currentPartSize = fileSize / threadNum + 1;
        var file = new RandomAccessFile(targetFile, "rw");
        // 设置本地文件的大小
        file.setLength(fileSize);
        file.close();
        for (var i = 0; i < threadNum; i++)
        {
            // 计算每条线程的下载的开始位置
            var startPos = i * currentPartSize;
            // 每个线程使用一个RandomAccessFile进行下载
            var currentPart = new RandomAccessFile(targetFile, "rw");
            // 定位该线程的下载位置
            currentPart.seek(startPos);
            // 创建下载线程
            threads[i] = new DownThread(startPos, currentPartSize, currentPart);
            // 启动下载线程
            threads[i].start();
        }
    }

    // 获取下载的完成百分比
    public double getCompleteRate()
    {
        // 统计多条线程已经下载的总大小
        var sumSize = 0;
        for (var i = 0; i < threadNum; i++)
        {
            sumSize += threads[i].length;
        }
        // 返回已经完成的百分比
        return sumSize * 1.0 / fileSize;
    }

    private class DownThread extends Thread
    {
        // 当前线程的下载位置
        private int startPos;
        // 定义当前线程负责下载的文件大小
        private int currentPartSize;
        // 当前线程需要下载的文件块
        private RandomAccessFile currentPart;
        // 定义已经该线程已下载的字节数
        public int length;

        public DownThread(int startPos, int currentPartSize,
                          RandomAccessFile currentPart)
        {
            this.startPos = startPos;
            this.currentPartSize = currentPartSize;
            this.currentPart = currentPart;
        }

        @Override
        public void run()
        {
            try
            {
                var url = new URL(path);
                var conn = (HttpURLConnection) url.openConnection();
                conn.setConnectTimeout(5 * 1000);
                conn.setRequestMethod("GET");
                conn.setRequestProperty(
                        "Accept",
                        "image/gif, image/jpeg, image/pjpeg, image/pjpeg, "
                                + "application/x-shockwave-flash, application/xaml+xml, "
                                + "application/vnd.ms-xpsdocument, application/x-ms-xbap, "
                                + "application/x-ms-application, application/vnd.ms-excel, "
                                + "application/vnd.ms-powerpoint, application/msword, */*");
                conn.setRequestProperty("Accept-Language", "zh-CN");
                conn.setRequestProperty("Charset", "UTF-8");
                InputStream inStream = conn.getInputStream();
                // 跳过startPos个字节,表明该线程只下载自己负责哪部分文件。
                inStream.skip(this.startPos);
                var buffer = new byte[1024];
                var hasRead = 0;
                // 读取网络数据,并写入本地文件
                while (length < currentPartSize
                        && (hasRead = inStream.read(buffer)) != -1)
                {
                    currentPart.write(buffer, 0, hasRead);
                    // 累计该线程下载的总大小
                    length += hasRead;
                }
                currentPart.close();
                inStream.close();
            }
            catch (Exception e)
            {
                e.printStackTrace();
            }
        }
    }
}

上面定义了一个DownThread线程类,该线程负责从startPos开始,长度为currentPartSize的所有字节数据,并写入RandomAccessFile对象。这个DownThread线程类的run()方法就是一个简单的输入、输出的实现。
程序中DownUtils类中的download()方法负责按如下步骤实现多线程下载:
(1)创建URL对象。
(2)获取指定的URL对象所指向资源的大小(通过getContentLength()方法获取),此处还应用了URLConnection类,该类代表Java应用程序与URL之间的通信链接。
(3)在磁盘中创建一个与网络资源具有相同大小的空文件。
(4)计算每个线程应该下载网络资源的哪个部分(从哪个字节开始,到哪个字节结束)。
(5)依次创建、启动多个线程来下载网络资源的指定部分。

14.2 Java的基本网络支持

原文:https://www.cnblogs.com/weststar/p/12890374.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!